Skip to content

Commit d0aacfd

Browse files
committed
one more spot
1 parent 9b92ad7 commit d0aacfd

File tree

1 file changed

+13
-11
lines changed

1 file changed

+13
-11
lines changed

controller/PostgreSQL.cpp

Lines changed: 13 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -485,18 +485,20 @@ void PostgreSQL::initializeMembers(PGconn *conn)
485485
deletes.insert(key);
486486
}
487487

488-
if (_rc->clusterMode) {
489-
auto tx = _cluster->transaction(_myAddressStr, true);
490-
for (std::string k : deletes) {
491-
tx.del(k);
492-
}
493-
tx.exec();
494-
} else {
495-
auto tx = _redis->transaction(true);
496-
for (std::string k : deletes) {
497-
tx.del(k);
488+
if (!deletes.empty()) {
489+
if (_rc->clusterMode) {
490+
auto tx = _cluster->transaction(_myAddressStr, true);
491+
for (std::string k : deletes) {
492+
tx.del(k);
493+
}
494+
tx.exec();
495+
} else {
496+
auto tx = _redis->transaction(true);
497+
for (std::string k : deletes) {
498+
tx.del(k);
499+
}
500+
tx.exec();
498501
}
499-
tx.exec();
500502
}
501503
}
502504

0 commit comments

Comments
 (0)