From 698a6379f5249a8f496d1897cddaebec39be7fb4 Mon Sep 17 00:00:00 2001
From: Noah Hilverling <noah.hilverling@icinga.com>
Date: Fri, 22 Mar 2019 11:22:04 +0100
Subject: [PATCH] SqlFetchIds(): Use envId

---
 mysql.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/mysql.go b/mysql.go
index dda19fd6..b49aa427 100644
--- a/mysql.go
+++ b/mysql.go
@@ -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) {