vitalif
/
openesb-components
mirror of https://github.com/vitalif/openesb-components
1
0
Fork 0
Code Issues Releases Wiki Activity

Pause only after an empty resultset

master
Vitaliy Filippov 2015-12-08 20:08:09 +03:00
parent 2e7c554b48
commit 13c99b9314
2 changed files with 26 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/InboundMessageProcessor.java
View File

@ -170,6 +170,7 @@ public class InboundMessageProcessor implements Runnable, MessageExchangeReplyLi
PreparedStatement ps = null;
ResultSet rs = null;
private int mRowCount = 0;
Connection connection = null;
@ -247,6 +248,7 @@ public class InboundMessageProcessor implements Runnable, MessageExchangeReplyLi
}
do {
mRowCount = 0;
try {
execute();
} catch (final Exception ex) {
@ -257,10 +259,12 @@ public class InboundMessageProcessor implements Runnable, MessageExchangeReplyLi
mLogger.log(Level.INFO,mMessages.getString("DBBC_R00660.IMP_FINISHED_EXECUTING_SQL"));
}
try {
Thread.sleep(mPollMilliSeconds);
} catch (final Exception e) {
mLogger.log(Level.SEVERE, mMessages.getString("DBBC_E00661.IMP_THREAD_SLEEP_ABRUPTED"), e);
if (mRowCount <= 0) {
try {
Thread.sleep(mPollMilliSeconds);
} catch (final Exception e) {
mLogger.log(Level.SEVERE, mMessages.getString("DBBC_E00661.IMP_THREAD_SLEEP_ABRUPTED"), e);
}
}
} while (mMonitor.get() != Boolean.TRUE);
}
@ -462,6 +466,7 @@ public class InboundMessageProcessor implements Runnable, MessageExchangeReplyLi
normalizer.setRecordsProcessedList(mProcessedList);
normalizer.setJDBCClusterManager(mJDBCClusterManager);
inMsg = normalizer.normalizeSelectInbound(rs, exchange, meta, epb, mPKName,mDbName);
mRowCount = normalizer.mRowCount;
if(normalizationMeasurement != null){
normalizationMeasurement.end();

17
ojc-core/databasebc/databasebcimpl/src/org/glassfish/openesb/databasebc/JDBCNormalizer.java
View File

@ -95,6 +95,7 @@ public class JDBCNormalizer {
private String insertQuery = null;
public ArrayList mProcessedList = new ArrayList();
public Map mInboundExchangeProcessRecordsMap = new HashMap();
public int mRowCount = 0;
private JDBCClusterManager mJDBCClusterManager;
/** Creates a new instance of SoapNormalizer
@ -124,6 +125,7 @@ public class JDBCNormalizer {
final MessageExchange exchange, final OperationMetaData meta)
throws MessagingException {
final NormalizedMessage normalMsg = exchange.createMessage();
mRowCount = 0;
try {
Document normalDoc = JDBCNormalizer.newDocument();
@ -350,6 +352,7 @@ public class JDBCNormalizer {
final ResultSetMetaData rsmd = rs.getMetaData();
if (numberOfRecords == -1)
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(
Level.FINE))
mLogger.log(Level.FINE,
@ -385,6 +388,7 @@ public class JDBCNormalizer {
}
else
while (rs.next() && (numberOfRecords > 0)) {
mRowCount++;
if (mLogger.isLoggable(
Level.FINE))
mLogger.log(Level.FINE,
@ -436,6 +440,7 @@ public class JDBCNormalizer {
if (numberOfRecords == -1)
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(
Level.FINE))
mLogger.log(Level.FINE,
@ -508,6 +513,7 @@ public class JDBCNormalizer {
}
else
while (rs.next() && (numberOfRecords > 0)) {
mRowCount++;
if (mLogger.isLoggable(
Level.FINE))
mLogger.log(Level.FINE,
@ -642,6 +648,7 @@ public class JDBCNormalizer {
final ResultSetMetaData rsmd = rs.getMetaData();
if (numberOfRecords == -1)
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");
@ -671,6 +678,7 @@ public class JDBCNormalizer {
}
else
while (rs.next() && (numberOfRecords > 0)) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");
@ -809,6 +817,7 @@ public class JDBCNormalizer {
if (numberOfRecords == -1)
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");
@ -840,6 +849,7 @@ public class JDBCNormalizer {
}
else
while (rs.next() && (numberOfRecords > 0)) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");
@ -889,6 +899,7 @@ public class JDBCNormalizer {
if (numberOfRecords == -1)
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");
@ -922,6 +933,7 @@ public class JDBCNormalizer {
}
else
while (rs.next() && (numberOfRecords > 0)) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");
@ -999,6 +1011,7 @@ public class JDBCNormalizer {
if (numberOfRecords == -1)
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");
@ -1027,6 +1040,7 @@ public class JDBCNormalizer {
}
else
while (rs.next() && (numberOfRecords > 0)) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");
@ -1169,6 +1183,7 @@ public class JDBCNormalizer {
final ResultSetMetaData rsmd =
rs.getMetaData();
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(
Level.FINE))
mLogger.log(
@ -1290,6 +1305,7 @@ public class JDBCNormalizer {
final ResultSetMetaData rsmd =
rs.getMetaData();
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(
Level.FINE))
mLogger.log(
@ -1430,6 +1446,7 @@ public class JDBCNormalizer {
if (rs != null) {
final ResultSetMetaData rsmd = rs.getMetaData();
while (rs.next()) {
mRowCount++;
if (mLogger.isLoggable(Level.FINE))
mLogger.log(Level.FINE,
"DBBC_R00706.JDBCN_ProcessNextRecord");