Function main

test/stable/main.go:81–121

()

}

func main() {
	log.SetLevel(log.InfoLevel)
	var config, password, dsn string

	flag.StringVar(&config, "config", "./conf/config.yaml", "config file path")
	flag.StringVar(&dsn, "dsn", "", "database url")
	flag.StringVar(&password, "password", "", "master key password for covenantsql")
	flag.Parse()

	go func() {
		http.ListenAndServe("0.0.0.0:6061", nil)
	}()

	err := client.Init(config, []byte(password))
	if err != nil {
		log.Fatal(err)
	}

	db, err := sql.Open("covenantsql", dsn)
	if err != nil {
		log.Fatal(err)
	}

	tableName := fmt.Sprintf(tableNamePattern, 0)
	_, err = db.Exec(fmt.Sprintf("DROP TABLE IF EXISTS %s;", tableName))
	if err != nil {
		log.Fatal(err)
	}

	createSqliteTestTable(db, tableName)

	pool := grpool.NewPool(8, 16)
	defer pool.Release()
	insertData(db, tableName, 500000000, pool)
	pool.WaitAll()

	err = db.Close()
	if err != nil {
		log.Fatal(err)
	}
}