sqldriver

type CreateSingleDBConn func(cfg *config.SQL) (*sqlx.DB, error)

type Driver interface {

	// BeginTxx starts a new transaction in the shard of dbShardID
	BeginTxx(ctx context.Context, dbShardID int, opts *sql.TxOptions) (*sqlx.Tx, error)
	// Commit commits the current transaction(started by BeginTxx)
	Commit() error
	// Rollback rollbacks the current transaction(started by BeginTxx)
	Rollback() error
	// Close closes this driver(and underlying connections)
	Close() error

	// ExecDDL executes a DDL query
	ExecDDL(ctx context.Context, dbShardID int, query string, args ...interface{}) (sql.Result, error)
	// SelectForSchemaQuery executes a select query for schema(returning multiple rows).
	SelectForSchemaQuery(dbShardID int, dest interface{}, query string, args ...interface{}) error
	// GetForSchemaQuery executes a get query for schema(returning single row).
	GetForSchemaQuery(dbShardID int, dest interface{}, query string, args ...interface{}) error
	// contains filtered or unexported methods
}