Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

dbs

package

Go to main page

Versions in this module

v0

v0.1.8

May 10, 2024

v0.1.7

May 6, 2024

Changes in this version

type DB

+ func (db *DB) RetrieveFirstByArgs(dataModel interface{}, where string, args []interface{}) error

+ func (db *DB) RetrieveFirstByFind(whereModel interface{}) error

+ func (db *DB) RetrieveFirstById(whereModel interface{}) error

+ func (db *DB) RetrieveFirstByMap(dataModel interface{}, whereMap map[string]interface{}) error

+ func (db *DB) RetrieveLastByArgs(dataModel interface{}, where string, args []interface{}) error

+ func (db *DB) RetrieveLastByFind(whereModel interface{}) error

+ func (db *DB) RetrieveLastById(whereModel interface{}) error

+ func (db *DB) RetrieveLastByMap(dataModel interface{}, whereMap map[string]interface{}) error

+ func (db *DB) RetrieveOrderInByModel(pageSize, pageNo int, whereModel interface{}, orderKey string, ...) (interface{}, int64, error)

+ func (db *DB) RetrieveOrderInByModelBytes(pageSize, pageNo int, whereModel interface{}, orderKey string, ...) ([]byte, int64, error)

+ func (db *DB) RetrieveOrderInByModelSelect(pageSize, pageNo int, whereModel interface{}, fields []string, orderKey string, ...) (interface{}, int64, error)

+ func (db *DB) RetrieveOrderInByModelSelectBytes(pageSize, pageNo int, whereModel interface{}, fields []string, orderKey string, ...) ([]byte, int64, error)

+ func (db *DB) RetrieveOrderInByModelSelectString(pageSize, pageNo int, whereModel interface{}, fields []string, orderKey string, ...) (string, int64, error)

+ func (db *DB) RetrieveOrderInByModelString(pageSize, pageNo int, whereModel interface{}, orderKey string, ...) (string, int64, error)

+ func (db *DB) RetrieveOrderInByWhere(pageSize, pageNo int, dataModel interface{}, where string, args []interface{}, ...) (interface{}, int64, error)

+ func (db *DB) RetrieveOrderInByWhereBytes(pageSize, pageNo int, dataModel interface{}, where string, args []interface{}, ...) ([]byte, int64, error)

+ func (db *DB) RetrieveOrderInByWhereSelect(pageSize, pageNo int, dataModel interface{}, fields []string, where string, ...) (interface{}, int64, error)

+ func (db *DB) RetrieveOrderInByWhereSelectBytes(pageSize, pageNo int, dataModel interface{}, fields []string, where string, ...) ([]byte, int64, error)

+ func (db *DB) RetrieveOrderInByWhereSelectString(pageSize, pageNo int, dataModel interface{}, fields []string, where string, ...) (string, int64, error)

+ func (db *DB) RetrieveOrderInByWhereString(pageSize, pageNo int, dataModel interface{}, where string, args []interface{}, ...) (string, int64, error)

v0.1.6

Jan 9, 2024

Changes in this version

type DB

+ func OpenDBClickhouseCluster(dsns []string, dryRun bool, maxConn, idleConn uint64) *DB

+ func OpenDBMySQLCluster(dsns []string, dryRun bool, maxConn, idleConn uint64) *DB

+ func OpenDBPostgreSQLCluster(dsns []string, dryRun bool, maxConn, idleConn uint64) *DB

+ func OpenDBSQLServerCluster(dsns []string, dryRun bool, maxConn, idleConn uint64) *DB

+ func OpenDBSQLiteCluster(fileNames []string, dryRun bool, maxConn, idleConn uint64, customConn string) *DB

+ func OpenDBTiDBCluster(dsns []string, dryRun bool, maxConn, idleConn uint64) *DB

v0.1.5

Sep 21, 2023

Changes in this version

+ var DefaultIdleConn uint64 = 20

+ var DefaultLimit = 10

+ var DefaultMaxConn uint64 = 2000

+ var DefaultMaxLimit = 1000

+ func HandleFunc(handler func(tx *TX) error) func(db *gorm.DB) error

+ func Rows2Bytes(rows *sql.Rows) []byte

+ func Rows2Map(rows *sql.Rows) []map[string]interface

+ type BaseModel struct

+ CreatedAt time.Time

+ DeletedAt *time.Time

+ Id uint64

+ IsDel uint64

+ Remark string

+ UpdatedAt time.Time

+ func (m *BaseModel) AfterCreate(fc func(tx *TX) error, db *DB) error

+ func (m *BaseModel) AfterDelete(fc func(tx *TX) error, db *DB) error

+ func (m *BaseModel) AfterSave(fc func(tx *TX) error, db *DB) error

+ func (m *BaseModel) AfterUpdate(fc func(tx *TX) error, db *DB) error

+ func (m *BaseModel) BeforeCreate(fc func(tx *TX) error, db *DB) error

+ func (m *BaseModel) BeforeDelete(fc func(tx *TX) error, db *DB) error

+ func (m *BaseModel) BeforeSave(fc func(tx *TX) error, db *DB) error

+ func (m *BaseModel) BeforeUpdate(fc func(tx *TX) error, db *DB) error

+ func (m *BaseModel) TableName() string

+ type DB struct

+ func OpenDBClickhouse(username, password, ip string, port uint64, dbName string, dryRun bool, ...) *DB

+ func OpenDBMySQL(username, password, ip string, port uint64, dbName string, dryRun bool, ...) *DB

+ func OpenDBPostgreSQL(username, password, ip string, port uint64, dbName string, dryRun bool, ...) *DB

+ func OpenDBSQLServer(username, password, ip string, port uint64, dbName string, dryRun bool, ...) *DB

+ func OpenDBSQLite(fileName string, dryRun bool, maxConn, idleConn uint64, customConn string) *DB

+ func OpenDBTiDB(username, password, ip string, port uint64, dbName string, dryRun bool, ...) *DB

+ func (db *DB) Create(dataModel interface{}) error

+ func (db *DB) CreateBatch(dataModels interface{}, batchSize uint) error

+ func (db *DB) DeleteHardById(dataModels interface{}) error

+ func (db *DB) DeleteHardByWhere(dataModel interface{}, where string, args []interface{}) error

+ func (db *DB) DeleteSoftById(dataModels interface{}) error

+ func (db *DB) DeleteSoftByWhere(dataModel interface{}, where string, args []interface{}) error

+ func (db *DB) Exec(sql string, values ...interface{}) error

+ func (db *DB) InitDefaultData(basePath string)

+ func (db *DB) Migration(models []interface{})

+ func (db *DB) RawSqlForByte(sql string, values ...interface{}) ([]byte, error)

+ func (db *DB) RawSqlForMap(sql string, values ...interface{}) ([]map[string]interface{}, error)

+ func (db *DB) RetrieveByArgs(dataModel interface{}, where string, args []interface{}) error

+ func (db *DB) RetrieveByFind(whereModel interface{}) error

+ func (db *DB) RetrieveById(whereModel interface{}) error

+ func (db *DB) RetrieveByMap(dataModel interface{}, whereMap map[string]interface{}) error

+ func (db *DB) RetrieveByModel(pageSize, pageNo int, whereModel interface{}, order string) (interface{}, int64, error)

+ func (db *DB) RetrieveByModelBytes(pageSize, pageNo int, whereModel interface{}, order string) ([]byte, int64, error)

+ func (db *DB) RetrieveByModelSelect(pageSize, pageNo int, whereModel interface{}, fields []string, order string) (interface{}, int64, error)

+ func (db *DB) RetrieveByModelSelectBytes(pageSize, pageNo int, whereModel interface{}, fields []string, order string) ([]byte, int64, error)

+ func (db *DB) RetrieveByModelSelectString(pageSize, pageNo int, whereModel interface{}, fields []string, order string) (string, int64, error)

+ func (db *DB) RetrieveByModelString(pageSize, pageNo int, whereModel interface{}, order string) (string, int64, error)

+ func (db *DB) RetrieveByWhere(pageSize, pageNo int, dataModel interface{}, order, where string, ...) (interface{}, int64, error)

+ func (db *DB) RetrieveByWhereBytes(pageSize, pageNo int, dataModel interface{}, order, where string, ...) ([]byte, int64, error)

+ func (db *DB) RetrieveByWhereSelect(pageSize, pageNo int, dataModel interface{}, fields []string, ...) (interface{}, int64, error)

+ func (db *DB) RetrieveByWhereSelectBytes(pageSize, pageNo int, dataModel interface{}, fields []string, ...) ([]byte, int64, error)

+ func (db *DB) RetrieveByWhereSelectString(pageSize, pageNo int, dataModel interface{}, fields []string, ...) (string, int64, error)

+ func (db *DB) RetrieveByWhereString(pageSize, pageNo int, dataModel interface{}, order, where string, ...) (string, int64, error)

+ func (db *DB) RetrieveCountByArgs(dataModel interface{}, where string, args []interface{}) (int64, error)

+ func (db *DB) RetrieveCountByModel(whereModel interface{}) (int64, error)

+ func (db *DB) Transaction(fc func(tx *TX) error) error

+ func (db *DB) TruncateTable(dataModel interface{}) error

+ func (db *DB) UpdateByArgsField(dataModel interface{}, where string, args []interface{}, column, expr string, ...) error

+ func (db *DB) UpdateByArgsWhere(dataModel interface{}, where string, args []interface{}, ...) error

+ func (db *DB) UpdateByArgsWhereModel(where string, args []interface{}, updateModel interface{}) error

+ func (db *DB) UpdateByField(dataModel interface{}, where interface{}, column, expr string, ...) error

+ func (db *DB) UpdateById(dataModel interface{}) error

+ func (db *DB) UpdateByModelField(whereModel interface{}, column, expr string, updates ...interface{}) error

+ func (db *DB) UpdateByModelWhere(whereModel interface{}, updates map[string]interface{}) error

+ func (db *DB) UpdateByModelWhereModel(whereModel interface{}, updateModel interface{}) error

+ func (db *DB) UpdateByWhere(dataModel interface{}, where string, updates map[string]interface{}) error

+ func (db *DB) UpdateByWhereModel(where string, updateModel interface{}) error

+ type LogInfoModel struct

+ AccountId uint64

+ AccountInfo string

+ AccountName string

+ ApiDesc string

+ ApiPath string

+ ContentLength uint64

+ ContentType string

+ CostTime uint64

+ ExecuteTime time.Time

+ Method string

+ Referer string

+ RemoteAddr string

+ RemoteIp string

+ RequestHost string

+ RequestParams string

+ RequestToken string

+ RequestUrl string

+ ResponseData string

+ StatusCode int

+ UserAgent string

+ func (m *LogInfoModel) TableName() string

+ type TX struct

+ type UpdateModel struct

+ ExecuteTime time.Time

+ FileName string

+ func (m *UpdateModel) TableName() string