upstream/icingadb
1
0
Fork 0
mirror of https://github.com/Icinga/icingadb.git synced 2026-05-28 04:35:54 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Drop unused SqlFetchAll*()

Browse source
This commit is contained in:
Alexander A. Klimov 2021-02-17 16:26:09 +01:00
parent 22a727cb19
commit 5c8a012ceb
1 changed files with 1 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
connection/mysql.go
View file

@ -60,7 +60,7 @@ var connectionErrors = []string{
"operation timed out",
}
// DbClientOrTransaction is used in SqlFetchAll and SqlFetchAllQuiet.
// DbClientOrTransaction abstracts database connections and transactions.
type DbClientOrTransaction interface {
Query(query string, args ...interface{}) (*sql.Rows, error)
Exec(query string, args ...interface{}) (sql.Result, error)
@ -357,18 +357,10 @@ func (dbw *DBWrapper) SqlFetchAll(queryObserver prometheus.Observer, query strin
return dbw.sqlFetchAllInternal(dbw.Db, queryObserver, query, false, args...)
}
func (dbw *DBWrapper) SqlFetchAllQuiet(queryObserver prometheus.Observer, query string, args ...interface{}) ([][]interface{}, error) {
return dbw.sqlFetchAllInternal(dbw.Db, queryObserver, query, true, args...)
}
func (dbw *DBWrapper) SqlFetchAllTx(tx DbTransaction, queryObserver prometheus.Observer, query string, args ...interface{}) ([][]interface{}, error) {
return dbw.sqlFetchAllInternal(tx, queryObserver, query, false, args...)
}
func (dbw *DBWrapper) SqlFetchAllTxQuiet(tx DbTransaction, queryObserver prometheus.Observer, query string, args ...interface{}) ([][]interface{}, error) {
return dbw.sqlFetchAllInternal(tx, queryObserver, query, true, args...)
}
// sqlExecInternal is a wrapper around sql.Exec() for auto-logging.
func (dbw *DBWrapper) sqlExecInternal(db DbClientOrTransaction, opObserver prometheus.Observer, query string, quiet bool, args ...interface{}) (sql.Result, error) {
for {