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

db

package

Go to main page

Versions in this module

v1

v1.4.3

May 21, 2020

v1.4.2

May 13, 2020

v1.4.1

May 6, 2020

v1.4.0

May 3, 2020

v1.3.1

May 3, 2020

v1.3.0

May 3, 2020

Changes in this version

+ const DELETE

+ const DriverMssql

+ const DriverMysql

+ const DriverPostgresql

+ const DriverSqlite

+ const INSERT

+ const QUERY

+ const UPDATE

+ var BoolTypeList = []DatabaseType

+ var FloatTypeList = []DatabaseType

+ var IntTypeList = []DatabaseType

+ var SQLPool = sync.Pool

+ var StringTypeList = []DatabaseType

+ var UintTypeList = []DatabaseType

+ func CheckError(err error, t int) bool

+ func CommonBeginTxWithLevel(db *sql.DB, level sql.IsolationLevel) *sql.Tx

+ func CommonExec(db *sql.DB, query string, args ...interface{}) (sql.Result, error)

+ func CommonExecWithTx(tx *sql.Tx, query string, args ...interface{}) (sql.Result, error)

+ func CommonQuery(db *sql.DB, query string, args ...interface{}) ([]map[string]interface{}, error)

+ func CommonQueryWithTx(tx *sql.Tx, query string, args ...interface{}) ([]map[string]interface{}, error)

+ func Contains(v DatabaseType, a []DatabaseType) bool

+ func GetAggregationExpression(driver, field, headField, delimiter string) string

+ func RecycleSQL(sql *SQL)

+ func SetColVarType(colVar *[]interface{}, i int, typeName string)

+ func SetResultValue(result *map[string]interface{}, index string, colVar interface{}, ...)

+ type Base struct

+ DbList map[string]*sql.DB

+ Once sync.Once

+ func (db *Base) Close() []error

+ func (db *Base) GetDB(key string) *sql.DB

+ type Connection interface

+ BeginTx func() *sql.Tx

+ BeginTxAndConnection func(conn string) *sql.Tx

+ BeginTxWithLevel func(level sql.IsolationLevel) *sql.Tx

+ BeginTxWithLevelAndConnection func(conn string, level sql.IsolationLevel) *sql.Tx

+ BeginTxWithReadCommitted func() *sql.Tx

+ BeginTxWithReadCommittedAndConnection func(conn string) *sql.Tx

+ BeginTxWithReadUncommitted func() *sql.Tx

+ BeginTxWithReadUncommittedAndConnection func(conn string) *sql.Tx

+ BeginTxWithRepeatableRead func() *sql.Tx

+ BeginTxWithRepeatableReadAndConnection func(conn string) *sql.Tx

+ Close func() []error

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ ExecWithConnection func(conn, query string, args ...interface{}) (sql.Result, error)

+ ExecWithTx func(tx *sql.Tx, query string, args ...interface{}) (sql.Result, error)

+ GetDB func(key string) *sql.DB

+ GetDelimiter func() string

+ InitDB func(cfg map[string]config.Database) Connection

+ Name func() string

+ Query func(query string, args ...interface{}) ([]map[string]interface{}, error)

+ QueryWithConnection func(conn, query string, args ...interface{}) ([]map[string]interface{}, error)

+ QueryWithTx func(tx *sql.Tx, query string, args ...interface{}) ([]map[string]interface{}, error)

+ func GetConnection(srvs service.List) Connection

+ func GetConnectionByDriver(driver string) Connection

+ func GetConnectionFromService(srv interface{}) Connection

+ type DatabaseType string

+ const Bigint

+ const Bigserial

+ const Binary

+ const Bit

+ const Blob

+ const Bool

+ const Boolean

+ const Box

+ const Bpchar

+ const Char

+ const Character

+ const Cidr

+ const Circle

+ const Clob

+ const Date

+ const Datetime

+ const Decimal

+ const Double

+ const Doubleprecision

+ const Enum

+ const Float

