0005295: Started work on relational to json

symmetric-assemble/src/asciidoc/configuration.ad

@@ -27,6 +27,12 @@ endif::pro[]
 
 include::configuration/groups.ad[]
 include::configuration/group-links.ad[]
+
+ifdef::pro[]
+include::configuration/table-groups.ad[]
+include::configuration/table-group-hiers.ad[]
+endif::pro[]
+
 include::configuration/routers.ad[]
 include::configuration/channels.ad[]
 include::configuration/table-triggers.ad[]

symmetric-assemble/src/asciidoc/configuration/table-group-hiers.ad

@@ -0,0 +1,25 @@
+
+== Table Group Hierarchies
+Table group hierarchies
+
+ID:: Unique identifier for a table group hierarchy.
+Table Group ID:: Unique identifier for the table group associated with this table in the hierarchy.
+Source Catalog:: Optional name for the catalog the configured table is in.
+Source Schema:: Optional name for the schema the configured table is in.
+Source Table:: The name of the source table that will be a part of this table group.
+Parent ID:: Unique identifier for the parent of this table in the hierarchy.
+Parent Relation Type:: 
+
+[cols="<2,<7", options="header"]
+|===
+|Type
+|Description
+
+|Object|
+
+|Array|
+
+|===
+
+Primary Key Column Names:: A comma-separated list of the configured table's primary keys
+Foreign Key Column Names:: A comma-separated list of the configured table's foreign keys

symmetric-assemble/src/asciidoc/configuration/table-groups.ad

@@ -0,0 +1,17 @@
+
+== Table Groups
+Table groups
+
+ID:: Unique identifier for a table group.
+Writer Type:: 
+
+[cols="<2,<7", options="header"]
+|===
+|Type
+|Description
+
+|Default|
+
+|Json|
+
+|===

symmetric-io/src/main/java/org/jumpmind/symmetric/io/data/transform/CsvDataHier.java

@@ -20,16 +20,27 @@
  */
 package org.jumpmind.symmetric.io.data.transform;
 
+import java.util.ArrayList;
 import java.util.List;
 
+import org.jumpmind.db.model.Table;
 import org.jumpmind.symmetric.io.data.CsvData;
+import org.jumpmind.symmetric.io.data.transform.TableGroupHier.RelationType;
 
 public class CsvDataHier {
     private CsvData csvData;
     private List<CsvDataHier> children;
+    private String catalog;
+    private String schema;
+    private String table;
+    private RelationType parentRelationType;
 
-    public CsvDataHier(CsvData csvData) {
+    public CsvDataHier(CsvData csvData, Table table, RelationType parentRelationType) {
         this.csvData = csvData;
+        this.catalog = table.getCatalog();
+        this.schema = table.getSchema();
+        this.table = table.getName();
+        this.parentRelationType = parentRelationType;
     }
 
     public CsvData getCsvData() {
@@ -49,6 +60,41 @@ public void setChildren(List<CsvDataHier> children) {
     }
 
     public void addChild(CsvDataHier csvDataHier) {
+        if (children == null) {
+            children = new ArrayList<CsvDataHier>();
+        }
         children.add(csvDataHier);
     }
+
+    public String getCatalog() {
+        return catalog;
+    }
+
+    public void setCatalog(String catalog) {
+        this.catalog = catalog;
+    }
+
+    public String getSchema() {
+        return schema;
+    }
+
+    public void setSchema(String schema) {
+        this.schema = schema;
+    }
+
+    public String getTable() {
+        return table;
+    }
+
+    public void setTable(String table) {
+        this.table = table;
+    }
+
+    public RelationType getParentRelationType() {
+        return parentRelationType;
+    }
+
+    public void setParentRelationType(RelationType parentRelationType) {
+        this.parentRelationType = parentRelationType;
+    }
 }