Function TestDatabaseRecycle

worker/db_test.go:434–521

(t *testing.T)

}

func TestDatabaseRecycle(t *testing.T) {
	defer leaktest.Check(t)()
	defer kms.ClosePublicKeyStore()

	// test init/shutdown/destroy
	// test goroutine status
	Convey("test init destroy", t, func() {
		var err error
		var server *rpc.Server
		var cleanup func()
		cleanup, server, err = initNode()
		So(err, ShouldBeNil)

		defer cleanup()

		var rootDir string
		rootDir, err = ioutil.TempDir("", "db_test_")
		So(err, ShouldBeNil)

		// create mux service
		kayakMuxService, err := NewDBKayakMuxService("DBKayak", server)
		So(err, ShouldBeNil)

		chainMuxService, err := sqlchain.NewMuxService("sqlchain", server)
		So(err, ShouldBeNil)

		// create peers
		var peers *proto.Peers
		peers, err = getPeers(1)
		So(err, ShouldBeNil)

		// create file
		cfg := &DBConfig{
			DatabaseID:       "00000bef611d346c0cbe1beaa76e7f0ed705a194fdf9ac3a248ec70e9c198bf9",
			DataDir:          rootDir,
			KayakMux:         kayakMuxService,
			ChainMux:         chainMuxService,
			MaxWriteTimeGap:  time.Duration(5 * time.Second),
			UpdateBlockCount: 2,
		}

		// create genesis block
		var block *types.Block
		block, err = types.CreateRandomBlock(rootHash, true)
		So(err, ShouldBeNil)

		// create database
		var db *Database
		db, err = NewDatabase(cfg, peers, block)
		So(err, ShouldBeNil)

		// do some query
		var writeQuery *types.Request
		var res *types.Response
		writeQuery, err = buildQuery(types.WriteQuery, 1, 1, []string{
			"create table test (test int)",
			"insert into test values(1)",
		})