summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
-rw-r--r--sli/common/src/main/java/org/onap/ccsdk/sli/core/sli/SvcLogicDblibStore.java22
-rw-r--r--sli/recording/src/main/java/org/onap/ccsdk/sli/core/sli/recording/FileRecorder.java12
2 files changed, 29 insertions, 5 deletions
diff --git a/sli/common/src/main/java/org/onap/ccsdk/sli/core/sli/SvcLogicDblibStore.java b/sli/common/src/main/java/org/onap/ccsdk/sli/core/sli/SvcLogicDblibStore.java
index f11b362c..9216519a 100644
--- a/sli/common/src/main/java/org/onap/ccsdk/sli/core/sli/SvcLogicDblibStore.java
+++ b/sli/common/src/main/java/org/onap/ccsdk/sli/core/sli/SvcLogicDblibStore.java
@@ -132,7 +132,7 @@ public class SvcLogicDblibStore implements SvcLogicStore {
String mode) throws SvcLogicException {
DbLibService dbSvc = getDbLibService();
-
+ PreparedStatement fetchGraphStmt = null;
Connection dbConn = null;
SvcLogicGraph retval = null;
ResultSet results = null;
@@ -146,7 +146,7 @@ public class SvcLogicDblibStore implements SvcLogicStore {
try {
dbConn = ((DBResourceManager) dbSvc).getConnection();
- PreparedStatement fetchGraphStmt;
+
ArrayList<String> args = new ArrayList<String>();
args.add(module);
@@ -193,6 +193,13 @@ public class SvcLogicDblibStore implements SvcLogicStore {
} catch (Exception e) {
throw new ConfigurationException("Graph processing failed", e);
} finally {
+ try {
+ if (fetchGraphStmt != null) {
+ fetchGraphStmt.close();
+ }
+ } catch (SQLException e) {
+ LOG.info(e.getMessage());
+ }
if (results != null) {
try {
results.close();
@@ -267,12 +274,12 @@ public class SvcLogicDblibStore implements SvcLogicStore {
}
Connection dbConn = null;
-
+ PreparedStatement storeGraphStmt = null;
try {
dbConn = ((DBResourceManager) dbSvc).getConnection();
boolean oldAutoCommit = dbConn.getAutoCommit();
dbConn.setAutoCommit(false);
- PreparedStatement storeGraphStmt = dbConn
+ storeGraphStmt = dbConn
.prepareStatement(storeGraphSql);
storeGraphStmt.setString(1, graph.getModule());
storeGraphStmt.setString(2, graph.getRpc());
@@ -289,6 +296,13 @@ public class SvcLogicDblibStore implements SvcLogicStore {
throw new SvcLogicException("Could not write object to database", e);
} finally {
try {
+ if (storeGraphStmt != null) {
+ storeGraphStmt.close();
+ }
+ } catch (SQLException e) {
+ LOG.info(e.getMessage());
+ }
+ try {
if (dbConn != null && !dbConn.isClosed()) {
dbConn.close();
}
diff --git a/sli/recording/src/main/java/org/onap/ccsdk/sli/core/sli/recording/FileRecorder.java b/sli/recording/src/main/java/org/onap/ccsdk/sli/core/sli/recording/FileRecorder.java
index 1143ef74..4a60de95 100644
--- a/sli/recording/src/main/java/org/onap/ccsdk/sli/core/sli/recording/FileRecorder.java
+++ b/sli/recording/src/main/java/org/onap/ccsdk/sli/core/sli/recording/FileRecorder.java
@@ -24,6 +24,7 @@ package org.onap.ccsdk.sli.core.sli.recording;
import java.io.File;
import java.io.FileWriter;
import java.io.PrintWriter;
+import java.io.IOException;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;
@@ -82,6 +83,7 @@ public class FileRecorder implements SvcLogicRecorder {
File recordFile = new File(fileName);
PrintWriter recPrinter = null;
+ FileWriter fileWriter = null;
Date now = new Date();
TimeZone tz = TimeZone.getTimeZone("UTC");
@@ -95,7 +97,7 @@ public class FileRecorder implements SvcLogicRecorder {
try
{
- recPrinter = new PrintWriter(new FileWriter(recordFile, true));
+ recPrinter = new PrintWriter(fileWriter = new FileWriter(recordFile, true));
recPrinter.println(record);
}
catch (Exception e)
@@ -108,6 +110,14 @@ public class FileRecorder implements SvcLogicRecorder {
{
recPrinter.close();
}
+ if (fileWriter != null)
+ {
+ try {
+ fileWriter.close();
+ } catch (IOException e) {
+
+ }
+ }
}