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.1.601

Jan 6, 2020

Changes in this version

+ 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

+ Close func() []error

+ GetDB func(key string) *sql.DB

type SQL

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

v1.1.24

Jan 1, 2020

v1.1.23

Jan 1, 2020

v1.1.22

Jan 1, 2020

v1.1.21

Dec 31, 2019

v1.1.20

Dec 31, 2019

v1.1.19

Dec 31, 2019

v1.1.18

Dec 31, 2019

v1.1.17

Dec 31, 2019

v1.1.16

Dec 31, 2019

v1.1.15

Dec 25, 2019

v1.1.10

Dec 20, 2019

v1.1.9

Dec 19, 2019

v1.1.8

Dec 18, 2019

v1.1.7

Dec 18, 2019

v1.1.6

Dec 18, 2019

v1.1.5

Dec 13, 2019

v1.1.4

Dec 12, 2019

Changes in this version

+ const DriverMssql

+ const DriverMysql

+ const DriverPostgresql

+ const DriverSqlite

+ var BoolTypeList = []DatabaseType

+ var DB = Sqlite

+ var FloatTypeList = []DatabaseType

+ var IntTypeList = []DatabaseType

+ var MssqlDB = Mssql

+ var MysqlDB = Mysql

+ var PostgresqlDB = Postgresql

+ var SQLPool = sync.Pool

+ var StringTypeList = []DatabaseType

+ var UintTypeList = []DatabaseType

+ 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 RecycleSQL(sql *SQL)

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

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

+ 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

+ 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)

+ 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 Char

+ const Character

+ const Cidr

+ const Circle

+ const Clob

+ const Date

+ const Datetime

+ const Decimal

+ const Double

+ const Doubleprecision

+ const Enum

+ const Float

+ const Geometry

+ const Geometrycollection

+ const Inet

+ const Int

+ const Int4

+ 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 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

+ DbList map[string]*sql.DB

+ Once sync.Once

+ 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

+ DbList map[string]*sql.DB

+ Once sync.Once

+ 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

+ DbList map[string]*sql.DB

+ Once sync.Once

+ 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) 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) Select(fields ...string) *SQL

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

+ func (sql *SQL) ShowTables() ([]map[string]interface{}, 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

+ DbList map[string]*sql.DB

+ Once sync.Once

+ 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{}) Value

+ func (v Value) String() string

+ func (v Value) ToInt64() int64