define

Mar 19, 2025

Changes in this version

+ type NullRawBytes struct

+ RawBytes []byte

+ Valid bool

+ func (n *NullRawBytes) Scan(value interface{}) error

+ func (n NullRawBytes) Value() (interface{}, error)

Feb 28, 2025

Changes in this version

type Condition

+ IsRawExpr bool

+ func Raw(expr string, args ...interface{}) *Condition

Feb 18, 2025

Changes in this version

+ const ErrEncryptionAlgorithm

+ const ErrEncryptionConfig

+ const ErrKeySource

+ type DBError struct

+ Code int

+ Err error

+ Message string

+ Op string

+ func (e *DBError) Error() string

+ type ExecuteType string

+ const Exec

+ const Query

+ type SqlProto struct

+ Args []any

+ Error error

+ Sql string

+ SqlType ExecuteType

Feb 15, 2025

Changes in this version

+ func StructToMapWithZero(obj interface{}) (map[string]interface{}, error)

type DataRow

+ func (r *DataRow) GetBoolOrDefault(name string, defaultValue bool) bool

+ func (r *DataRow) GetBytes(name string) ([]byte, error)

+ func (r *DataRow) GetBytesOrDefault(name string, defaultValue []byte) []byte

+ func (r *DataRow) GetFloat64OrDefault(name string, defaultValue float64) float64

+ func (r *DataRow) GetInt64OrDefault(name string, defaultValue int64) int64

+ func (r *DataRow) GetIntOrDefault(name string, defaultValue int) int

+ func (r *DataRow) GetMap(name string) (map[string]interface{}, error)

+ func (r *DataRow) GetMapOrDefault(name string, defaultValue map[string]interface{}) map[string]interface{}

+ func (r *DataRow) GetNullBool(name string) (sql.NullBool, error)

+ func (r *DataRow) GetNullFloat64(name string) (sql.NullFloat64, error)

+ func (r *DataRow) GetNullInt64(name string) (sql.NullInt64, error)

+ func (r *DataRow) GetNullString(name string) (sql.NullString, error)

+ func (r *DataRow) GetNullTime(name string) (sql.NullTime, error)

+ func (r *DataRow) GetSlice(name string) ([]interface{}, error)

+ func (r *DataRow) GetSliceOrDefault(name string, defaultValue []interface{}) []interface{}

+ func (r *DataRow) GetStringOrDefault(name string, defaultValue string) string

+ func (r *DataRow) GetTimeOrDefault(name string, defaultValue time.Time) time.Time

type TableInfo

+ HasTime bool

type Transfer

+ func (t *Transfer) GetFieldTag(fieldName string) string

Feb 10, 2025

Changes in this version

type TableStruct

+ ColToFieldMap map[string]string

Feb 10, 2025

Changes in this version

+ func ConvertRowToStruct(data map[string]interface{}, structValue reflect.Value) error

type ColumnInfo

+ DataType reflect.Type

+ TypeName string

+ type DataRow struct

+ func (r *DataRow) GetBool(name string) bool

+ func (r *DataRow) GetDataMap() map[string]any

+ func (r *DataRow) GetFloat64(name string) float64

+ func (r *DataRow) GetInt(name string) int

+ func (r *DataRow) GetInt64(name string) int64

+ func (r *DataRow) GetString(name string) string

+ func (r *DataRow) GetTime(name string) time.Time

type Result

+ func (r *Result) GetFirstRow() (*DataRow, error)

+ func (r *Result) GetRow(index int) (*DataRow, error)

Feb 8, 2025

Changes in this version

+ func GetFieldToColMap(i any, tableInfo *TableInfo) (map[string]string, error)

+ type TableStruct struct

+ FieldToColMap map[string]string

Jan 23, 2025

Changes in this version

+ type Column struct

+ ColumnName string

+ ColumnType string

+ Comment string

+ Primary bool

+ PrimaryAuto bool

type MockSQLFactory

+ func (f *MockSQLFactory) GetColumns(tableName string, db *sql.DB) ([]Column, error)

type SQLFactory

+ GetColumns func(tableName string, db *sql.DB) ([]Column, error)

Jan 22, 2025

Changes in this version

+ func GetDefaultsColumnFieldMap(rawType reflect.Type) (map[string]FieldInfo, []string)

+ func Md5Text(str string) string

+ func ScannerResultToStruct(rawMeta RawMetaInfo, index int64, scanners []interface{}, columnNames []string) reflect.Value

+ type ConnectionConfig struct

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ MaxIdleConns int

