Function initTestDB

cmd/cql-fuse/block_test.go:234–288

()

}

func initTestDB() (*sql.DB, func()) {

	startNodes()
	var err error

	time.Sleep(10 * time.Second)

	err = client.Init(FJ(testWorkingDir, "./fuse/node_c/config.yaml"), []byte(""))
	if err != nil {
		log.Errorf("init client failed: %v", err)
		return nil, stopNodes
	}

	// wait for chain service
	var ctx1, cancel1 = context.WithTimeout(context.Background(), 1*time.Minute)
	defer cancel1()
	err = test.WaitBPChainService(ctx1, 3*time.Second)
	if err != nil {
		log.Errorf("wait for chain service failed: %v", err)
		return nil, stopNodes
	}

	// create
	meta := client.ResourceMeta{}
	meta.Node = 1
	_, dsn, err := client.Create(meta)
	if err != nil {
		log.Errorf("create db failed: %v", err)
		return nil, stopNodes
	}

	db, err := sql.Open("covenantsql", dsn)
	if err != nil {
		log.Errorf("open db failed: %v", err)
		return nil, stopNodes
	}

	// wait for creation
	var ctx2, cancel2 = context.WithTimeout(context.Background(), 1*time.Minute)
	defer cancel2()
	err = client.WaitDBCreation(ctx2, dsn)
	if err != nil {
		log.Errorf("wait for creation failed: %v", err)
		return nil, stopNodes
	}

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

	if err := initSchema(db); err != nil {
		stopNodes()
		log.Fatal(err)
	}

	return db, stopNodes
}

func getAllBlocks(db *sql.DB, inode uint64) ([]byte, error) {
	blocks, err := getBlocks(db, inode)