Versions in this module Expand all Collapse all v0 v0.0.2 Jan 3, 2024 v0.0.1 Jan 3, 2024 Changes in this version + const DRV_NAME_MYSQL + const DRV_NAME_ORACLE + const DRV_NAME_POSTGRES + const DRV_NAME_SQLITE3 + const DRV_NAME_SQLSERVER + func Close(closer io.Closer) + func CloseCache() + func Commit(tx *sql.Tx, fn func() error) error + func InsertStruct(drvName string, exec Execer, obj interface{}, tbName string) (sql.Result, error) + func InsertStructContext(drvName string, exec Execer, ctx context.Context, obj interface{}, ...) (sql.Result, error) + func QueryElem(queryer Queryer, result interface{}, querySql string, args ...interface{}) error + func QueryElemContext(queryer Queryer, ctx context.Context, result interface{}, querySql string, ...) error + func QueryElems(queryer Queryer, result interface{}, querySql string, args ...interface{}) error + func QueryElemsContext(queryer Queryer, ctx context.Context, result interface{}, querySql string, ...) error + func QueryPageArr(queryer Queryer, querySql string, args ...interface{}) (titles []string, result [][]interface{}, err error) + func QueryPageArrContext(queryer Queryer, ctx context.Context, querySql string, args ...interface{}) (titles []string, result [][]interface{}, err error) + func QueryPageMap(queryer Queryer, querySql string, args ...interface{}) (titles []string, result []map[string]interface{}, err error) + func QueryPageMapContext(queryer Queryer, ctx context.Context, querySql string, args ...interface{}) (titles []string, result []map[string]interface{}, err error) + func QueryStruct(queryer Queryer, obj interface{}, querySql string, args ...interface{}) error + func QueryStructContext(queryer Queryer, ctx context.Context, obj interface{}, querySql string, ...) error + func QueryStructs(queryer Queryer, obj interface{}, querySql string, args ...interface{}) error + func QueryStructsContext(queryer Queryer, ctx context.Context, obj interface{}, querySql string, ...) error + func RegCache(key string, db *DB) + func RegCacheWithIni(iniPath string) + func Rollback(tx *sql.Tx) + func ScanStruct(rows Rows, obj interface{}) error + func ScanStructs(rows Rows, obj interface{}) error + func StmtSliceArgs(args ...interface{}) []interface + func StmtWhereIn(drvName string, paramStartIdx, paramsLen int) string + type Bool bool + func (v *Bool) Scan(i interface{}) error + func (v *Bool) Value() (driver.Value, error) + type DB struct + func GetCache(key string) *DB + func HasCache(key string) (*DB, error) + func NewDB(drvName string, db *sql.DB) *DB + func Open(drvName, dsn string) (*DB, error) + func (db *DB) Close() error + func (db *DB) Commit(tx *sql.Tx, fn func() error) error + func (db *DB) DriverName() string + func (db *DB) InsertStruct(obj interface{}, tbName string) (sql.Result, error) + func (db *DB) InsertStructContext(ctx context.Context, obj interface{}, tbName string) (sql.Result, error) + func (db *DB) IsClose() bool + func (db *DB) QueryElem(result interface{}, querySql string, args ...interface{}) error + func (db *DB) QueryElemContext(ctx context.Context, result interface{}, querySql string, args ...interface{}) error + func (db *DB) QueryElems(result interface{}, querySql string, args ...interface{}) error + func (db *DB) QueryElemsContext(ctx context.Context, result interface{}, querySql string, args ...interface{}) error + func (db *DB) QueryPageArr(querySql string, args ...interface{}) (titles []string, result [][]interface{}, err error) + func (db *DB) QueryPageArrContext(ctx context.Context, querySql string, args ...interface{}) (titles []string, result [][]interface{}, err error) + func (db *DB) QueryPageMap(querySql string, args ...interface{}) (titles []string, result []map[string]interface{}, err error) + func (db *DB) QueryPageMapContext(ctx context.Context, querySql string, args ...interface{}) (titles []string, result []map[string]interface{}, err error) + func (db *DB) QueryStruct(obj interface{}, querySql string, args ...interface{}) error + func (db *DB) QueryStructContext(ctx context.Context, obj interface{}, querySql string, args ...interface{}) error + func (db *DB) QueryStructs(obj interface{}, querySql string, args ...interface{}) error + func (db *DB) QueryStructsContext(ctx context.Context, obj interface{}, querySql string, args ...interface{}) error + func (db *DB) ScanStruct(rows Rows, obj interface{}) error + func (db *DB) ScanStructs(rows Rows, obj interface{}) error + func (db *DB) StmtWhereIn(paramStartIdx, paramsLen int) string + type DBData string + func (d *DBData) Scan(i interface{}) error + func (d *DBData) String() string + type Execer interface + Exec func(query string, args ...interface{}) (sql.Result, error) + ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error) + type Float64 float64 + func (v *Float64) Scan(i interface{}) error + func (v Float64) Value() (driver.Value, error) + type Int64 int64 + func (v *Int64) Scan(i interface{}) error + func (v Int64) Value() (driver.Value, error) + type PageArgs struct + func NewPageArgs(args ...interface{}) *PageArgs + func (p *PageArgs) Limit(offset, limit int64) *PageArgs + type PageSql struct + func NewPageSql(countSql, dataSql string) *PageSql + func (p *PageSql) QueryCount(db *DB, args ...interface{}) (int64, error) + func (p *PageSql) QueryPageArr(db *DB, doCount bool, args *PageArgs) (int64, []string, [][]interface{}, error) + func (p *PageSql) QueryPageMap(db *DB, doCount bool, args *PageArgs) (int64, []string, []map[string]interface{}, error) + func (p PageSql) CountSql() string + func (p PageSql) DataSql() string + func (p PageSql) FmtPage(args ...interface{}) PageSql + type Queryer interface + Query func(query string, args ...interface{}) (*sql.Rows, error) + QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error) + QueryRow func(query string, args ...interface{}) *sql.Row + QueryRowContext func(ctx context.Context, query string, args ...interface{}) *sql.Row + type Rows interface + Close func() error + Columns func() ([]string, error) + Err func() error + Next func() bool + Scan func(...interface{}) error + type String string + func (v *String) Scan(i interface{}) error + func (v *String) String() string + func (v String) Value() (driver.Value, error)