db

package

Go to main page

Versions in this module

v1

v1.0.4

May 8, 2026

Changes in this version

+ var IncludedPlaceValue = IncludedPlace(1)

+ var IncludedPlaceWhere = IncludedPlace(2)

type Condition

+ Args []any

+ type IncludedPlace int

+ type ModelCountSet = func(in *ModelCount)

type ModelDelete

+ func (this_ *ModelDelete) CanDeleteAll() *ModelDelete

+ type ModelDeleteSet = func(in *ModelDelete)

+ type ModelInsertSet = func(in *ModelInsert)

type ModelSelect

+ func (this_ *ModelSelect) CanSelectAll() *ModelSelect

+ type ModelSelectSet = func(in *ModelSelect)

type ModelSetting

+ func (this_ *ModelSetting) AppendSql(appendSql string, appendArgs ...any) *ModelSetting

+ func (this_ *ModelSetting) EmptySelectExclude() *ModelSetting

+ func (this_ *ModelSetting) EmptySelectInclude() *ModelSetting

+ func (this_ *ModelSetting) EmptyValueExclude() *ModelSetting

+ func (this_ *ModelSetting) EmptyValueInclude() *ModelSetting

+ func (this_ *ModelSetting) EmptyWhereExclude() *ModelSetting

+ func (this_ *ModelSetting) EmptyWhereInclude() *ModelSetting

+ func (this_ *ModelSetting) GetAppendSql() (appendSql string, appendArgs []any)

+ func (this_ *ModelSetting) IsSelectExclude(column string) bool

+ func (this_ *ModelSetting) IsSelectInclude(column string) bool

+ func (this_ *ModelSetting) IsValueExclude(column string) bool

+ func (this_ *ModelSetting) IsValueInclude(column string) bool

+ func (this_ *ModelSetting) IsWhereExclude(column string) bool

+ func (this_ *ModelSetting) IsWhereInclude(column string) bool

+ func (this_ *ModelSetting) SelectExclude(columns ...string) *ModelSetting

+ func (this_ *ModelSetting) SelectInclude(columns ...string) *ModelSetting

+ func (this_ *ModelSetting) ValueExclude(columns ...string) *ModelSetting

+ func (this_ *ModelSetting) ValueInclude(columns ...string) *ModelSetting

+ func (this_ *ModelSetting) WhereExclude(columns ...string) *ModelSetting

+ func (this_ *ModelSetting) WhereInclude(columns ...string) *ModelSetting

type ModelUpdate

+ func (this_ *ModelUpdate) CanUpdateAll() *ModelUpdate

+ type ModelUpdateSet = func(in *ModelUpdate)

+ type SqlCountSet = func(in *SqlCount)

type SqlDelete

+ func (this_ *SqlDelete) CanDeleteAll() *SqlDelete

+ type SqlDeleteSet = func(in *SqlDelete)

+ type SqlInsertSet = func(in *SqlInsert)

type SqlSelect

+ func (this_ *SqlSelect) CanSelectAll() *SqlSelect

type SqlUpdate

+ func (this_ *SqlUpdate) CanUpdateAll() *SqlUpdate

+ type SqlUpdateSet = func(in *SqlUpdate)

v1.0.3

Apr 13, 2026

Changes in this version

+ type IGetSql interface

+ GetSql func() (sqlInfo string, args []any, err error)

type ModelCount

+ func NewModelCount(model any) (res *ModelCount)

type ModelDelete

+ func NewModelDelete(model any) (res *ModelDelete)

type ModelInsert

+ func NewModelInsert(model any) (res *ModelInsert)

type ModelSelect

+ func NewModelSelect(model any) (res *ModelSelect)

type ModelUpdate

+ func NewModelUpdate(model any) (res *ModelUpdate)

v1.0.2

Apr 10, 2026

v1.0.1

Apr 9, 2026

Changes in this version

+ var DefaultModelOption = NewModelOption()

+ var DefaultSqlOption = NewSqlOption()

+ var ErrorHasMoreRows = errors.New("has more rows by query one")

+ var ErrorNotSupportCreateTable = errors.New("not support create table")

+ var SqlParamParserDefaultParamAfter = "}"

+ var SqlParamParserDefaultParamBefore = "\\${"

+ func AddDialectByConfigDir(configDir string) (err error)

+ func AddDialectByConfigFile(configFile string) (err error)

+ func DoExec(ctx context.Context, sqlConn SqlConn, sqlInfo string, args []interface{}, ...) (result sql.Result, err error)

+ func DoExecBatch(ctx context.Context, sqlConn SqlConn, sqlInfo string, argsList [][]interface{}, ...) (res []sql.Result, err error)

+ func DoExecs(ctx context.Context, sqlConn SqlConn, sqlList []string, ...) (resultList []sql.Result, errSql string, errArgs []interface{}, err error)

+ func DoQuery(ctx context.Context, sqlConn SqlConn, sqlInfo string, args []interface{}, ...) (list []map[string]interface{}, err error)

+ func DoQueryCount(ctx context.Context, sqlConn SqlConn, sqlInfo string, args []interface{}, ...) (count int64, err error)

+ func DoQueryListStructWithService[S any](ctx context.Context, service IService, sqlInfo string, args []interface{}) (res []S, err error)

+ func DoQueryListStruct[S any](ctx context.Context, sqlConn SqlConn, sqlInfo string, args []interface{}, ...) (list []S, err error)

+ func DoQueryListWithModel[S any](ctx context.Context, s IModelSql) (res []S, err error)

+ func DoQueryListWithSql[S any](ctx context.Context, service IService, sqlInfo string, sqlArgs []any) (res []S, err error)

+ func DoQueryOne(ctx context.Context, sqlConn SqlConn, sqlInfo string, args []interface{}, ...) (data map[string]interface{}, err error)

+ func DoQueryOneStructWithService[S any](ctx context.Context, service IService, sqlInfo string, args []interface{}) (res S, err error)

+ func DoQueryOneStruct[S any](ctx context.Context, sqlConn SqlConn, sqlInfo string, args []interface{}, ...) (res S, err error)

+ func DoQueryOneWithModel[S any](ctx context.Context, s IModelSql) (res S, err error)

+ func DoQueryOneWithSql[S any](ctx context.Context, service IService, sqlInfo string, sqlArgs []any) (res S, err error)

+ func DoQueryPageWithModel[S any](ctx context.Context, s IModelSql, pageSize int64, pageNo int64) (res []S, err error)

+ func DoQueryPageWithSql[S any](ctx context.Context, service IService, sqlInfo string, sqlArgs []any, ...) (res []S, err error)

+ func DoQueryWithColumnTypes(ctx context.Context, sqlConn SqlConn, sqlInfo string, args []interface{}, ...) (columns []string, columnTypes []*sql.ColumnType, list []map[string]any, ...)

+ func DoTxExec(ctx context.Context, sqlConn SqlConn, sqlInfo string, args []interface{}, ...) (result sql.Result, err error)

+ func DoTxExecs(ctx context.Context, sqlConn SqlConn, sqlList []string, ...) (resultList []sql.Result, errSql string, errArgs []interface{}, err error)

+ func FormatColumnType(columnType string) (dataType string, length int, precision int, scale int)

+ func FormatDriverDSN(driverDSN string, dbCfg *Config, isUrl bool, paramSpaceChar string, ...) string

+ func GetBaseTypeValue(data any) (res any, is bool)

+ func GetParamValue(dbCfg *Config, name string) string

+ func GetSqlValue(columnType *sql.ColumnType, data any) (value any)

+ func GetStringValue(value any) (valueString string)

+ func HasNewLine(str string) bool

+ func IsFloat(s string) bool

+ func IsIdentifier(s string) bool

+ func IsInt(s string) bool

+ func IsInt64Value(value any) (res int64, ok bool)

+ func IsNumber(s string) bool

+ func IsTrue(arg any) bool

+ func IsWhiteSpace(s string) bool

+ func NewSqlDb(cfg *Config) (sqlDb *sql.DB, err error)

+ func ParserToFormat(str string) (formatStr string, names []string)

+ func SqlParamParse(sqlInfo string, param any) (string, []any, error)

+ func SqlTemplateHasContent(t *SqlTemplate) bool

+ func TableColumnAdd(dbService IService, moduleName, version, tableName string, column *Column) (err error)

+ func TableColumnDrop(dbService IService, moduleName, version, tableName string, columnName string) (err error)

+ func TableCreate(dbService IService, moduleName, version, tableName string, table *Table) (err error)

+ func TableIndexAdd(dbService IService, moduleName, version, tableName string, index *Index) (err error)

+ func TableIndexDrop(dbService IService, moduleName, version, tableName string, indexName string) (err error)

+ func ToInt64Value(value any) (res int64, err error)

+ func ToIntValue(value any) (res int, err error)

+ func ToKeyValueParams(params map[string]string, paramSpaceChar string) (res string)

+ func ToUrlParams(params map[string]string) (res string)

+ type ChangeSqlReader func(r *SqlReader)

+ type Column struct

+ AutoIncrement bool

+ AutoIncrementCreate bool

+ AutoIncrementName string

+ AutoIncrementStart int64

+ Comment string

+ DataType string

+ DatabaseName string

+ Default string

+ Extend map[string]any

+ Key bool

+ Length int

+ Name string

+ NotNull bool

+ Precision int

+ Scale int

+ SchemaName string

+ TableName string

+ Type string

+ func ColumnByMap(data map[string]any) (res *Column)

+ func (this_ *Column) Init(handler DDLHandler, databaseName string, schemaName string, tableName string)

+ type Condition struct

+ Children *Conditions

+ Field string

+ IsOr bool

+ Op Op

+ Value any

+ WhereSql string

+ type Conditions []*Condition

+ func NewConditions() *Conditions

+ func (cs *Conditions) And(field string, op Op, value any) *Conditions

+ func (cs *Conditions) AndGroup(sub *Conditions) *Conditions

+ func (cs *Conditions) AndWhereSql(whereSql string) *Conditions

+ func (cs *Conditions) Build(b *OrmSqlBuilder, s IService) (string, []any)

+ func (cs *Conditions) Custom(custom string, values []any) *Conditions

+ func (cs *Conditions) Eq(field string, value any) *Conditions

+ func (cs *Conditions) Gt(field string, value any) *Conditions

+ func (cs *Conditions) Gte(field string, value any) *Conditions

+ func (cs *Conditions) In(field string, values any) *Conditions

+ func (cs *Conditions) IsNotNull(field string) *Conditions

+ func (cs *Conditions) IsNull(field string) *Conditions

+ func (cs *Conditions) Like(field string, pattern any) *Conditions

+ func (cs *Conditions) Lt(field string, value any) *Conditions

+ func (cs *Conditions) Lte(field string, value any) *Conditions

+ func (cs *Conditions) Ne(field string, value any) *Conditions

+ func (cs *Conditions) NotIn(field string, values any) *Conditions

+ func (cs *Conditions) NotLike(field string, pattern any) *Conditions

+ func (cs *Conditions) Or(field string, op Op, value any) *Conditions

+ func (cs *Conditions) OrCustom(custom string, values []any) *Conditions

+ func (cs *Conditions) OrEq(field string, value any) *Conditions

+ func (cs *Conditions) OrGroup(sub *Conditions) *Conditions

+ func (cs *Conditions) OrGt(field string, value any) *Conditions

+ func (cs *Conditions) OrGte(field string, value any) *Conditions

+ func (cs *Conditions) OrIn(field string, values any) *Conditions

+ func (cs *Conditions) OrIsNotNull(field string) *Conditions

+ func (cs *Conditions) OrIsNull(field string) *Conditions

+ func (cs *Conditions) OrLike(field string, pattern any) *Conditions

+ func (cs *Conditions) OrLt(field string, value any) *Conditions

+ func (cs *Conditions) OrLte(field string, value any) *Conditions

+ func (cs *Conditions) OrNe(field string, value any) *Conditions

+ func (cs *Conditions) OrNotIn(field string, values any) *Conditions

+ func (cs *Conditions) OrNotLike(field string, pattern any) *Conditions

+ func (cs *Conditions) OrWhereSql(whereSql string) *Conditions

+ func (cs *Conditions) Where(field string, value any) *Conditions

+ type Config struct

+ Address string

+ Database string

+ DatabasePath string

+ DialectType string

+ Disabled bool

+ Dsn string

+ DsnAppend string

+ Host string

+ MaxIdleConn int

+ MaxOpenConn int

+ Password string

+ Port int

+ Schema string

+ ServerName string

+ TlsClientCert string

+ TlsClientKey string

+ TlsConfig string

+ TlsRootCert string

+ Type string

+ Username string

+ func (this_ *Config) Clone() (res *Config)

+ func (this_ *Config) GetConnProxy() ConnProxy

+ func (this_ *Config) SetConnProxy(connProxy ConnProxy)

+ func (this_ *Config) SetGetDatabasePath(getDatabasePath func(cfg *Config) string)

+ type ConnProxy interface

+ Dial func(n string, addr string) (net.Conn, error)

+ type Constraint struct

+ ColumnNames []string

+ Comment string

+ DatabaseName string

+ Extend map[string]any

+ IsForeign bool

+ IsPrimary bool

+ IsUnique bool

+ Name string

+ ReferencedColumnNames []string

+ ReferencedDatabaseName string

+ ReferencedTableName string

+ SchemaName string

+ TableName string

+ Type string

+ func ConstraintListByColumns(columns []*ConstraintColumn) (res []*Constraint)

+ func (this_ *Constraint) GenName(databaseName string, schemaName string, tableName string) string

+ func (this_ *Constraint) Init(handler DDLHandler, databaseName string, schemaName string, tableName string)

+ type ConstraintColumn struct

+ ColumnName string

+ ColumnOrder int

+ Comment string

+ DatabaseName string

+ Extend map[string]any

+ Name string

+ ReferencedColumnName string

+ ReferencedDatabaseName string

+ ReferencedTableName string

+ SchemaName string

+ TableName string

+ Type string

+ func ConstraintColumnByMap(data map[string]any) (res *ConstraintColumn)

+ type DDLHandler interface

+ IsAppendDatabaseName func() (res bool)

+ IsAppendSchemaName func() (res bool)

+ WrapColumnName func(columnName string) (res string)

+ WrapConstraintName func(constraintName string) (res string)

+ WrapDatabaseName func(databaseName string) (res string)

+ WrapIndexName func(indexName string) (res string)

+ WrapName func(name string) (res string)

+ WrapSchemaName func(schemaName string) (res string)

+ WrapSequenceName func(sequenceName string) (res string)

+ WrapString func(str string) (res string)

+ WrapTableName func(tableName string) (res string)

+ WrapUserName func(userName string) (res string)

+ type DDLOption struct

+ AppendDatabaseName *bool

+ AppendSchemaName *bool

+ WrapConstraintNameOpen *bool

+ WrapDatabaseNameOpen *bool

+ WrapIndexNameOpen *bool

+ WrapSchemaNameOpen *bool

+ WrapSequenceNameOpen *bool

+ WrapUserNameOpen *bool

+ func NewDDLOption() (res *DDLOption)

+ func (this_ *DDLOption) IsAppendDatabaseName() bool

+ func (this_ *DDLOption) IsAppendSchemaName() bool

+ func (this_ *DDLOption) IsWrapConstraintName() bool

+ func (this_ *DDLOption) IsWrapDatabaseName() bool

+ func (this_ *DDLOption) IsWrapIndexName() bool

+ func (this_ *DDLOption) IsWrapSchemaName() bool

+ func (this_ *DDLOption) IsWrapSequenceName() bool

+ func (this_ *DDLOption) IsWrapUserName() bool

+ func (this_ *DDLOption) WrapConstraintName(name string) string

+ func (this_ *DDLOption) WrapDatabaseName(name string) string

+ func (this_ *DDLOption) WrapIndexName(name string) string

+ func (this_ *DDLOption) WrapSchemaName(name string) string

+ func (this_ *DDLOption) WrapSequenceName(name string) string

+ func (this_ *DDLOption) WrapUserName(name string) string

+ type Database struct

+ Cascade bool

+ Extend map[string]any

+ IfNotExists bool

+ IsSystem bool

+ Name string

+ func DatabaseByMap(data map[string]any) (res *Database)

+ type Dialect interface

+ ArgChar func() string

