database

Mar 28, 2023

Changes in this version

type DB

+ DoesTableExist func(schema, table string) (exist bool)

type PgxDB

+ func (db *PgxDB) DoesTableExist(schema, table string) (exist bool)

Feb 15, 2023

Changes in this version

type DB

+ GetPGConn func() (Conn *pgxpool.Pool, err error)

type PgxDB

+ func (db *PgxDB) GetPGConn() (Conn *pgxpool.Pool, err error)

Feb 15, 2023

Changes in this version

+ var ErrCouldNotBeCreated = errors.New("could not be created in DB")

+ var ErrNoRecordFound = errors.New("record not found")

+ func GetErrorF(errMsg string, err error) error

+ type DB interface

+ Close func()

+ ExecActionQuery func(sql string, arguments ...interface{}) (rowsAffected int, err error)

+ GetQueryBool func(sql string, arguments ...interface{}) (result bool, err error)

+ GetQueryInt func(sql string, arguments ...interface{}) (result int, err error)

+ GetQueryString func(sql string, arguments ...interface{}) (result string, err error)

+ GetVersion func() (result string, err error)

+ Insert func(sql string, arguments ...interface{}) (lastInsertId int, err error)

+ func GetInstance(dbDriver, dbConnectionString string, maxConnectionCount int, log *log.Logger) (DB, error)

+ type PgxDB struct

+ Conn *pgxpool.Pool

+ func (db *PgxDB) Close()

+ func (db *PgxDB) ExecActionQuery(sql string, arguments ...interface{}) (rowsAffected int, err error)

+ func (db *PgxDB) GetQueryBool(sql string, arguments ...interface{}) (result bool, err error)

+ func (db *PgxDB) GetQueryInt(sql string, arguments ...interface{}) (result int, err error)

+ func (db *PgxDB) GetQueryString(sql string, arguments ...interface{}) (result string, err error)

+ func (db *PgxDB) GetVersion() (result string, err error)

+ func (db *PgxDB) Insert(sql string, arguments ...interface{}) (lastInsertId int, err error)