+ MaxOpenConns int

+ type ConnectionPool interface

+ Close func() error

+ GetConnection func() (*sql.DB, error)

+ HealthCheck func() error

+ ReturnConnection func(*sql.DB)

+ type ReplicationConfig struct

+ Master *ConnectionConfig

+ Slaves []*ConnectionConfig

+ type RetryConfig struct

+ MaxDelay time.Duration

+ MaxRetries int

+ RetryDelay time.Duration

Jan 11, 2025

Changes in this version

+ var CommonValidators = map[string]ValidationRule

+ func IsErrorCode(err error, code ErrorCode) bool

+ func RecoverHandler(handler func(interface{}) error) func()

+ type ConversionError struct

+ From string

+ Message string

+ To string

+ Value interface{}

+ func (e *ConversionError) Error() string

+ type EnhancedError struct

+ Cause error

+ Code ErrorCode

+ Context ErrorContext

+ Message string

+ Severity ErrorSeverity

+ func NewError(code ErrorCode, message string, severity ErrorSeverity, cause error) *EnhancedError

+ func (e *EnhancedError) Error() string

+ func (e *EnhancedError) WithData(key string, value interface{}) *EnhancedError

+ type ErrorCode string

+ const ErrConfiguration

+ const ErrDatabaseConnection

+ const ErrDatabaseExec

+ const ErrDatabaseQuery

+ const ErrDatabaseTx

+ const ErrDecryption

+ const ErrEncryption

+ const ErrEnvironment

+ const ErrIO

+ const ErrInternal

+ const ErrInvalidFormat

+ const ErrInvalidInput

+ const ErrInvalidType

+ const ErrKeyManagement

+ const ErrRequired

+ const ErrTimeout

+ const ErrUnauthorized

+ const ErrUniqueConstraint

+ const ErrValidation

+ type ErrorContext struct

+ Data map[string]interface{}

+ Stack []StackTrace

+ Timestamp time.Time

+ func GetErrorContext(err error) *ErrorContext

+ type ErrorHandler struct

+ func NewErrorHandler() *ErrorHandler

+ func (h *ErrorHandler) Handle(err error) error

+ func (h *ErrorHandler) RegisterHandler(code ErrorCode, handler func(*EnhancedError) error)

+ type ErrorLogger struct

+ func NewErrorLogger(minSeverity ErrorSeverity, logFunc func(error)) *ErrorLogger

+ func (l *ErrorLogger) Log(err error)

+ type ErrorRetrier struct

+ func NewErrorRetrier(maxAttempts int, backoff time.Duration) *ErrorRetrier

+ func (r *ErrorRetrier) Retry(operation func() error) error

+ type ErrorSeverity int

+ const SeverityCritical

+ const SeverityDebug

+ const SeverityError

+ const SeverityInfo

+ const SeverityWarning

+ type ITypeConverter interface

+ Convert func(value interface{}, targetType reflect.Type) (interface{}, error)

+ func NewTypeConverter() ITypeConverter

+ type StackTrace struct

+ File string

+ Function string

+ Line int

+ type ValidationContext struct

+ FieldName string

+ Parent interface{}

+ Rules []ValidationRule

+ Value interface{}

+ type ValidationError struct

+ Field string

+ Message string

+ Rule string

+ func (e *ValidationError) Error() string

+ type ValidationManager struct

+ func NewValidationManager() *ValidationManager

+ func (vm *ValidationManager) AddCustomRule(field string, validate func(value interface{}) error, message string)

+ func (vm *ValidationManager) AddRule(field string, rule ValidationRule)

+ func (vm *ValidationManager) CrossFieldValidation(s interface{}, rules map[string]func(fields map[string]interface{}) error) []error

+ func (vm *ValidationManager) ValidateField(field string, value interface{}) error

+ func (vm *ValidationManager) ValidateStruct(s interface{}) []error

+ type ValidationRule struct

+ Message string

+ Name string

+ Parameters map[string]interface{}

+ Validate func(value interface{}) error

+ type Validator interface

+ Validate func(ctx *ValidationContext) error

Jan 11, 2025

Changes in this version

+ var ErrEmptyTableName = errors.New("empty table name")

+ func ConvertValue(value interface{}, targetType reflect.Type) (interface{}, error)

+ func GetFieldMap(obj interface{}) map[string]interface

+ type MockSQLFactory struct

+ func (f *MockSQLFactory) BuildBatchInsert(table string, values []map[string]interface{}) (string, []interface{})