+ Column func(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (column *Column, err error)

+ ColumnAdd func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ ColumnAddSql func(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ ColumnCheckExists func(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (exists bool)

+ ColumnDelete func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ ColumnDeleteSql func(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ ColumnList func(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (columnList []*Column, err error)

+ ColumnSelectSql func(databaseName string, schemaName string, tableName string, columnName string) (sqlInfo string, sqlArgs []any)

+ ColumnUpdate func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ ColumnUpdateSql func(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ Constraint func(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (constraint *Constraint, err error)

+ ConstraintAdd func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ ConstraintAddSql func(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ ConstraintDelete func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ ConstraintDeleteSql func(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ ConstraintList func(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (constraintList []*Constraint, err error)

+ ConstraintSelectSql func(databaseName string, schemaName string, tableName string, ...) (sqlInfo string, sqlArgs []any)

+ Database func(sqlConn SqlConn, databaseName string) (database *Database, err error)

+ DatabaseChange func(sqlConn SqlConn, databaseName string) (ok bool, err error)

+ DatabaseCreate func(sqlConn SqlConn, handler DDLHandler, database *Database) (err error)

+ DatabaseCreateFieldList func() (sqlList []*Field)

+ DatabaseCreateSql func(handler DDLHandler, database *Database) (sqlList []string, sqlArgsList [][]any)

+ DatabaseDelete func(sqlConn SqlConn, handler DDLHandler, databaseName string, cascade bool) (err error)

+ DatabaseDeleteSql func(handler DDLHandler, databaseName string, cascade bool) (sqlList []string, sqlArgsList [][]any)

+ DatabaseList func(sqlConn SqlConn) (databaseList []*Database, err error)

+ DatabaseSelectSql func(databaseName string) (sqlInfo string, sqlArgs []any)

+ EscapeStringChar func() string

+ FormatPageSql func(sqlInfo string, pageSize int64, pageNo int64) (res string)

+ FormatSqlArgChar func(sqlInfo string) (res string)

+ GetDriverDSN func(dbCfg *Config, params map[string]string) string

+ GetDriverName func() string

+ Index func(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (index *Index, err error)

+ IndexAdd func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ IndexAddSql func(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ IndexCheckExists func(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (exists bool)

+ IndexDelete func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ IndexDeleteSql func(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ IndexList func(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (indexList []*Index, err error)

+ IndexSelectSql func(databaseName string, schemaName string, tableName string, indexName string) (sqlInfo string, sqlArgs []any)

+ Info func() (info *Info)

+ Match func() []string

+ Open func(dbCfg *Config, params map[string]string) (sqlDb *sql.DB, err error)

+ Schema func(sqlConn SqlConn, databaseName string, schemaName string) (schema *Schema, err error)

+ SchemaChange func(sqlConn SqlConn, schemaName string) (ok bool, err error)

+ SchemaCreate func(sqlConn SqlConn, handler DDLHandler, databaseName string, schema *Schema) (err error)

+ SchemaCreateFieldList func() (sqlList []*Field)

+ SchemaCreateSql func(handler DDLHandler, databaseName string, schema *Schema) (sqlList []string, sqlArgsList [][]any)

+ SchemaDelete func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ SchemaDeleteSql func(handler DDLHandler, databaseName string, schemaName string, cascade bool) (sqlList []string, sqlArgsList [][]any)

+ SchemaList func(sqlConn SqlConn, databaseName string) (schemaList []*Schema, err error)

+ SchemaSelectSql func(databaseName string, schemaName string) (sqlInfo string, sqlArgs []any)

+ Sequence func(sqlConn SqlConn, databaseName string, schemaName string, sequenceName string) (sequence *Sequence, err error)

+ SequenceCreate func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ SequenceCreateFieldList func() (sqlList []*Field)

+ SequenceCreateSql func(handler DDLHandler, databaseName string, schemaName string, sequence *Sequence) (sqlList []string, sqlArgsList [][]any)

+ SequenceDelete func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ SequenceDeleteSql func(handler DDLHandler, databaseName string, schemaName string, ...) (sqlList []string, sqlArgsList [][]any)

+ SequenceList func(sqlConn SqlConn, databaseName string, schemaName string) (sequenceList []*Sequence, err error)

+ SequenceSelectSql func(databaseName string, schemaName string, sequenceName string) (sqlInfo string, sqlArgs []any)

+ SqlConcat func(args ...string) (res string)

+ Table func(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (table *Table, err error)

+ TableCheckExists func(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (exists bool)

+ TableCreate func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ TableCreateFieldList func() (sqlList []*Field)

+ TableCreateSql func(handler DDLHandler, databaseName string, schemaName string, table *Table) (sqlList []string, sqlArgsList [][]any)

+ TableDelete func(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ TableDeleteSql func(handler DDLHandler, databaseName string, schemaName string, tableName string) (sqlList []string, sqlArgsList [][]any)

+ TableDetail func(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (table *Table, err error)

+ TableList func(sqlConn SqlConn, databaseName string, schemaName string) (tableList []*Table, err error)

+ TableSelectSql func(databaseName string, schemaName string, tableName string) (sqlInfo string, sqlArgs []any)

+ Type func() string

+ User func(sqlConn SqlConn, userName string) (user *User, err error)

+ UserChange func(sqlConn SqlConn, userName string, password string) (ok bool, err error)

+ UserCreate func(sqlConn SqlConn, handler DDLHandler, user *User) (err error)

+ UserCreateFieldList func() (sqlList []*Field)

+ UserCreateSql func(handler DDLHandler, user *User) (sqlList []string, sqlArgsList [][]any)

+ UserDelete func(sqlConn SqlConn, handler DDLHandler, userName string) (err error)

+ UserDeleteSql func(handler DDLHandler, userName string) (sqlList []string, sqlArgsList [][]any)

+ UserList func(sqlConn SqlConn) (userList []*User, err error)

+ UserSelectSql func(userName string) (sqlInfo string, sqlArgs []any)

+ WrapNameChar func() string

+ WrapStringChar func() string

+ func AddByDialectConfigBase64(dialectType string, cfgContent string) (dia Dialect, err error)

+ func AddDialect(dia Dialect) Dialect

+ func GetDialect(name string) Dialect

+ func NewDialect(cfg *DialectConfig) Dialect

+ type DialectColumnConfig struct

+ Add string

+ Comment string

+ Delete string

+ Select string

+ Update string

+ UpdateDefault string

+ UpdateNotNull string

+ UpdateRename string

+ UpdateType string

+ type DialectConfig struct

+ ArgChar string

+ Column *DialectColumnConfig

+ Constraint *DialectConstraintConfig

+ Database *DialectDatabaseConfig

+ Driver *DialectDriverConfig

+ Extend string

+ FormList []*Form

+ FuncExtend bool

+ FuncList map[string]map[string]any

+ Index *DialectIndexConfig

+ Match []string

+ NameNoWrapIsUpper bool

+ NameWrapChar string

+ Relation string

+ Schema *DialectSchemaConfig

+ Sequence *DialectSequenceConfig

+ StringEscapeChar string

+ StringWrapChar string

+ Table *DialectTableConfig

+ Tree []*DialectNodeConfig

+ Type string

+ TypeExtend bool

+ TypeList []*DialectTypeConfig

+ User *DialectUserConfig

+ func AddDialectConfig(cfg *DialectConfig) *DialectConfig

+ func GetDialectConfig(name string) *DialectConfig

+ func LoadDialectConfigByFile(configFile string) (cfg *DialectConfig, err error)

+ func ToDialectConfigByBytes(configFile string, bs []byte) (cfg *DialectConfig, err error)

+ func (this_ *DialectConfig) CreateUserAutoCreateDatabase() bool

+ func (this_ *DialectConfig) CreateUserAutoCreateSchema() bool

+ func (this_ *DialectConfig) FindFunc(name string) (r map[string]any)

+ func (this_ *DialectConfig) FindType(name string) (r *DialectTypeConfig)

+ func (this_ *DialectConfig) GetArgChar() string

+ func (this_ *DialectConfig) GetColumnAdd() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetColumnComment() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetColumnDelete() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetColumnSelect() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetColumnUpdate() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetColumnUpdateDefault() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetColumnUpdateNotNull() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetColumnUpdateRename() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetColumnUpdateType() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetConstraintAdd() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetConstraintComment() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetConstraintDelete() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetConstraintSelect() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetDatabaseChange() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetDatabaseCreate() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetDatabaseCreateFieldList() (res []*Field)

+ func (this_ *DialectConfig) GetDatabaseDelete() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetDatabaseSelect() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetDriver() *DialectDriverConfig

+ func (this_ *DialectConfig) GetIndexAdd() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetIndexComment() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetIndexDelete() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetIndexSelect() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetNameNoWrapIsUpper() bool

+ func (this_ *DialectConfig) GetNameWrapChar() string

+ func (this_ *DialectConfig) GetSchemaChange() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetSchemaCreate() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetSchemaCreateFieldList() (res []*Field)

+ func (this_ *DialectConfig) GetSchemaDelete() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetSchemaSelect() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetSequenceCreate() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetSequenceCreateFieldList() (res []*Field)

+ func (this_ *DialectConfig) GetSequenceDelete() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetSequenceSelect() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetStringEscapeChar() string

+ func (this_ *DialectConfig) GetStringWrapChar() string

+ func (this_ *DialectConfig) GetTableCreate() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableCreateColumn() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableCreateColumnComment() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableCreateComment() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableCreateConstraint() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableCreateConstraintComment() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableCreateFieldList() (res []*Field)

+ func (this_ *DialectConfig) GetTableCreateIndex() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableCreateIndexComment() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableCreateSequenceTrigger() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableDelete() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetTableSelect() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetUserChange() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetUserCreate() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetUserCreateFieldList() (res []*Field)

+ func (this_ *DialectConfig) GetUserDelete() (t *SqlTemplate)

+ func (this_ *DialectConfig) GetUserSelect() (t *SqlTemplate)

+ func (this_ *DialectConfig) Init() (err error)

+ func (this_ *DialectConfig) IsSystemDatabase(name string) bool

+ func (this_ *DialectConfig) IsSystemSchema(name string) bool

+ func (this_ *DialectConfig) IsSystemUser(name string) bool

+ func (this_ *DialectConfig) MatchType(dataType string, length, precision, scale int) (r *DialectTypeConfig)

+ func (this_ *DialectConfig) NewPlaceSqlTemplate(place string, sqlInfo string) (res *SqlTemplate, err error)

+ type DialectConstraintConfig struct

+ Add string

+ Comment string

+ Delete string

+ Select string

+ type DialectDatabaseConfig struct

+ Change string

+ Create string

+ CreateFieldList []*Field

+ Delete string

+ Select string

+ ShouldChangeDatabase bool

+ ShouldChangeSchema bool

+ ShouldChangeUser bool

+ Systems []string

+ type DialectDriverConfig struct

+ CanPathEscape bool

+ Dsn string

+ HasDatabase bool

+ HasSchema bool

+ IsUrl bool

+ Name string

+ ParamSpaceChar string

+ Params map[string]string

+ type DialectIndexConfig struct

+ Add string

+ Comment string

+ Delete string

+ Select string

+ type DialectNodeConfig struct

+ Children []*DialectNodeConfig

+ Comment string

+ Name string

+ Rule string

+ ShouldChangeDatabase bool

+ ShouldChangeSchema bool

+ ShouldChangeUser bool

+ type DialectSchemaConfig struct

+ Change string

+ Create string

+ CreateFieldList []*Field

+ Delete string

+ Select string

+ ShouldChangeDatabase bool

+ ShouldChangeSchema bool

+ ShouldChangeUser bool

+ Systems []string

+ type DialectSequenceConfig struct

+ Create string

+ CreateFieldList []*Field

+ Delete string

+ Select string

+ type DialectService struct

+ func (this_ *DialectService) AppendParam(handler DDLHandler, param map[string]any, obj any, ignoreNames ...string)

+ func (this_ *DialectService) AppendParamExtend(handler DDLHandler, param map[string]any, extend map[string]any)

+ func (this_ *DialectService) AppendParamTableName(handler DDLHandler, param map[string]any, databaseName string, ...)

+ func (this_ *DialectService) ArgChar() string

+ func (this_ *DialectService) Column(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (column *Column, err error)

+ func (this_ *DialectService) ColumnAdd(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) ColumnAddSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) ColumnCheckExists(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (exists bool)

+ func (this_ *DialectService) ColumnComment(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) ColumnCommentSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) ColumnDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) ColumnDeleteSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) ColumnFull(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (err error)

+ func (this_ *DialectService) ColumnList(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (columnList []*Column, err error)

+ func (this_ *DialectService) ColumnParam(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (param map[string]any)

+ func (this_ *DialectService) ColumnSelectSql(databaseName string, schemaName string, tableName string, columnName string) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) ColumnUpdate(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) ColumnUpdateSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) Constraint(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (constraint *Constraint, err error)

+ func (this_ *DialectService) ConstraintAdd(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) ConstraintAddSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) ConstraintComment(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) ConstraintCommentSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) ConstraintDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) ConstraintDeleteSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) ConstraintList(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (constraintList []*Constraint, err error)

+ func (this_ *DialectService) ConstraintParam(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (param map[string]any)

+ func (this_ *DialectService) ConstraintSelectSql(databaseName string, schemaName string, tableName string, ...) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) Database(sqlConn SqlConn, databaseName string) (database *Database, err error)

+ func (this_ *DialectService) DatabaseChange(sqlConn SqlConn, databaseName string) (ok bool, err error)

+ func (this_ *DialectService) DatabaseCreate(sqlConn SqlConn, handler DDLHandler, database *Database) (err error)

+ func (this_ *DialectService) DatabaseCreateFieldList() (sqlList []*Field)

+ func (this_ *DialectService) DatabaseCreateSql(handler DDLHandler, database *Database) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) DatabaseDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, cascade bool) (err error)

+ func (this_ *DialectService) DatabaseDeleteSql(handler DDLHandler, databaseName string, cascade bool) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) DatabaseList(sqlConn SqlConn) (databaseList []*Database, err error)

+ func (this_ *DialectService) DatabaseParam(handler DDLHandler, database *Database) (param map[string]any)

+ func (this_ *DialectService) DatabaseSelectSql(databaseName string) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) EscapeStringChar() string

+ func (this_ *DialectService) Exec(sqlConn SqlConn, sqlInfo string, sqlArgs []any) (err error)

+ func (this_ *DialectService) Execs(sqlConn SqlConn, sqlList []string, sqlArgsList [][]any) (err error)

+ func (this_ *DialectService) FormatPageSql(sqlInfo string, pageSize int64, pageNo int64) (res string)

+ func (this_ *DialectService) FormatSqlArgChar(sqlInfo string) (res string)

+ func (this_ *DialectService) GetColumnDefault(handler DDLHandler, column *Column) (res string)

+ func (this_ *DialectService) GetColumnType(handler DDLHandler, column *Column) (columnType string)

+ func (this_ *DialectService) GetDDLHandler(handler DDLHandler) DDLHandler

+ func (this_ *DialectService) GetDriverDSN(dbCfg *Config, params map[string]string) string

+ func (this_ *DialectService) GetDriverName() string

+ func (this_ *DialectService) GetParam(handler DDLHandler, obj any) (param map[string]any)

+ func (this_ *DialectService) Index(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (index *Index, err error)

+ func (this_ *DialectService) IndexAdd(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) IndexAddSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) IndexCheckExists(sqlConn SqlConn, databaseName string, schemaName string, tableName string, ...) (exists bool)

+ func (this_ *DialectService) IndexComment(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) IndexCommentSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) IndexDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) IndexDeleteSql(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) IndexList(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (indexList []*Index, err error)

+ func (this_ *DialectService) IndexParam(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) (param map[string]any)

+ func (this_ *DialectService) IndexSelectSql(databaseName string, schemaName string, tableName string, indexName string) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) Info() (info *Info)

+ func (this_ *DialectService) IsAppendDatabaseName() bool

+ func (this_ *DialectService) IsAppendSchemaName() bool

+ func (this_ *DialectService) Match() []string

+ func (this_ *DialectService) Names(names ...string) (res string)

+ func (this_ *DialectService) Open(dbCfg *Config, params map[string]string) (sqlDb *sql.DB, err error)

+ func (this_ *DialectService) Query(sqlConn SqlConn, sqlInfo string, sqlArgs []any) (res []map[string]any, err error)

+ func (this_ *DialectService) QueryOne(sqlConn SqlConn, sqlInfo string, sqlArgs []any) (res map[string]any, err error)

+ func (this_ *DialectService) Schema(sqlConn SqlConn, databaseName string, schemaName string) (schema *Schema, err error)

+ func (this_ *DialectService) SchemaChange(sqlConn SqlConn, schemaName string) (ok bool, err error)

+ func (this_ *DialectService) SchemaCreate(sqlConn SqlConn, handler DDLHandler, databaseName string, schema *Schema) (err error)

+ func (this_ *DialectService) SchemaCreateFieldList() (sqlList []*Field)

+ func (this_ *DialectService) SchemaCreateSql(handler DDLHandler, databaseName string, schema *Schema) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) SchemaDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) SchemaDeleteSql(handler DDLHandler, databaseName string, schemaName string, cascade bool) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) SchemaList(sqlConn SqlConn, databaseName string) (schemaList []*Schema, err error)

+ func (this_ *DialectService) SchemaParam(handler DDLHandler, databaseName string, schema *Schema) (param map[string]any)

+ func (this_ *DialectService) SchemaSelectSql(databaseName string, schemaName string) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) Sequence(sqlConn SqlConn, databaseName string, schemaName string, sequenceName string) (sequence *Sequence, err error)

+ func (this_ *DialectService) SequenceCreate(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) SequenceCreateFieldList() (sqlList []*Field)

+ func (this_ *DialectService) SequenceCreateSql(handler DDLHandler, databaseName string, schemaName string, sequence *Sequence) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) SequenceDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) SequenceDeleteSql(handler DDLHandler, databaseName string, schemaName string, ...) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) SequenceList(sqlConn SqlConn, databaseName string, schemaName string) (sequenceList []*Sequence, err error)

+ func (this_ *DialectService) SequenceParam(handler DDLHandler, databaseName string, schemaName string, sequence *Sequence) (param map[string]any)

+ func (this_ *DialectService) SequenceSelectSql(databaseName string, schemaName string, sequenceName string) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) SqlConcat(args ...string) (res string)

+ func (this_ *DialectService) Table(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (table *Table, err error)

+ func (this_ *DialectService) TableCheckExists(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (exists bool)

+ func (this_ *DialectService) TableCreate(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) TableCreateFieldList() (sqlList []*Field)

+ func (this_ *DialectService) TableCreateSql(handler DDLHandler, databaseName string, schemaName string, table *Table) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) TableDelete(sqlConn SqlConn, handler DDLHandler, databaseName string, schemaName string, ...) (err error)

+ func (this_ *DialectService) TableDeleteSql(handler DDLHandler, databaseName string, schemaName string, tableName string) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) TableDetail(sqlConn SqlConn, databaseName string, schemaName string, tableName string) (table *Table, err error)

+ func (this_ *DialectService) TableDetailList(sqlConn SqlConn, databaseName string, schemaName string) (tableList []*Table, err error)

+ func (this_ *DialectService) TableList(sqlConn SqlConn, databaseName string, schemaName string) (tableList []*Table, err error)

+ func (this_ *DialectService) TableParam(handler DDLHandler, databaseName string, schemaName string, table *Table) (param map[string]any)

+ func (this_ *DialectService) TableSelectSql(databaseName string, schemaName string, tableName string) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) TemplateSql(t *SqlTemplate, param map[string]any) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) TemplateSqlList(t *SqlTemplate, param map[string]any) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) Type() string

