db

Documentation

Index

• func AddDataSource(name string, dbPool *pool.DbPool)
• func Commit(id uint64) error
• func GetConnection(name string) (*pool.Connection, error)
• func GetTx(id uint64, dataSourceName string) (*sql.Tx, error)
• func Rollback(id uint64) error
• func SelectList(connection *sql.DB, sql string, params []interface{}) ([]map[string]string, error)
• func Transaction() (uint64, error)
• func Update(connection *sql.DB, sql string, params []interface{}) (sql.Result, error)
• func UpdateByTx(tx *sql.Tx, sql string, params []interface{}) (sql.Result, error)
• type TxData

Functions

func AddDataSource

func AddDataSource(name string, dbPool *pool.DbPool)

AddDataSource Add DbPool as a data source

func Commit

func Commit(id uint64) error

Commit transaction

func GetConnection

func GetConnection(name string) (*pool.Connection, error)

GetConnection Obtaining a connection from a specified data source

func GetTx

func GetTx(id uint64, dataSourceName string) (*sql.Tx, error)

GetTx Get the corresponding transaction manager based on ID and data source name

func Rollback

func Rollback(id uint64) error

Rollback transactions

func SelectList

func SelectList(connection *sql.DB, sql string, params []interface{}) ([]map[string]string, error)

SelectList Query list based on sql and parameters

func Transaction

func Transaction() (uint64, error)

Transaction Open a transaction

func Update

func Update(connection *sql.DB, sql string, params []interface{}) (sql.Result, error)

Update Add, delete and change operations

func UpdateByTx

func UpdateByTx(tx *sql.Tx, sql string, params []interface{}) (sql.Result, error)

UpdateByTx Add, delete and change operations

Types

type TxData

type TxData struct {
	Tx   *sql.Tx
	Conn *pool.Connection
}