Function TestWriteBatch_SyncCommit

driver/hybriddb/write_batch_test.go:118–150

(t *testing.T)

}

func TestWriteBatch_SyncCommit(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()

	wb := db.NewWriteBatch()
	defer wb.Close()

	key := []byte("sync-key")
	value := []byte("sync-value")

	wb.Put(key, value)

	// Test SyncCommit
	err = wb.SyncCommit()
	require.NoError(t, err)

	// Verify value
	val, err := db.Get(key)
	require.NoError(t, err)
	assert.Equal(t, value, val)
}

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