+ func (this_ *DialectService) User(sqlConn SqlConn, userName string) (user *User, err error)

+ func (this_ *DialectService) UserChange(sqlConn SqlConn, userName string, password string) (ok bool, err error)

+ func (this_ *DialectService) UserCreate(sqlConn SqlConn, handler DDLHandler, user *User) (err error)

+ func (this_ *DialectService) UserCreateFieldList() (sqlList []*Field)

+ func (this_ *DialectService) UserCreateSql(handler DDLHandler, user *User) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) UserDelete(sqlConn SqlConn, handler DDLHandler, userName string) (err error)

+ func (this_ *DialectService) UserDeleteSql(handler DDLHandler, userName string) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *DialectService) UserList(sqlConn SqlConn) (userList []*User, err error)

+ func (this_ *DialectService) UserParam(handler DDLHandler, user *User) (param map[string]any)

+ func (this_ *DialectService) UserSelectSql(userName string) (sqlInfo string, sqlArgs []any)

+ func (this_ *DialectService) WrapColumnName(name string) string

+ func (this_ *DialectService) WrapConstraintName(name string) string

+ func (this_ *DialectService) WrapDatabaseName(name string) string

+ func (this_ *DialectService) WrapIndexName(name string) string

+ func (this_ *DialectService) WrapName(name string) (res string)

