db

package

v0.0.0-...-f1d2d96 Latest Latest Go to latest Published: Jun 28, 2024 License: MIT Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

func RegisterCustomType(t reflect.Type, fn CustomTypeFunc)

RegisterCustomType registers a custom type and its conversion function.

type CustomTypeFunc func(string) (reflect.Value, error)

CustomTypeFunc is a type for functions that convert a string to a custom type.

type MyDB struct {
	*sql.DB
}

myDB wraps a sql.DB connection pool.

func NewDB(dataSourceName string) (*MyDB, error)

NewDB initializes a new database connection.

func (db *MyDB) Begin() (*sql.Tx, error)

Begin starts a new database transaction.

func (db *MyDB) BulkInsert(table string, data []map[string]interface{}) (sql.Result, error)

BulkInsert inserts multiple rows into the specified table.

func (db *MyDB) BulkUpdate(table string, data []map[string]interface{}, key string) error

BulkUpdate updates multiple rows in the specified table based on the key column.

func (db *MyDB) Get(dest interface{}, query string, args ...interface{}) error

Get executes a query and scans the first row into the destination struct.

func (db *MyDB) In(query string, args ...interface{}) (string, []interface{}, error)

In expands slice arguments for SQL IN queries.

func (db *MyDB) NamedExec(query string, arg map[string]interface{}) (sql.Result, error)

NamedExec executes a named query with the provided arguments.

func (db *MyDB) Select(dest interface{}, query string, args ...interface{}) error

Select executes a query and scans all rows into the destination slice.