+ func (f *MockSQLFactory) BuildCreateTable(table string, modelType reflect.Type) string

+ func (f *MockSQLFactory) BuildDelete(table string, conditions []*Condition) (string, []interface{})

+ func (f *MockSQLFactory) BuildInsert(table string, fields map[string]interface{}, fieldOrder []string) (string, []interface{})

+ func (f *MockSQLFactory) BuildOrderBy(orders []OrderBy) string

+ func (f *MockSQLFactory) BuildRawQuery(query string, args []interface{}) (*SQLQuery, error)

+ func (f *MockSQLFactory) BuildSelect(table string, fields []string, conditions []*Condition, orderBy string, ...) (string, []interface{})

+ func (f *MockSQLFactory) BuildUpdate(table string, fields map[string]interface{}, fieldOrder []string, ...) (string, []interface{})

+ func (f *MockSQLFactory) Connect(dsn string) (*sql.DB, error)

+ func (f *MockSQLFactory) GetTableInfo(db *sql.DB, tableName string) (*TableInfo, error)

+ func (f *MockSQLFactory) GetTables(db *sql.DB, pattern string) ([]string, error)

+ func (f *MockSQLFactory) GetType() string

type OrderType

+ func (o OrderType) String() string

type Result

+ func (r *Result) Scan(rows *sql.Rows) error

+ type SQLQuery struct

+ Args []interface{}

+ Query string

type Transfer

+ func (t *Transfer) First(rows *sql.Rows) (interface{}, error)

+ func (t *Transfer) Result(rows *sql.Rows) (interface{}, error)

+ func (t *Transfer) ScanRows(rows *sql.Rows) (interface{}, error)

Jan 9, 2025

Changes in this version

+ type TypeConverter interface

+ FromDB func(value interface{}) error

+ ToDB func() (interface{}, error)

Jan 9, 2025

Changes in this version

+ func ClearCache()

+ func StructToMap(model interface{}) map[string]interface

+ type FieldInfo struct

+ Column string

+ HasDefault bool

+ Index int

+ IsAuto bool

+ IsPrimary bool

+ Name string

+ Type reflect.Type

+ type ScannerInfo struct

+ Convert func(interface{}) interface{}

+ Index int

+ Scanner interface{}

+ type Transfer struct

+ FieldOrder []string

+ Fields map[string]*FieldInfo

+ PrimaryKey *FieldInfo

+ TableName string

+ func GetTransfer(model interface{}) *Transfer

+ func (t *Transfer) CreateScanners(columns []string) []interface{}

+ func (t *Transfer) GetFieldNames() []string

+ func (t *Transfer) GetPrimaryKeyValue(model interface{}) (interface{}, error)

+ func (t *Transfer) GetTableName() string

+ func (t *Transfer) ScanAll(rows *sql.Rows) (interface{}, error)

+ func (t *Transfer) ScanRow(rows *sql.Rows, columns []string) (interface{}, error)

+ func (t *Transfer) SetModel(model interface{})

+ func (t *Transfer) ToMap(model interface{}) map[string]interface{}

Jan 8, 2025

Changes in this version

type Result

+ func (r *Result) FromJSON(jsonStr string) error

+ func (r *Result) IntoMap() (map[string]interface{}, error)

+ func (r *Result) IntoMaps() ([]map[string]interface{}, error)

+ func (r *Result) ToJSON() (string, error)

Jan 8, 2025

Changes in this version

type Result

+ Columns []string

+ Data []map[string]any

+ func (r *Result) Empty() bool

+ func (r *Result) First() *Result

+ func (r *Result) Into(dest interface{}) error

+ func (r *Result) Size() int

Jan 7, 2025

Changes in this version

type Condition

+ JoinType JoinType

+ type Conditions []Condition

+ type IsolationLevel sql.IsolationLevel

+ const LevelDefault

+ const LevelLinearizable

+ const LevelReadCommitted

+ const LevelReadUncommitted

+ const LevelRepeatableRead

+ const LevelSerializable

+ const LevelSnapshot

+ const LevelWriteCommitted

+ type LockType int

+ const LockForShare

+ const LockForUpdate

+ const LockNone

type SQLFactory

+ GetType func() string

+ type Transaction struct

+ func NewTransaction(db interface{}, tx interface{}, driver string) *Transaction

+ func (t *Transaction) GetDB() interface{}

+ func (t *Transaction) GetDriver() string

+ func (t *Transaction) GetTx() interface{}

+ type TransactionFunc func(tx *Transaction) Result

+ type TransactionOptions struct

+ IsolationLevel IsolationLevel

