orm

Jun 11, 2023

Changes in this version

type ORM

+ func (orm *ORM) Logger(logger log.Log)

May 19, 2023

Changes in this version

type ORM

+ func (orm *ORM) GetBaseExecutor() (conn db.BaseExecutor, isTx bool)

+ func (orm *ORM) GetExecutor() db.Executor

+ func (orm *ORM) GetTx() db.Tx

Apr 17, 2023

Changes in this version

+ var ErrFetchType = errors.New("[fetch]: datatype is not a pointer, int string map struct is required")

type ORM

+ func (orm *ORM) FetchData(dataType interface{}, flat bool, fetch func(row interface{}) bool) (err error)

Apr 14, 2023

Changes in this version

+ func CloseVerify()

Apr 14, 2023

Changes in this version

+ var ErrParams = errors.New("when \"flat=false\", the value of the map can only be interface{}")

type Reference

+ func (c *Reference) GetTableCacheByPath(tablePath string) *tableStructData

+ func (c *Reference) GetTableCacheByTp(tableTp reflect.Type) *tableStructData

Apr 13, 2023

Changes in this version

+ var ErrMapKeyType = errors.New("map's key type must be \"String\"")

Apr 13, 2023

Changes in this version

+ var ErrTooFewColumn = errors.New("too few columns")

+ var ErrTooManyColumn = errors.New("too many columns")

Apr 12, 2023

Changes in this version

type ORM

+ func (orm *ORM) SetDefLimit(n uint) *ORM

Apr 6, 2023

Changes in this version

+ var ErrBetweenValueMatch = errors.New("[between]: the parameter array length is required to be 2")

+ var ErrCustomSQL = errors.New("custom sql does not allow this operation")

+ var ErrDBFunc = errors.New("this method is not currently supported in the current database")

+ var ErrDBType = errors.New("the current database type is not currently supported")

+ func InitNotReadyLastInsertID(db ...int)

type BaseQuery

+ CustomSQL string

+ PrivateKey string

type ORM

+ func (orm *ORM) CustomSQL(sql string) *ORM

+ func (orm *ORM) ExecuteSQL(customSQL string) (affectedRow int64, err error)

+ func (orm *ORM) OracleMergeUnionAll(all bool) *ORM

+ func (orm *ORM) SQLServerExcludePK(exclude bool) *ORM

+ func (orm *ORM) UniqueKeys(uniqueKey ...string) *ORM

type Reference

+ func (c *Reference) GetDBType() int

Mar 7, 2023

Changes in this version

type ORM

+ func (orm *ORM) Exist() (bool, error)

Jan 26, 2023

Changes in this version

+ var ErrClient = fmt.Errorf("db and tx are all nil")

+ var ErrTargetNotSettable = errors.New("[scanner]: target is not settable! a pointer is required")

+ func SetGlobalVerify(v Verify)

+ func SimpleCount()

+ func SimpleDeleteByWhere()

+ func SimpleInsertMany()

+ func SimpleInsertManySameClos()

+ func SimpleInsertOne()

+ func SimpleInsertOne2()

+ func SimpleReplaceMany()

+ func SimpleReplaceManySameClos()

+ func SimpleReplaceOne()

+ func SimpleToData()

+ func SimpleToData2()

+ func SimpleUpdateByWhere()

+ func SimpleUpdateMany()

+ func SimpleUpsertManySameClos()

+ func SimpleUpsertOne()

+ func Struct2Map(raw interface{}, excludeKey ...string) map[string]interface

+ func TestTransSession()

+ func TransSession(ctx context.Context, db *DB, f func(ctx context.Context, tx *Tx) error) (err error)

+ type BaseQuery struct

+ Distinct bool

+ GroupBy GroupBy

+ Having Having

+ Limit Limit

+ Order Order

+ RefConf *Reference

+ Select Select

+ SelectColLinkStr string

+ SelectForUpdate bool

+ SelectRaw bool

+ TableName string

+ Where Where

+ func (q *BaseQuery) Count() string

+ func (q *BaseQuery) GetWhere() string

+ func (q *BaseQuery) SQL() string

+ type Client struct

+ func NewClient(cfg *Config) *Client

+ func (c *Client) Connect() (*DB, error)

+ type Config struct

+ ConnMaxIdleTime int

+ ConnMaxLifeTime int

+ DBDriver string

+ DBName string

+ DSNParams string

+ Host string

+ MaxIdleConn int

+ MaxOpenConn int

+ Password string

+ Port int

+ Username string

+ type DB = sql.DB

+ func GetMySQL() *DB

+ type GroupBy = []string

+ type Having = map[string]interface

+ type Limit = []uint

+ type ORM struct

+ Q *mysqlQuery

+ func NewORM(ctx context.Context, tableName string, db *DB, ref *Reference) *ORM

+ func NewORMWithTx(ctx context.Context, tableName string, tx *Tx, ref *Reference) *ORM

+ func (orm *ORM) ClearCache() *ORM

+ func (orm *ORM) Clone() *ORM

+ func (orm *ORM) Count(clearCache bool) (int64, error)

+ func (orm *ORM) DeleteByWhere(where map[string]interface{}) (affected int64, err error)

+ func (orm *ORM) Distinct(b bool) *ORM

+ func (orm *ORM) GroupBy(cols ...string) *ORM

+ func (orm *ORM) Having(col string, value interface{}) *ORM

+ func (orm *ORM) HavingSome(where Having) *ORM

+ func (orm *ORM) InsertMany(data []interface{}, trans bool) (affected int64, insertIds []int64, err error)

+ func (orm *ORM) InsertManySameClos(data []interface{}, cols []string, batchSize int, trans bool) (affected int64, err error)

+ func (orm *ORM) InsertOne(data interface{}) (insertID int64, err error)

+ func (orm *ORM) KeepQuery(b bool) *ORM

+ func (orm *ORM) Limit(size uint) *ORM

+ func (orm *ORM) Order(cols ...string) *ORM

+ func (orm *ORM) OverLimit(over, size uint) *ORM

+ func (orm *ORM) Page(pageNo, pageSize uint) *ORM

+ func (orm *ORM) PageData(result interface{}, flat bool, pageNo, pageSize uint) (*Paging, error)

+ func (orm *ORM) PrimaryKey(k string) *ORM

+ func (orm *ORM) Query(pair ...interface{}) *ORM

+ func (orm *ORM) ReplaceMany(data []interface{}, trans bool) (affected int64, insertIds []int64, err error)

+ func (orm *ORM) ReplaceManySameClos(data []interface{}, cols []string, batchSize int, trans bool) (affected int64, err error)

+ func (orm *ORM) ReplaceOne(data interface{}) (affected int64, err error)

+ func (orm *ORM) SaveMany(data []interface{}, trans bool) (affected int64, err error)

+ func (orm *ORM) Select(cols ...string) *ORM

+ func (orm *ORM) SelectColLinkStr(s string) *ORM

+ func (orm *ORM) SelectForUpdate(b bool) *ORM

+ func (orm *ORM) ToData(result interface{}, flat bool) error

+ func (orm *ORM) ToSQL(flat bool) string

+ func (orm *ORM) UpdateByWhere(update map[string]interface{}, where Where) (affected int64, err error)

+ func (orm *ORM) UpdateMany(data []interface{}, trans bool) (affected int64, err error)

+ func (orm *ORM) UpdateOne(data interface{}) (affected int64, err error)

+ func (orm *ORM) UpsertMany(data []interface{}, trans bool) (affected int64, insertIDs []int64, err error)

+ func (orm *ORM) UpsertManySameClos(data []interface{}, cols []string, batchSize int, trans bool) (affected int64, err error)

+ func (orm *ORM) UpsertOne(data interface{}) (insertID int64, err error)

+ func (orm *ORM) Where(col string, value interface{}) *ORM

+ func (orm *ORM) Wheres(where Where) *ORM

+ type Order = []string

+ type Paging struct

+ PageNo int

+ PageSize int

+ PageTotal int

+ Total int

+ type Reference struct

+ func NewReference() *Reference

+ func (c *Reference) AddTableDef(table string, def interface{})

+ func (c *Reference) BuildRefs()

+ func (c *Reference) GetTableDef(table string) []string

+ type Select = []string

+ type Tb1 struct

+ ID int64

+ JSON []int

+ Name string

+ Ref int64

+ Tb *Tb2

+ type Tb2 struct

+ ID int64

+ Name string

+ Tb *Tb3

+ type Tb3 struct

+ ID int64

+ Name string

+ Tb *Tb1

+ type Tx = sql.Tx

+ type Verify interface

+ VerifyFieldName func(name string) error

+ VerifyTableName func(name string) error

+ VerifyTagName func(name string) error

+ type Where = map[string]interface