Versions in this module Expand all Collapse all v1 v1.1.1 Aug 26, 2026 v1.1.0 Aug 26, 2026 Changes in this version type DBCli + func (d *DBCli) GetSchemaObjects(dbName, schema string) (*dialect.SchemaObjects, error) + func (d *DBCli) GetSchemaSummaries(dbName string) ([]dialect.SchemaSummary, error) + func (d *DBCli) GetSchemas(dbName string) ([]string, error) v1.0.0 Aug 21, 2026 Changes in this version + var NewDBCliMgr = NewSqlMgr + func AutoMigrate(d def.DatabaseClient, model any, opts ...migrate.AutoMigrateOption) error + func ConvertToCountSQL(sqlStr string) string + func DetectSQLType(sql string) string + func EnsureDBExists(v *def.DBConnection) error + func FlushTableInfoCache() + func GetDBLogger() *cylog.Logger + func ParseCount(row map[string]any) int64 + func Q(options ...QueryOption) def.SQLStmt + func SplitSQLStatements(dbtype, sql string) []string + func ToColumn[T any](qr QueryResult, columnName string) ([]T, error) + func ToMigrationTableInfo(t def.TableInfo, opts ...migrate.ToMigrationTableInfoOption) def.TableInfo + func ToResultEx[T any](qr QueryResult, transform def.ItemTransformFunc, opts ...cystructmap.Option) (T, error) + func ToResult[T any](qr QueryResult, opts ...cystructmap.Option) (T, error) + func ToValue[T any](qr QueryResult, columnName string, rowIndex ...int) (T, error) + func WithTransactions[T IRepo](repos []T, fn func([]T) error) (err error) + type BooleanCondition = def.BooleanCondition + type CLiExtendProps struct + FormatTime string + NumbersAsString bool + type CLiExtendPropsFunc func(props *CLiExtendProps) + func WithNumbersAsString(asString bool) CLiExtendPropsFunc + func WithTimeFormat(format string) CLiExtendPropsFunc + type ColumnExpr = def.ColumnExpr + type ComparisonCondition = def.ComparisonCondition type DBCli + func (d *DBCli) AnalyzeSQL(sql string) (*def.SQLImpact, error) + func (d *DBCli) BatchInsertContext(ctx context.Context, tableName string, data []map[string]any, ...) (int64, error) + func (d *DBCli) BatchReplaceContext(ctx context.Context, tableName string, data []map[string]any, ...) (int64, error) + func (d *DBCli) BatchUpdateContext(ctx context.Context, tableName string, data []map[string]any, ...) (int64, error) + func (d *DBCli) BeginTx() (r *DBCli, err error) + func (d *DBCli) BeginTxContext(ctx context.Context) (r *DBCli, err error) + func (d *DBCli) ColumnExists(tableName string, columnName string) (bool, error) + func (d *DBCli) CompatCollation() bool + func (d *DBCli) CountContext(ctx context.Context, tableName string, data map[string]any, ...) (int64, error) + func (d *DBCli) DBSubType() string + func (d *DBCli) DeleteContext(ctx context.Context, tableName string, data map[string]any, ...) (int64, error) + func (d *DBCli) DirectExcute(sql string, arguments ...any) (int64, error) + func (d *DBCli) DirectExecute(sql string, arguments ...any) (int64, error) + func (d *DBCli) DirectExecuteContext(ctx context.Context, sql string, arguments ...any) (int64, error) + func (d *DBCli) DirectForEachQuery(tableName string, selectSQL string, fn func(RowData) error) error + func (d *DBCli) DirectNQuery(sql string, data any) ([]map[string]any, error) + func (d *DBCli) DirectNQueryContext(ctx context.Context, sql string, data any) ([]map[string]any, error) + func (d *DBCli) DirectNQueryRow(sql string, data any) (map[string]any, error) + func (d *DBCli) DirectNQueryRowContext(ctx context.Context, sql string, data any) (map[string]any, error) + func (d *DBCli) DirectNamedExecute(sql string, data any) (int64, error) + func (d *DBCli) DirectNamedExecuteContext(ctx context.Context, sql string, data any) (int64, error) + func (d *DBCli) DirectNamedForEachQuery(tableName string, selectSQL string, data any, fn func(RowData) error) error + func (d *DBCli) DirectNamedForEachQueryContext(ctx context.Context, tableName string, selectSQL string, data any, ...) error + func (d *DBCli) DirectNamedInsert(sql string, data any) (int64, error) + func (d *DBCli) DirectNamedInsertContext(ctx context.Context, sql string, data any) (int64, error) + func (d *DBCli) DirectNamedQuery(sql string, data any) ([]map[string]any, error) + func (d *DBCli) DirectNamedQueryAsResult(sql string, params any) def.QueryResult + func (d *DBCli) DirectNamedQueryAsResultContext(ctx context.Context, sql string, params any) def.QueryResult + func (d *DBCli) DirectNamedQueryContext(ctx context.Context, sql string, data any) ([]map[string]any, error) + func (d *DBCli) DirectNamedQueryFast(sql string, data any) ([][]any, []string, error) + func (d *DBCli) DirectNamedQueryFastContext(ctx context.Context, sql string, data any) ([][]any, []string, error) + func (d *DBCli) DirectNamedQueryRow(sql string, data any) (map[string]any, error) + func (d *DBCli) DirectNamedQueryRowContext(ctx context.Context, sql string, data any) (map[string]any, error) + func (d *DBCli) DirectNamedQueryRowFast(sql string, data any) ([]any, []string, error) + func (d *DBCli) DirectNamedQueryRowFastContext(ctx context.Context, sql string, data any) ([]any, []string, error) + func (d *DBCli) DirectNamedSelect(dest any, query string, arg any) error + func (d *DBCli) DirectQuery(sql string, arguments ...any) ([]map[string]any, error) + func (d *DBCli) DirectQueryContext(ctx context.Context, sql string, arguments ...any) ([]map[string]any, error) + func (d *DBCli) DirectQueryFast(sql string, arguments ...any) ([][]any, []string, error) + func (d *DBCli) DirectQueryFastContext(ctx context.Context, sql string, arguments ...any) ([][]any, []string, error) + func (d *DBCli) DirectQueryRow(sql string, args ...any) (map[string]any, error) + func (d *DBCli) DirectQueryRowContext(ctx context.Context, sql string, args ...any) (map[string]any, error) + func (d *DBCli) DirectQueryRowFast(sql string, args ...any) ([]any, []string, error) + func (d *DBCli) DirectQueryRowFastContext(ctx context.Context, sql string, args ...any) ([]any, []string, error) + func (d *DBCli) EnsureDBExists(dbName string) error + func (d *DBCli) EnsureLimit(sql string, limit, offset int) (string, error) + func (d *DBCli) Execute(sql string, arguments ...any) (int64, error) + func (d *DBCli) ExecuteContext(ctx context.Context, sql string, arguments ...any) (int64, error) + func (d *DBCli) ExistsContext(ctx context.Context, tableName string, data map[string]any, ...) (bool, error) + func (d *DBCli) ExplainSQL(sql string) def.QueryResult + func (d *DBCli) FirstAsResult(tableName any, data map[string]any, cc ...QueryOption) QueryResult + func (d *DBCli) FirstAsResultContext(ctx context.Context, tableName any, data map[string]any, cc ...QueryOption) QueryResult + func (d *DBCli) FirstContext(ctx context.Context, tableName string, data map[string]any, ...) (map[string]any, error) + func (d *DBCli) ForEachData(tableName string, data []map[string]any, fn func(RowData) error) error + func (d *DBCli) ForEachQuery(tableName string, selectSQL string, fn func(RowData) error) error + func (d *DBCli) ForEachQueryByWhere(tableName string, where []def.QueryOption, p P, fn func(RowData) error) error + func (d *DBCli) ForEachQueryContext(ctx context.Context, tableName string, selectSQL string, ...) error + func (d *DBCli) GetContext(ctx context.Context, dest any, query string, args ...any) error + func (d *DBCli) GetDatabases() ([]string, error) + func (d *DBCli) GetIndexes(tableName string) ([]dialect.IndexInfo, error) + func (d *DBCli) GetObjects(dbName string, schema *string, objectType dialect.DatabaseObjectType) ([]string, error) + func (d *DBCli) GetPassword() string + func (d *DBCli) GetPrimaryKeys(tableName string) ([]string, error) + func (d *DBCli) GetSqlTransformer() (DatabaseTransformer, bool) + func (d *DBCli) GetTableInfo(tableName string) (TableInfo, error) + func (d *DBCli) GetTables(dbName string, schema *string, keyword *string) ([]string, error) + func (d *DBCli) GetUniqueKeys(tableName string) ([]string, error) + func (d *DBCli) InsertAndGetID(tableName string, data map[string]any, cc ...def.QueryOption) (int64, error) + func (d *DBCli) InsertAndGetIDContext(ctx context.Context, tableName string, data map[string]any, ...) (int64, error) + func (d *DBCli) InsertContext(ctx context.Context, tableName string, data map[string]any, ...) (int64, error) + func (d *DBCli) ListAsResult(tableName any, data map[string]any, cc ...QueryOption) QueryResult + func (d *DBCli) ListAsResultContext(ctx context.Context, tableName any, data map[string]any, cc ...QueryOption) QueryResult + func (d *DBCli) ListContext(ctx context.Context, tableName string, data map[string]any, ...) ([]map[string]any, error) + func (d *DBCli) ListWithPageAsResult(tableName any, data map[string]any, pageIndex int, pageSize int, ...) QueryResult + func (d *DBCli) ListWithPageAsResultContext(ctx context.Context, tableName any, data map[string]any, pageIndex int, ...) QueryResult + func (d *DBCli) ListWithPageContext(ctx context.Context, tableName string, data map[string]any, pageIndex int, ...) ([]map[string]any, int64, error) + func (d *DBCli) NQueryContext(ctx context.Context, sql string, data any) ([]map[string]any, error) + func (d *DBCli) NQueryRow(sql string, data any) (map[string]any, error) + func (d *DBCli) NQueryRowContext(ctx context.Context, sql string, data any) (map[string]any, error) + func (d *DBCli) NamedExecute(sql string, data any) (int64, error) + func (d *DBCli) NamedExecuteContext(ctx context.Context, sql string, data any) (int64, error) + func (d *DBCli) NamedForEachQuery(tableName string, selectSQL string, data any, fn func(RowData) error) error + func (d *DBCli) NamedForEachQueryContext(ctx context.Context, tableName string, selectSQL string, data any, ...) error + func (d *DBCli) NamedQuery(sql string, data any) ([]map[string]any, error) + func (d *DBCli) NamedQueryAsResult(sql string, data any) QueryResult + func (d *DBCli) NamedQueryAsResultContext(ctx context.Context, sql string, data any) QueryResult + func (d *DBCli) NamedQueryContext(ctx context.Context, sql string, data any) ([]map[string]any, error) + func (d *DBCli) NamedQueryFastContext(ctx context.Context, sql string, data any) ([][]any, []string, error) + func (d *DBCli) NamedQueryRow(sql string, data any) (map[string]any, error) + func (d *DBCli) NamedQueryRowAsResultContext(ctx context.Context, sql string, data any) QueryResult + func (d *DBCli) NamedQueryRowContext(ctx context.Context, sql string, data any) (map[string]any, error) + func (d *DBCli) NamedQueryRowFast(sql string, data any) ([]any, []string, error) + func (d *DBCli) NamedQueryRowFastContext(ctx context.Context, sql string, data any) ([]any, []string, error) + func (d *DBCli) ObjectExists(objectName string, objectType dialect.DatabaseObjectType) (bool, error) + func (d *DBCli) PaginatedList(tableName string, data map[string]any, pageIndex int, pageSize int, ...) ([]map[string]any, int64, error) + func (d *DBCli) PaginatedListAsResult(tableName any, data map[string]any, pageIndex int, pageSize int, ...) QueryResult + func (d *DBCli) PaginatedListAsResultContext(ctx context.Context, tableName any, data map[string]any, pageIndex int, ...) QueryResult + func (d *DBCli) PaginatedListContext(ctx context.Context, tableName string, data map[string]any, pageIndex int, ...) ([]map[string]any, int64, error) + func (d *DBCli) QueryAsResult(sql string, arguments ...any) QueryResult + func (d *DBCli) QueryAsResultContext(ctx context.Context, sql string, arguments ...any) QueryResult + func (d *DBCli) QueryContext(ctx context.Context, sql string, arguments ...any) ([]map[string]any, error) + func (d *DBCli) QueryFast(sql string, arguments ...any) ([][]any, []string, error) + func (d *DBCli) QueryFastContext(ctx context.Context, sql string, arguments ...any) ([][]any, []string, error) + func (d *DBCli) QueryRow(sql string, args ...any) (map[string]any, error) + func (d *DBCli) QueryRowAsResult(sql string, args ...any) QueryResult + func (d *DBCli) QueryRowAsResultContext(ctx context.Context, sql string, args ...any) QueryResult + func (d *DBCli) QueryRowContext(ctx context.Context, sql string, args ...any) (map[string]any, error) + func (d *DBCli) QueryRowFast(sql string, args ...any) ([]any, []string, error) + func (d *DBCli) QueryRowFastContext(ctx context.Context, sql string, args ...any) ([]any, []string, error) + func (d *DBCli) QueryWithLimitContext(ctx context.Context, sql string, limit, offset int) ([][]any, []string, error) + func (d *DBCli) ReplaceContext(ctx context.Context, tableName string, data map[string]any, ...) (int64, error) + func (d *DBCli) SelectContext(ctx context.Context, dest any, query string, args ...any) error + func (d *DBCli) UpdateContext(ctx context.Context, tableName string, data map[string]any, ...) (int64, error) + func (d *DBCli) UpsertContext(ctx context.Context, tableName string, data map[string]any, ...) (int64, error) + func (d *DBCli) ValidateSQL(sql string) *def.ValidationError + func (d *DBCli) WithTransactionContext(ctx context.Context, fn func(tx DatabaseClient) error) (err error) type DBMgr + func (s *DBMgr) Exist(key string) bool + func (s *DBMgr) GetDatebase() []string + func (s *DBMgr) SetCliIfNotExists(key string, cli *DBCli) + func (s *DBMgr) TestConnect(con *def.DBConnection) error + type DatabaseObjectType = dialect.DatabaseObjectType + const ObjectTypeFunction + const ObjectTypeProcedure + const ObjectTypeSequence + const ObjectTypeTable + const ObjectTypeTrigger + const ObjectTypeView type Expression + func Named(name string) Expression type IRepo + NewTransactionCopy func(tx *DBCli) (IRepo, error) + type ItemTransformFunc = def.ItemTransformFunc type OP + const OP_NOT_LIKE + type Object = map[string]any + type P = map[string]any + type PaginatedResult = schema.PaginatedResult[T] + func ToPagedResultEx[T any](qr QueryResult, transform ItemTransformFunc, opts ...cystructmap.Option) (*PaginatedResult[T], error) + func ToPagedResult[T any](qr QueryResult, opts ...cystructmap.Option) (*PaginatedResult[T], error) + type QueryOption = def.QueryOption + func WithBeforeBuild(callback func(def.SQLStmt) error) QueryOption + func WithContains(field string, value string) QueryOption + func WithEQs(field ...string) QueryOption + func WithEndsWith(field string, value string) QueryOption + func WithGTEs(field ...string) QueryOption + func WithGTs(field ...string) QueryOption + func WithISNOTNULL(field string) QueryOption + func WithISNULL(field string) QueryOption + func WithInSub(field string, subquery def.SQLStmt) QueryOption + func WithLTEs(field ...string) QueryOption + func WithLTs(field ...string) QueryOption + func WithNEQs(field ...string) QueryOption + func WithNotInSub(field string, subquery def.SQLStmt) QueryOption + func WithOrderByAsc(orders ...any) QueryOption + func WithOrderByDesc(orders ...any) QueryOption + func WithStartsWith(field string, value string) QueryOption + func WithUnion(stmt *ss.SQLStmt) QueryOption + func WithUnionAll(stmt *ss.SQLStmt) QueryOption + type QueryResult = def.QueryResult + type RawCondition = def.RawCondition + type SQLBlock = dialect.SQLBlock + type SQLImpact = def.SQLImpact + type SQLStmt = def.SQLStmt + type SortDirection = ss.SortDirection + const SortAsc + const SortDesc + type TableInfo = def.TableInfo + type ValidationError = def.ValidationError type Where + func AllEQ(fields []string, values ...any) Where + func AllGT(fields []string, values ...any) Where + func AllGTE(fields []string, values ...any) Where + func AllLT(fields []string, values ...any) Where + func AllLTE(fields []string, values ...any) Where + func AllNEQ(fields []string, values ...any) Where + func AnyEQ(fields []string, values ...any) Where + func AnyGT(fields []string, values ...any) Where + func AnyGTE(fields []string, values ...any) Where + func AnyLT(fields []string, values ...any) Where + func AnyLTE(fields []string, values ...any) Where + func AnyNEQ(fields []string, values ...any) Where + func ISNOTNULL(field string) Where + func ISNULL(field string) Where + func LIKEN(field string, value string) Where + func NOT_LIKE(field string, value string, pt def.LikePatternType) Where + func NOT_LIKEC(field string, value string) Where + func NOT_LIKEL(field string, value string) Where + func NOT_LIKEN(field string, value string) Where + func NOT_LIKER(field string, value string) Where + func TupleEQ(cols []string, vals ...any) Where + func TupleGT(cols []string, vals ...any) Where + func TupleGTE(cols []string, vals ...any) Where + func TupleIN(cols []string, valsList [][]any) Where + func TupleLT(cols []string, vals ...any) Where + func TupleLTE(cols []string, vals ...any) Where + func TupleNE(cols []string, vals ...any) Where + func TupleNOTIN(cols []string, valsList [][]any) Where v0 v0.0.1 Sep 23, 2025 Changes in this version + const DefaultBufferSize + const ErrCodeConnection + const ErrCodeConstraint + const ErrCodeDuplicate + const ErrCodeInvalidParam + const ErrCodeNotFound + const ErrCodeQuery + const ErrCodeTimeout + const ErrCodeTransaction + const ErrCodeUnsupported + const MigrationCommentPrefix + const MigrationDown + const MigrationUp + const PreRetTypeCallCallback + const PreRetTypeContinue + const PreRetTypeReturn + var WithValue = WithLiteral + func DBLog() *cylog.Logger + func EscapeLikePattern(pattern string, t LikePatternType) string + func FormatValue(v interface{}, colType DBFieldType) (string, error) + func GetDBAndTable(cli DatabaseClient, name ...string) (string, string) + func GetSupportSqlDialect() []string + func InMapParam(ids map[string]struct{}) string + func InParam(ids []string) string + func InParam2(ids [][]string) string + func InternalExcute(cli DatabaseClient, sql string, arguments ...interface{}) (int64, error) + func InternalNQuery(cli DatabaseClient, sql string, data interface{}) ([]map[string]interface{}, error) + func InternalNQueryOne(cli DatabaseClient, sql string, data interface{}) (map[string]interface{}, error) + func InternalQuery(cli DatabaseClient, sql string, arguments ...interface{}) ([]map[string]interface{}, error) + func InternalQueryOne(cli DatabaseClient, sql string, arguments ...interface{}) (map[string]interface{}, error) + func IsMySQLKeyword(word string) bool + func LeafDirs(efs *embed.FS) ([]string, error) + func NewSQLParseError(errorType, message string, lineNum int, lineText string) error + func NormalData(d interface{}) interface + func NormalData2(d interface{}) interface + func ReadSQLFile(r io.Reader, callback FuncSQLStatementCallback, ...) error + func RegisterSqlDialect(dbtype string, sql any) + func TestParseMySQL() + func WithBufferSize(size int) func(*ReadSQLFileOptions) + func WithFilter(filter []string) func(*ReadSQLFileOptions) + func WithMigrationMode(mode string) func(*ReadSQLFileOptions) + func WithPreProcessSqlLine(callback FuncPreProcessSqlLine) func(*ReadSQLFileOptions) + func WithTransaction[T IRepo](repo T, fn func(repo T) error) error + func WithWordCallback(callback ProcessWordCallback) func(*ReadSQLFileOptions) + type ArithExpr struct + Alias string + Left Expression + Op string + Right Expression + func (ae *ArithExpr) GetAlias() string + func (ae *ArithExpr) GetFields() []string + func (ae *ArithExpr) SetAlias(alias string) Expression + func (ae *ArithExpr) ToSQL(dt DatabaseTransformer) (string, error) + type BuildResult struct + ParamOrder []string + SQL string + type BuildSql interface + GetAssignString func(dt DatabaseTransformer, all bool) (string, []string, error) + GetFieldsString func(dt DatabaseTransformer, skipAS bool) (string, error) + GetPkFieldsString func(dt DatabaseTransformer, skipAS bool) (string, error) + GetValuesString func(dt DatabaseTransformer, all bool) (string, []string, error) + type CRUDOperations interface + BatchInsert func(ctx context.Context, tableName string, data []map[string]any) (int64, error) + Delete func(ctx context.Context, tableName string, condition map[string]any) (int64, error) + Insert func(ctx context.Context, tableName string, data map[string]any) (int64, error) + Replace func(ctx context.Context, tableName string, data map[string]any) (int64, error) + Update func(ctx context.Context, tableName string, data map[string]any, ...) (int64, error) + type CRUDSqlFuncName string + const FuncNameGetDeleteSql + const FuncNameGetInsertSql + const FuncNameGetReplaceSql + const FuncNameGetSelectSql + const FuncNameGetUpdateSql + type CaseExpr struct + Alias string + ElseClause Expression + Value Expression + WhenClauses []WhenThenClause + func (ce *CaseExpr) ELSE(elseClause Expression) Expression + func (ce *CaseExpr) GetFields() []string + func (ce *CaseExpr) SetAlias(alias string) Expression + func (ce *CaseExpr) ToSQL(dt DatabaseTransformer) (string, error) + type Condition struct + Condition string + Fields []string + type Config struct + Connections []DBConnection + type DBCli struct + func NewDBCli(cli IDBOperWrapper, dbtype, key, database, un, pw string) *DBCli + func TryConnect(v *DBConnection) (*DBCli, error) + func (d *DBCli) BatchInsert(tableName string, data []map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) BatchReplace(tableName string, data []map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) BatchUpdate(tableName string, data []map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) BeginX() (r *DBCli, err error) + func (d *DBCli) Close() error + func (d *DBCli) Commit() error + func (d *DBCli) Count(tableName any, data map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) DBType() string + func (d *DBCli) Database() string + func (d *DBCli) Delete(tableName any, data map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) Excute(sql string, arguments ...interface{}) (int64, error) + func (d *DBCli) Exists(tableName string, data map[string]interface{}, cc ...FuncWithBuilder) (bool, error) + func (d *DBCli) FieldExists(tableName string, fieldName string) (bool, error) + func (d *DBCli) First(tableName any, data map[string]interface{}, cc ...FuncWithBuilder) (map[string]interface{}, error) + func (d *DBCli) Get(dest interface{}, query string, args ...interface{}) error + func (d *DBCli) GetDB() *sqlx.DB + func (d *DBCli) GetDDLSql(funcName DDLSqlFuncName, name ...string) (*SqlContent, error) + func (d *DBCli) GetPK(tableName string) ([]string, error) + func (d *DBCli) GetSortedSql(funcName SortFuncName, database string, names []string) ([]*SqlContent, error) + func (d *DBCli) GetTableColumns(tableName string) ([]*DBColumn, error) + func (d *DBCli) Insert(tableName string, data map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) IsTableExist(tableName string) (bool, error) + func (d *DBCli) Key() string + func (d *DBCli) List(tableName any, data map[string]interface{}, cc ...FuncWithBuilder) ([]map[string]interface{}, error) + func (d *DBCli) ListWithPage(tableName any, data map[string]interface{}, pageIndex int, pageSize int, ...) ([]map[string]interface{}, int, error) + func (d *DBCli) MakeSureDBExists(dbName string) error + func (d *DBCli) NExcute(sql string, data interface{}) (int64, error) + func (d *DBCli) NQuery(sql string, data interface{}) ([]map[string]interface{}, error) + func (d *DBCli) NQueryOne(sql string, data interface{}) (map[string]interface{}, error) + func (d *DBCli) PW() string + func (d *DBCli) Query(sql string, arguments ...interface{}) ([]map[string]interface{}, error) + func (d *DBCli) QueryOne(sql string, args ...interface{}) (map[string]interface{}, error) + func (d *DBCli) ReadSQLFile(r io.Reader, callback FuncSQLStatementCallback, ...) error + func (d *DBCli) Replace(tableName string, data map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) Rollback() error + func (d *DBCli) Select(dest interface{}, query string, args ...interface{}) error + func (d *DBCli) TravelData(tableName string, data []map[string]interface{}, ...) error + func (d *DBCli) TravelQuery(tableName string, selectSQL string, fn func(*DBCli, *RowData) error) error + func (d *DBCli) Update(tableName string, data map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) Upsert(tableName string, data map[string]interface{}, cc ...FuncWithBuilder) (int64, error) + func (d *DBCli) WithTransaction(fn func(tx *DBCli) error) (err error) + type DBColumn struct + ColumnKey string + DBFieldType DBFieldType + Name string + Nullable bool + OrgDataType string + type DBConnection struct + DBName string + Host string + Key string + Path string + Port int + Pw string + Role string + SSLMode string + Schema string + Service string + Type string + Un string + type DBFieldType int + const DBFieldTypeBinary + const DBFieldTypeBit + const DBFieldTypeFloat + const DBFieldTypeInt + const DBFieldTypeJson + const DBFieldTypeString + const DBFieldTypeTime + type DBMgr struct + func NewSqlMgr(conf *Config, migrateFileFunc ...MigrateFileFunc) (*DBMgr, error) + func (s *DBMgr) CloseAll() + func (s *DBMgr) GetCli(key string) *DBCli + func (s *DBMgr) GetOrCreateCli(params map[string]interface{}) (*DBCli, error) + func (s *DBMgr) InitByConfig(conf *Config) error + func (s *DBMgr) SetCli(key string, cli *DBCli) + type DDLSqlFunc func(cli DatabaseClient, name ...string) (*SqlContent, error) + type DDLSqlFuncName string + const FuncNameGetBeginSql + const FuncNameGetCreateFunctionSql + const FuncNameGetCreateProcedureSql + const FuncNameGetCreateTableSql + const FuncNameGetCreateViewSql + const FuncNameGetEndSql + const FuncNameGetTableEventSql + type DatabaseClient interface + Close func() error + DBType func() string + Database func() string + Excute func(sql string, arguments ...interface{}) (int64, error) + Get func(dest interface{}, query string, args ...interface{}) error + NQuery func(sql string, data any) ([]map[string]any, error) + NQueryOne func(sql string, data any) (map[string]any, error) + PW func() string + Query func(sql string, args ...interface{}) ([]map[string]interface{}, error) + Select func(dest interface{}, query string, args ...interface{}) error + type DatabaseError struct + Cause error + Code string + Details string + Message string + func NewDatabaseError(code, message string) *DatabaseError + func (e *DatabaseError) Error() string + func (e *DatabaseError) Unwrap() error + func (e *DatabaseError) WithCause(cause error) *DatabaseError + func (e *DatabaseError) WithDetails(details string) *DatabaseError + type DatabaseManager interface + AddClient func(key string, client DatabaseClient) + CloseAll func() error + GetClient func(key string) (DatabaseClient, error) + ListClients func() []string + RemoveClient func(key string) + type DatabaseMetadata interface + Name func() string + Type func() string + Version func(ctx context.Context) (string, error) + type DatabaseTransformer interface + BuildPagination func(limit, offset string) string + BuildReplaceSQL func(tableName string, buildSql BuildSql) (string, []string, error) + BuildUpsertSQL func(tableName string, buildSql BuildSql) (string, []string, error) + EscapeColumnName func(columnName string) string + EscapeTableName func(tableName string) string + SupportsBatch func() bool + func GetSqlTransformer(dbtype string) (DatabaseTransformer, bool) + type DefaultDBFieldType int + const DefaultDBFieldTypeBinary + const DefaultDBFieldTypeBit + const DefaultDBFieldTypeBool + const DefaultDBFieldTypeFloat + const DefaultDBFieldTypeInt + const DefaultDBFieldTypeJson + const DefaultDBFieldTypeString + const DefaultDBFieldTypeTime + type Expression interface + GetFields func() []string + SetAlias func(alias string) Expression + ToSQL func(dt DatabaseTransformer) (string, error) + func ADD(left, right Expression) Expression + func AS(v ...string) Expression + func AVG(arg Expression) Expression + func CASE(value Expression, whenThenPairs ...Expression) Expression + func CASE_WHEN(whenThenPairs ...Expression) Expression + func COALESCE(args ...Expression) Expression + func CONCAT(args ...Expression) Expression + func CONST(value any) Expression + func COUNT(arg Expression) Expression + func COUNT_DISTINCT(arg Expression) Expression + func DIV(left, right Expression) Expression + func FIELD(name string) Expression + func FUNC(name string, args ...Expression) Expression + func FUNC_DISTINCT(name string, args ...Expression) Expression + func IFNULL(arg1, arg2 Expression) Expression + func MAX(arg Expression) Expression + func MIN(arg Expression) Expression + func MOD(left, right Expression) Expression + func MUL(left, right Expression) Expression + func SUB(left, right Expression) Expression + func SUM(arg Expression) Expression + type ExtraData interface + IsBlockEnd func(string) bool + type FieldData struct + Data interface{} + Index int + IsPK bool + IsUQ bool + Name string + Nullable bool + OrgDataType string + Type DBFieldType + type FuncExpr struct + Alias string + Args []Expression + Distinct bool + Name string + func (fe *FuncExpr) GetAlias() string + func (fe *FuncExpr) GetFields() []string + func (fe *FuncExpr) SetAlias(alias string) Expression + func (fe *FuncExpr) ToSQL(dt DatabaseTransformer) (string, error) + type FuncPreProcessSqlLine func(ctx *ParseContext, pline *string) (PreRetType, error) + type FuncSQLStatementCallback func(sqlStatement *SQLStatement) error + type FuncWithBuilder func(SQLBuilder) SQLBuilder + func WithBetween(field string, start, end any) FuncWithBuilder + func WithCount(field string) FuncWithBuilder + func WithDatabase(database string) FuncWithBuilder + func WithDistinct(distinct bool) FuncWithBuilder + func WithEQ(field ...string) FuncWithBuilder + func WithFields(fields any, reset ...bool) FuncWithBuilder + func WithGT(field ...string) FuncWithBuilder + func WithGTE(field ...string) FuncWithBuilder + func WithGroupBy(columns any) FuncWithBuilder + func WithIn(field string, values []any) FuncWithBuilder + func WithInnerJoin(tableSrc TableSource, on ...Where) FuncWithBuilder + func WithJoin(tableSrc TableSource, on ...Where) FuncWithBuilder + func WithLT(field ...string) FuncWithBuilder + func WithLTE(field ...string) FuncWithBuilder + func WithLeftJoin(tableSrc TableSource, on ...Where) FuncWithBuilder + func WithLike(field string, value string) FuncWithBuilder + func WithLikeL(field string, value string) FuncWithBuilder + func WithLikeR(field string, value string) FuncWithBuilder + func WithLimit(limit int) FuncWithBuilder + func WithNEQ(field ...string) FuncWithBuilder + func WithNotIn(field string, values []any) FuncWithBuilder + func WithOffset(offset int) FuncWithBuilder + func WithOrderBy(orderBy ...OrderBy) FuncWithBuilder + func WithRightJoin(tableSrc TableSource, on ...Where) FuncWithBuilder + func WithSelect(selects any) FuncWithBuilder + func WithSubQueryValues(builder SQLBuilder) FuncWithBuilder + func WithTable(table any) FuncWithBuilder + func WithUpdate(columns any) FuncWithBuilder + func WithUpdateExpr(updates ...Expression) FuncWithBuilder + func WithValues(data ...[]Expression) FuncWithBuilder + func WithValuesAppend(data ...[]Expression) FuncWithBuilder + func WithWhere(where ...Where) FuncWithBuilder + func WithWhereAnd(where ...Where) FuncWithBuilder + func WithWhereOr(where ...Where) FuncWithBuilder + type IDBOperWrapper interface + BindNamed func(query string, arg interface{}) (string, []interface{}, error) + Exec func(query string, args ...any) (sql.Result, error) + ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error) + Get func(dest interface{}, query string, args ...interface{}) error + GetContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error + MustExec func(query string, args ...interface{}) sql.Result + MustExecContext func(ctx context.Context, query string, args ...interface{}) sql.Result + NamedExec func(query string, arg interface{}) (sql.Result, error) + NamedExecContext func(ctx context.Context, query string, arg interface{}) (sql.Result, error) + NamedQuery func(query string, arg interface{}) (*sqlx.Rows, error) + Prepare func(query string) (*sql.Stmt, error) + PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error) + PrepareNamed func(query string) (*sqlx.NamedStmt, error) + PrepareNamedContext func(ctx context.Context, query string) (*sqlx.NamedStmt, error) + Preparex func(query string) (*sqlx.Stmt, error) + PreparexContext func(ctx context.Context, query string) (*sqlx.Stmt, error) + Query func(query string, args ...any) (*sql.Rows, error) + QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error) + QueryRow func(query string, args ...any) *sql.Row + QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row + QueryRowx func(query string, args ...interface{}) *sqlx.Row + QueryRowxContext func(ctx context.Context, query string, args ...interface{}) *sqlx.Row + Queryx func(query string, args ...interface{}) (*sqlx.Rows, error) + QueryxContext func(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error) + Select func(dest interface{}, query string, args ...interface{}) error + SelectContext func(ctx context.Context, dest interface{}, query string, args ...interface{}) error + type IRepo interface + GetDBCli func() *DBCli + SetDBCli func(*DBCli) + type LikePatternType int + const Contains + const EndsWith + const Escape + const None + const StartsWith + type LiteralValue struct + Embed bool + Fields []string + Value any + func (lv *LiteralValue) GetFields() []string + func (lv *LiteralValue) GetValue() (string, error) + func (lv *LiteralValue) SetAlias(alias string) Expression + func (lv *LiteralValue) ToSQL(dt DatabaseTransformer) (string, error) + type MigrateFileFunc func(pm *MigrateSQLParam) *MigrateSQLParam + func WithIgnoreError(ignoreError bool) MigrateFileFunc + func WithMigrateFileFunc(f *embed.FS) MigrateFileFunc + func WithServiceOwner(serviceOwner string) MigrateFileFunc + type MigrateInfo struct + DBType string + Key string + type MigrateSQLParam struct + type OP string + const OP_ADD + const OP_BETWEEN + const OP_DIVIDE + const OP_EQ + const OP_EXISTS + const OP_GT + const OP_GTE + const OP_IN + const OP_IS_NOT_NULL + const OP_IS_NULL + const OP_LIKE + const OP_LT + const OP_LTE + const OP_MOD + const OP_MULTIPLY + const OP_NEQ + const OP_NOT_EXISTS + const OP_NOT_IN + const OP_SUBTRACT + type OrderBy struct + Column []Expression + Direction string + func ASC(field any) OrderBy + func DESC(field any) OrderBy + type PARAMS = map[string]interface + type ParameterValue struct + Name string + func (pv *ParameterValue) GetFields() []string + func (pv *ParameterValue) GetValue() (string, error) + func (pv *ParameterValue) SetAlias(alias string) Expression + func (pv *ParameterValue) ToSQL(dt DatabaseTransformer) (string, error) + type ParseContext struct + BlockIndex int + CurrentLineNum int + CurrentStmt strings.Builder + CurrentType SQLType + ExpectedStringEnd string + Extra ExtraData + Filter []string + HasContent bool + IsMultiLineComment bool + LineContent string + PreProcessSqlLine FuncPreProcessSqlLine + StartLineNum int + TraceWord *TraceWord + TypeWord string + WordCallback ProcessWordCallback + func (ctx *ParseContext) ReadSQLCallback(callback FuncSQLStatementCallback) error + func (pc *ParseContext) IsBlockEnd(line string) bool + func (pc *ParseContext) IsCurrentTypeNull() bool + func (pc *ParseContext) Reset() + type ParseMysqlContext struct + func (ctx *ParseMysqlContext) GetParamExpr(index int) *ParameterValue + func (ctx *ParseMysqlContext) GetParamValue(index int) string + type PreRetType int + type ProcessWordCallback func(ctx *ParseContext, word *cyutil.WordInfo) (bool, error) + type QueryExecutor interface + Exec func(ctx context.Context, sql string, args ...any) (sql.Result, error) + Query func(ctx context.Context, sql string, args ...any) ([]map[string]any, error) + QueryRow func(ctx context.Context, sql string, args ...any) (map[string]any, error) + type QueryMetadata struct + ExecutionTime time.Duration + QueryHash string + RowsAffected int64 + type ReadSQLFileOptions struct + BufferSize int + Filter []string + MigrationMode string + PreProcessSqlLine FuncPreProcessSqlLine + WordCallback ProcessWordCallback + func NewReadSQLFileOptions(options ...func(*ReadSQLFileOptions)) ReadSQLFileOptions + type ResultSet struct + Data []T + Metadata QueryMetadata + Page int + PageSize int + TotalCount int64 + type RowData struct + Data []*FieldData + func (r *RowData) GetData() map[string]interface{} + func (r *RowData) GetReplaceSql(cli DatabaseClient, table string) (string, error) + type SQLBuilder interface + Build func(dt DatabaseTransformer) (*BuildResult, error) + Count func(fields string) SQLBuilder + Database func(db string) SQLBuilder + Distinct func(distinct bool) SQLBuilder + Fields func(columns any, reset ...bool) SQLBuilder + From func(tableSrc any) SQLBuilder + GroupBy func(columns any) SQLBuilder + Having func(fv Where) SQLBuilder + HavingAnd func(fvs ...Where) SQLBuilder + HavingOr func(fvs ...Where) SQLBuilder + InnerJoin func(tableSrc TableSource, condition ...Where) SQLBuilder + Join func(tableSrc TableSource, condition ...Where) SQLBuilder + LeftJoin func(tableSrc TableSource, condition ...Where) SQLBuilder + Limit func(limit int) SQLBuilder + LimitPlaceholder func(limit string) SQLBuilder + Offset func(offset int) SQLBuilder + OffsetPlaceholder func(offset string) SQLBuilder + OrderBy func(orderBy ...OrderBy) SQLBuilder + PrimaryKeys func(keys ...string) SQLBuilder + RightJoin func(tableSrc TableSource, condition ...Where) SQLBuilder + Select func(fields any) SQLBuilder + SubQueryValues func(builder SQLBuilder) SQLBuilder + Table func(table any) SQLBuilder + Type func(t SQLOperationType) SQLBuilder + Update func(columns any) SQLBuilder + UpdateExpr func(updates ...Expression) SQLBuilder + Values func(data ...[]Expression) SQLBuilder + ValuesAppend func(data ...[]Expression) SQLBuilder + Where func(fv Where, reset ...bool) SQLBuilder + WhereAnd func(fvs ...Where) SQLBuilder + WhereOr func(fvs ...Where) SQLBuilder + func Builder() SQLBuilder + func ParseMySQL(sql string) (SQLBuilder, error) + type SQLDialect interface + GetConnectStr func(dbConn *DBConnection) (string, string) + GetDDLSqlFunc func(funcName DDLSqlFuncName) (DDLSqlFunc, error) + GetDefaultTypeName func(tp DefaultDBFieldType) string + GetReplaceSql func(cli DatabaseClient, table string, rd *RowData) (string, error) + GetSortedSqlFunc func(funcName SortFuncName) (SortedSqlFunc, error) + GetTableColumns func(cli DatabaseClient, database, tableName string) ([]*DBColumn, error) + IsTableExist func(cli DatabaseClient, tableName string) (bool, error) + MakeSureDBExists func(cli DatabaseClient, dbName string) error + PreProcess func(sql string, param ...int) string + ReadSQLFile func(r io.Reader, callback FuncSQLStatementCallback, ...) error + func GetSqlDialect(dbtype string) (SQLDialect, bool) + type SQLOperationType string + const SQLOperationCount + const SQLOperationDelete + const SQLOperationInsert + const SQLOperationReplace + const SQLOperationSelect + const SQLOperationUnknown + const SQLOperationUpdate + const SQLOperationUpsert + type SQLParseError struct + ErrorType string + LineNum int + LineText string + Message string + func (e *SQLParseError) Error() string + type SQLStatement struct + Content string + EndLine int + Index int + StartLine int + Type string + type SQLType interface + AsInt func() int + IsBlock func() bool + IsNull func() bool + String func() string + type SchemaInspector interface + GetTableColumns func(ctx context.Context, database, tableName string) ([]*DBColumn, error) + GetTableNames func(ctx context.Context, database string) ([]string, error) + IsTableExist func(ctx context.Context, tableName string) (bool, error) + type SimpleExpr struct + Alias string + Field string + Schema string + Table string + Value Expression + func (se *SimpleExpr) GetFields() []string + func (se *SimpleExpr) SetAlias(alias string) Expression + func (se *SimpleExpr) ToSQL(dt DatabaseTransformer) (string, error) + type SortFuncName string + const FuncNameSortFunctions + const FuncNameSortProcedures + const FuncNameSortTables + type SortedSqlFunc func(cli DatabaseClient, names []string) ([]*SqlContent, error) + type SqlContent struct + Content string + Name string + type SubQuery struct + Alias string + Builder SQLBuilder + func (s *SubQuery) GetAlias() string + func (s *SubQuery) GetFields() []string + func (s *SubQuery) SetAlias(alias string) Expression + func (s *SubQuery) ToCondition(dt DatabaseTransformer) (*Condition, error) + func (s *SubQuery) ToSQL(dt DatabaseTransformer) (string, error) + type Table struct + Alias string + Name string + Schema string + func (t *Table) GetAlias() string + func (t *Table) ToSQL(dt DatabaseTransformer) (string, error) + type TableSource interface + GetAlias func() string + ToSQL func(dt DatabaseTransformer) (string, error) + func ALIAS(table string, alias string) TableSource + func SUBQUERY(builder SQLBuilder, alias ...string) TableSource + func TABLE(param ...string) TableSource + type TraceWord struct + Key string + NextKeys map[string]SQLType + Skip int + type Transaction interface + Commit func() error + Rollback func() error + type TransactionManager interface + Begin func(ctx context.Context) (Transaction, error) + BeginTx func(ctx context.Context, opts *sql.TxOptions) (Transaction, error) + type TypedQueryExecutor interface + Get func(ctx context.Context, dest any, query string, args ...any) error + Select func(ctx context.Context, dest any, query string, args ...any) error + type Value interface + GetValue func() (string, error) + type WhenThenClause struct + Then Expression + When Expression + type Where interface + ToCondition func(dt DatabaseTransformer) (*Condition, error) + func AND(conditions ...Where) Where + func BETWEEN(field string, start, end any, f ...WhereOptionFunc) Where + func COMBINE(andConditions []Where, orConditions []Where) Where + func EQ(field string, f ...WhereOptionFunc) Where + func EXISTS(subquery Expression, f ...WhereOptionFunc) Where + func GT(field string, f ...WhereOptionFunc) Where + func GTE(field string, f ...WhereOptionFunc) Where + func IN(field string, values []any, f ...WhereOptionFunc) Where + func IS_NOT_NULL(field string, f ...WhereOptionFunc) Where + func IS_NULL(field string, f ...WhereOptionFunc) Where + func LIKE(field string, value string, pt LikePatternType, f ...WhereOptionFunc) Where + func LIKEC(field string, value string, f ...WhereOptionFunc) Where + func LIKEL(field string, value string, f ...WhereOptionFunc) Where + func LIKER(field string, value string, f ...WhereOptionFunc) Where + func LT(field string, f ...WhereOptionFunc) Where + func LTE(field string, f ...WhereOptionFunc) Where + func MergeWhere(w1 Where, w2 Where) Where + func NEQ(field string, f ...WhereOptionFunc) Where + func NOT_EXISTS(subquery Expression, f ...WhereOptionFunc) Where + func NOT_IN(field string, values []any, f ...WhereOptionFunc) Where + func ON(leftField any, rightField any, op ...string) Where + func OR(conditions ...Where) Where + func WHERE(field string, value any, ops ...OP) Where + type WhereOP string + const WhereOPAnd + const WhereOPOr + type WhereOptionFunc func(*whereItem) *whereItem + func WithLiteral(v any) WhereOptionFunc + func WithNativeValue(v any) WhereOptionFunc + func WithParameter(name string) WhereOptionFunc
Go to main page