diff --git a/obp-api/src/main/scala/code/api/util/migration/Migration.scala b/obp-api/src/main/scala/code/api/util/migration/Migration.scala
index e31cdeb08..84cef63c0 100644
--- a/obp-api/src/main/scala/code/api/util/migration/Migration.scala
+++ b/obp-api/src/main/scala/code/api/util/migration/Migration.scala
@@ -648,8 +648,11 @@ object Migration extends MdcLoggable {
           if (performWrite) {
             logFunc(ct)
             val st = conn.createStatement
-            st.execute(ct)
-            st.close
+            try {
+              st.execute(ct)
+            } finally {
+              st.close()
+            }
           }
           ct
       }
diff --git a/obp-api/src/main/scala/code/bankconnectors/storedprocedure/StoredProcedureUtils.scala b/obp-api/src/main/scala/code/bankconnectors/storedprocedure/StoredProcedureUtils.scala
index 7ca06811c..12aa0b4d7 100644
--- a/obp-api/src/main/scala/code/bankconnectors/storedprocedure/StoredProcedureUtils.scala
+++ b/obp-api/src/main/scala/code/bankconnectors/storedprocedure/StoredProcedureUtils.scala
@@ -58,12 +58,15 @@ object StoredProcedureUtils extends MdcLoggable{
         val sql = s"{ CALL $procedureName(?, ?) }"
 
         val callableStatement = conn.prepareCall(sql)
-        callableStatement.setString(1, procedureParam)
-
-        callableStatement.registerOutParameter(2, java.sql.Types.LONGVARCHAR)
-        //        callableStatement.setString(2, "") // MS sql server must comment this line, other DB need check.
-        callableStatement.executeUpdate()
-        callableStatement.getString(2)
+        try {
+          callableStatement.setString(1, procedureParam)
+          callableStatement.registerOutParameter(2, java.sql.Types.LONGVARCHAR)
+          //        callableStatement.setString(2, "") // MS sql server must comment this line, other DB need check.
+          callableStatement.executeUpdate()
+          callableStatement.getString(2)
+        } finally {
+          callableStatement.close()
+        }
      }
     logger.debug(s"${StoredProcedureConnector_vDec2019.toString} inBoundJson: $procedureName = $responseJson" )
     Connector.extractAdapterResponse[T](responseJson, Empty)