Function TestDB_Merge2

engine/merge_test.go:26–62

All valid data

(t *testing.T)

// All valid data
func TestDB_Merge2(t *testing.T) {
	opts := config.DefaultOptions
	dir, _ := os.MkdirTemp("", "flydb-merge-2")
	opts.DataFileSize = 32 * 1024 * 1024
	opts.DirPath = dir
	db, err := NewDB(opts)
	defer db.Clean()
	assert.Nil(t, err)
	assert.NotNil(t, db)

	for i := 0; i < 50000; i++ {
		err := db.Put(randkv.GetTestKey(i), randkv.RandomValue(1024))
		assert.Nil(t, err)
	}

	err = db.Merge()
	assert.Nil(t, err)

	// Restart check
	err = db.Close()
	assert.Nil(t, err)

	db2, err := NewDB(opts)
	defer func() {
		_ = db2.Close()
	}()
	assert.Nil(t, err)
	keys := db2.GetListKeys()
	assert.Equal(t, 50000, len(keys))

	for i := 0; i < 50000; i++ {
		val, err := db2.Get(randkv.GetTestKey(i))
		assert.Nil(t, err)
		assert.NotNil(t, val)
	}

}

// All invalid data
func TestDB_Merge3(t *testing.T) {