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

SqlFetchIds(): Use envId

Browse source
This commit is contained in:
Noah Hilverling 2019-03-22 11:22:04 +01:00
parent 2265c22041
commit 698a6379f5
1 changed files with 2 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
mysql.go
View file

@ -530,7 +530,7 @@ func (dbw *DBWrapper) sqlTryTransaction(f func(transaction DbTransaction) error,
return dbw.SqlCommit(tx, quiet)
}
func (dbw *DBWrapper) SqlFetchIds(table string) ([]string, error) {
func (dbw *DBWrapper) SqlFetchIds(envId []byte, table string) ([]string, error) {
var keys []string
for {
if !dbw.IsConnected() {
@ -538,7 +538,7 @@ func (dbw *DBWrapper) SqlFetchIds(table string) ([]string, error) {
continue
}
rows, err := dbw.SqlQuery(fmt.Sprintf("SELECT id FROM %s", table))
rows, err := dbw.SqlQuery(fmt.Sprintf("SELECT id FROM %s WHERE env_id='X%s'", table, icingadb_utils.DecodeChecksum(envId)))
if err != nil {
if !dbw.checkConnection(false) {