db

Documentation

Index

• func Delete(pool *pool.DbPool, sql *string, args ...interface{}) (sql.Result, error)
• func Insert(pool *pool.DbPool, sql *string, args ...any) (sql.Result, error)
• func NamedDelete(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)
• func NamedInsert(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)
• func NamedUpdate(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)
• func NextSeqMargin(pool *pool.DbPool, sqlSelect *string, sqlUpdate *string, seqName string) (map[string]interface{}, error)
• func SelectAsJson(pool *pool.DbPool, sql *string, args ...interface{}) ([]byte, error)
• func SelectAsJsonArray(pool *pool.DbPool, sql *string, args ...interface{}) ([]byte, error)
• func SelectAsMap(pool *pool.DbPool, sql *string, args ...interface{}) (map[string]interface{}, error)
• func SelectAsMapSlice(pool *pool.DbPool, sql *string, args ...interface{}) ([]interface{}, error)
• func SelectAsObject(pool *pool.DbPool, outObject interface{}, sql *string, args ...interface{}) error
• func SelectAsSlice(pool *pool.DbPool, outSlice interface{}, sql *string, args ...interface{}) error
• func TxDelete(pool *pool.DbPool, sql *string, args ...interface{}) (sql.Result, error)
• func TxInsert(pool *pool.DbPool, sql *string, args ...any) (sql.Result, error)
• func TxNamedDelete(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)
• func TxNamedInsert(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)
• func TxNamedUpdate(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)
• func TxSelectAsMap(pool *pool.DbPool, sql *string, args ...interface{}) (map[string]interface{}, error)
• func TxSelectAsMapSlice(pool *pool.DbPool, sql *string, args ...interface{}) ([]interface{}, error)
• func TxSelectAsObject(pool *pool.DbPool, outObject interface{}, sql *string, args ...interface{}) error
• func TxSelectAsSlice(pool *pool.DbPool, outSlice interface{}, sql *string, args ...interface{}) error
• func TxUpdate(pool *pool.DbPool, sql *string, args ...interface{}) (sql.Result, error)
• func Update(pool *pool.DbPool, sql *string, args ...interface{}) (sql.Result, error)
• func UpdateOri(db *sqlx.DB, sql *string, args ...interface{}) (sql.Result, error)

Functions

func Delete

func Delete(pool *pool.DbPool, sql *string, args ...interface{}) (sql.Result, error)

for delete with param list bind with ?

"delete from person where id = ?"

func Insert

func Insert(pool *pool.DbPool, sql *string, args ...any) (sql.Result, error)

for insert with param list bind with ?

"INSERT INTO person (first_name, last_name, email) VALUES (?, ?, ?)"

func NamedDelete

func NamedDelete(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)

for delete with named param bind:

"delete from person where id = :id"

func NamedInsert

func NamedInsert(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)

for insert with named param bind:

"INSERT INTO person (first_name, last_name, email) VALUES (:first, :last, :email)"

func NamedUpdate

func NamedUpdate(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)

for update with named param bind:

"update person set first_name = :first, last_name = :last, email = :email where id = :id"

func NextSeqMargin

func NextSeqMargin(pool *pool.DbPool, sqlSelect *string, sqlUpdate *string, seqName string) (map[string]interface{}, error)

func SelectAsJson

func SelectAsJson(pool *pool.DbPool, sql *string, args ...interface{}) ([]byte, error)

func SelectAsJsonArray

func SelectAsJsonArray(pool *pool.DbPool, sql *string, args ...interface{}) ([]byte, error)

func SelectAsMap

func SelectAsMap(pool *pool.DbPool, sql *string, args ...interface{}) (map[string]interface{}, error)

for select single row, return result as map[string]interface{}

resMap, err := SelectAsMap(db, &slice, "SELECT * FROM person WHERE first_name=?", "Jason")

func SelectAsMapSlice

func SelectAsMapSlice(pool *pool.DbPool, sql *string, args ...interface{}) ([]interface{}, error)

for select multi row, return result as []map[string]interface{}

sliceMap, err := SelectAsMapSlice(db, sql, "SELECT * FROM person WHERE first_name=?", "Jason")

func SelectAsObject

func SelectAsObject(pool *pool.DbPool, outObject interface{}, sql *string, args ...interface{}) error

for select single row, return outObject automatic reflect to dest struct

obj := Person{}
err := crud.SelectAsObject(db, &obj, "SELECT * FROM person WHERE first_name=?", "Jason")

func SelectAsSlice

func SelectAsSlice(pool *pool.DbPool, outSlice interface{}, sql *string, args ...interface{}) error

for select multi rows, return outSlice automatic reflect to dest struct

slice := []Person{}
err := SelectAsSlice(db, &slice, "SELECT * FROM person ORDER BY first_name ASC")

func TxDelete

func TxDelete(pool *pool.DbPool, sql *string, args ...interface{}) (sql.Result, error)

func TxInsert

func TxInsert(pool *pool.DbPool, sql *string, args ...any) (sql.Result, error)

func TxNamedDelete

func TxNamedDelete(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)

func TxNamedInsert

func TxNamedInsert(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)

func TxNamedUpdate

func TxNamedUpdate(pool *pool.DbPool, sql *string, args *map[string]interface{}) (sql.Result, error)

func TxSelectAsMap

func TxSelectAsMap(pool *pool.DbPool, sql *string, args ...interface{}) (map[string]interface{}, error)

func TxSelectAsMapSlice

func TxSelectAsMapSlice(pool *pool.DbPool, sql *string, args ...interface{}) ([]interface{}, error)

func TxSelectAsObject

func TxSelectAsObject(pool *pool.DbPool, outObject interface{}, sql *string, args ...interface{}) error

func TxSelectAsSlice

func TxSelectAsSlice(pool *pool.DbPool, outSlice interface{}, sql *string, args ...interface{}) error

select with transaction

func TxUpdate

func TxUpdate(pool *pool.DbPool, sql *string, args ...interface{}) (sql.Result, error)

func Update

func Update(pool *pool.DbPool, sql *string, args ...interface{}) (sql.Result, error)

for update with param list bind with ?

"update person set first_name = ?, last_name = ?, email = ? where id = ?"

func UpdateOri

func UpdateOri(db *sqlx.DB, sql *string, args ...interface{}) (sql.Result, error)