log when query runs longer than expected

JumpMind · Jun 26, 2015 · 7c60f39 · 7c60f39
1 parent f68d3b0
commit 7c60f39
Showing 1 changed file with 6 additions and 0 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapDetector.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/route/DataGapDetector.java
@@ -26,6 +26,7 @@
 import org.jumpmind.db.sql.ISqlTemplate;
 import org.jumpmind.db.sql.ISqlTransaction;
 import org.jumpmind.db.sql.mapper.NumberMapper;
+import org.jumpmind.symmetric.common.Constants;
 import org.jumpmind.symmetric.common.ParameterConstants;
 import org.jumpmind.symmetric.db.ISymmetricDialect;
 import org.jumpmind.symmetric.model.DataGap;
@@ -103,7 +104,12 @@ public void beforeRouting() {
                 Object[] params = new Object[] { dataGap.getStartId(), dataGap.getEndId() };
                 lastDataId = -1;
                 processInfo.setStatus(Status.QUERYING);
+                long queryForIdsTs = System.currentTimeMillis();
                 List<Number> ids = sqlTemplate.query(sql, new NumberMapper(), params);
+                if (System.currentTimeMillis()-queryForIdsTs > Constants.LONG_OPERATION_THRESHOLD) {
+                    log.info("It took longer than {}ms to run the following sql for gap from {} to {}.  {}", 
+                            new Object[] {Constants.LONG_OPERATION_THRESHOLD, dataGap.getStartId(), dataGap.getEndId(), sql});
+                }
                 processInfo.setStatus(Status.PROCESSING);
 
                 idsFilled += ids.size();