database

Documentation

Index

• func GetSqlError(err error) error
• func ManageUpdateError(callerName string, result sql.Result, err error) error
• type Connection
• type DbPool
  • func CreateDbPool(user, password, databaseName, host string, port, timeout uint16) (*DbPool, error)
  • func (d *DbPool) BeginEnhacedTx() (*EnhacedTx, error)
  • func (d *DbPool) BeginTx() (*sql.Tx, error)
  • func (d *DbPool) Close()
  • func (d *DbPool) GetConnection() *sql.DB
• type EnhacedTx
  • func (v *EnhacedTx) Commit() error
  • func (v *EnhacedTx) Exec(query string, args ...any) (sql.Result, error)
  • func (v *EnhacedTx) ForceClose() error
  • func (v *EnhacedTx) IsActive() bool
  • func (v *EnhacedTx) Query(query string, args ...any) (*sql.Rows, error)
  • func (v *EnhacedTx) QueryRow(query string, args ...any) *sql.Row
  • func (v *EnhacedTx) Rollback() error

Functions

func GetSqlError

func GetSqlError(err error) error

func ManageUpdateError

func ManageUpdateError(callerName string, result sql.Result, err error) error

Manages the possible error coming for an update execution and returns the database error if exists. If not, it checks if any row has been affected and returns err if nothing has been updated.

  params

	'callerName' is the name of the caller function, it is used in log message
	'result' is the sql.Result returned by Exec function
	'err' is the error returned by Exec function

Types

type Connection

type Connection interface {
	Exec(query string, args ...interface{}) (sql.Result, error)
	Query(query string, args ...interface{}) (*sql.Rows, error)
	QueryRow(query string, args ...interface{}) *sql.Row
}

type DbPool

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

func CreateDbPool

func CreateDbPool(user, password, databaseName, host string, port, timeout uint16) (*DbPool, error)

CreateDbPool creates the DB connections pool. time out must be in seconds

func (*DbPool) BeginEnhacedTx

func (d *DbPool) BeginEnhacedTx() (*EnhacedTx, error)

Returns a new Enhaced Improved Transaction

func (*DbPool) BeginTx

func (d *DbPool) BeginTx() (*sql.Tx, error)

Returns a new Transaction

func (*DbPool) Close

func (d *DbPool) Close()

Close closes de DB connection

func (*DbPool) GetConnection

func (d *DbPool) GetConnection() *sql.DB

Gets the DB connection

type EnhacedTx

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

func (*EnhacedTx) Commit

func (v *EnhacedTx) Commit() error

Commit commits the transaction

func (*EnhacedTx) Exec

func (v *EnhacedTx) Exec(query string, args ...any) (sql.Result, error)

Exec executes a query that doesn't return rows. For example: an INSERT and UPDATE.

func (*EnhacedTx) ForceClose

func (v *EnhacedTx) ForceClose() error

ForceClose closes and aborts the transaction

func (*EnhacedTx) IsActive

func (v *EnhacedTx) IsActive() bool

IsOpen returns true if the transaction is still active

func (*EnhacedTx) Query

func (v *EnhacedTx) Query(query string, args ...any) (*sql.Rows, error)

Query executes a query that returns rows, typically a SELECT.

func (*EnhacedTx) QueryRow

func (v *EnhacedTx) QueryRow(query string, args ...any) *sql.Row

QueryRow executes a query that is expected to return at most one row. QueryRow always returns a non-nil value. Errors are deferred until [Row]'s Scan method is called.

func (*EnhacedTx) Rollback

func (v *EnhacedTx) Rollback() error

Rollback aborts the transaction