postgres

Documentation

Index

• Variables
• func NewPGXPostgresqlDB(cfg config.PGXDbConfig) (db ports.IBaseDb, err error)
• func NewPQPostgresqlDB(cfg config.PQDbConfig) (db ports.IBaseDb, err error)
• func NewSQLXPostgresqlDB(cfg config.SQLXDbConfig) (db ports.IBaseDb, err error)
• type PgxDb
  • func (s *PgxDb) Delete(query string, dat ...interface{}) (rows_affected int64, err error)
  • func (s *PgxDb) Exec(query string, dat ...interface{}) (rows_affected int64, err error)
  • func (s *PgxDb) Insert(query string, dat ...interface{}) (data int64, err error)
  • func (s *PgxDb) Select(query string, dat ...interface{}) (data []byte, err error)
  • func (s *PgxDb) Update(query string, dat ...interface{}) (rows_affected int64, err error)
• type SqlDb
  • func (s *SqlDb) Delete(query string, dat ...interface{}) (rows_affected int64, err error)
  • func (s *SqlDb) Exec(query string, dat ...interface{}) (rows_affected int64, err error)
  • func (s *SqlDb) Insert(query string, dat ...interface{}) (data int64, err error)
  • func (s *SqlDb) Select(query string, dat ...interface{}) (data []byte, err error)
  • func (s *SqlDb) Update(query string, dat ...interface{}) (rows_affected int64, err error)
• type SqlxDb
  • func (s *SqlxDb) Delete(query string, dat ...interface{}) (rows_affected int64, err error)
  • func (s *SqlxDb) Exec(query string, dat ...interface{}) (rows_affected int64, err error)
  • func (s *SqlxDb) Insert(query string, dat ...interface{}) (data int64, err error)
  • func (s *SqlxDb) Select(query string, dat ...interface{}) (data []byte, err error)
  • func (s *SqlxDb) Update(query string, dat ...interface{}) (rows_affected int64, err error)

Variables

var (
	ConnStr string
)

var (
	PQConnStr string
)

var (
	SQLXConnStr string
)

Functions

func NewPGXPostgresqlDB

func NewPGXPostgresqlDB(cfg config.PGXDbConfig) (db ports.IBaseDb, err error)

NewPGXPostgresqlDB Return new Postgresql client

func NewPQPostgresqlDB

func NewPQPostgresqlDB(cfg config.PQDbConfig) (db ports.IBaseDb, err error)

NewPQPostgresqlDB Return new Postgresql client

func NewSQLXPostgresqlDB

func NewSQLXPostgresqlDB(cfg config.SQLXDbConfig) (db ports.IBaseDb, err error)

NewSQLXPostgresqlDB Return new Postgresql client

Types

type PgxDb

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

func (*PgxDb) Delete

func (s *PgxDb) Delete(query string, dat ...interface{}) (rows_affected int64, err error)

func (*PgxDb) Exec

func (s *PgxDb) Exec(query string, dat ...interface{}) (rows_affected int64, err error)

func (*PgxDb) Insert

func (s *PgxDb) Insert(query string, dat ...interface{}) (data int64, err error)

func (*PgxDb) Select

func (s *PgxDb) Select(query string, dat ...interface{}) (data []byte, err error)

func (*PgxDb) Update

func (s *PgxDb) Update(query string, dat ...interface{}) (rows_affected int64, err error)

type SqlDb

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

func (*SqlDb) Delete

func (s *SqlDb) Delete(query string, dat ...interface{}) (rows_affected int64, err error)

func (*SqlDb) Exec

func (s *SqlDb) Exec(query string, dat ...interface{}) (rows_affected int64, err error)

func (*SqlDb) Insert

func (s *SqlDb) Insert(query string, dat ...interface{}) (data int64, err error)

func (*SqlDb) Select

func (s *SqlDb) Select(query string, dat ...interface{}) (data []byte, err error)

func (*SqlDb) Update

func (s *SqlDb) Update(query string, dat ...interface{}) (rows_affected int64, err error)

type SqlxDb

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

func (*SqlxDb) Delete

func (s *SqlxDb) Delete(query string, dat ...interface{}) (rows_affected int64, err error)

func (*SqlxDb) Exec

func (s *SqlxDb) Exec(query string, dat ...interface{}) (rows_affected int64, err error)

func (*SqlxDb) Insert

func (s *SqlxDb) Insert(query string, dat ...interface{}) (data int64, err error)

func (*SqlxDb) Select

func (s *SqlxDb) Select(query string, dat ...interface{}) (data []byte, err error)

func (*SqlxDb) Update

func (s *SqlxDb) Update(query string, dat ...interface{}) (rows_affected int64, err error)