db

package

Go to main page

Versions in this module

v1

v1.0.0-beta

Oct 12, 2019

v1.0.0-alpha.2

Oct 10, 2019

v1.0.0-alpha.1

Oct 10, 2019

v1.0.0-alpha

Oct 8, 2019

v0

v0.6.0

Oct 7, 2019

v0.5.1

Oct 7, 2019

v0.5.0

Oct 7, 2019

v0.4.2

Oct 7, 2019

v0.4.1

Oct 7, 2019

v0.4.0

Oct 7, 2019

v0.3.1

Oct 6, 2019

v0.3.0

Oct 6, 2019

v0.2.6

Oct 6, 2019

v0.2.5

Oct 5, 2019

v0.2.4

Oct 5, 2019

v0.2.3

Oct 5, 2019

v0.2.2

Oct 5, 2019

v0.2.1

Oct 5, 2019

v0.2.0

Oct 4, 2019

Changes in this version

type Connection

+ GetDelimiter func() string

type DatabaseType

+ const Varbinary

type Mssql

+ func (db *Mssql) GetDelimiter() string

type Mysql

+ func (db *Mysql) GetDelimiter() string

type Postgresql

+ func (db *Postgresql) GetDelimiter() string

type Sqlite

+ func (db *Sqlite) GetDelimiter() string

v0.1.2

Oct 4, 2019

v0.1.1

Sep 29, 2019

v0.1.0

Sep 28, 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 StringTypeList = []DatabaseType

+ var UintTypeList = []DatabaseType

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

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

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

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

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

type Connection

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

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

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

+ DbList map[string]*sql.DB

+ Once sync.Once

+ func GetMssqlDB() *Mssql

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

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

+ func (db *Mssql) GetName() string

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

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

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

+ type Mysql struct

+ DbList map[string]*sql.DB

+ Once sync.Once

+ func GetMysqlDB() *Mysql

+ func (db *Mysql) BeginTransactions() *SqlTxStruct

+ func (db *Mysql) BeginTransactionsWithLevel(level sql.IsolationLevel) *SqlTxStruct

+ func (db *Mysql) BeginTransactionsWithReadCommitted() *SqlTxStruct

+ func (db *Mysql) BeginTransactionsWithReadUncommitted() *SqlTxStruct

+ func (db *Mysql) BeginTransactionsWithRepeatableRead() *SqlTxStruct

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

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

+ func (db *Mysql) GetName() string

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

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

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

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

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

+ type Postgresql struct

+ DbList map[string]*sql.DB

+ Once sync.Once

+ func GetPostgresqlDB() *Postgresql

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

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

+ func (db *Postgresql) GetName() string

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

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

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

type Sql

+ func WithDriverAndConnection(conn, driver string) *Sql

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

+ type SqlTxStruct struct

+ Tx *sql.Tx

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

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

+ type Sqlite struct

+ DbList map[string]*sql.DB

+ Once sync.Once

+ func GetSqliteDB() *Sqlite

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

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

+ func (db *Sqlite) GetName() string

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

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

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

+ type TxFn func(*SqlTxStruct) (error, map[string]interface{})

+ type Value string

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

+ func (v Value) String() string

+ func (v Value) ToInt64() int64

v0.0.4

Apr 24, 2019

Changes in this version

+ const DRIVER_MSSQL

+ const DRIVER_MYSQL

+ const DRIVER_POSTGRESQL

+ const DRIVER_SQLITE

+ var SqlPool = sync.Pool

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

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

+ func RecycleSql(sql *Sql)

+ type Connection interface

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

+ GetName func() string

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

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

+ func GetConnection() Connection

+ func GetConnectionByDriver(driver string) Connection

+ type H map[string]interface

+ type Join struct

+ type RawUpdate struct

+ type Sql struct

+ func Table(table string) *Sql

+ func WithDriver(driver string) *Sql

+ func (sql *Sql) All() ([]map[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) OrderBy(filed string, order 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) 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

+ type Where struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL