db

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 28, 2019 License: Apache-2.0 Imports: 16 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	DriverMysql      = "mysql"
	DriverMssql      = "mssql"
	DriverSqlite     = "sqlite"
	DriverPostgresql = "postgresql"
)

Variables

View Source 
var (
	StringTypeList = []DatabaseType{Date, Time, Year, Datetime, Timestamptz, Timestamp,
		Varchar, Char, Mediumtext, Longtext, Tinytext,
		Text, Json, Blob, Tinyblob, Mediumblob, Longblob,
		Interval, Point,
		Line, Lseg, Box, Path, Polygon, Circle, Cidr, Inet, Macaddr, Character, Varyingcharacter,
		Nchar, Nativecharacter, Nvarchar, Clob, Binary, VarBinary, Enum, Set, Geometry, Multilinestring,
		Multipolygon, Linestring, Multipoint, Geometrycollection, Name, Uuid, Timestamptz,
		Name, Uuid, Inet}
	BoolTypeList = []DatabaseType{Bool, Boolean}
	IntTypeList  = []DatabaseType{Int4,
		Int,
		Tinyint,
		Mediumint,
		Smallint,
		Numeric, Smallserial, Serial, Bigserial, Money,
		Integer,
		Bigint}
	FloatTypeList = []DatabaseType{Float, Double, Real, Doubleprecision}
	UintTypeList  = []DatabaseType{Decimal, Bit}
)
View Source 
var DB = Sqlite{
	DbList: map[string]*sql.DB{},
}
View Source 
var MssqlDB = Mssql{
	DbList: map[string]*sql.DB{},
}
View Source 
var MysqlDB = Mysql{
	DbList: map[string]*sql.DB{},
}
View Source 
var PostgresqlDB = Postgresql{
	DbList: map[string]*sql.DB{},
}
View Source 
var SqlPool = sync.Pool{
	New: func() interface{} {
		return &Sql{
			SqlComponent: dialect.SqlComponent{
				Fields:     make([]string, 0),
				TableName:  "",
				Args:       make([]interface{}, 0),
				Wheres:     make([]dialect.Where, 0),
				Leftjoins:  make([]dialect.Join, 0),
				UpdateRaws: make([]dialect.RawUpdate, 0),
				WhereRaws:  "",
			},
			diver:   nil,
			dialect: nil,
		}
	},
}

Functions

func CommonExec added in v0.1.0 

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

func CommonQuery added in v0.1.0 

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

func Contains added in v0.1.0 

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

func Exec 

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

func Query 

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

func RecycleSql 

func RecycleSql(sql *Sql)

func SetColVarType added in v0.1.0 

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

func SetResultValue added in v0.1.0 

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

Types

type Connection 

type Connection interface {
	Query(query string, args ...interface{}) ([]map[string]interface{}, *sql.Rows)
	Exec(query string, args ...interface{}) sql.Result
	QueryWithConnection(conn, query string, args ...interface{}) ([]map[string]interface{}, *sql.Rows)
	ExecWithConnection(conn, query string, args ...interface{}) sql.Result
	InitDB(cfg map[string]config.Database)
	GetName() string
}

func GetConnection 

func GetConnection() Connection

func GetConnectionByDriver 

func GetConnectionByDriver(driver string) Connection

type DatabaseType added in v0.1.0 

