Function TestDB_Iterator

driver/hybriddb/db_test.go:188–232

(t *testing.T)

}

func TestDB_Iterator(t *testing.T) {
	tempDir := t.TempDir()
	cfg := &config.Config{
		LevelDB: config.LevelDBConfig{
			CacheSize:       64 * 1024 * 1024,
			BlockSize:       4 * 1024,
			WriteBufferSize: 4 * 1024 * 1024,
			MaxOpenFiles:    1000,
			Compression:     true,
		},
	}

	db, err := Store{}.Open(tempDir, cfg)
	require.NoError(t, err)
	defer db.Close()

	// Insert test data
	testData := map[string]string{
		"a": "1",
		"b": "2",
		"c": "3",
	}

	for k, v := range testData {
		err = db.Put([]byte(k), []byte(v))
		require.NoError(t, err)
	}

	// Test iterator
	iter := db.NewIterator()
	defer iter.Close()

	count := 0
	for iter.First(); iter.Valid(); iter.Next() {
		key := string(iter.Key())
		value := string(iter.Value())

		expectedValue, exists := testData[key]
		assert.True(t, exists)
		assert.Equal(t, expectedValue, value)
		count++
	}

	assert.Equal(t, len(testData), count)
}

func TestDB_Snapshot(t *testing.T) {
	tempDir := t.TempDir()