+ const Float4

+ const Float8

+ const Geometry

+ const Geometrycollection

+ const Inet

+ const Int

+ const Int2

+ const Int4

+ const Int8

+ const Integer

+ const Interval

+ const JSON

+ const Line

+ const Linestring

+ const Longblob

+ const Longtext

+ const Lseg

+ const Macaddr

+ const Mediumblob

+ const Mediumint

+ const Mediumtext

+ const Money

+ const Multilinestring

+ const Multipoint

+ const Multipolygon

+ const Name

+ const Nativecharacter

+ const Nchar

+ const Numeric

+ const Nvarchar

+ const Path

+ const Point

+ const Polygon

+ const Real

+ const Serial

+ const Set

+ const Smallint

+ const Smallserial

+ const Text

+ const Time

+ const Timestamp

+ const Timestamptz

+ const Timetz

+ const Tinyblob

+ const Tinyint

+ const Tinytext

+ const UUID

+ const Varbinary

+ const Varchar

+ const Varyingcharacter

+ const Year

+ func DT(s string) DatabaseType

+ func GetDTAndCheck(s string) DatabaseType

+ type H map[string]interface

+ type Mssql struct

+ func GetMssqlDB() *Mssql

+ func (db *Mssql) BeginTx() *sql.Tx

+ func (db *Mssql) BeginTxAndConnection(conn string) *sql.Tx

+ func (db *Mssql) BeginTxWithLevel(level sql.IsolationLevel) *sql.Tx

+ func (db *Mssql) BeginTxWithLevelAndConnection(conn string, level sql.IsolationLevel) *sql.Tx

+ func (db *Mssql) BeginTxWithReadCommitted() *sql.Tx

+ func (db *Mssql) BeginTxWithReadCommittedAndConnection(conn string) *sql.Tx

+ func (db *Mssql) BeginTxWithReadUncommitted() *sql.Tx

+ func (db *Mssql) BeginTxWithReadUncommittedAndConnection(conn string) *sql.Tx

+ func (db *Mssql) BeginTxWithRepeatableRead() *sql.Tx

+ func (db *Mssql) BeginTxWithRepeatableReadAndConnection(conn string) *sql.Tx

+ func (db *Mssql) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (db *Mssql) ExecWithConnection(con string, query string, args ...interface{}) (sql.Result, error)

+ func (db *Mssql) ExecWithTx(tx *sql.Tx, query string, args ...interface{}) (sql.Result, error)

+ func (db *Mssql) GetDelimiter() string

+ func (db *Mssql) InitDB(cfglist map[string]config.Database) Connection

+ func (db *Mssql) Name() string

+ func (db *Mssql) Query(query string, args ...interface{}) ([]map[string]interface{}, error)

+ func (db *Mssql) QueryWithConnection(con string, query string, args ...interface{}) ([]map[string]interface{}, error)

+ func (db *Mssql) QueryWithTx(tx *sql.Tx, query string, args ...interface{}) ([]map[string]interface{}, error)

+ type Mysql struct

+ func GetMysqlDB() *Mysql

+ func (db *Mysql) BeginTx() *sql.Tx

+ func (db *Mysql) BeginTxAndConnection(conn string) *sql.Tx

+ func (db *Mysql) BeginTxWithLevel(level sql.IsolationLevel) *sql.Tx

+ func (db *Mysql) BeginTxWithLevelAndConnection(conn string, level sql.IsolationLevel) *sql.Tx

+ func (db *Mysql) BeginTxWithReadCommitted() *sql.Tx

+ func (db *Mysql) BeginTxWithReadCommittedAndConnection(conn string) *sql.Tx

+ func (db *Mysql) BeginTxWithReadUncommitted() *sql.Tx

+ func (db *Mysql) BeginTxWithReadUncommittedAndConnection(conn string) *sql.Tx

+ func (db *Mysql) BeginTxWithRepeatableRead() *sql.Tx

+ func (db *Mysql) BeginTxWithRepeatableReadAndConnection(conn string) *sql.Tx

+ func (db *Mysql) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (db *Mysql) ExecWithConnection(con string, query string, args ...interface{}) (sql.Result, error)

+ func (db *Mysql) ExecWithTx(tx *sql.Tx, query string, args ...interface{}) (sql.Result, error)

+ func (db *Mysql) GetDelimiter() string

+ func (db *Mysql) InitDB(cfgs map[string]config.Database) Connection

+ func (db *Mysql) Name() string

+ func (db *Mysql) Query(query string, args ...interface{}) ([]map[string]interface{}, error)

+ func (db *Mysql) QueryWithConnection(con string, query string, args ...interface{}) ([]map[string]interface{}, error)

+ func (db *Mysql) QueryWithTx(tx *sql.Tx, query string, args ...interface{}) ([]map[string]interface{}, error)

+ type Postgresql struct

+ func GetPostgresqlDB() *Postgresql

+ func (db *Postgresql) BeginTx() *sql.Tx

+ func (db *Postgresql) BeginTxAndConnection(conn string) *sql.Tx

+ func (db *Postgresql) BeginTxWithLevel(level sql.IsolationLevel) *sql.Tx

+ func (db *Postgresql) BeginTxWithLevelAndConnection(conn string, level sql.IsolationLevel) *sql.Tx

+ func (db *Postgresql) BeginTxWithReadCommitted() *sql.Tx

+ func (db *Postgresql) BeginTxWithReadCommittedAndConnection(conn string) *sql.Tx

+ func (db *Postgresql) BeginTxWithReadUncommitted() *sql.Tx

+ func (db *Postgresql) BeginTxWithReadUncommittedAndConnection(conn string) *sql.Tx

+ func (db *Postgresql) BeginTxWithRepeatableRead() *sql.Tx

+ func (db *Postgresql) BeginTxWithRepeatableReadAndConnection(conn string) *sql.Tx

+ func (db *Postgresql) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (db *Postgresql) ExecWithConnection(con string, query string, args ...interface{}) (sql.Result, error)

+ func (db *Postgresql) ExecWithTx(tx *sql.Tx, query string, args ...interface{}) (sql.Result, error)

+ func (db *Postgresql) GetDelimiter() string

+ func (db *Postgresql) InitDB(cfgList map[string]config.Database) Connection

+ func (db *Postgresql) Name() string

+ func (db *Postgresql) Query(query string, args ...interface{}) ([]map[string]interface{}, error)

+ func (db *Postgresql) QueryWithConnection(con string, query string, args ...interface{}) ([]map[string]interface{}, error)

+ func (db *Postgresql) QueryWithTx(tx *sql.Tx, query string, args ...interface{}) ([]map[string]interface{}, error)

+ type SQL struct

+ func Table(table string) *SQL

+ func WithDriver(conn Connection) *SQL

+ func WithDriverAndConnection(connName string, conn Connection) *SQL

+ func (sql *SQL) All() ([]map[string]interface{}, error)

+ func (sql *SQL) Avg(field string) (interface{}, error)

+ func (sql *SQL) Count() (int64, error)

+ func (sql *SQL) Delete() error

+ func (sql *SQL) Exec() (int64, error)

+ func (sql *SQL) Find(arg interface{}) (map[string]interface{}, error)

+ func (sql *SQL) First() (map[string]interface{}, error)

+ func (sql *SQL) GroupBy(fields ...string) *SQL

+ func (sql *SQL) GroupByRaw(group string) *SQL

+ func (sql *SQL) Insert(values dialect.H) (int64, error)

+ func (sql *SQL) LeftJoin(table string, fieldA string, operation string, fieldB string) *SQL

+ func (sql *SQL) Max(field string) (interface{}, error)

+ func (sql *SQL) Min(field string) (interface{}, error)

+ func (sql *SQL) OrderBy(fields ...string) *SQL

+ func (sql *SQL) OrderByRaw(order string) *SQL

+ func (sql *SQL) Select(fields ...string) *SQL

+ func (sql *SQL) ShowColumns() ([]map[string]interface{}, error)

+ func (sql *SQL) ShowTables() ([]string, error)

+ func (sql *SQL) Skip(offset int) *SQL

+ func (sql *SQL) Sum(field string) (float64, error)

+ func (sql *SQL) Table(table string) *SQL

+ func (sql *SQL) Take(take int) *SQL

+ func (sql *SQL) Update(values dialect.H) (int64, error)

+ func (sql *SQL) UpdateRaw(raw string, args ...interface{}) *SQL

+ func (sql *SQL) Where(field string, operation string, arg interface{}) *SQL

+ func (sql *SQL) WhereIn(field string, arg []interface{}) *SQL

+ func (sql *SQL) WhereNotIn(field string, arg []interface{}) *SQL

+ func (sql *SQL) WhereRaw(raw string, args ...interface{}) *SQL

+ func (sql *SQL) WithConnection(conn string) *SQL

+ func (sql *SQL) WithDriver(conn Connection) *SQL

+ func (sql *SQL) WithTransaction(fn TxFn) (res map[string]interface{}, err error)

+ func (sql *SQL) WithTransactionByLevel(level dbsql.IsolationLevel, fn TxFn) (res map[string]interface{}, err error)

+ func (sql *SQL) WithTx(tx *dbsql.Tx) *SQL

+ type SQLTx struct

+ Tx *sql.Tx

+ type Sqlite struct

+ func GetSqliteDB() *Sqlite

+ func (db *Sqlite) BeginTx() *sql.Tx

+ func (db *Sqlite) BeginTxAndConnection(conn string) *sql.Tx

+ func (db *Sqlite) BeginTxWithLevel(level sql.IsolationLevel) *sql.Tx

+ func (db *Sqlite) BeginTxWithLevelAndConnection(conn string, level sql.IsolationLevel) *sql.Tx

+ func (db *Sqlite) BeginTxWithReadCommitted() *sql.Tx

+ func (db *Sqlite) BeginTxWithReadCommittedAndConnection(conn string) *sql.Tx

+ func (db *Sqlite) BeginTxWithReadUncommitted() *sql.Tx

+ func (db *Sqlite) BeginTxWithReadUncommittedAndConnection(conn string) *sql.Tx

+ func (db *Sqlite) BeginTxWithRepeatableRead() *sql.Tx

+ func (db *Sqlite) BeginTxWithRepeatableReadAndConnection(conn string) *sql.Tx

+ func (db *Sqlite) Exec(query string, args ...interface{}) (sql.Result, error)

+ func (db *Sqlite) ExecWithConnection(con string, query string, args ...interface{}) (sql.Result, error)

+ func (db *Sqlite) ExecWithTx(tx *sql.Tx, query string, args ...interface{}) (sql.Result, error)

+ func (db *Sqlite) GetDelimiter() string

+ func (db *Sqlite) InitDB(cfgList map[string]config.Database) Connection

+ func (db *Sqlite) Name() string

+ func (db *Sqlite) Query(query string, args ...interface{}) ([]map[string]interface{}, error)

+ func (db *Sqlite) QueryWithConnection(con string, query string, args ...interface{}) ([]map[string]interface{}, error)

+ func (db *Sqlite) QueryWithTx(tx *sql.Tx, query string, args ...interface{}) ([]map[string]interface{}, error)

+ type TxFn func(tx *dbsql.Tx) (error, map[string]interface{})

+ type Value string

+ func GetValueFromDatabaseType(typ DatabaseType, value interface{}, json bool) Value

+ func GetValueFromJSONOfDatabaseType(typ DatabaseType, value interface{}) Value

+ func GetValueFromSQLOfDatabaseType(typ DatabaseType, value interface{}) Value

+ func (v Value) HTML() template.HTML

+ func (v Value) String() string

+ func (v Value) ToInt64() int64