database

Documentation

Index

• Constants
• func ConnExecContext(c *sql.Conn, ctx context.Context, query string, args ...interface{}) (sql.Result, error)
• func ConnPrepareContext(c *sql.Conn, ctx context.Context, query string) (*sql.Stmt, error)
• func ConnQueryContext(c *sql.Conn, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
• func DBClose(db *sql.DB) error
• func DBExecContext(db *sql.DB, ctx context.Context, query string, args ...interface{}) (sql.Result, error)
• func DBOpen(driverName, dataSourceName string) (*sql.DB, error)
• func DBPrepareContext(db *sql.DB, ctx context.Context, query string) (*sql.Stmt, error)
• func DBQueryContext(db *sql.DB, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
• func DBexecDC(db *sql.DB, ctx context.Context, dc *driverConn, release func(error), ...) (res sql.Result, err error)
• func DBprepareDC(db *sql.DB, ctx context.Context, dc *driverConn, release func(error), ...) (*sql.Stmt, error)
• func DBqueryDC(db *sql.DB, ctx, txctx context.Context, dc *driverConn, ...) (*sql.Rows, error)
• func RowsClose(rs *sql.Rows) error
• func StmtClose(s *sql.Stmt) error
• func StmtExecContext(s *sql.Stmt, ctx context.Context, args ...interface{}) (sql.Result, error)
• func StmtQueryContext(s *sql.Stmt, ctx context.Context, args ...interface{}) (*sql.Rows, error)
• func StrSplit(source string, issep func(byte) bool, handler func(string) bool)
• func TxExecContext(tx *sql.Tx, ctx context.Context, query string, args ...interface{}) (sql.Result, error)
• func TxPrepareContext(tx *sql.Tx, ctx context.Context, query string) (*sql.Stmt, error)
• func TxQueryContext(tx *sql.Tx, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
• func WrapConnExecContext(c *sql.Conn, ctx context.Context, query string, args ...interface{}) (sql.Result, error)
• func WrapConnPrepareContext(c *sql.Conn, ctx context.Context, query string) (*sql.Stmt, error)
• func WrapConnQueryContext(c *sql.Conn, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
• func WrapDBClose(db *sql.DB) error
• func WrapDBExecContext(db *sql.DB, ctx context.Context, query string, args ...interface{}) (sql.Result, error)
• func WrapDBOpen(driverName, dataSourceName string) (*sql.DB, error)
• func WrapDBPrepareContext(db *sql.DB, ctx context.Context, query string) (*sql.Stmt, error)
• func WrapDBQueryContext(db *sql.DB, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
• func WrapDBexecDC(db *sql.DB, ctx context.Context, dc *driverConn, release func(error), ...) (res sql.Result, err error)
• func WrapDBprepareDC(db *sql.DB, ctx context.Context, dc *driverConn, release func(error), ...) (*sql.Stmt, error)
• func WrapDBqueryDC(db *sql.DB, ctx, txctx context.Context, dc *driverConn, ...) (*sql.Rows, error)
• func WrapRowsClose(rs *sql.Rows) error
• func WrapStmtClose(s *sql.Stmt) error
• func WrapStmtExecContext(s *sql.Stmt, ctx context.Context, args ...interface{}) (sql.Result, error)
• func WrapStmtQueryContext(s *sql.Stmt, ctx context.Context, args ...interface{}) (*sql.Rows, error)
• func WrapTxExecContext(tx *sql.Tx, ctx context.Context, query string, args ...interface{}) (sql.Result, error)
• func WrapTxPrepareContext(tx *sql.Tx, ctx context.Context, query string) (*sql.Stmt, error)
• func WrapTxQueryContext(tx *sql.Tx, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

Constants

const (
	StorageIndexContext = tingyun3.StorageIndexDatabase + 0
	StorageIndexLock    = tingyun3.StorageIndexDatabase + 1
)

Functions

func ConnExecContext

func ConnExecContext(c *sql.Conn, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func ConnPrepareContext

func ConnPrepareContext(c *sql.Conn, ctx context.Context, query string) (*sql.Stmt, error)

func ConnQueryContext

func ConnQueryContext(c *sql.Conn, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func DBClose

func DBClose(db *sql.DB) error

func DBExecContext

func DBExecContext(db *sql.DB, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func DBOpen

func DBOpen(driverName, dataSourceName string) (*sql.DB, error)

func DBPrepareContext

func DBPrepareContext(db *sql.DB, ctx context.Context, query string) (*sql.Stmt, error)

func DBQueryContext

func DBQueryContext(db *sql.DB, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func DBexecDC

func DBexecDC(db *sql.DB, ctx context.Context, dc *driverConn, release func(error), query string, args []interface{}) (res sql.Result, err error)

func DBprepareDC

func DBprepareDC(db *sql.DB, ctx context.Context, dc *driverConn, release func(error), cg stmtConnGrabber, query string) (*sql.Stmt, error)

func DBqueryDC

func DBqueryDC(db *sql.DB, ctx, txctx context.Context, dc *driverConn, releaseConn func(error), query string, args []interface{}) (*sql.Rows, error)

func RowsClose

func RowsClose(rs *sql.Rows) error

func StmtClose

func StmtClose(s *sql.Stmt) error

func StmtExecContext

func StmtExecContext(s *sql.Stmt, ctx context.Context, args ...interface{}) (sql.Result, error)

func StmtQueryContext

func StmtQueryContext(s *sql.Stmt, ctx context.Context, args ...interface{}) (*sql.Rows, error)

func StrSplit

func StrSplit(source string, issep func(byte) bool, handler func(string) bool)

func TxExecContext

func TxExecContext(tx *sql.Tx, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func TxPrepareContext

func TxPrepareContext(tx *sql.Tx, ctx context.Context, query string) (*sql.Stmt, error)

func TxQueryContext

func TxQueryContext(tx *sql.Tx, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func WrapConnExecContext

func WrapConnExecContext(c *sql.Conn, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func WrapConnPrepareContext

func WrapConnPrepareContext(c *sql.Conn, ctx context.Context, query string) (*sql.Stmt, error)

func WrapConnQueryContext

func WrapConnQueryContext(c *sql.Conn, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func WrapDBClose

func WrapDBClose(db *sql.DB) error

func WrapDBExecContext

func WrapDBExecContext(db *sql.DB, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func WrapDBOpen

func WrapDBOpen(driverName, dataSourceName string) (*sql.DB, error)

func WrapDBPrepareContext

func WrapDBPrepareContext(db *sql.DB, ctx context.Context, query string) (*sql.Stmt, error)

func WrapDBQueryContext

func WrapDBQueryContext(db *sql.DB, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func WrapDBexecDC

func WrapDBexecDC(db *sql.DB, ctx context.Context, dc *driverConn, release func(error), query string, args []interface{}) (res sql.Result, err error)

func WrapDBprepareDC

func WrapDBprepareDC(db *sql.DB, ctx context.Context, dc *driverConn, release func(error), cg stmtConnGrabber, query string) (*sql.Stmt, error)

func WrapDBqueryDC

func WrapDBqueryDC(db *sql.DB, ctx, txctx context.Context, dc *driverConn, releaseConn func(error), query string, args []interface{}) (*sql.Rows, error)

func WrapRowsClose

func WrapRowsClose(rs *sql.Rows) error

func WrapStmtClose

func WrapStmtClose(s *sql.Stmt) error

func WrapStmtExecContext

func WrapStmtExecContext(s *sql.Stmt, ctx context.Context, args ...interface{}) (sql.Result, error)

func WrapStmtQueryContext

func WrapStmtQueryContext(s *sql.Stmt, ctx context.Context, args ...interface{}) (*sql.Rows, error)

func WrapTxExecContext

func WrapTxExecContext(tx *sql.Tx, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func WrapTxPrepareContext

func WrapTxPrepareContext(tx *sql.Tx, ctx context.Context, query string) (*sql.Stmt, error)

func WrapTxQueryContext

func WrapTxQueryContext(tx *sql.Tx, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)