DK101010 commented on a change in pull request #4399:
URL: https://github.com/apache/cloudstack/pull/4399#discussion_r504465881
##########
File path: engine/schema/src/main/java/com/cloud/host/dao/HostDaoImpl.java
##########
@@ -1147,27 +1155,68 @@ public HostVO findByIp(final String ipAddress) {
}
@Override
- public List<Long> listClustersByHostTag(String hostTagOnOffering) {
+ public List<Long> listClustersByHostTag(String computeOfferingTags) {
TransactionLegacy txn = TransactionLegacy.currentTxn();
+ String sql = this.LIST_CLUSTERID_FOR_HOST_TAG;
PreparedStatement pstmt = null;
- List<Long> result = new ArrayList<Long>();
- StringBuilder sql = new StringBuilder(LIST_CLUSTERID_FOR_HOST_TAG);
- // during listing the clusters that cross the threshold
- // we need to check with disabled thresholds of each cluster if not
defined at cluster consider the global value
+ List<Long> result = new ArrayList();
+ List<String> tags =
Arrays.asList(computeOfferingTags.split(this.SEPARATOR));
+ String subselect = getHostIdsByComputeTags(tags);
+ sql = String.format(sql, subselect);
+
try {
- pstmt = txn.prepareAutoCloseStatement(sql.toString());
- pstmt.setString(1, hostTagOnOffering);
+ pstmt = txn.prepareStatement(sql);
+
+ for(int i = 0; i < tags.size(); i++){
+ pstmt.setString(i+1, tags.get(i));
+ }
+ //pstmt = txn.prepareAutoCloseStatement();
ResultSet rs = pstmt.executeQuery();
- while (rs.next()) {
- result.add(rs.getLong(1));
+ while (rs.next()) {
+ result.add(rs.getLong(1));
+ }
Review comment:
ups sorry, i've fixed this
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
