database

Documentation

Index

• func CheckDSN(driver, dsn, dbName, dbHost, dbPort, dbUser, dbPass string) string
• func CheckDriver(driver string) string
• func Connect(driver, dsn string) (interface{}, error)
• func DefaultPorts() map[string]string
• func PGXConnect(dsn string) (*pgx.Conn, error)
• func PGXExec(db *pgx.Conn, ctx context.Context, query string, args ...interface{}) (pgconn.CommandTag, error)
• func PGXExecNoResult(db *pgx.Conn, ctx context.Context, query string, args ...interface{}) error
• func PGXQuery(db *pgx.Conn, ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)
• func PGXQueryRow(db *pgx.Conn, ctx context.Context, query string, args ...interface{}) pgx.Row
• func SQLConnect(driver, dsn string) (*sql.DB, error)
• func SQLExec(db *sql.DB, ctx context.Context, query string, args ...interface{}) (sql.Result, error)
• func SQLExecNoResult(db *sql.DB, ctx context.Context, query string, args ...interface{}) error
• func SQLQuery(db *sql.DB, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
• func SQLQueryRow(db *sql.DB, ctx context.Context, query string, args ...interface{}) *sql.Row
• func SetDBDriver(driver string, usePgx bool) string
• func SupportedDrivers() []string
• type DB
  • func New() DB
  • func (d *DB) CheckDriver()
  • func (d *DB) Close() error
  • func (d *DB) Exec(ctx context.Context, query string, args ...interface{}) (interface{}, error)
  • func (d *DB) ExecNoResult(ctx context.Context, query string, args ...interface{}) error
  • func (d *DB) Open(dsn string) error
  • func (d *DB) PGXNew(db *pgx.Conn)
  • func (d *DB) Pgx() *pgx.Conn
  • func (d *DB) PgxClose() error
  • func (d *DB) PgxExec(ctx context.Context, query string, args ...interface{}) (pgconn.CommandTag, error)
  • func (d *DB) PgxExecNoResult(ctx context.Context, query string, args ...interface{}) error
  • func (d *DB) PgxOpen(dsn string) error
  • func (d *DB) PgxQuery(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)
  • func (d *DB) PgxQueryRow(ctx context.Context, query string, args ...interface{}) pgx.Row
  • func (d *DB) Query(ctx context.Context, query string, args ...interface{}) (interface{}, error)
  • func (d *DB) QueryRow(ctx context.Context, query string, args ...interface{}) interface{}
  • func (d *DB) SetDB(db interface{}, driver string)
  • func (d *DB) SetDSN(driver, dsn, dbName, dbHost, dbPort, dbUser, dbPass string) string
  • func (d *DB) SetDriver(driver string, usePgx bool)
  • func (d *DB) Sql() *sql.DB
  • func (d *DB) SqlClose() error
  • func (d *DB) SqlExec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
  • func (d *DB) SqlExecNoResult(ctx context.Context, query string, args ...interface{}) error
  • func (d *DB) SqlNew(db *sql.DB, driver string)
  • func (d *DB) SqlOpen(driver, dsn string) error
  • func (d *DB) SqlQuery(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
  • func (d *DB) SqlQueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row

Functions

func CheckDSN

func CheckDSN(driver, dsn, dbName, dbHost, dbPort, dbUser, dbPass string) string

func CheckDriver

func CheckDriver(driver string) string

checks

func Connect

func Connect(driver, dsn string) (interface{}, error)

func DefaultPorts

func DefaultPorts() map[string]string

func PGXConnect

func PGXConnect(dsn string) (*pgx.Conn, error)

func PGXExec

func PGXExec(db *pgx.Conn, ctx context.Context, query string, args ...interface{}) (pgconn.CommandTag, error)

func PGXExecNoResult

func PGXExecNoResult(db *pgx.Conn, ctx context.Context, query string, args ...interface{}) error

func PGXQuery

func PGXQuery(db *pgx.Conn, ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)

func PGXQueryRow

func PGXQueryRow(db *pgx.Conn, ctx context.Context, query string, args ...interface{}) pgx.Row

func SQLConnect

func SQLConnect(driver, dsn string) (*sql.DB, error)

Connect to database

func SQLExec

func SQLExec(db *sql.DB, ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func SQLExecNoResult

func SQLExecNoResult(db *sql.DB, ctx context.Context, query string, args ...interface{}) error

func SQLQuery

func SQLQuery(db *sql.DB, ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func SQLQueryRow

func SQLQueryRow(db *sql.DB, ctx context.Context, query string, args ...interface{}) *sql.Row

func SetDBDriver

func SetDBDriver(driver string, usePgx bool) string

func SupportedDrivers

func SupportedDrivers() []string

Types

type DB

type DB struct {
	Driver string
	UsePgx bool
	// contains filtered or unexported fields
}

func New

func New() DB

All databases will use the sql.DB interface unless pgx is specified pgx is a PostgreSQL driver that is more efficient than the standard sql.DB pgx will be used if the driver is set to "pgx" or "postgres" and pgxNew is called

func (*DB) CheckDriver

func (d *DB) CheckDriver()

func (*DB) Close

func (d *DB) Close() error

func (*DB) Exec

func (d *DB) Exec(ctx context.Context, query string, args ...interface{}) (interface{}, error)

func (*DB) ExecNoResult

func (d *DB) ExecNoResult(ctx context.Context, query string, args ...interface{}) error

func (*DB) Open

func (d *DB) Open(dsn string) error

func (*DB) PGXNew

func (d *DB) PGXNew(db *pgx.Conn)

func (*DB) Pgx

func (d *DB) Pgx() *pgx.Conn

func (*DB) PgxClose

func (d *DB) PgxClose() error

func (*DB) PgxExec

func (d *DB) PgxExec(ctx context.Context, query string, args ...interface{}) (pgconn.CommandTag, error)

func (*DB) PgxExecNoResult

func (d *DB) PgxExecNoResult(ctx context.Context, query string, args ...interface{}) error

func (*DB) PgxOpen

func (d *DB) PgxOpen(dsn string) error

func (*DB) PgxQuery

func (d *DB) PgxQuery(ctx context.Context, query string, args ...interface{}) (pgx.Rows, error)

func (*DB) PgxQueryRow

func (d *DB) PgxQueryRow(ctx context.Context, query string, args ...interface{}) pgx.Row

func (*DB) Query

func (d *DB) Query(ctx context.Context, query string, args ...interface{}) (interface{}, error)

func (*DB) QueryRow

func (d *DB) QueryRow(ctx context.Context, query string, args ...interface{}) interface{}

func (*DB) SetDB

func (d *DB) SetDB(db interface{}, driver string)

func (*DB) SetDSN

func (d *DB) SetDSN(driver, dsn, dbName, dbHost, dbPort, dbUser, dbPass string) string

func (*DB) SetDriver

func (d *DB) SetDriver(driver string, usePgx bool)

func (*DB) Sql

func (d *DB) Sql() *sql.DB

func (*DB) SqlClose

func (d *DB) SqlClose() error

func (*DB) SqlExec

func (d *DB) SqlExec(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

func (*DB) SqlExecNoResult

func (d *DB) SqlExecNoResult(ctx context.Context, query string, args ...interface{}) error

func (*DB) SqlNew

func (d *DB) SqlNew(db *sql.DB, driver string)

func (*DB) SqlOpen

func (d *DB) SqlOpen(driver, dsn string) error

func (*DB) SqlQuery

func (d *DB) SqlQuery(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

func (*DB) SqlQueryRow

func (d *DB) SqlQueryRow(ctx context.Context, query string, args ...interface{}) *sql.Row