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

Jan 1, 2021

v1.2.20

Jan 1, 2021

v1.2.19

Dec 30, 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

+ Configs config.DatabaseList

+ DbList map[string]*sql.DB

+ Once sync.Once

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

+ func (db *Base) CreateDB(name string, beans ...interface{}) error

+ func (db *Base) GetConfig(name string) config.Database

+ 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

+ CreateDB func(name string, beans ...interface{}) error

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

+ ExecWith func(tx *sql.Tx, conn, 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)

+ GetConfig func(name string) config.Database

+ GetDB func(key string) *sql.DB

+ GetDelimiter func() string

+ GetDelimiter2 func() string

+ GetDelimiters func() []string

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

+ Name func() string

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

+ QueryWith func(tx *sql.Tx, conn, 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) ExecWith(tx *sql.Tx, conn, 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) GetDelimiter2() string

+ func (db *Mssql) GetDelimiters() []string

+ func (db *Mssql) InitDB(cfgs 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) QueryWith(tx *sql.Tx, conn, 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) ExecWith(tx *sql.Tx, conn, 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) GetDelimiter2() string

+ func (db *Mysql) GetDelimiters() []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) QueryWith(tx *sql.Tx, conn, 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) ExecWith(tx *sql.Tx, conn, 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) GetDelimiter2() string

+ func (db *Postgresql) GetDelimiters() []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) QueryWith(tx *sql.Tx, conn, 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) ExecWith(tx *sql.Tx, conn, 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) GetDelimiter2() string

+ func (db *Sqlite) GetDelimiters() []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) QueryWith(tx *sql.Tx, conn, 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

Other modules containing this package

github.com/betterwithbenji/go-admin/v2