type DatabaseType string
const (
	Int       DatabaseType = "INT"
	Tinyint   DatabaseType = "TINYINT"
	Mediumint DatabaseType = "MEDIUMINT"
	Smallint  DatabaseType = "SMALLINT"
	Bigint    DatabaseType = "BIGINT"
	Bit       DatabaseType = "BIT"
	Int4      DatabaseType = "INT4"

	Integer     DatabaseType = "INTEGER"
	Numeric     DatabaseType = "NUMERIC"
	Smallserial DatabaseType = "SMALLSERIAL"
	Serial      DatabaseType = "SERIAL"
	Bigserial   DatabaseType = "BIGSERIAL"
	Money       DatabaseType = "MONEY"

	Real    DatabaseType = "REAL"
	Float   DatabaseType = "FLOAT"
	Double  DatabaseType = "DOUBLE"
	Decimal DatabaseType = "DECIMAL"

	Doubleprecision DatabaseType = "DOUBLEPRECISION"

	Date      DatabaseType = "DATE"
	Time      DatabaseType = "TIME"
	Year      DatabaseType = "YEAR"
	Datetime  DatabaseType = "DATETIME"
	Timestamp DatabaseType = "TIMESTAMP"

	Text       DatabaseType = "TEXT"
	Longtext   DatabaseType = "LONGTEXT"
	Mediumtext DatabaseType = "MEDIUMTEXT"
	Tinytext   DatabaseType = "TINYTEXT"

	Varchar DatabaseType = "VARCHAR"
	Char    DatabaseType = "CHAR"
	Json    DatabaseType = "JSON"

	Blob       DatabaseType = "BLOB"
	Tinyblob   DatabaseType = "TINYBLOB"
	Mediumblob DatabaseType = "MEDIUMBLOB"
	Longblob   DatabaseType = "LONGBLOB"

	Interval DatabaseType = "INTERVAL"
	Boolean  DatabaseType = "BOOLEAN"
	Bool     DatabaseType = "Bool"

	Point   DatabaseType = "POINT"
	Line    DatabaseType = "LINE"
	Lseg    DatabaseType = "LSEG"
	Box     DatabaseType = "BOX"
	Path    DatabaseType = "PATH"
	Polygon DatabaseType = "POLYGON"
	Circle  DatabaseType = "CIRCLE"

	Cidr    DatabaseType = "CIDR"
	Inet    DatabaseType = "INET"
	Macaddr DatabaseType = "MACADDR"

	Character        DatabaseType = "CHARACTER"
	Varyingcharacter DatabaseType = "VARYINGCHARACTER"
	Nchar            DatabaseType = "NCHAR"
	Nativecharacter  DatabaseType = "NATIVECHARACTER"
	Nvarchar         DatabaseType = "NVARCHAR"
	Clob             DatabaseType = "CLOB"

	Binary    DatabaseType = "BINARY"
	VarBinary DatabaseType = "VARBINARY"
	Enum      DatabaseType = "ENUM"
	Set       DatabaseType = "SET"

	Geometry DatabaseType = "GEOMETRY"

	Multilinestring    DatabaseType = "MULTILINESTRING"
	Multipolygon       DatabaseType = "MULTIPOLYGON"
	Linestring         DatabaseType = "LINESTRING"
	Multipoint         DatabaseType = "MULTIPOINT"
	Geometrycollection DatabaseType = "GEOMETRYCOLLECTION"

	Name DatabaseType = "NAME"
	Uuid DatabaseType = "UUID"

	Timestamptz DatabaseType = "TIMESTAMPTZ"
)

func DT added in v0.1.0 

func DT(s string) DatabaseType

func GetDTAndCheck added in v0.1.0 

func GetDTAndCheck(s string) DatabaseType

type H 

type H map[string]interface{}

type Join 

type Join struct {
	// contains filtered or unexported fields
}

type Mssql added in v0.1.0 

type Mssql struct {
	DbList map[string]*sql.DB
	Once   sync.Once
}

func GetMssqlDB added in v0.1.0 

func GetMssqlDB() *Mssql

func (*Mssql) Exec added in v0.1.0 

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

func (*Mssql) ExecWithConnection added in v0.1.0 

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

func (*Mssql) GetName added in v0.1.0 

func (db *Mssql) GetName() string

func (*Mssql) InitDB added in v0.1.0 

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

func (*Mssql) Query added in v0.1.0 

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

func (*Mssql) QueryWithConnection added in v0.1.0 

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

type Mysql added in v0.1.0 

type Mysql struct {
	DbList map[string]*sql.DB
	Once   sync.Once
}

func GetMysqlDB added in v0.1.0 

func GetMysqlDB() *Mysql

func (*Mysql) BeginTransactions added in v0.1.0 

func (db *Mysql) BeginTransactions() *SqlTxStruct

func (*Mysql) BeginTransactionsWithLevel added in v0.1.0 

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

func (*Mysql) BeginTransactionsWithReadCommitted added in v0.1.0 

func (db *Mysql) BeginTransactionsWithReadCommitted() *SqlTxStruct

func (*Mysql) BeginTransactionsWithReadUncommitted added in v0.1.0 

func (db *Mysql) BeginTransactionsWithReadUncommitted() *SqlTxStruct

func (*Mysql) BeginTransactionsWithRepeatableRead added in v0.1.0 