+ PropagationMode TransactionPropagation

+ ReadOnly bool

+ Timeout time.Duration

+ type TransactionPropagation int

+ const PropagationMandatory

+ const PropagationNested

+ const PropagationNever

+ const PropagationNotSupported

+ const PropagationRequired

+ const PropagationRequiresNew

+ const PropagationSupports

Jan 6, 2025

Changes in this version

+ const Version

+ const VersionInfo

+ type BatchOptions struct

+ BatchSize int

+ Concurrency int

+ RetryCount int

+ RetryInterval time.Duration

+ Timeout time.Duration

+ func DefaultBatchOptions() BatchOptions

+ func (o *BatchOptions) Validate() error

+ type DBOptions struct

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ Debug bool

+ MaxIdleConns int

+ MaxOpenConns int

+ func DefaultDBOptions() DBOptions

+ func (o *DBOptions) Validate() error

Jan 3, 2025

Changes in this version

+ var ErrManualRollback = errors.New("manual rollback")

type Condition

+ IsSubGroup bool

+ Join JoinType

+ SubConds []*Condition

+ func Between(field string, start, end interface{}) *Condition

+ func Eq(field string, value interface{}) *Condition

+ func Ge(field string, value interface{}) *Condition

+ func Gt(field string, value interface{}) *Condition

+ func In(field string, values ...interface{}) *Condition

+ func IsNotNull(field string) *Condition

+ func IsNull(field string) *Condition

+ func Le(field string, value interface{}) *Condition

+ func Like(field string, value interface{}) *Condition

+ func Lt(field string, value interface{}) *Condition

+ func Ne(field string, value interface{}) *Condition

+ func NewCondition(field string, op OpType, value interface{}) *Condition

+ func NotBetween(field string, start, end interface{}) *Condition

+ func NotIn(field string, values ...interface{}) *Condition

+ func NotLike(field string, value interface{}) *Condition

+ func (c *Condition) And(cond *Condition) *Condition

+ func (c *Condition) Or(cond *Condition) *Condition

+ type JoinType int

+ const JoinAnd

+ const JoinOr

+ type OpType int

+ const OpBetween

+ const OpCustom

+ const OpEq

+ const OpGe

+ const OpGt

+ const OpIn

+ const OpIsNotNull

+ const OpIsNull

+ const OpLe

+ const OpLike

+ const OpLt

+ const OpNe

+ const OpNotBetween

+ const OpNotIn

+ const OpNotLike

+ type OrderBy struct

+ Field string

+ Type OrderType

+ type OrderType int

+ const OrderAsc

+ const OrderDesc

type Result

+ Error error

type SQLFactory

+ BuildOrderBy func(orders []OrderBy) string

Dec 26, 2024

Changes in this version

+ var Debug bool

+ func RegisterFactory(driver string, factory SQLFactory)

+ func UnregisterFactory(driver string)

+ type ColumnInfo struct

+ Comment string

+ DefaultValue string

+ IsAutoIncrement bool

+ IsNullable bool

+ IsPrimaryKey bool

+ Length int64

+ Name string

+ Precision int

+ Scale int

+ Type string

+ type Condition struct

+ Field string

+ Op string

+ Value interface{}

+ type ITableModel interface

+ CreateSql func() string

+ TableName func() string

+ type Result struct

+ Affected int64

+ ID int64

+ func (r *Result) LastInsertId() (int64, error)

+ func (r *Result) RowsAffected() (int64, error)

+ type SQLFactory interface

+ BuildBatchInsert func(table string, values []map[string]interface{}) (string, []interface{})

+ BuildCreateTable func(table string, modelType reflect.Type) string

+ BuildDelete func(table string, conditions []*Condition) (string, []interface{})

+ BuildInsert func(table string, fields map[string]interface{}) (string, []interface{})

+ BuildSelect func(table string, fields []string, conditions []*Condition, orderBy string, ...) (string, []interface{})

+ BuildUpdate func(table string, fields map[string]interface{}, conditions []*Condition) (string, []interface{})

+ Connect func(dsn string) (*sql.DB, error)

+ GetTableInfo func(db *sql.DB, tableName string) (*TableInfo, error)

+ GetTables func(db *sql.DB, pattern string) ([]string, error)

+ func GetFactory(driver string) (SQLFactory, error)

+ type TableInfo struct

+ Columns []ColumnInfo

+ HasDecimal bool

+ HasIP bool

+ HasUUID bool

+ PrimaryKeys []string

+ TableComment string

+ TableName string