sqlmer

Mar 4, 2025

Changes in this version

type TransactionKeeperEx

+ func ExtendTx(raw TransactionKeeper) *TransactionKeeperEx

Feb 25, 2025

Changes in this version

type AbstractDbClient

+ func (client *AbstractDbClient) GetConnTimeout() time.Duration

+ func (client *AbstractDbClient) GetExecTimeout() time.Duration

type DbClient

+ GetConnTimeout func() time.Duration

+ GetExecTimeout func() time.Duration

+ Row func(sqlText string, args ...any) (row *sqlen.EnhanceRow, err error)

+ RowContext func(context context.Context, sqlText string, args ...any) (row *sqlen.EnhanceRow, err error)

type DbClientEx

+ func (client *DbClientEx) MustExecute(sqlText string, args ...any) int64

+ func (client *DbClientEx) MustExecuteContext(ctx context.Context, sqlText string, args ...any) int64

+ func (client *DbClientEx) MustExists(sqlText string, args ...any) bool

+ func (client *DbClientEx) MustExistsContext(ctx context.Context, sqlText string, args ...any) bool

+ func (client *DbClientEx) MustGet(sqlText string, args ...any) map[string]any

+ func (client *DbClientEx) MustGetContext(ctx context.Context, sqlText string, args ...any) map[string]any

+ func (client *DbClientEx) MustRow(sqlText string, args ...any) *sqlen.EnhanceRow

+ func (client *DbClientEx) MustRowContext(ctx context.Context, sqlText string, args ...any) *sqlen.EnhanceRow

+ func (client *DbClientEx) MustRows(sqlText string, args ...any) *sqlen.EnhanceRows

+ func (client *DbClientEx) MustRowsContext(ctx context.Context, sqlText string, args ...any) *sqlen.EnhanceRows

+ func (client *DbClientEx) MustScalar(sqlText string, args ...any) (any, bool)

+ func (client *DbClientEx) MustScalarContext(ctx context.Context, sqlText string, args ...any) (any, bool)

+ func (client *DbClientEx) MustSizedExecute(expectedSize int64, sqlText string, args ...any)

+ func (client *DbClientEx) MustSizedExecuteContext(ctx context.Context, expectedSize int64, sqlText string, args ...any)

+ func (client *DbClientEx) MustSliceGet(sqlText string, args ...any) []map[string]any

+ func (client *DbClientEx) MustSliceGetContext(ctx context.Context, sqlText string, args ...any) []map[string]any

type TransactionKeeperEx

+ func (transKeeper *TransactionKeeperEx) MustClose()

+ func (transKeeper *TransactionKeeperEx) MustCommit()

+ func (transKeeper *TransactionKeeperEx) MustCreateTransaction() TransactionKeeper

+ func (transKeeper *TransactionKeeperEx) MustRollback()

Jul 17, 2023

Changes in this version

+ var MaxLengthErrorValue = 64 * 1024

Apr 28, 2022

Changes in this version

type DbClientEx

+ func (c *DbClientEx) CreateTransactionEx() (tran *TransactionKeeperEx, err error)

+ func (c *DbClientEx) MustCreateTransactionEx() (tran *TransactionKeeperEx)

Apr 20, 2022

Changes in this version

type DbClientEx

+ func (c *DbClientEx) CreateTransaction() (tran *TransactionKeeperEx, err error)

+ func (c *DbClientEx) MustCreateTransaction() (tran *TransactionKeeperEx)

+ type TransactionKeeperEx struct

Apr 10, 2022

Changes in this version

+ type DbClientEx struct

+ Conv conv.Conv

+ func Extend(raw DbClient) *DbClientEx

+ func (c *DbClientEx) GetStruct(ptr any, query string, args ...any) (ok bool, err error)

+ func (c *DbClientEx) ListOf(elemExample any, query string, args ...any) (any, error)

+ func (c *DbClientEx) ListType(elemTyp reflect.Type, query string, args ...any) (any, error)

+ func (c *DbClientEx) MustGetStruct(ptr any, query string, args ...any) (ok bool)

+ func (c *DbClientEx) MustListOf(elemExample any, query string, args ...any) any

+ func (c *DbClientEx) MustListType(elemTyp reflect.Type, query string, args ...any) any

+ func (c *DbClientEx) MustScalarBool(query string, args ...any) (value *bool, ok bool)

+ func (c *DbClientEx) MustScalarFloat32(query string, args ...any) (value *float32, ok bool)

+ func (c *DbClientEx) MustScalarFloat64(query string, args ...any) (value *float64, ok bool)