func (db *Mysql) BeginTransactionsWithRepeatableRead() *SqlTxStruct

func (*Mysql) Exec added in v0.1.0 

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

func (*Mysql) ExecWithConnection added in v0.1.0 

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

func (*Mysql) GetName added in v0.1.0 

func (db *Mysql) GetName() string

func (*Mysql) InitDB added in v0.1.0 

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

func (*Mysql) Query added in v0.1.0 

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

func (*Mysql) QueryWithConnection added in v0.1.0 

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

func (*Mysql) WithTransaction added in v0.1.0 

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

func (*Mysql) WithTransactionByLevel added in v0.1.0 

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

type Postgresql added in v0.1.0 

type Postgresql struct {
	DbList map[string]*sql.DB
	Once   sync.Once
}

func GetPostgresqlDB added in v0.1.0 

func GetPostgresqlDB() *Postgresql

func (*Postgresql) Exec added in v0.1.0 

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

func (*Postgresql) ExecWithConnection added in v0.1.0 

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

func (*Postgresql) GetName added in v0.1.0 

func (db *Postgresql) GetName() string

func (*Postgresql) InitDB added in v0.1.0 

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

func (*Postgresql) Query added in v0.1.0 

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

func (*Postgresql) QueryWithConnection added in v0.1.0 

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

type RawUpdate 

type RawUpdate struct {
	// contains filtered or unexported fields
}

type Sql 

type Sql struct {
	dialect.SqlComponent
	// contains filtered or unexported fields
}

func Table 

func Table(table string) *Sql

func WithDriver 

func WithDriver(driver string) *Sql

func WithDriverAndConnection added in v0.1.0 

func WithDriverAndConnection(conn, driver string) *Sql

func (*Sql) All 

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

func (*Sql) Count 

func (sql *Sql) Count() (int64, error)

func (*Sql) Delete 

func (sql *Sql) Delete() error

func (*Sql) Exec 

func (sql *Sql) Exec() (int64, error)

func (*Sql) Find 

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

func (*Sql) First 

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

func (*Sql) Insert 

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

func (*Sql) LeftJoin 

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

func (*Sql) OrderBy 

func (sql *Sql) OrderBy(fields ...string) *Sql

func (*Sql) Select 

func (sql *Sql) Select(fields ...string) *Sql

func (*Sql) ShowColumns 

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

func (*Sql) ShowTables 

func (sql *Sql) ShowTables() ([]map[string]interface{}, error)

func (*Sql) Skip 

func (sql *Sql) Skip(offset int) *Sql

func (*Sql) Table 

func (sql *Sql) Table(table string) *Sql

func (*Sql) Take 

func (sql *Sql) Take(take int) *Sql

func (*Sql) Update 

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

func (*Sql) UpdateRaw 

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

func (*Sql) Where 

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

func (*Sql) WhereIn 

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

func (*Sql) WhereNotIn 

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

func (*Sql) WhereRaw 

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

func (*Sql) WithConnection added in v0.1.0 

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

type SqlTxStruct added in v0.1.0 

type SqlTxStruct struct {
	Tx *sql.Tx
}

func (*SqlTxStruct) Exec added in v0.1.0 

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

func (*SqlTxStruct) Query added in v0.1.0 

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

type Sqlite added in v0.1.0 

type Sqlite struct {
	DbList map[string]*sql.DB
	Once   sync.Once
}

func GetSqliteDB added in v0.1.0 

func GetSqliteDB() *Sqlite

func (*Sqlite) Exec added in v0.1.0 

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

func (*Sqlite) ExecWithConnection added in v0.1.0 

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

func (*Sqlite) GetName added in v0.1.0 

func (db *Sqlite) GetName() string

func (*Sqlite) InitDB added in v0.1.0 

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

func (*Sqlite) Query added in v0.1.0 

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

func (*Sqlite) QueryWithConnection added in v0.1.0 

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

type TxFn added in v0.1.0 

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

type Value added in v0.1.0 

type Value string

func GetValueFromDatabaseType added in v0.1.0 

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

func (Value) String added in v0.1.0 

func (v Value) String() string

func (Value) ToInt64 added in v0.1.0 

func (v Value) ToInt64() int64

type Where 

type Where struct {
	// contains filtered or unexported fields
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.