Skip to content

Commit 0b344bd

Browse files
authored
Cleanup database tests (#2654)
1 parent 13bb7e4 commit 0b344bd

File tree

11 files changed

+107
-89
lines changed

11 files changed

+107
-89
lines changed

database/corruptabledb/db_test.go

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -18,19 +18,19 @@ import (
1818

1919
var errTest = errors.New("non-nil error")
2020

21-
func TestInterface(t *testing.T) {
22-
for _, test := range database.Tests {
23-
baseDB := memdb.New()
24-
db := New(baseDB)
25-
test(t, db)
26-
}
27-
}
28-
2921
func newDB() *Database {
3022
baseDB := memdb.New()
3123
return New(baseDB)
3224
}
3325

26+
func TestInterface(t *testing.T) {
27+
for name, test := range database.Tests {
28+
t.Run(name, func(t *testing.T) {
29+
test(t, newDB())
30+
})
31+
}
32+
}
33+
3434
func FuzzKeyValue(f *testing.F) {
3535
database.FuzzKeyValue(f, newDB())
3636
}

database/encdb/db_test.go

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,14 @@ import (
1616
const testPassword = "lol totally a secure password" //nolint:gosec
1717

1818
func TestInterface(t *testing.T) {
19-
for _, test := range database.Tests {
20-
unencryptedDB := memdb.New()
21-
db, err := New([]byte(testPassword), unencryptedDB)
22-
require.NoError(t, err)
23-
24-
test(t, db)
19+
for name, test := range database.Tests {
20+
t.Run(name, func(t *testing.T) {
21+
unencryptedDB := memdb.New()
22+
db, err := New([]byte(testPassword), unencryptedDB)
23+
require.NoError(t, err)
24+
25+
test(t, db)
26+
})
2527
}
2628
}
2729

database/leveldb/db_test.go

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,14 +16,16 @@ import (
1616
)
1717

1818
func TestInterface(t *testing.T) {
19-
for _, test := range database.Tests {
20-
folder := t.TempDir()
21-
db, err := New(folder, nil, logging.NoLog{}, "", prometheus.NewRegistry())
22-
require.NoError(t, err)
19+
for name, test := range database.Tests {
20+
t.Run(name, func(t *testing.T) {
21+
folder := t.TempDir()
22+
db, err := New(folder, nil, logging.NoLog{}, "", prometheus.NewRegistry())
23+
require.NoError(t, err)
2324

24-
test(t, db)
25+
test(t, db)
2526

26-
_ = db.Close()
27+
_ = db.Close()
28+
})
2729
}
2830
}
2931

database/memdb/db_test.go

Lines changed: 4 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -11,8 +11,10 @@ import (
1111
)
1212

1313
func TestInterface(t *testing.T) {
14-
for _, test := range database.Tests {
15-
test(t, New())
14+
for name, test := range database.Tests {
15+
t.Run(name, func(t *testing.T) {
16+
test(t, New())
17+
})
1618
}
1719
}
1820

database/meterdb/db_test.go

Lines changed: 8 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -16,12 +16,14 @@ import (
1616
)
1717

1818
func TestInterface(t *testing.T) {
19-
for _, test := range database.Tests {
20-
baseDB := memdb.New()
21-
db, err := New("", prometheus.NewRegistry(), baseDB)
22-
require.NoError(t, err)
23-
24-
test(t, db)
19+
for name, test := range database.Tests {
20+
t.Run(name, func(t *testing.T) {
21+
baseDB := memdb.New()
22+
db, err := New("", prometheus.NewRegistry(), baseDB)
23+
require.NoError(t, err)
24+
25+
test(t, db)
26+
})
2527
}
2628
}
2729

database/pebble/db_test.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -23,10 +23,12 @@ func newDB(t testing.TB) *Database {
2323
}
2424

2525
func TestInterface(t *testing.T) {
26-
for _, test := range database.Tests {
27-
db := newDB(t)
28-
test(t, db)
29-
_ = db.Close()
26+
for name, test := range database.Tests {
27+
t.Run(name, func(t *testing.T) {
28+
db := newDB(t)
29+
test(t, db)
30+
_ = db.Close()
31+
})
3032
}
3133
}
3234

database/prefixdb/db_test.go

Lines changed: 10 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -12,14 +12,16 @@ import (
1212
)
1313

1414
func TestInterface(t *testing.T) {
15-
for _, test := range database.Tests {
16-
db := memdb.New()
17-
test(t, New([]byte("hello"), db))
18-
test(t, New([]byte("world"), db))
19-
test(t, New([]byte("wor"), New([]byte("ld"), db)))
20-
test(t, New([]byte("ld"), New([]byte("wor"), db)))
21-
test(t, NewNested([]byte("wor"), New([]byte("ld"), db)))
22-
test(t, NewNested([]byte("ld"), New([]byte("wor"), db)))
15+
for name, test := range database.Tests {
16+
t.Run(name, func(t *testing.T) {
17+
db := memdb.New()
18+
test(t, New([]byte("hello"), db))
19+
test(t, New([]byte("world"), db))
20+
test(t, New([]byte("wor"), New([]byte("ld"), db)))
21+
test(t, New([]byte("ld"), New([]byte("wor"), db)))
22+
test(t, NewNested([]byte("wor"), New([]byte("ld"), db)))
23+
test(t, NewNested([]byte("ld"), New([]byte("wor"), db)))
24+
})
2325
}
2426
}
2527

database/rpcdb/db_test.go

Lines changed: 6 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -54,11 +54,13 @@ func setupDB(t testing.TB) *testDatabase {
5454
}
5555

5656
func TestInterface(t *testing.T) {
57-
for _, test := range database.Tests {
58-
db := setupDB(t)
59-
test(t, db.client)
57+
for name, test := range database.Tests {
58+
t.Run(name, func(t *testing.T) {
59+
db := setupDB(t)
60+
test(t, db.client)
6061

61-
db.closeFn()
62+
db.closeFn()
63+
})
6264
}
6365
}
6466

database/test_database.go

Lines changed: 38 additions & 38 deletions
Original file line numberDiff line numberDiff line change
@@ -24,44 +24,44 @@ import (
2424
)
2525

2626
// Tests is a list of all database tests
27-
var Tests = []func(t *testing.T, db Database){
28-
TestSimpleKeyValue,
29-
TestOverwriteKeyValue,
30-
TestEmptyKey,
31-
TestKeyEmptyValue,
32-
TestSimpleKeyValueClosed,
33-
TestNewBatchClosed,
34-
TestBatchPut,
35-
TestBatchDelete,
36-
TestBatchReset,
37-
TestBatchReuse,
38-
TestBatchRewrite,
39-
TestBatchReplay,
40-
TestBatchReplayPropagateError,
41-
TestBatchInner,
42-
TestBatchLargeSize,
43-
TestIteratorSnapshot,
44-
TestIterator,
45-
TestIteratorStart,
46-
TestIteratorPrefix,
47-
TestIteratorStartPrefix,
48-
TestIteratorMemorySafety,
49-
TestIteratorClosed,
50-
TestIteratorError,
51-
TestIteratorErrorAfterRelease,
52-
TestCompactNoPanic,
53-
TestMemorySafetyDatabase,
54-
TestMemorySafetyBatch,
55-
TestAtomicClear,
56-
TestClear,
57-
TestAtomicClearPrefix,
58-
TestClearPrefix,
59-
TestModifyValueAfterPut,
60-
TestModifyValueAfterBatchPut,
61-
TestModifyValueAfterBatchPutReplay,
62-
TestConcurrentBatches,
63-
TestManySmallConcurrentKVPairBatches,
64-
TestPutGetEmpty,
27+
var Tests = map[string]func(t *testing.T, db Database){
28+
"SimpleKeyValue": TestSimpleKeyValue,
29+
"OverwriteKeyValue": TestOverwriteKeyValue,
30+
"EmptyKey": TestEmptyKey,
31+
"KeyEmptyValue": TestKeyEmptyValue,
32+
"SimpleKeyValueClosed": TestSimpleKeyValueClosed,
33+
"NewBatchClosed": TestNewBatchClosed,
34+
"BatchPut": TestBatchPut,
35+
"BatchDelete": TestBatchDelete,
36+
"BatchReset": TestBatchReset,
37+
"BatchReuse": TestBatchReuse,
38+
"BatchRewrite": TestBatchRewrite,
39+
"BatchReplay": TestBatchReplay,
40+
"BatchReplayPropagateError": TestBatchReplayPropagateError,
41+
"BatchInner": TestBatchInner,
42+
"BatchLargeSize": TestBatchLargeSize,
43+
"IteratorSnapshot": TestIteratorSnapshot,
44+
"Iterator": TestIterator,
45+
"IteratorStart": TestIteratorStart,
46+
"IteratorPrefix": TestIteratorPrefix,
47+
"IteratorStartPrefix": TestIteratorStartPrefix,
48+
"IteratorMemorySafety": TestIteratorMemorySafety,
49+
"IteratorClosed": TestIteratorClosed,
50+
"IteratorError": TestIteratorError,
51+
"IteratorErrorAfterRelease": TestIteratorErrorAfterRelease,
52+
"CompactNoPanic": TestCompactNoPanic,
53+
"MemorySafetyDatabase": TestMemorySafetyDatabase,
54+
"MemorySafetyBatch": TestMemorySafetyBatch,
55+
"AtomicClear": TestAtomicClear,
56+
"Clear": TestClear,
57+
"AtomicClearPrefix": TestAtomicClearPrefix,
58+
"ClearPrefix": TestClearPrefix,
59+
"ModifyValueAfterPut": TestModifyValueAfterPut,
60+
"ModifyValueAfterBatchPut": TestModifyValueAfterBatchPut,
61+
"ModifyValueAfterBatchPutReplay": TestModifyValueAfterBatchPutReplay,
62+
"ConcurrentBatches": TestConcurrentBatches,
63+
"ManySmallConcurrentKVPairBatches": TestManySmallConcurrentKVPairBatches,
64+
"PutGetEmpty": TestPutGetEmpty,
6565
}
6666

6767
// TestSimpleKeyValue tests to make sure that simple Put + Get + Delete + Has

database/versiondb/db_test.go

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -14,9 +14,11 @@ import (
1414
)
1515

1616
func TestInterface(t *testing.T) {
17-
for _, test := range database.Tests {
18-
baseDB := memdb.New()
19-
test(t, New(baseDB))
17+
for name, test := range database.Tests {
18+
t.Run(name, func(t *testing.T) {
19+
baseDB := memdb.New()
20+
test(t, New(baseDB))
21+
})
2022
}
2123
}
2224

0 commit comments

Comments
 (0)