Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
0001018: Add a mechanism for a remote node to request a table reload.…
… This is helpful while rolling out new tables.
  • Loading branch information
chenson42 committed Jan 30, 2013
1 parent 34bd45a commit 7ea5311
Show file tree
Hide file tree
Showing 3 changed files with 2 additions and 15 deletions.
Expand Up @@ -126,8 +126,8 @@ public void exportTestDatabaseSQL() throws Exception {
export.setCompatible(Compatible.H2);
String output = export.exportTables(tables).toLowerCase();

Assert.assertEquals(output, 32, StringUtils.countMatches(output, "create table \"sym_"));
Assert.assertEquals(32,
Assert.assertEquals(output, 33, StringUtils.countMatches(output, "create table \"sym_"));
Assert.assertEquals(34,
StringUtils.countMatches(output, "varchar(" + Integer.MAX_VALUE + ")"));
}

Expand Down
Expand Up @@ -64,7 +64,6 @@ public class TableConstants {
public static final String SYM_INCOMING_ERROR = "incoming_error";
public static final String SYM_SEQUENCE = "sequence";
public static final String SYM_TABLE_RELOAD_REQUEST = "table_reload_request";
public static final String SYM_SELECTIVE_ROUTER_CTL = "selective_Router_ctl";

private static List<String> tablesWithPrefix;

Expand Down Expand Up @@ -114,7 +113,6 @@ protected static List<String> populateConfigTables(String tablePrefix) {
configTables.add(getTableName(tablePrefix, TableConstants.SYM_TRANSFORM_COLUMN));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_CONFLICT));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_TABLE_RELOAD_REQUEST));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_SELECTIVE_ROUTER_CTL));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_NODE_IDENTITY));
return configTables;
}
Expand Down Expand Up @@ -155,7 +153,6 @@ protected static List<String> populateAllTables(String tablePrefix) {
tables.add(getTableName(tablePrefix, SYM_SEQUENCE));
tables.add(getTableName(tablePrefix, SYM_NODE_COMMUNICATION));
tables.add(getTableName(tablePrefix, TableConstants.SYM_TABLE_RELOAD_REQUEST));
tables.add(getTableName(tablePrefix, TableConstants.SYM_SELECTIVE_ROUTER_CTL));
return tables;
}

Expand Down
10 changes: 0 additions & 10 deletions symmetric-core/src/main/resources/symmetric-schema.xml
Expand Up @@ -580,14 +580,4 @@
<column name="last_update_time" type="TIMESTAMP" required="true" description="Timestamp when a user last updated this entry." />
</table>

<table name="selective_router_ctl" description="">
<column name="node_id" type="VARCHAR" size="50" required="true" primaryKey="true" description="Unique identifier for a node." />
<column name="router_id" type="VARCHAR" size="50" required="true" primaryKey="true" description="Unique description of a specific router" />
<column name="trigger_id" type="VARCHAR" size="50" required="true" primaryKey="true" description="Unique identifier for a trigger. If this id should represent all triggers, then the * wildcard character should be used" />
<column name="enabled" type="BOOLEANINT" size="1" default="1" description="" />
<column name="create_time" type="TIMESTAMP" required="true" description="Timestamp when this entry was created." />
<column name="last_update_by" type="VARCHAR" size="50" description="The user who last updated this entry." />
<column name="last_update_time" type="TIMESTAMP" required="true" description="Timestamp when a user last updated this entry." />
</table>

</database>

0 comments on commit 7ea5311

Please sign in to comment.