+ func (this_ *DialectService) WrapNameChar() string

+ func (this_ *DialectService) WrapNames(wrapName func(name string) (res string), names ...string) (res string)

+ func (this_ *DialectService) WrapSchemaName(name string) string

+ func (this_ *DialectService) WrapSequenceName(name string) string

+ func (this_ *DialectService) WrapString(str string) (res string)

+ func (this_ *DialectService) WrapStringChar() string

+ func (this_ *DialectService) WrapTableName(name string) string

+ func (this_ *DialectService) WrapUserName(name string) string

+ type DialectTableConfig struct

+ Comment string

+ Create string

+ CreateColumn string

+ CreateColumnComment string

+ CreateComment string

+ CreateConstraint string

+ CreateConstraintComment string

+ CreateFieldList []*Field

+ CreateIndex string

+ CreateIndexComment string

+ CreateSequenceTrigger string

+ Delete string

+ Select string

+ ShouldChangeDatabase bool

+ ShouldChangeSchema bool

+ ShouldChangeUser bool

+ type DialectTypeConfig struct

+ Args []string

+ Format string

+ Match []string

+ Name string

+ func (this_ *DialectTypeConfig) FormatColumnType(length, precision, scale int) (columnType string)

+ type DialectUserConfig struct

+ AutoCreateDatabase bool

+ AutoCreateSchema bool

+ Change string

+ Create string

+ CreateFieldList []*Field

+ Delete string

+ Select string

+ Systems []string

+ type DmBlobType interface

+ Read func(dest []byte) (n int, err error)

+ ReadAt func(pos int, dest []byte) (n int, err error)

+ Scan func(src interface{}) error

+ Truncate func(length int64) error

+ Write func(pos int, src []byte) (n int, err error)

+ type DmClobType interface

+ GetLength func() (int64, error)

+ ReadString func(pos int, length int) (result string, err error)

+ Scan func(src interface{}) error

+ Truncate func(length int64) error

+ WriteString func(pos int, s string) (n int, err error)

+ type Field struct

+ Default string

+ FormName string

+ IsInteger bool

+ Label string

+ List bool

+ Name string

+ Required bool

+ Type string

+ type FieldSetterType func(model reflect.Value, modelField *ModelField, fieldValue reflect.Value, ...) (err error)

+ type FieldValue struct

+ func FieldValueByData(data any) (res *FieldValue)

+ func FieldValueByValue(v reflect.Value) (res *FieldValue)

+ func GetInsertOrUpdateColumnValues(list []*InsertOrUpdateValue) (columns []string, values []*FieldValue)

+ func (this_ *FieldValue) GetData() any

+ func (this_ *FieldValue) GetValue() reflect.Value

+ func (this_ *FieldValue) GetValueType() reflect.Type

+ func (this_ *FieldValue) IsEmpty() bool

+ func (this_ *FieldValue) IsNull() bool

+ func (this_ *FieldValue) IsZero() bool

+ type FiledGetColumn func() string

+ type FiledGetValue func(columnName string, columnValue *FieldValue) any

+ type Form struct

+ FieldList []*Field

+ Name string

+ type GetSqlValueType func(columnType *sql.ColumnType, data any) (res any)

+ type HasStringFuncType interface

+ String func() string

+ type IDynamicService interface

+ RealService func(param *SqlParam, tableName string) IService

+ type IGetObjectField interface

+ GetObjectField func(b *SqlBuilder, object any) (res any)

+ type IGetPrimaryKey interface

+ GetPrimaryKey func() []string

+ type IGetTableName interface

+ GetTableName func() string

+ type IModel interface

+ type IModelSql interface

+ GetService func() (service IService)

+ GetSql func() (sqlInfo string, args []any, err error)

+ type IService interface

+ Close func()

+ Count func(ctx context.Context, model IModel) (res int64, err error)

+ Delete func(ctx context.Context, model IModel) (res sql.Result, err error)

+ Exec func(ctx context.Context, sql string, args []any) (result sql.Result, err error)

+ Execs func(ctx context.Context, sqlList []string, argsList [][]any) (results []sql.Result, err error)

+ GetConfig func() Config

+ GetDDLHandler func() (handler DDLHandler)

+ GetDialect func() Dialect

+ GetModelOption func() (modelOption *ModelOption)

+ GetSqlConn func() SqlConn

+ Insert func(ctx context.Context, model IModel) (res sql.Result, err error)

+ ModelCount func(model any) (res *ModelCount)

+ ModelDelete func(model any) (res *ModelDelete)

+ ModelInsert func(model any) (res *ModelInsert)

+ ModelSelect func(model any) (res *ModelSelect)

+ ModelUpdate func(model any) (res *ModelUpdate)

+ QueryCount func(ctx context.Context, sql string, args []any) (count int64, err error)

+ QueryMapList func(ctx context.Context, sql string, args []any) (list []map[string]any, err error)

+ QueryMapOne func(ctx context.Context, sql string, args []any) (one map[string]any, err error)

+ QueryMapPage func(ctx context.Context, sql string, args []any, pageSize int64, pageNo int64) (list []map[string]any, err error)

+ SetDynamicService func(dynamicService IDynamicService)

+ ShowExecSql func() bool

+ ShowQuerySql func() bool

+ SqlCount func(table string) (res *SqlCount)

+ SqlDelete func(table string) (res *SqlDelete)

+ SqlInsert func(table string) (res *SqlInsert)

+ SqlSelect func(table string, columns ...string) (res *SqlSelect)

+ SqlUpdate func(table string) (res *SqlUpdate)

+ Update func(ctx context.Context, model IModel) (res sql.Result, err error)

+ type Index struct

+ ColumnNames []string

+ Comment string

+ DatabaseName string

+ Extend map[string]any

+ Name string

+ SchemaName string

+ TableName string

+ Type string

+ func IndexListByColumns(columns []*IndexColumn) (res []*Index)

+ func (this_ *Index) GenName(databaseName string, schemaName string, tableName string) string

+ func (this_ *Index) Init(handler DDLHandler, databaseName string, schemaName string, tableName string)

+ type IndexColumn struct

+ ColumnName string

+ ColumnOrder int

+ Comment string

+ DatabaseName string

+ Extend map[string]any

+ Name string

+ SchemaName string

+ TableName string

+ Type string

+ func IndexColumnByMap(data map[string]any) (res *IndexColumn)

+ type Info struct

+ CreateUserAutoCreateDatabase bool

+ CreateUserAutoCreateSchema bool

+ DriverName string

+ Dsn string

+ DsnHasDatabase bool

+ DsnHasSchema bool

+ HasDatabase bool

+ HasSchema bool

+ HasSequence bool

+ HasUser bool

+ NameNoWrapIsUpper bool

+ SqlChangeDatabase bool

+ SqlChangeSchema bool

+ SqlChangeUser bool

+ type InsertOrUpdateValue struct

+ Column string

+ Value any

+ type ModelCount struct

+ func (this_ *ModelCount) Count(ctx context.Context) (res int64, err error)

+ func (this_ *ModelCount) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *ModelCount) SetWhere(where *Conditions) *ModelCount

+ func (this_ *ModelCount) Where() *Conditions

+ type ModelDelete struct

+ func (this_ *ModelDelete) DeleteAll() *ModelDelete

+ func (this_ *ModelDelete) Exec(ctx context.Context) (res sql.Result, err error)

+ func (this_ *ModelDelete) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *ModelDelete) SetWhere(where *Conditions) *ModelDelete

+ func (this_ *ModelDelete) Where() *Conditions

+ type ModelField struct

+ AnonymousModel *ModelInfo

+ ColumnName string

+ Field reflect.StructField

+ FieldName string

+ ImplementsSqlScanner bool

+ Index int

+ IsAnonymous bool

+ IsBool bool

+ IsNumber bool

+ IsPtr bool

+ IsString bool

+ JsonName string

+ Kind reflect.Kind

+ type ModelInfo struct

+ type ModelInsert struct

+ func (this_ *ModelInsert) Exec(ctx context.Context) (res sql.Result, err error)

+ func (this_ *ModelInsert) GetSql() (sqlInfo string, args []any, err error)

+ type ModelOption struct

+ ColumnStrictCase bool

+ ColumnTag string

+ ColumnUseFieldName bool

+ ColumnUseJsonTag bool

+ func NewModelOption() (res *ModelOption)

+ func (this_ *ModelOption) GetColumnValue(modelV reflect.Value, columnName string) (fieldValue *FieldValue)

+ func (this_ *ModelOption) GetColumnValues(modelV reflect.Value) (columns []string, values []*FieldValue)

+ func (this_ *ModelOption) GetColumns(modelV reflect.Value) (columns []string)

+ func (this_ *ModelOption) GetModelInfo(inType reflect.Type) (info *ModelInfo)

+ func (this_ *ModelOption) SetGetColumn(getColumn FiledGetColumn) *ModelOption

+ func (this_ *ModelOption) SetGetValue(getValue FiledGetValue) *ModelOption

+ type ModelSelect struct

+ func (this_ *ModelSelect) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *ModelSelect) SelectAll() *ModelSelect

+ func (this_ *ModelSelect) SetWhere(where *Conditions) *ModelSelect

+ func (this_ *ModelSelect) Where() *Conditions

+ type ModelSetting struct

+ func (this_ *ModelSetting) EmptyExcludeColumn() *ModelSetting

+ func (this_ *ModelSetting) EmptyIncludeColumn() *ModelSetting

+ func (this_ *ModelSetting) EmptyUseNull() *ModelSetting

+ func (this_ *ModelSetting) ExcludeColumn(columns ...string) *ModelSetting

+ func (this_ *ModelSetting) GetModelAndWhereSql(b *OrmSqlBuilder, model any, where *Conditions) (whereSql string, whereArgs []any)

+ func (this_ *ModelSetting) GetPrimaryKey(model any) []string

+ func (this_ *ModelSetting) GetService() IService

+ func (this_ *ModelSetting) GetTableName(model any) string

+ func (this_ *ModelSetting) GetValue(columnValue *FieldValue) (isNull bool, res any)

+ func (this_ *ModelSetting) IncludeColumn(columns ...string) *ModelSetting

+ func (this_ *ModelSetting) IncludeEmpty() *ModelSetting

+ func (this_ *ModelSetting) IncludeNull() *ModelSetting

+ func (this_ *ModelSetting) IncludeZero() *ModelSetting

+ func (this_ *ModelSetting) Included(columnName string, columnValue *FieldValue) bool

+ func (this_ *ModelSetting) IsExcludeColumn(column string) bool

+ func (this_ *ModelSetting) IsIncludeColumn(column string) bool

+ func (this_ *ModelSetting) NewBuilder(model any) (res *OrmSqlBuilder)

+ func (this_ *ModelSetting) SetModelOption(modelOption *ModelOption) *ModelSetting

+ func (this_ *ModelSetting) SetPrimaryKey(columns ...string) *ModelSetting

+ func (this_ *ModelSetting) SetService(service *Service) *ModelSetting

+ func (this_ *ModelSetting) SetSqlHandler(sqlHandler SqlHandler) *ModelSetting

+ func (this_ *ModelSetting) SetTableName(tableName string) *ModelSetting

+ func (this_ *ModelSetting) WhereOperator(column string, op string) *ModelSetting

+ func (this_ *ModelSetting) ZeroUseNull() *ModelSetting

+ type ModelUpdate struct

+ func (this_ *ModelUpdate) Exec(ctx context.Context) (res sql.Result, err error)

+ func (this_ *ModelUpdate) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *ModelUpdate) SetWhere(where *Conditions) *ModelUpdate

+ func (this_ *ModelUpdate) UpdateAll() *ModelUpdate

+ func (this_ *ModelUpdate) Where() *Conditions

+ type Op string

+ const Custom

+ const Eq

+ const Gt

+ const Gte

+ const In

+ const IsNotNull

+ const IsNull

+ const Like

+ const Lt

+ const Lte

+ const Ne

+ const NotIn

+ const NotLike

+ type OrmSqlBuilder struct

+ func (this_ *OrmSqlBuilder) IsPrimaryKey(column string) bool

+ type ReadExpression struct

+ Expressions []SqlExpression

+ LastExpression SqlExpression

+ StartExpression SqlExpression

+ func (this_ *ReadExpression) Add(e SqlExpression)

+ func (this_ *ReadExpression) ReplaceLast(replaceIndex int, e SqlExpression)

+ type ReadScope struct

+ ArithmeticOperator bool

+ InDDL bool

+ InDelete bool

+ InExpression bool

+ InFrom bool

+ InGroupBy bool

+ InInsert bool

+ InInsertColumn bool

+ InInsertValue bool

+ InJoin bool

+ InJoinOn bool

+ InOrderBy bool

+ InSelect bool

+ InSelectColumn bool

+ InSelectFrom bool

+ InUpdate bool

+ InUpdateColumn bool

+ InValue bool

+ InWhere bool

+ LogicalOperator bool

+ RelationalOperator bool

+ type ReadState struct

+ type ReadText struct

+ type Schema struct

+ Cascade bool

+ DatabaseName string

+ Extend map[string]any

+ IfNotExists bool

+ IsSystem bool

+ Name string

+ func SchemaByMap(data map[string]any) (res *Schema)

+ type Sequence struct

+ DatabaseName string

+ Extend map[string]any

+ IfNotExists bool

+ Increment int64

+ Max int64

+ Min int64

+ Name string

+ SchemaName string

+ Start int64

