database

package

v0.0.0-...-6ee99b5 Latest Latest Go to latest Published: Jan 23, 2022 License: Apache-2.0 Imports: 4 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/niroopreddym/caymanislandsquerybuilder

Links

Open Source Insights

Documentation ¶

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	// DB : for the database at the global space
	DB *pgx.Conn
	// ReaderConnectionString ...
	ReaderConnectionString string
	// WriterConnectionString ...
	WriterConnectionString string
)

Functions ¶

func SetConnectionStrings ¶

func SetConnectionStrings()

SetConnectionStrings ...

Types ¶

type DBHandler ¶

type DBHandler struct {
	DatabaseService DbIface
}

DBHandler provides the class implementation for DbIface interface

func DBNewHandler ¶

func DBNewHandler() *DBHandler

DBNewHandler ...

func (DBHandler) CreateConnection ¶

func (dbService DBHandler) CreateConnection(connectionString string) (*pgx.Conn, error)

CreateConnection : Creates the Connection

func (DBHandler) DbClose ¶

func (dbService DBHandler) DbClose()

DbClose : Close the DB connectivity.

func (DBHandler) DbExecuteConflict ¶

func (dbService DBHandler) DbExecuteConflict(query string, args ...interface{}) error

DbExecuteConflict : To check foreign key violations...

func (DBHandler) DbExecuteQuery ¶

func (dbService DBHandler) DbExecuteQuery(query string) (int64, error)

DbExecuteQuery : To execute queries.

func (DBHandler) DbExecuteScalar ¶

func (dbService DBHandler) DbExecuteScalar(query string, args ...interface{}) (pgx.Rows, error)

DbExecuteScalar : To insert/update records.

func (DBHandler) DbGetMultipleRow ¶

func (dbService DBHandler) DbGetMultipleRow(query string, args ...interface{}) (pgx.Rows, error)

DbGetMultipleRow : To fetch multiple records.

func (DBHandler) DbGetSingleRow ¶

func (dbService DBHandler) DbGetSingleRow(query string) (pgx.Row, error)

DbGetSingleRow : To get a single record.

func (DBHandler) DbWriter ¶

func (dbService DBHandler) DbWriter(query string) error

DbWriter : To insert/update records in the database.

func (DBHandler) InitDbReader ¶

func (dbService DBHandler) InitDbReader() (*pgx.Conn, error)

InitDbReader : for the database at the global space

func (DBHandler) InitDbWriter ¶

func (dbService DBHandler) InitDbWriter() (*pgx.Conn, error)

InitDbWriter : for the database at the global space

func (DBHandler) TxBegin ¶

func (dbService DBHandler) TxBegin() (pgx.Tx, error)

TxBegin : To begin transaction.

func (DBHandler) TxComplete ¶

func (dbService DBHandler) TxComplete(tx pgx.Tx) error

TxComplete : Save Changes to the Database.

func (DBHandler) TxExecuteStmt ¶

func (dbService DBHandler) TxExecuteStmt(tx pgx.Tx, query string, args ...interface{}) (pgconn.CommandTag, error)

TxExecuteStmt : Executes the Query. Usually an INSERT/UPDATE.

func (DBHandler) TxQuery ¶

func (dbService DBHandler) TxQuery(tx pgx.Tx, query string) (pgx.Rows, error)

TxQuery : To execute a query and fetch rows. This will typically perform an insert & select (or) a plain select.

type DbIface ¶

type DbIface interface {
	TxBegin() (pgx.Tx, error)
	InitDbReader() (*pgx.Conn, error)
	InitDbWriter() (*pgx.Conn, error)
	CreateConnection(connstring string) (*pgx.Conn, error)
	TxQuery(tx pgx.Tx, query string) (pgx.Rows, error)
	DbGetMultipleRow(query string, args ...interface{}) (pgx.Rows, error)
	DbExecuteQuery(query string) (int64, error)
	DbExecuteScalar(query string, args ...interface{}) (pgx.Rows, error)
	DbExecuteConflict(query string, args ...interface{}) error
	DbWriter(query string) error
	TxExecuteStmt(tx pgx.Tx, query string, args ...interface{}) (pgconn.CommandTag, error)
	TxComplete(tx pgx.Tx) error
	DbClose()
}

DbIface exposes db interconnection methods

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL