You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@synapse.apache.org by as...@apache.org on 2007/12/13 20:00:28 UTC
svn commit: r603982 -
/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java
Author: asankha
Date: Thu Dec 13 11:00:28 2007
New Revision: 603982
URL: http://svn.apache.org/viewvc?rev=603982&view=rev
Log:
close DB connections cleanly
Modified:
webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java
Modified: webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java
URL: http://svn.apache.org/viewvc/webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java?rev=603982&r1=603981&r2=603982&view=diff
==============================================================================
--- webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java (original)
+++ webservices/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/mediators/db/DBReportMediator.java Thu Dec 13 11:00:28 2007
@@ -23,6 +23,7 @@
import java.sql.PreparedStatement;
import java.sql.SQLException;
+import java.sql.Connection;
/**
* A mediator that writes (i.e. inserts one row) to a table using message information
@@ -34,8 +35,10 @@
boolean traceOn = isTraceOn(msgCtx);
boolean traceOrDebugOn = isTraceOrDebugOn(traceOn);
+ Connection con = null;
try {
PreparedStatement ps = getPreparedStatement(stmnt, msgCtx);
+ con = ps.getConnection();
int count = ps.executeUpdate();
if (count > 0) {
@@ -49,9 +52,17 @@
"No rows were inserted for statement : " + stmnt.getRawStatement());
}
}
+ con.commit();
+
} catch (SQLException e) {
handleException("Error execuring insert statement : " + stmnt.getRawStatement() +
" against DataSource : " + getDSName(), e, msgCtx);
+ } finally {
+ if (con != null) {
+ try {
+ con.close();
+ } catch (SQLException ignore) {}
+ }
}
}
}
---------------------------------------------------------------------
To unsubscribe, e-mail: synapse-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: synapse-dev-help@ws.apache.org