+ func SequenceByMap(data map[string]any) (res *Sequence)

+ func (this_ *Sequence) GenName(handler DDLHandler, databaseName string, schemaName string, tableName string, ...) string

+ func (this_ *Sequence) Init(handler DDLHandler, databaseName string, schemaName string, tableName string, ...)

+ type Service struct

+ func New(cfg *Config, sqlConn SqlConn) (res *Service, err error)

+ func (this_ *Service) AddColumn(tableName string, column *Column) (err error)

+ func (this_ *Service) CheckColumnExist(tableName string, columnName string) (res bool)

+ func (this_ *Service) CheckIndexExist(tableName string, checkIndex *Index) (res bool)

+ func (this_ *Service) CheckTableExist(tableName string) (res bool)

+ func (this_ *Service) Close()

+ func (this_ *Service) CloseShowExecSql() *Service

+ func (this_ *Service) CloseShowQuerySql() *Service

+ func (this_ *Service) Count(ctx context.Context, model IModel) (res int64, err error)

+ func (this_ *Service) CreateIndex(tableName string, index *Index) (err error)

+ func (this_ *Service) CreateTable(table *Table) (err error)

+ func (this_ *Service) Delete(ctx context.Context, model IModel) (res sql.Result, err error)

+ func (this_ *Service) Exec(ctx context.Context, sqlInfo string, args []any) (res sql.Result, err error)

+ func (this_ *Service) Execs(ctx context.Context, sqlList []string, argsList [][]any) (results []sql.Result, err error)

+ func (this_ *Service) GetConfig() Config

+ func (this_ *Service) GetDDLHandler() (handler DDLHandler)

+ func (this_ *Service) GetDatabaseName() string

+ func (this_ *Service) GetDialect() Dialect

+ func (this_ *Service) GetModelOption() (modelOption *ModelOption)

+ func (this_ *Service) GetSchemaName() string

+ func (this_ *Service) GetSqlConn() SqlConn

+ func (this_ *Service) GetSqlHandler() (handler SqlHandler)

+ func (this_ *Service) GetSqlValue() GetSqlValueType

+ func (this_ *Service) Insert(ctx context.Context, model IModel) (res sql.Result, err error)

+ func (this_ *Service) ModelCount(model any) (res *ModelCount)

+ func (this_ *Service) ModelDelete(model any) (res *ModelDelete)

+ func (this_ *Service) ModelInsert(model any) (res *ModelInsert)

+ func (this_ *Service) ModelSelect(model any) (res *ModelSelect)

+ func (this_ *Service) ModelUpdate(model any) (res *ModelUpdate)

+ func (this_ *Service) OpenShowExecSql() *Service

+ func (this_ *Service) OpenShowQuerySql() *Service

+ func (this_ *Service) QueryCount(ctx context.Context, sqlInfo string, args []any) (count int64, err error)

+ func (this_ *Service) QueryMapList(ctx context.Context, sqlInfo string, args []any) (list []map[string]any, err error)

+ func (this_ *Service) QueryMapOne(ctx context.Context, sqlInfo string, args []any) (one map[string]any, err error)

+ func (this_ *Service) QueryMapPage(ctx context.Context, sqlInfo string, args []any, pageSize int64, pageNo int64) (list []map[string]any, err error)

+ func (this_ *Service) RealService(param *SqlParam, tableName string) IService

+ func (this_ *Service) RealTableName(param *SqlParam, tableName string) (realTableName string)

+ func (this_ *Service) SetDDLHandler(handler DDLHandler)

+ func (this_ *Service) SetDynamicService(dynamicService IDynamicService)

+ func (this_ *Service) SetFieldValue() SetFieldValueType

+ func (this_ *Service) SetGetSqlValue(getSqlValue GetSqlValueType)

+ func (this_ *Service) SetModelOption(modelOption *ModelOption)

+ func (this_ *Service) SetSetFieldValue(setFieldValue SetFieldValueType)

+ func (this_ *Service) SetSqlHandler(handler SqlHandler)

+ func (this_ *Service) ShowExecSql() bool

+ func (this_ *Service) ShowQuerySql() bool

+ func (this_ *Service) SqlCount(table string) (res *SqlCount)

+ func (this_ *Service) SqlDelete(table string) (res *SqlDelete)

+ func (this_ *Service) SqlInsert(table string) (res *SqlInsert)

+ func (this_ *Service) SqlSelect(table string, columns ...string) (res *SqlSelect)

+ func (this_ *Service) SqlUpdate(table string) (res *SqlUpdate)

+ func (this_ *Service) Update(ctx context.Context, model IModel) (res sql.Result, err error)

+ func (this_ *Service) WrapColumnName(param *SqlParam, columnName string) (wrapColumnName string)

+ func (this_ *Service) WrapTableName(param *SqlParam, tableName string) (wrapTableName string)

+ type SetFieldValueType func(columnType *sql.ColumnType, field reflect.StructField, ...) (err error)

+ type SqlBuilder struct

+ func (this_ *SqlBuilder) Append(s string, args ...any)

+ func (this_ *SqlBuilder) GetValue(e SqlExpression) (res any)

+ func (this_ *SqlBuilder) Test(test SqlExpression) (res bool)

+ type SqlConcatValue struct

+ Value any

+ Values []string

+ type SqlConfiguration struct

+ func NewSqlConfiguration(sets ...SqlConfigurationSet) (c *SqlConfiguration)

+ func (this_ *SqlConfiguration) GetSqlHandler() SqlHandler

+ func (this_ *SqlConfiguration) SetSqlHandler(sqlHandler SqlHandler) *SqlConfiguration

+ type SqlConfigurationSet func(c *SqlConfiguration)

+ type SqlConn interface

+ BeginTx func(ctx context.Context, opts *sql.TxOptions) (*sql.Tx, error)

+ ExecContext func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ PingContext func(ctx context.Context) error

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ QueryContext func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ QueryRowContext func(ctx context.Context, query string, args ...any) *sql.Row

+ type SqlCount struct

+ func (this_ *SqlCount) Count(ctx context.Context) (res int64, err error)

+ func (this_ *SqlCount) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *SqlCount) SetWhere(where *Conditions) *SqlCount

+ func (this_ *SqlCount) Where() *Conditions

+ type SqlDelete struct

+ func (this_ *SqlDelete) DeleteAll() *SqlDelete

+ func (this_ *SqlDelete) Exec(ctx context.Context) (res sql.Result, err error)

+ func (this_ *SqlDelete) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *SqlDelete) SetWhere(where *Conditions) *SqlDelete

+ func (this_ *SqlDelete) Where() *Conditions

+ type SqlExpression interface

+ GetValue func(b *SqlBuilder) (res any)

+ type SqlHandler interface

+ RealTableName func(param *SqlParam, tableName string) (realTableName string)

+ WrapColumnName func(param *SqlParam, columnName string) (wrapColumnName string)

+ WrapTableName func(param *SqlParam, tableName string) (wrapTableName string)

+ type SqlInsert struct

+ func (this_ *SqlInsert) Exec(ctx context.Context) (res sql.Result, err error)

+ func (this_ *SqlInsert) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *SqlInsert) Value(column string, value any) *SqlInsert

+ type SqlNode interface

+ Append func(b *SqlBuilder)

+ type SqlNodeArgParam struct

+ Param SqlExpression

+ func (this_ *SqlNodeArgParam) Append(b *SqlBuilder)

+ type SqlNodeArithmeticOperate struct

+ Left SqlExpression

+ Operator string

+ Right SqlExpression

+ func (this_ *SqlNodeArithmeticOperate) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeBlock struct

+ Children []SqlNode

+ func (this_ *SqlNodeBlock) Append(b *SqlBuilder)

+ type SqlNodeComment struct

+ Comment string

+ func (this_ *SqlNodeComment) Append(b *SqlBuilder)

+ type SqlNodeDDL struct

+ type SqlNodeDelete struct

+ type SqlNodeDotExpression struct

+ Left SqlExpression

+ Right SqlExpression

+ func (this_ *SqlNodeDotExpression) GetObjectField(b *SqlBuilder, object any) (res any)

+ func (this_ *SqlNodeDotExpression) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeElse struct

+ Children []SqlNode

+ type SqlNodeElseIf struct

+ Children []SqlNode

+ Test SqlExpression

+ type SqlNodeFloat struct

+ String string

+ Value float64

+ func ToSqlNodeFloat(str string) (res *SqlNodeFloat, err error)

+ func (this_ *SqlNodeFloat) Append(b *SqlBuilder)