+ func (c *DbClientEx) MustScalarInt(query string, args ...any) (value *int, ok bool)

+ func (c *DbClientEx) MustScalarInt16(query string, args ...any) (value *int16, ok bool)

+ func (c *DbClientEx) MustScalarInt32(query string, args ...any) (value *int32, ok bool)

+ func (c *DbClientEx) MustScalarInt64(query string, args ...any) (value *int64, ok bool)

+ func (c *DbClientEx) MustScalarInt8(query string, args ...any) (value *int8, ok bool)

+ func (c *DbClientEx) MustScalarOf(example any, query string, args ...any) (value any, ok bool, err error)

+ func (c *DbClientEx) MustScalarString(query string, args ...any) (value *string, ok bool)

+ func (c *DbClientEx) MustScalarType(typ reflect.Type, query string, args ...any) (value any, ok bool)

+ func (c *DbClientEx) ScalarBool(query string, args ...any) (value *bool, ok bool, err error)

+ func (c *DbClientEx) ScalarFloat32(query string, args ...any) (value *float32, ok bool, err error)

+ func (c *DbClientEx) ScalarFloat64(query string, args ...any) (value *float64, ok bool, err error)

+ func (c *DbClientEx) ScalarInt(query string, args ...any) (value *int, ok bool, err error)

+ func (c *DbClientEx) ScalarInt16(query string, args ...any) (value *int16, ok bool, err error)

+ func (c *DbClientEx) ScalarInt32(query string, args ...any) (value *int32, ok bool, err error)

+ func (c *DbClientEx) ScalarInt64(query string, args ...any) (value *int64, ok bool, err error)

+ func (c *DbClientEx) ScalarInt8(query string, args ...any) (value *int8, ok bool, err error)

+ func (c *DbClientEx) ScalarOf(example any, query string, args ...any) (value any, ok bool, err error)

+ func (c *DbClientEx) ScalarString(query string, args ...any) (value *string, ok bool, err error)

+ func (c *DbClientEx) ScalarType(typ reflect.Type, query string, args ...any) (value any, ok bool, err error)

Apr 9, 2022

Changes in this version

+ var ErrExecutingSql = errors.New("dbClient: failed to execute sql")

type AbstractDbClient

+ Db *sqlen.DbEnhance

+ func NewAbstractDbClient(config *DbClientConfig) (*AbstractDbClient, error)

+ func (client *AbstractDbClient) Dsn() string

type DbClient

+ Dsn func() string

type DbClientConfig

+ Db *sql.DB

+ Driver string

+ Dsn string

type DbClientOption

+ func WithDsn(driver string, dsn string) DbClientOption

+ func WithGetScanTypeFunc(scanFunc sqlen.GetScanTypeFunc) DbClientOption

Apr 9, 2022

Changes in this version

+ type ErrorDbClient interface

+ CreateTransaction func() (tran TransactionKeeper, err error)

+ Execute func(sqlText string, args ...interface{}) (rowsEffected int64, err error)

+ ExecuteContext func(ctx context.Context, sqlText string, args ...interface{}) (rowsEffected int64, err error)

+ Exists func(sqlText string, args ...interface{}) (ok bool, err error)

+ ExistsContext func(ctx context.Context, sqlText string, args ...interface{}) (ok bool, err error)

+ Get func(sqlText string, args ...interface{}) (mapRow map[string]interface{}, err error)

+ GetContext func(ctx context.Context, sqlText string, args ...interface{}) (mapRow map[string]interface{}, err error)

+ Row func(sqlText string, args ...interface{}) (row *sqlen.EnhanceRow, err error)

+ RowContext func(context context.Context, sqlText string, args ...interface{}) (row *sqlen.EnhanceRow, err error)

+ Rows func(sqlText string, args ...interface{}) (rows *sqlen.EnhanceRows, err error)

+ RowsContext func(context context.Context, sqlText string, args ...interface{}) (rows *sqlen.EnhanceRows, err error)

+ Scalar func(sqlText string, args ...interface{}) (cell interface{}, hit bool, err error)

+ ScalarContext func(ctx context.Context, sqlText string, args ...interface{}) (cell interface{}, hit bool, err error)

+ SizedExecute func(expectedSize int64, sqlText string, args ...interface{}) error

+ SizedExecuteContext func(ctx context.Context, expectedSize int64, sqlText string, args ...interface{}) error

+ SliceGet func(sqlText string, args ...interface{}) (mapRows []map[string]interface{}, err error)

+ SliceGetContext func(ctx context.Context, sqlText string, args ...interface{}) (mapRows []map[string]interface{}, err error)

+ type ErrorTransactionKeeper interface

+ Close func() error

+ Commit func() error

+ Rollback func() error

+ type MustDbClient interface

+ MustCreateTransaction func() (tran TransactionKeeper)

+ MustExecute func(sqlText string, args ...interface{}) (rowsEffected int64)

+ MustExecuteContext func(context context.Context, sqlText string, args ...interface{}) (rowsEffected int64)

+ MustExists func(sqlText string, args ...interface{}) (ok bool)

+ MustExistsContext func(context context.Context, sqlText string, args ...interface{}) (ok bool)

+ MustGet func(sqlText string, args ...interface{}) (mapRow map[string]interface{})

+ MustGetContext func(context context.Context, sqlText string, args ...interface{}) (mapRow map[string]interface{})

+ MustRow func(sqlText string, args ...interface{}) (row *sqlen.EnhanceRow)

+ MustRowContext func(context context.Context, sqlText string, args ...interface{}) (row *sqlen.EnhanceRow)

+ MustRows func(sqlText string, args ...interface{}) (rows *sqlen.EnhanceRows)

+ MustRowsContext func(context context.Context, sqlText string, args ...interface{}) (rows *sqlen.EnhanceRows)

+ MustScalar func(sqlText string, args ...interface{}) (cell interface{}, hit bool)

+ MustScalarContext func(context context.Context, sqlText string, args ...interface{}) (cell interface{}, hit bool)

+ MustSizedExecute func(expectedSize int64, sqlText string, args ...interface{})

+ MustSizedExecuteContext func(context context.Context, expectedSize int64, sqlText string, ...)

+ MustSliceGet func(sqlText string, args ...interface{}) (mapRows []map[string]interface{})

+ MustSliceGetContext func(context context.Context, sqlText string, args ...interface{}) (mapRows []map[string]interface{})

+ type MustTransactionKeeper interface

+ MustClose func()

+ MustCommit func()

+ MustRollback func()

Apr 9, 2022

Changes in this version

+ var ErrExpectedSizeWrong = errors.New("dbClient: effected rows was wrong")

+ var ErrGetEffectedRows = errors.New("database: the db driver do not support getting effected rows")

+ var ErrParseParamFailed = errors.New("dbClient: fail to parse named params")

Apr 7, 2022

Changes in this version

type DbClientOption

+ func WithUnifyDataTypeFunc(unifyDataType sqlen.UnifyDataTypeFn) DbClientOption

Apr 5, 2022

Changes in this version

+ type AbstractDbClient struct

+ Exer sqlen.EnhancedDbExer

+ SqlDB *sql.DB

+ func NewInternalDbClient(config *DbClientConfig) (AbstractDbClient, error)

+ func (client *AbstractDbClient) ConnectionString() string

+ func (client *AbstractDbClient) CreateTransaction() (TransactionKeeper, error)

+ func (client *AbstractDbClient) Execute(sqlText string, args ...interface{}) (int64, error)

+ func (client *AbstractDbClient) ExecuteContext(ctx context.Context, sqlText string, args ...interface{}) (int64, error)

+ func (client *AbstractDbClient) Exists(sqlText string, args ...interface{}) (bool, error)

+ func (client *AbstractDbClient) ExistsContext(ctx context.Context, sqlText string, args ...interface{}) (bool, error)

+ func (client *AbstractDbClient) Get(sqlText string, args ...interface{}) (map[string]interface{}, error)

+ func (client *AbstractDbClient) GetContext(ctx context.Context, sqlText string, args ...interface{}) (map[string]interface{}, error)

+ func (client *AbstractDbClient) MustCreateTransaction() TransactionKeeper

+ func (client *AbstractDbClient) MustExecute(sqlText string, args ...interface{}) int64

+ func (client *AbstractDbClient) MustExecuteContext(ctx context.Context, sqlText string, args ...interface{}) int64

+ func (client *AbstractDbClient) MustExists(sqlText string, args ...interface{}) bool

+ func (client *AbstractDbClient) MustExistsContext(ctx context.Context, sqlText string, args ...interface{}) bool

+ func (client *AbstractDbClient) MustGet(sqlText string, args ...interface{}) map[string]interface{}

+ func (client *AbstractDbClient) MustGetContext(ctx context.Context, sqlText string, args ...interface{}) map[string]interface{}

+ func (client *AbstractDbClient) MustRow(sqlText string, args ...interface{}) *sqlen.EnhanceRow

+ func (client *AbstractDbClient) MustRowContext(ctx context.Context, sqlText string, args ...interface{}) *sqlen.EnhanceRow

