Function TestTx_ListRecoveryMultipleLists

tx_list_test.go:718–759

TestTx_ListRecoveryMultipleLists tests recovery of multiple lists

(t *testing.T)

// TestTx_ListRecoveryMultipleLists tests recovery of multiple lists
func TestTx_ListRecoveryMultipleLists(t *testing.T) {
	bucket := "list_bucket"

	dir := filepath.Join(t.TempDir(), "test_nutsdb_list_recovery_multiple")
	defer func() { _ = os.RemoveAll(dir) }()

	opts := DefaultOptions
	opts.Dir = dir
	db, err := Open(opts)
	require.NoError(t, err)

	// Create bucket
	txCreateBucket(t, db, DataStructureList, bucket, nil)

	// Create multiple lists
	for listIdx := 0; listIdx < 3; listIdx++ {
		key := testutils.GetTestBytes(listIdx)
		for i := 0; i < 5; i++ {
			txPush(t, db, bucket, key, testutils.GetTestBytes(listIdx*100+i), false, nil, nil)
		}
	}

	// Close and reopen
	err = db.Close()
	require.NoError(t, err)

	db, err = Open(opts)
	require.NoError(t, err)
	defer func() { _ = db.Close() }()

	// Verify all lists recovered correctly
	for listIdx := 0; listIdx < 3; listIdx++ {
		key := testutils.GetTestBytes(listIdx)
		txLSize(t, db, bucket, key, 5, nil)

		expected := make([][]byte, 5)
		for i := 0; i < 5; i++ {
			expected[i] = testutils.GetTestBytes(listIdx*100 + i)
		}
		txLRange(t, db, bucket, key, 0, -1, 5, expected, nil)
	}
}