2c3a2e9235
* add query builder to facilitate dynamic SQL construction * leverage query builder to refactor user store This is partially setup work for MM-13120, but merged to master to avoid further conflicts. * fix unrelated unit test breakage * documentation tweaks * Apply suggestions from code review Co-Authored-By: lieut-data <jesse.hallam@gmail.com> * prefer comma separated case options to fallthrough * vendor github.com/Masterminds/squirrel and deps * switch to using github.com/Masterminds/squirrel * rm querybuilder
86 строки
1.7 KiB
Go
86 строки
1.7 KiB
Go
package squirrel
|
|
|
|
import (
|
|
"database/sql"
|
|
"sync"
|
|
)
|
|
|
|
// Prepareer is the interface that wraps the Prepare method.
|
|
//
|
|
// Prepare executes the given query as implemented by database/sql.Prepare.
|
|
type Preparer interface {
|
|
Prepare(query string) (*sql.Stmt, error)
|
|
}
|
|
|
|
// DBProxy groups the Execer, Queryer, QueryRower, and Preparer interfaces.
|
|
type DBProxy interface {
|
|
Execer
|
|
Queryer
|
|
QueryRower
|
|
Preparer
|
|
}
|
|
|
|
// NOTE: NewStmtCacher is defined in stmtcacher_ctx.go (Go >= 1.8) or stmtcacher_noctx.go (Go < 1.8).
|
|
|
|
type stmtCacher struct {
|
|
prep Preparer
|
|
cache map[string]*sql.Stmt
|
|
mu sync.Mutex
|
|
}
|
|
|
|
func (sc *stmtCacher) Prepare(query string) (*sql.Stmt, error) {
|
|
sc.mu.Lock()
|
|
defer sc.mu.Unlock()
|
|
stmt, ok := sc.cache[query]
|
|
if ok {
|
|
return stmt, nil
|
|
}
|
|
stmt, err := sc.prep.Prepare(query)
|
|
if err == nil {
|
|
sc.cache[query] = stmt
|
|
}
|
|
return stmt, err
|
|
}
|
|
|
|
func (sc *stmtCacher) Exec(query string, args ...interface{}) (res sql.Result, err error) {
|
|
stmt, err := sc.Prepare(query)
|
|
if err != nil {
|
|
return
|
|
}
|
|
return stmt.Exec(args...)
|
|
}
|
|
|
|
func (sc *stmtCacher) Query(query string, args ...interface{}) (rows *sql.Rows, err error) {
|
|
stmt, err := sc.Prepare(query)
|
|
if err != nil {
|
|
return
|
|
}
|
|
return stmt.Query(args...)
|
|
}
|
|
|
|
func (sc *stmtCacher) QueryRow(query string, args ...interface{}) RowScanner {
|
|
stmt, err := sc.Prepare(query)
|
|
if err != nil {
|
|
return &Row{err: err}
|
|
}
|
|
return stmt.QueryRow(args...)
|
|
}
|
|
|
|
type DBProxyBeginner interface {
|
|
DBProxy
|
|
Begin() (*sql.Tx, error)
|
|
}
|
|
|
|
type stmtCacheProxy struct {
|
|
DBProxy
|
|
db *sql.DB
|
|
}
|
|
|
|
func NewStmtCacheProxy(db *sql.DB) DBProxyBeginner {
|
|
return &stmtCacheProxy{DBProxy: NewStmtCacher(db), db: db}
|
|
}
|
|
|
|
func (sp *stmtCacheProxy) Begin() (*sql.Tx, error) {
|
|
return sp.db.Begin()
|
|
}
|