Function TestFullProcess

sqlchain/mirror/mirror_test.go:213–323

(t *testing.T)

}

func TestFullProcess(t *testing.T) {
	log.SetLevel(log.DebugLevel)

	Convey("test mirror full process", t, func() {
		var (
			err error
		)

		startNodes()
		defer stopNodes()

		err = client.Init(FJ(testWorkingDir, "./mirror/node_c/config.yaml"), []byte(""))
		So(err, ShouldBeNil)

		// wait bp chain service to start
		ctx, ccl1 := context.WithTimeout(context.Background(), 1*time.Minute)
		defer ccl1()
		err = test.WaitBPChainService(ctx, 3*time.Second)
		So(err, ShouldBeNil)

		// create
		meta := client.ResourceMeta{}
		meta.Node = 1
		_, dsn, err := client.Create(meta)
		So(err, ShouldBeNil)
		dsnCfg, err := client.ParseDSN(dsn)
		So(err, ShouldBeNil)

		log.Infof("the created database dsn is %v", dsn)

		db, err := sql.Open("covenantsql", dsn)
		So(err, ShouldBeNil)
		defer db.Close()

		// wait for creation
		ctx, ccl2 := context.WithTimeout(context.Background(), 5*time.Minute)
		defer ccl2()
		err = client.WaitDBCreation(ctx, dsn)
		So(err, ShouldBeNil)

		_, err = db.Exec("CREATE TABLE test (test int)")
		So(err, ShouldBeNil)

		_, err = db.Exec("INSERT INTO test VALUES(?)", 4)
		So(err, ShouldBeNil)

		row := db.QueryRow("SELECT * FROM test LIMIT 1")

		var result int
		err = row.Scan(&result)
		So(err, ShouldBeNil)
		So(result, ShouldEqual, 4)

		// run mirror node
		utils.RemoveAll(FJ(testWorkingDir, "./mirror/node_mirror/"+dsnCfg.DatabaseID+"*"))
		defer utils.RemoveAll(FJ(testWorkingDir, "./mirror/node_mirror/"+dsnCfg.DatabaseID+"*"))

		var mirrorCmd *utils.CMD