+ func (client *AbstractDbClient) MustRows(sqlText string, args ...interface{}) *sqlen.EnhanceRows

+ func (client *AbstractDbClient) MustRowsContext(ctx context.Context, sqlText string, args ...interface{}) *sqlen.EnhanceRows

+ func (client *AbstractDbClient) MustScalar(sqlText string, args ...interface{}) (interface{}, bool)

+ func (client *AbstractDbClient) MustScalarContext(ctx context.Context, sqlText string, args ...interface{}) (interface{}, bool)

+ func (client *AbstractDbClient) MustSizedExecute(expectedSize int64, sqlText string, args ...interface{})

+ func (client *AbstractDbClient) MustSizedExecuteContext(ctx context.Context, expectedSize int64, sqlText string, args ...interface{})

+ func (client *AbstractDbClient) MustSliceGet(sqlText string, args ...interface{}) []map[string]interface{}

+ func (client *AbstractDbClient) MustSliceGetContext(ctx context.Context, sqlText string, args ...interface{}) []map[string]interface{}

+ func (client *AbstractDbClient) Row(sqlText string, args ...interface{}) (*sqlen.EnhanceRow, error)

+ func (client *AbstractDbClient) RowContext(ctx context.Context, sqlText string, args ...interface{}) (*sqlen.EnhanceRow, error)

+ func (client *AbstractDbClient) Rows(sqlText string, args ...interface{}) (*sqlen.EnhanceRows, error)

+ func (client *AbstractDbClient) RowsContext(ctx context.Context, sqlText string, args ...interface{}) (*sqlen.EnhanceRows, error)

+ func (client *AbstractDbClient) Scalar(sqlText string, args ...interface{}) (interface{}, bool, error)

+ func (client *AbstractDbClient) ScalarContext(ctx context.Context, sqlText string, args ...interface{}) (interface{}, bool, error)

+ func (client *AbstractDbClient) SizedExecute(expectedSize int64, sqlText string, args ...interface{}) error

+ func (client *AbstractDbClient) SizedExecuteContext(ctx context.Context, expectedSize int64, sqlText string, args ...interface{}) error

+ func (client *AbstractDbClient) SliceGet(sqlText string, args ...interface{}) ([]map[string]interface{}, error)

+ func (client *AbstractDbClient) SliceGetContext(ctx context.Context, sqlText string, args ...interface{}) ([]map[string]interface{}, error)

type DbClientOption

+ func WithConnectionString(driver string, connectionString string) DbClientOption

+ func WithDb(db *sql.DB) DbClientOption

+ func WithPingCheck(withPingCheck bool) DbClientOption

Jul 12, 2021

Changes in this version

+ const MySqlDriver

+ const SqlServeDriver

+ var ErrConnect = errors.New("sqlmer: connect")

+ var ErrSql = errors.New("sqlmer: sql")

+ var ErrTran = errors.New("sqlmer: transaction")

+ type BindSqlArgsFunc func(string, ...interface{}) (string, []interface{}, error)

+ type DbClient interface

+ ConnectionString func() string

+ CreateTransaction func() (TransactionKeeper, error)

+ Execute func(sqlText string, args ...interface{}) (int64, error)

+ ExecuteContext func(context context.Context, sqlText string, args ...interface{}) (int64, error)

+ Exists func(sqlText string, args ...interface{}) (bool, error)

+ ExistsContext func(context context.Context, sqlText string, args ...interface{}) (bool, error)

+ Get func(sqlText string, args ...interface{}) (map[string]interface{}, error)

+ GetContext func(context context.Context, sqlText string, args ...interface{}) (map[string]interface{}, error)

+ Rows func(sqlText string, args ...interface{}) (*sqlen.EnhanceRows, error)

+ RowsContext func(context context.Context, sqlText string, args ...interface{}) (*sqlen.EnhanceRows, error)

+ Scalar func(sqlText string, args ...interface{}) (interface{}, error)

+ ScalarContext func(context context.Context, sqlText string, args ...interface{}) (interface{}, error)

+ SizedExecute func(expectedSize int64, sqlText string, args ...interface{}) error

+ SizedExecuteContext func(context context.Context, expectedSize int64, sqlText string, ...) error

+ SliceGet func(sqlText string, args ...interface{}) ([]map[string]interface{}, error)

+ SliceGetContext func(context context.Context, sqlText string, args ...interface{}) ([]map[string]interface{}, error)

+ type DbClientConfig struct

+ func NewDbClientConfig(driver string, connectionString string, options ...DbClientOption) *DbClientConfig

