keep table from getting too big by mistake

JumpMind · Dec 27, 2007 · c26a8ae · c26a8ae
1 parent ad2f3c4
commit c26a8ae
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/symmetric/src/main/java/org/jumpmind/symmetric/db/derby/DerbyFunctions.java b/symmetric/src/main/java/org/jumpmind/symmetric/db/derby/DerbyFunctions.java
@@ -12,6 +12,8 @@
 public class DerbyFunctions {
 
     private static final String CURRENT_CONNECTION_URL = "jdbc:default:connection";
+
+    private static final int MAX_TABLE_SIZE = 200;
 
     private static Hashtable<String, Boolean> syncDisabledTable = new Hashtable<String, Boolean>();
 
@@ -28,6 +30,9 @@ public static int setSyncDisabled(int disabledIndicator) throws SQLException {
             syncDisabledTable.remove(getTransactionId());
             return 0;
         } else {
+            if (syncDisabledTable.size() >= MAX_TABLE_SIZE) {
+                clean();
+            }
             syncDisabledTable.put(getTransactionId(), Boolean.TRUE);
             return 1;
         }