0001925: Send Table Schema uses cached tables

JumpMind · Aug 20, 2014 · 9f698d7 · 9f698d7
1 parent ad5442c
commit 9f698d7
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java b/symmetric-core/src/main/java/org/jumpmind/symmetric/service/impl/DataExtractorService.java
@@ -1414,9 +1414,16 @@ public CsvData next() {
                                     routerId, triggerHistory, true, true);
                             Database db = new Database();
                             db.setName("dataextractor");
+                            /*
+                             * Force a reread of table so new columns are picked up.  A create
+                             * event is usually sent after there is a change to the table so 
+                             * we want to make sure that the cache is updated
+                             */
+                            Table table = platform.getTableFromCache(targetTable.getCatalog(), 
+                                    targetTable.getSchema(), targetTable.getName(), true);
                             db.setCatalog(targetTable.getCatalog());
                             db.setSchema(targetTable.getSchema());
-                            db.addTable(targetTable);
+                            db.addTable(table != null ? table : targetTable);
                             data.setRowData(CsvUtils.escapeCsvData(DatabaseXmlUtil.toXml(db)));
                         }
                     }