Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

postgres

package

Go to main page

Versions in this module

v1

v1.0.10

Sep 23, 2021

Changes in this version

+ func AddDatabaseToPool(name string, DB *sqlx.DB)

+ func ClearStmt()

+ func Get() (*sqlx.DB, error)

+ func GetDatabase() string

+ func GetPool() *connection.Pool

+ func GetURI(DBName string) string

+ func Load()

+ func MustGet() *sqlx.DB

+ func NormalizeGroupFunction(paramValue string) (groupFuncSQL string, err error)

+ func Prepare(db *sqlx.DB, SQL string) (stmt *sql.Stmt, err error)

+ func PrepareTx(tx *sql.Tx, SQL string) (stmt *sql.Stmt, err error)

+ func SetDatabase(name string)

+ type Postgres struct

+ func (adapter *Postgres) BatchInsertCopy(dbname, schema, table string, keys []string, values ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) BatchInsertValues(SQL string, values ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) CountByRequest(req *http.Request) (countQuery string, err error)

+ func (adapter *Postgres) DatabaseClause(req *http.Request) (query string, hasCount bool)

+ func (adapter *Postgres) DatabaseOrderBy(order string, hasCount bool) (orderBy string)

+ func (adapter *Postgres) DatabaseWhere(requestWhere string) (whereSyntax string)

+ func (adapter *Postgres) Delete(SQL string, params ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) DeleteSQL(database string, schema string, table string) string

+ func (adapter *Postgres) DeleteWithTransaction(tx *sql.Tx, SQL string, params ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) DistinctClause(r *http.Request) (distinctQuery string, err error)

+ func (adapter *Postgres) ExecuteScripts(method, sql string, values []interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) FieldsPermissions(r *http.Request, table string, op string) (fields []string, err error)

+ func (adapter *Postgres) GetDatabase() string

+ func (adapter *Postgres) GetScript(verb, folder, scriptName string) (script string, err error)

+ func (adapter *Postgres) GetTransaction() (tx *sql.Tx, err error)

+ func (adapter *Postgres) GroupByClause(r *http.Request) (groupBySQL string)

+ func (adapter *Postgres) Insert(SQL string, params ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) InsertSQL(database string, schema string, table string, names string, ...) string

+ func (adapter *Postgres) InsertWithTransaction(tx *sql.Tx, SQL string, params ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) JoinByRequest(r *http.Request) (values []string, err error)

+ func (adapter *Postgres) OrderByRequest(r *http.Request) (values string, err error)

+ func (adapter *Postgres) PaginateIfPossible(r *http.Request) (paginatedQuery string, err error)

+ func (adapter *Postgres) ParseBatchInsertRequest(r *http.Request) (colsName string, placeholders string, values []interface{}, err error)

+ func (adapter *Postgres) ParseInsertRequest(r *http.Request) (colsName string, colsValue string, values []interface{}, err error)

+ func (adapter *Postgres) ParseScript(scriptPath string, templateData map[string]interface{}) (sqlQuery string, values []interface{}, err error)

+ func (adapter *Postgres) Query(SQL string, params ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) QueryCount(SQL string, params ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) ReturningByRequest(r *http.Request) (returningSyntax string, err error)

+ func (adapter *Postgres) SchemaClause(req *http.Request) (query string, hasCount bool)

+ func (adapter *Postgres) SchemaOrderBy(order string, hasCount bool) (orderBy string)

+ func (adapter *Postgres) SchemaTablesClause() (query string)

+ func (adapter *Postgres) SchemaTablesOrderBy(order string) (orderBy string)

+ func (adapter *Postgres) SchemaTablesWhere(requestWhere string) (whereSyntax string)

+ func (adapter *Postgres) SelectFields(fields []string) (sql string, err error)

+ func (adapter *Postgres) SelectSQL(selectStr string, database string, schema string, table string) string

+ func (adapter *Postgres) SetByRequest(r *http.Request, initialPlaceholderID int) (setSyntax string, values []interface{}, err error)

+ func (adapter *Postgres) SetDatabase(name string)

+ func (adapter *Postgres) ShowTable(schema, table string) adapters.Scanner

+ func (adapter *Postgres) TableClause() (query string)

+ func (adapter *Postgres) TableOrderBy(order string) (orderBy string)

+ func (adapter *Postgres) TablePermissions(table string, op string) (access bool)

+ func (adapter *Postgres) TableWhere(requestWhere string) (whereSyntax string)

+ func (adapter *Postgres) Update(SQL string, params ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) UpdateSQL(database string, schema string, table string, setSyntax string) string

+ func (adapter *Postgres) UpdateWithTransaction(tx *sql.Tx, SQL string, params ...interface{}) (sc adapters.Scanner)

+ func (adapter *Postgres) WhereByRequest(r *http.Request, initialPlaceholderID int) (whereSyntax string, values []interface{}, err error)

+ type Stmt struct

+ Mtx *sync.Mutex

+ PrepareMap map[string]*sql.Stmt

+ func GetStmt() *Stmt

+ func (s *Stmt) Prepare(db *sqlx.DB, tx *sql.Tx, SQL string) (statement *sql.Stmt, err error)

v0

v0.2.0

Jun 16, 2017

Changes in this version

+ var ErrBodyEmpty = errors.New("body is empty")

+ func ParseInsertRequest(r *http.Request) (colsName string, colsValue string, values []interface{}, err error)

+ func SetByRequest(r *http.Request, initialPlaceholderID int) (setSyntax string, values []interface{}, err error)

v0.1.7

May 6, 2017

v0.1.6

Mar 21, 2017

v0.1.5

Mar 18, 2017

v0.1.4

Mar 11, 2017

v0.1.3

Mar 7, 2017

v0.1.2

Feb 26, 2017

v0.1.1

Feb 7, 2017

Changes in this version

+ func ColumnsByRequest(r *http.Request) []string

+ func CountByRequest(req *http.Request) (countQuery string, err error)

+ func DatabaseClause(req *http.Request) (query string)

+ func Delete(database, schema, table, where string, whereValues []interface{}) (jsonData []byte, err error)

+ func ExecuteScripts(method, sql string, values []interface{}) (result []byte, err error)

+ func FieldsPermissions(table string, cols []string, op string) []string

+ func GetQueryOperator(op string) (string, error)

+ func GetScript(verb, folder, scriptName string) (script string, err error)

+ func Insert(database, schema, table string, body api.Request) (jsonData []byte, err error)

+ func JoinByRequest(r *http.Request) (values []string, err error)

+ func OrderByRequest(r *http.Request) (values string, err error)

+ func PaginateIfPossible(r *http.Request) (paginatedQuery string, err error)

+ func ParseScript(scriptPath string, queryURL url.Values) (sqlQuery string, values []interface{}, err error)

+ func Query(SQL string, params ...interface{}) (jsonData []byte, err error)

+ func QueryCount(SQL string, params ...interface{}) ([]byte, error)

+ func SchemaClause(req *http.Request) (query string)

+ func SelectFields(fields []string) (sql string, err error)

+ func TablePermissions(table string, op string) bool

+ func Update(database, schema, table, where string, whereValues []interface{}, ...) (jsonData []byte, err error)

+ func WhereByRequest(r *http.Request, initialPlaceholderID int) (whereSyntax string, values []interface{}, err error)

+ func WriteSQL(sql string, values []interface{}) (resultByte []byte, err error)