0001301: BSH Load filter will not execute unless table exists on the …

…target database.
JumpMind · Jun 27, 2013 · a923247 · a923247
1 parent 511a6bf
commit a923247
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/load/BshDatabaseWriterFilter.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/load/BshDatabaseWriterFilter.java
@@ -91,12 +91,12 @@ public void afterWrite(DataContext context, Table table, CsvData data) {
         processLoadFilters(context, table, data, null, WriteMethod.AFTER_WRITE);
     }
 
-    public boolean handleError(DataContext context, Table table, CsvData data, Exception error) {        
+    public boolean handleError(DataContext context, Table table, CsvData data, Exception error) {
         return processLoadFilters(context, table, data, error, WriteMethod.HANDLE_ERROR);
     }
 
     public boolean handlesMissingTable(DataContext context, Table table) {
-        return loadFilters.containsKey(table.getName());
+        return loadFilters.containsKey(table.getFullyQualifiedTableName());
     }
 
     public void earlyCommit(DataContext context) {
@@ -228,7 +228,7 @@ protected boolean processLoadFilters(DataContext context, Table table, CsvData d
             if (wildcardLoadFilters != null) {
                 loadFiltersForTable.addAll(wildcardLoadFilters);
             }
-            
+
             if (tableSpecificLoadFilters != null) {
                 loadFiltersForTable.addAll(tableSpecificLoadFilters);
             }
@@ -261,9 +261,9 @@ protected boolean processLoadFilters(DataContext context, Table table, CsvData d
                         }
                     }
                 }
-            } catch (EvalError ex) {     
+            } catch (EvalError ex) {
                 processError(currentFilter, table, ex);
-            } 
+            }
         }
 
         return writeRow;