testutils

func CreateAccount(
	t *testing.T,
	c embed.Cluster,
	accountName string,
	password string,
) int32

func CreateTableAndWaitCNApplied(
	t *testing.T,
	db string,
	tableName string,
	tableSQL string,
	createOnCN embed.ServiceOperator,
	waitOnCNs ...embed.ServiceOperator,
) timestamp.Timestamp

func CreateTestDatabase(
	t *testing.T,
	name string,
	cn embed.ServiceOperator,
)

func CreateTestDatabaseWithAccount(
	t *testing.T,
	account int32,
	name string,
	cn embed.ServiceOperator,
)

func DBExists(
	t *testing.T,
	name string,
	cn embed.ServiceOperator,
) bool

func DBExistsWithAccount(
	t *testing.T,
	account int32,
	name string,
	cn embed.ServiceOperator,
) bool

func ExecSQL(
	t *testing.T,
	db string,
	cn embed.ServiceOperator,
	sql ...string,
) timestamp.Timestamp

func ExecSQLWithAccount(
	t *testing.T,
	account int32,
	db string,
	cn embed.ServiceOperator,
	sql ...string,
) timestamp.Timestamp

func ExecSQLWithMinCommittedTS(
	t *testing.T,
	db string,
	cn embed.ServiceOperator,
	min timestamp.Timestamp,
	sql ...string,
) timestamp.Timestamp

func ExecSQLWithMinCommittedTSAndAccount(
	t *testing.T,
	account int32,
	db string,
	cn embed.ServiceOperator,
	min timestamp.Timestamp,
	sql ...string,
) timestamp.Timestamp

func ExecSQLWithReadResult(
	t *testing.T,
	db string,
	cn embed.ServiceOperator,
	reader func(int, string, executor.Result),
	sql ...string,
) timestamp.Timestamp

func ExecSQLWithReadResultAndAccount(
	t *testing.T,
	account int32,
	db string,
	cn embed.ServiceOperator,
	reader func(int, string, executor.Result),
	sql ...string,
) timestamp.Timestamp

func GetDatabaseName(
	t *testing.T,
) string

func GetSQLExecutor(
	cn embed.ServiceOperator,
) executor.SQLExecutor

func GetTableID(
	t *testing.T,
	db string,
	table string,
	txn executor.TxnExecutor,
) uint64

func HasName(
	name string,
	res executor.Result,
) bool

func MustParseMOCtlResult(t *testing.T, result string) string

func ReadCount(
	res executor.Result,
) int

func TableExists(
	t *testing.T,
	db string,
	name string,
	cn embed.ServiceOperator,
) bool

func TableExistsWithAccount(
	t *testing.T,
	account int32,
	db string,
	name string,
	cn embed.ServiceOperator,
) bool

func WaitClusterAppliedTo(
	t *testing.T,
	c embed.Cluster,
	ts timestamp.Timestamp,
)

func WaitDatabaseCreated(
	t *testing.T,
	name string,
	cn embed.ServiceOperator,
)

func WaitDatabaseCreatedWithAccount(
	t *testing.T,
	account int32,
	name string,
	cn embed.ServiceOperator,
)

func WaitLogtailApplied(
	t *testing.T,
	min timestamp.Timestamp,
	cn embed.ServiceOperator,
)

func WaitTableCreated(
	t *testing.T,
	db string,
	name string,
	cn embed.ServiceOperator,
)

func WaitTableCreatedWithAccount(
	t *testing.T,
	account int32,
	db string,
	name string,
	cn embed.ServiceOperator,
)