+ type DbClientOption func(config *DbClientConfig)

+ func WithBindArgsFunc(argsFunc BindSqlArgsFunc) DbClientOption

+ func WithConnTimeout(timeout time.Duration) DbClientOption

+ func WithExecTimeout(timeout time.Duration) DbClientOption

+ type MsSqlDbClient struct

+ func NewMsSqlDbClient(connectionString string, options ...DbClientOption) (*MsSqlDbClient, error)

+ func (client *MsSqlDbClient) ConnectionString() string

+ func (client *MsSqlDbClient) CreateTransaction() (TransactionKeeper, error)

+ func (client *MsSqlDbClient) Execute(sqlText string, args ...interface{}) (int64, error)

+ func (client *MsSqlDbClient) ExecuteContext(ctx context.Context, sqlText string, args ...interface{}) (int64, error)

+ func (client *MsSqlDbClient) Exists(sqlText string, args ...interface{}) (bool, error)

+ func (client *MsSqlDbClient) ExistsContext(ctx context.Context, sqlText string, args ...interface{}) (bool, error)

+ func (client *MsSqlDbClient) Get(sqlText string, args ...interface{}) (map[string]interface{}, error)

+ func (client *MsSqlDbClient) GetContext(ctx context.Context, sqlText string, args ...interface{}) (map[string]interface{}, error)

+ func (client *MsSqlDbClient) Rows(sqlText string, args ...interface{}) (*sqlen.EnhanceRows, error)

+ func (client *MsSqlDbClient) RowsContext(ctx context.Context, sqlText string, args ...interface{}) (*sqlen.EnhanceRows, error)

+ func (client *MsSqlDbClient) Scalar(sqlText string, args ...interface{}) (interface{}, error)

+ func (client *MsSqlDbClient) ScalarContext(ctx context.Context, sqlText string, args ...interface{}) (interface{}, error)

+ func (client *MsSqlDbClient) SizedExecute(expectedSize int64, sqlText string, args ...interface{}) error

+ func (client *MsSqlDbClient) SizedExecuteContext(ctx context.Context, expectedSize int64, sqlText string, args ...interface{}) error

+ func (client *MsSqlDbClient) SliceGet(sqlText string, args ...interface{}) ([]map[string]interface{}, error)

+ func (client *MsSqlDbClient) SliceGetContext(ctx context.Context, sqlText string, args ...interface{}) ([]map[string]interface{}, error)

+ type MySqlDbClient struct

+ func NewMySqlDbClient(connectionString string, options ...DbClientOption) (*MySqlDbClient, error)

+ func (client *MySqlDbClient) ConnectionString() string

+ func (client *MySqlDbClient) CreateTransaction() (TransactionKeeper, error)

+ func (client *MySqlDbClient) Execute(sqlText string, args ...interface{}) (int64, error)

+ func (client *MySqlDbClient) ExecuteContext(ctx context.Context, sqlText string, args ...interface{}) (int64, error)

+ func (client *MySqlDbClient) Exists(sqlText string, args ...interface{}) (bool, error)

+ func (client *MySqlDbClient) ExistsContext(ctx context.Context, sqlText string, args ...interface{}) (bool, error)

+ func (client *MySqlDbClient) Get(sqlText string, args ...interface{}) (map[string]interface{}, error)

+ func (client *MySqlDbClient) GetContext(ctx context.Context, sqlText string, args ...interface{}) (map[string]interface{}, error)

+ func (client *MySqlDbClient) Rows(sqlText string, args ...interface{}) (*sqlen.EnhanceRows, error)

+ func (client *MySqlDbClient) RowsContext(ctx context.Context, sqlText string, args ...interface{}) (*sqlen.EnhanceRows, error)

+ func (client *MySqlDbClient) Scalar(sqlText string, args ...interface{}) (interface{}, error)

+ func (client *MySqlDbClient) ScalarContext(ctx context.Context, sqlText string, args ...interface{}) (interface{}, error)

+ func (client *MySqlDbClient) SizedExecute(expectedSize int64, sqlText string, args ...interface{}) error

+ func (client *MySqlDbClient) SizedExecuteContext(ctx context.Context, expectedSize int64, sqlText string, args ...interface{}) error

+ func (client *MySqlDbClient) SliceGet(sqlText string, args ...interface{}) ([]map[string]interface{}, error)

+ func (client *MySqlDbClient) SliceGetContext(ctx context.Context, sqlText string, args ...interface{}) ([]map[string]interface{}, error)

+ type TransactionKeeper interface

+ Close func() error

+ Commit func() error

+ Rollback func() error