+ func (this_ *SqlNodeFloat) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeIdentifier struct

+ Name string

+ func (this_ *SqlNodeIdentifier) GetObjectField(b *SqlBuilder, object any) (res any)

+ func (this_ *SqlNodeIdentifier) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeIf struct

+ Children []SqlNode

+ Else *SqlNodeElse

+ ElseIfs []*SqlNodeElseIf

+ Test SqlExpression

+ func (this_ *SqlNodeIf) Append(b *SqlBuilder)

+ type SqlNodeInsert struct

+ type SqlNodeInt struct

+ String string

+ Value int64

+ func ToSqlNodeInt(str string) (res *SqlNodeInt, err error)

+ func (this_ *SqlNodeInt) Append(b *SqlBuilder)

+ func (this_ *SqlNodeInt) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeLogicalOperate struct

+ Left SqlExpression

+ Operator string

+ Right SqlExpression

+ func (this_ *SqlNodeLogicalOperate) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeOptional struct

+ Children []SqlNode

+ func (this_ *SqlNodeOptional) Append(b *SqlBuilder)

+ type SqlNodeParam struct

+ Param SqlExpression

+ func (this_ *SqlNodeParam) Append(b *SqlBuilder)

+ type SqlNodeParenthesis struct

+ Expression SqlExpression

+ func (this_ *SqlNodeParenthesis) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeRelationalOperate struct

+ Left SqlExpression

+ Operator string

+ Right SqlExpression

+ func (this_ *SqlNodeRelationalOperate) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeSelect struct

+ type SqlNodeSql struct

+ IsDDL bool

+ IsDelete bool

+ IsInsert bool

+ IsOther bool

+ IsQuery bool

+ IsUpdate bool

+ Root SqlNode

+ func (this_ *SqlNodeSql) Append(b *SqlBuilder)

+ func (this_ *SqlNodeSql) GetSqlByMap(handler SqlHandler, data map[string]any) (sqlInfo string, args []any)

+ type SqlNodeString struct

+ Value string

+ func ToSqlNodeString(str string) (res *SqlNodeString)

+ func (this_ *SqlNodeString) Append(b *SqlBuilder)

+ func (this_ *SqlNodeString) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeTernary struct

+ Left SqlExpression

+ Right SqlExpression

+ Test SqlExpression

+ func (this_ *SqlNodeTernary) GetValue(b *SqlBuilder) (res any)

+ type SqlNodeText struct

+ Text string

+ func (this_ *SqlNodeText) Append(b *SqlBuilder)

+ type SqlNodeUpdate struct

+ type SqlOption struct

+ func NewSqlOption() (res *SqlOption)

+ func (this_ *SqlOption) RealTableName(param *SqlParam, tableName string) (realTableName string)

+ func (this_ *SqlOption) Set(fn func(o *SqlOption)) *SqlOption

+ func (this_ *SqlOption) WrapColumnName(param *SqlParam, columnName string) (wrapColumnName string)

+ func (this_ *SqlOption) WrapTableName(param *SqlParam, tableName string) (wrapTableName string)

+ type SqlParam struct

+ func NewMapSqlParam() (res *SqlParam)

+ func SqlParamByData(data any) (res *SqlParam)

+ func SqlParamByMap(data map[string]any) (res *SqlParam)

+ func SqlParamByValue(data any, value reflect.Value) (res *SqlParam)

+ func (this_ *SqlParam) FindParam(name string) (v any, find bool)

+ func (this_ *SqlParam) GetData() any

+ func (this_ *SqlParam) GetObjectField(obj any, name string) (res any)

+ func (this_ *SqlParam) GetParam(name string) (res any)

+ func (this_ *SqlParam) GetStringParam(name string) (res string)

+ func (this_ *SqlParam) Set(name string, value any) *SqlParam

+ type SqlParamParser struct

+ NotParseArg bool

+ ParamAfter string

+ ParamBefore string

+ func NewSqlParamParser(sqlInfo string, param any) (res *SqlParamParser)

+ func (this_ *SqlParamParser) Append(sql string, param any) *SqlParamParser

+ func (this_ *SqlParamParser) GetParamData(param any) (data map[string]any)

+ func (this_ *SqlParamParser) Parse() (res string, args []any, err error)

+ func (this_ *SqlParamParser) ParseInfo() (info *SqlParamParserInfo, err error)

+ type SqlParamParserInfo struct

+ Args []any

+ ParamNames []string

+ Sql string

+ type SqlReader struct

+ func NewSqlReader(str string) (r *SqlReader)

+ func (this_ *SqlReader) Next()

+ func (this_ *SqlReader) NextByCharEnd(endChar string, skipChar string)

+ func (this_ *SqlReader) NextHasChar()

+ func (this_ *SqlReader) NextLine() (res string)

+ func (this_ *SqlReader) Scan() (res string)

+ func (this_ *SqlReader) ScanMore(size int) (res []string)

+ type SqlSelect struct

+ func (this_ *SqlSelect) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *SqlSelect) Select(columns ...string) *SqlSelect

+ func (this_ *SqlSelect) SelectAll() *SqlSelect

+ func (this_ *SqlSelect) SetWhere(where *Conditions) *SqlSelect

+ func (this_ *SqlSelect) Where() *Conditions

+ type SqlTemplate struct

+ BracketOptional bool

+ Debug bool

+ SqlList []*SqlNodeSql

+ func NewSqlTemplate(sqlList ...string) (t *SqlTemplate)

+ func (this_ *SqlTemplate) Append(sqlList ...string) *SqlTemplate

+ func (this_ *SqlTemplate) GetSql(handler SqlHandler, param map[string]any) (sqlInfo string, sqlArgs []any)

+ func (this_ *SqlTemplate) GetSqlHandler() SqlHandler

+ func (this_ *SqlTemplate) GetSqlList(handler SqlHandler, param map[string]any) (sqlList []string, sqlArgsList [][]any)

+ func (this_ *SqlTemplate) GetTemplateSql() (str string)

+ func (this_ *SqlTemplate) Parse() (err error)

+ func (this_ *SqlTemplate) ParseSql(r *SqlReader) (res *SqlNodeSql, err error)

+ func (this_ *SqlTemplate) ParseSqlList(str string) (res []*SqlNodeSql, err error)

+ func (this_ *SqlTemplate) SetSqlHandler(sqlHandler SqlHandler) *SqlTemplate

+ type SqlUpdate struct

+ func (this_ *SqlUpdate) Exec(ctx context.Context) (res sql.Result, err error)

+ func (this_ *SqlUpdate) GetSql() (sqlInfo string, args []any, err error)

+ func (this_ *SqlUpdate) SetWhere(where *Conditions) *SqlUpdate

+ func (this_ *SqlUpdate) UpdateAll() *SqlUpdate

+ func (this_ *SqlUpdate) Value(column string, value any) *SqlUpdate

+ func (this_ *SqlUpdate) Where() *Conditions

+ type StringType interface

+ String func() string

+ type Table struct

+ AutoIncrement bool

+ AutoIncrementCreate bool

+ AutoIncrementName string

+ AutoIncrementStart int64

+ ColumnList []*Column

+ Comment string

+ ConstraintList []*Constraint

+ DatabaseName string

+ Extend map[string]any

+ IfNotExists bool

+ IndexList []*Index

+ Name string

+ SchemaName string

+ func TableByMap(data map[string]any) (res *Table)

+ func (this_ *Table) FindColumn(name string) (res *Column)

+ func (this_ *Table) Init(databaseName string, schemaName string, handler DDLHandler)

+ type User struct

+ Extend map[string]any

+ IsSystem bool

+ Name string

+ Password string

+ func UserByMap(data map[string]any) (res *User)

+ type WhereOperator struct

+ Column string

+ Operator string

+ type WrapOption struct

+ WrapColumnNameOpen *bool

+ WrapNameChar *string

+ WrapNameOpen *bool

+ WrapStringChar *string

+ WrapTableNameOpen *bool

+ func (this_ WrapOption) IsWrapColumnName() bool

+ func (this_ WrapOption) IsWrapName() bool

+ func (this_ WrapOption) IsWrapTableName() bool

+ func (this_ WrapOption) Names(names []string) (res string)

+ func (this_ WrapOption) Set(fn func(o WrapOption)) WrapOption

+ func (this_ WrapOption) WrapColumnName(name string) string

+ func (this_ WrapOption) WrapName(name string) (res string)

+ func (this_ WrapOption) WrapNames(names []string) (res string)

+ func (this_ WrapOption) WrapString(str string) (res string)

+ func (this_ WrapOption) WrapTableName(name string) string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL