From 3dcb42ee642f69960c4365c4c8b85d83d3c10c94 Mon Sep 17 00:00:00 2001 From: manoj Date: Fri, 29 May 2015 19:40:06 +0530 Subject: [PATCH] fix connection close issue while call super getOperation method inside loop --- .../mgt/dao/impl/CommandOperationDAOImpl.java | 28 +++++++++++-------- 1 file changed, 17 insertions(+), 11 deletions(-) diff --git a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/operation/mgt/dao/impl/CommandOperationDAOImpl.java b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/operation/mgt/dao/impl/CommandOperationDAOImpl.java index 3b73a8680f..e79681362c 100644 --- a/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/operation/mgt/dao/impl/CommandOperationDAOImpl.java +++ b/components/device-mgt/org.wso2.carbon.device.mgt.core/src/main/java/org/wso2/carbon/device/mgt/core/operation/mgt/dao/impl/CommandOperationDAOImpl.java @@ -20,7 +20,6 @@ package org.wso2.carbon.device.mgt.core.operation.mgt.dao.impl; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import org.wso2.carbon.device.mgt.common.DeviceIdentifier; import org.wso2.carbon.device.mgt.core.dto.operation.mgt.CommandOperation; import org.wso2.carbon.device.mgt.core.dto.operation.mgt.Operation; import org.wso2.carbon.device.mgt.core.operation.mgt.dao.OperationManagementDAOException; @@ -37,6 +36,7 @@ import java.util.List; public class CommandOperationDAOImpl extends OperationDAOImpl { private static final Log log = LogFactory.getLog(CommandOperationDAOImpl.class); + @Override public int addOperation(Operation operation) throws OperationManagementDAOException { @@ -138,29 +138,35 @@ public class CommandOperationDAOImpl extends OperationDAOImpl { Operation operation; List operationList = new ArrayList(); + List commandOperationList = new ArrayList(); + CommandOperation commandOperation = null; try { Connection conn = OperationManagementDAOFactory.getConnection(); - String sql = "Select co.OPERATION_ID,ENABLED from DM_COMMAND_OPERATION co "+ - "INNER JOIN "+ - "(Select * From DM_DEVICE_OPERATION_MAPPING WHERE DEVICE_ID=? "+ - "AND STATUS=? ) dm ON dm.OPERATION_ID = co.OPERATION_ID"; + String sql = "Select co.OPERATION_ID,ENABLED from DM_COMMAND_OPERATION co " + + "INNER JOIN " + + "(Select * From DM_DEVICE_OPERATION_MAPPING WHERE DEVICE_ID=? " + + "AND STATUS=? ) dm ON dm.OPERATION_ID = co.OPERATION_ID"; stmt = conn.prepareStatement(sql); stmt.setInt(1, deviceId); stmt.setString(2, status.toString()); rs = stmt.executeQuery(); - int operationId; - while (rs.next()) { + commandOperation = new CommandOperation(); + commandOperation.setEnabled(rs.getInt("ENABLED") == 0 ? false : true); + commandOperation.setId(rs.getInt("OPERATION_ID")); + commandOperationList.add(commandOperation); + } - operationId = rs.getInt("OPERATION_ID"); - operation = super.getOperation(operationId); - operation.setEnabled(rs.getInt("ENABLED") == 0?false:true); - operationList.add(operation); + for(CommandOperation cmOperation:commandOperationList){ + operation = super.getOperation(cmOperation.getId()); + operation.setEnabled(cmOperation.isEnabled()); + operationList.add(operation); } + } catch (SQLException e) { String errorMsg = "SQL error occurred while retrieving the operation available for the device'" + deviceId + "' with status '" + status.toString();