Skip to content

Commit

Permalink
0001226: Table sym_node_group_channel_window exceeds the max table na…
Browse files Browse the repository at this point in the history 
…me length for Sybase ASE 12.

0001225: Table sym_node_group_channel_window exceeds the max table name length for Sybase ASE 12.
  • Loading branch information
@abrougher
abrougher committed May 16, 2013
1 parent 4e7f223 commit 36741f5
Show file tree
Hide file tree
Showing 7 changed files with 64 additions and 64 deletions.
36 changes: 18 additions & 18 deletions symmetric-assemble/src/docbook/configuration.xml
View file
Expand Up @@ -1518,11 +1518,11 @@ insert into sym_trigger_router (TRIGGER_ID,ROUTER_ID,INITIAL_LOAD_ORDER,
<listitem>Copy Column Transform ('copy'): This transformation type
copies the source column value to the target column. This is the
default behavior.</listitem>

<listitem>Remove Column Transform ('remove'): This transformation type
removes the source column. This transform type is only valid for a
table transformation type of 'IMPLIED' where all the columns from the source
are automatically copied to the target.</listitem>
are automatically copied to the target.</listitem>

<listitem>Constant Transform ('const'): This transformation type
allows you to map a constant value to the given target column. The
Expand Down Expand Up @@ -1752,7 +1752,7 @@ values ('TABLE_TO_RELOAD','BSH','Client','Server',NULL,NULL,
</section>

<xi:include href="conflicts.xml"/>

<section id="jobs">
<title>Jobs</title>
<para>
Expand Down Expand Up @@ -1790,8 +1790,8 @@ means every 15 seconds, not every 15 minutes. See
documentation</ulink>
for more details.
</para>
<para>Some jobs cannot be run in parallel against a single node. When running on a cluster these jobs use the
<xref linkend="table_lock" xrefstyle="table" /> table to get an exclusive semaphore to run the job. In order to use this table the
<para>Some jobs cannot be run in parallel against a single node. When running on a cluster these jobs use the
<xref linkend="table_lock" xrefstyle="table" /> table to get an exclusive semaphore to run the job. In order to use this table the
<ns:literal>cluster.lock.enabled</ns:literal> must be set to true.
</para>
<para> The three main jobs in SymmetricDS are the route, push and
Expand Down Expand Up @@ -1848,14 +1848,14 @@ are updated to a status of New "NE".
</para>
<para>
The route job will respect the <literal>max_batch_size</literal> on <xref linkend="table_outgoing_batch" xrefstyle="table" />. If the max
batch size is reached before the end of a database tranaction and the batch algorithm is set to something other than
<ns:literal>nontransactional</ns:literal> the batch may exceed the specified max size.
batch size is reached before the end of a database tranaction and the batch algorithm is set to something other than
<ns:literal>nontransactional</ns:literal> the batch may exceed the specified max size.
</para>
<para>
The route job delegates to a router defined by the <literal>router_type</literal> and configured by the <literal>router_expression</literal> in the
<xref linkend="table_router" xrefstyle="table" /> table. Each router that has a <ns:literal>source_node_group_id</ns:literal>
The route job delegates to a router defined by the <literal>router_type</literal> and configured by the <literal>router_expression</literal> in the
<xref linkend="table_router" xrefstyle="table" /> table. Each router that has a <ns:literal>source_node_group_id</ns:literal>
that matches the current node's source node group id and is linked to the <xref linkend="table_trigger" xrefstyle="table" /> that captured the data gets an
opportunity to choose a list of nodes the data should be sent to. Data can only be routed to nodes that belong to the
opportunity to choose a list of nodes the data should be sent to. Data can only be routed to nodes that belong to the
router's <ns:literal>target_node_group_id</ns:literal>.
</para>
<section id="data-gaps">
Expand Down Expand Up @@ -1932,7 +1932,7 @@ SymmetricDS property is set to
<literal>true</literal>
, the frequency that data is pushed is controlled by the
<literal>job.push.period.time.ms</literal>
.
.
</para>
<para>
Data is extracted by channel from the source database's
Expand All @@ -1952,15 +1952,15 @@ the channel will be skipped for this run. If the
is set to zero, data extraction will happen every time the jobs run.
</para>
<para>
The maximum number of batches to extract per synchronization is controlled by
<ns:literal>max_batch_to_send</ns:literal> on the <xref linkend="table_channel" xrefstyle="table" /> table. There is also
The maximum number of batches to extract per synchronization is controlled by
<ns:literal>max_batch_to_send</ns:literal> on the <xref linkend="table_channel" xrefstyle="table" /> table. There is also
a setting that controls the max number of bytes to send in one synchronization. If SymmetricDS has extracted the more than the
number of bytes configured by the <ns:literal>transport.max.bytes.to.sync</ns:literal> parameter, then it will finish extracting the
number of bytes configured by the <ns:literal>transport.max.bytes.to.sync</ns:literal> parameter, then it will finish extracting the
current batch and finish synchronization so the client has a chance to process and acknowlege the "big" batch. This may happen before
the configured max number of batches has been reached.
the configured max number of batches has been reached.
</para>
<para>
Both the push and pull jobs can be configured to push and pull
Both the push and pull jobs can be configured to push and pull
multiple nodes in parallel. In order to take advantage of this the
<literal>pull.thread.per.server.count</literal>
or
Expand All @@ -1975,7 +1975,7 @@ multiple servers in a cluster.
<para>
SymmetricDS also provides the ability to configure windows of time when
synchronization is allowed. This is done using the
<xref linkend="table_node_group_channel_window" xrefstyle="table" />
<xref linkend="table_node_group_channel_wnd" xrefstyle="table" />
table. A list of allowed time windows can be specified for a node group
and a channel. If one or more windows exist, then data will only be
extracted and transported if the time of day falls within the window of
Expand Down Expand Up @@ -2142,5 +2142,5 @@ requires a lock before running. [&#xA0;Default:&#xA0;false&#xA0;] </para>
</section>

</section>

</chapter>
28 changes: 14 additions & 14 deletions symmetric-core/src/main/java/org/jumpmind/symmetric/common/TableConstants.java
View file
@@ -1,22 +1,22 @@
/*
* Licensed to JumpMind Inc under one or more contributor
* Licensed to JumpMind Inc under one or more contributor
* license agreements. See the NOTICE file distributed
* with this work for additional information regarding
* with this work for additional information regarding
* copyright ownership. JumpMind Inc licenses this file
* to you under the GNU Lesser General Public License (the
* "License"); you may not use this file except in compliance
* with the License.
*
* with the License.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library; if not, see
* License along with this library; if not, see
* <http://www.gnu.org/licenses/>.
*
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
* under the License.
*/

package org.jumpmind.symmetric.common;
Expand Down Expand Up @@ -46,7 +46,7 @@ public class TableConstants {
public static final String SYM_DATA_EVENT = "data_event";
public static final String SYM_TRANSFORM_TABLE = "transform_table";
public static final String SYM_LOAD_FILTER = "load_filter";
public static final String SYM_TRANSFORM_COLUMN = "transform_column";
public static final String SYM_TRANSFORM_COLUMN = "transform_column";
public static final String SYM_TRIGGER_ROUTER = "trigger_router";
public static final String SYM_CHANNEL = "channel";
public static final String SYM_NODE_SECURITY = "node_security";
Expand All @@ -59,7 +59,7 @@ public class TableConstants {
public static final String SYM_REGISTRATION_REDIRECT = "registration_redirect";
public static final String SYM_NODE_CHANNEL_CTL = "node_channel_ctl";
public static final String SYM_CONFLICT = "conflict";
public static final String SYM_NODE_GROUP_CHANNEL_WINDOW = "node_group_channel_window";
public static final String SYM_NODE_GROUP_CHANNEL_WND = "node_group_channel_wnd";
public static final String SYM_NODE_HOST_CHANNEL_STATS = "node_host_channel_stats";
public static final String SYM_INCOMING_ERROR = "incoming_error";
public static final String SYM_SEQUENCE = "sequence";
Expand All @@ -70,7 +70,7 @@ public class TableConstants {
public static final String SYM_FILE_TRIGGER = "file_trigger";
public static final String SYM_FILE_TRIGGER_ROUTER = "file_trigger_router";
public static final String SYM_FILE_SNAPSHOT = "file_snapshot";


private static List<String> tablesWithPrefix;

Expand Down Expand Up @@ -110,7 +110,7 @@ protected static List<String> populateConfigTables(String tablePrefix) {
configTables.add(getTableName(tablePrefix, TableConstants.SYM_NODE_SECURITY));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_PARAMETER));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_CHANNEL));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_NODE_GROUP_CHANNEL_WINDOW));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_NODE_GROUP_CHANNEL_WND));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_TRIGGER));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_ROUTER));
configTables.add(getTableName(tablePrefix, TableConstants.SYM_TRIGGER_ROUTER));
Expand Down Expand Up @@ -147,7 +147,7 @@ protected static List<String> populateAllTables(String tablePrefix) {
tables.add(getTableName(tablePrefix, SYM_NODE_IDENTITY));
tables.add(getTableName(tablePrefix, SYM_NODE_SECURITY));
tables.add(getTableName(tablePrefix, SYM_NODE_CHANNEL_CTL));
tables.add(getTableName(tablePrefix, SYM_NODE_GROUP_CHANNEL_WINDOW));
tables.add(getTableName(tablePrefix, SYM_NODE_GROUP_CHANNEL_WND));
tables.add(getTableName(tablePrefix, SYM_PARAMETER));
tables.add(getTableName(tablePrefix, SYM_NODE_HOST_CHANNEL_STATS));
tables.add(getTableName(tablePrefix, SYM_NODE_HOST_STATS));
Expand All @@ -170,10 +170,10 @@ protected static List<String> populateAllTables(String tablePrefix) {
tables.add(getTableName(tablePrefix, SYM_TRIGGER_ROUTER_GROUPLET));
tables.add(getTableName(tablePrefix, TableConstants.SYM_FILE_TRIGGER));
tables.add(getTableName(tablePrefix, TableConstants.SYM_FILE_TRIGGER_ROUTER));
tables.add(getTableName(tablePrefix, TableConstants.SYM_FILE_SNAPSHOT));
tables.add(getTableName(tablePrefix, TableConstants.SYM_FILE_SNAPSHOT));
return tables;
}

public static final List<String> getTablesThatSync(String tablePrefix) {
List<String> tables = new ArrayList<String>(getConfigTables(tablePrefix));
tables.removeAll(getTablesThatDoNotSync(tablePrefix));
Expand Down
26 changes: 13 additions & 13 deletions ...ic-core/src/main/java/org/jumpmind/symmetric/service/impl/ConfigurationServiceSqlMap.java
View file
Expand Up @@ -11,7 +11,7 @@ public ConfigurationServiceSqlMap(IDatabasePlatform platform,
super(platform, replacementTokens);

// @formatter:off

putSql("selectDataEventActionsByIdSql",
" select data_event_action from $(node_group_link) where "
+ " source_node_group_id = ? and target_node_group_id = ? ");
Expand All @@ -20,11 +20,11 @@ public ConfigurationServiceSqlMap(IDatabasePlatform platform,
+ "select source_node_group_id, target_node_group_id, data_event_action, last_update_time, last_update_by, create_time from "
+ " $(node_group_link) order by source_node_group_id ");

putSql("updateNodeGroupSql",
putSql("updateNodeGroupSql",
" update $(node_group) set description=?, last_update_time=?, last_update_by=? where "
+ " node_group_id=? ");

putSql("insertNodeGroupSql",
putSql("insertNodeGroupSql",
"insert into $(node_group) "
+ " (description, node_group_id, last_update_time, last_update_by, create_time) values(?,?,?,?,?) ");

Expand All @@ -44,7 +44,7 @@ public ConfigurationServiceSqlMap(IDatabasePlatform platform,
+ " $(node_group_link) where source_node_group_id = ? ");

putSql("isChannelInUseSql", "select count(*) from $(trigger) where channel_id = ? ");

putSql("selectChannelsSql",
"select c.channel_id, c.processing_order, c.max_batch_size, c.enabled, " +
" c.max_batch_to_send, c.max_data_to_route, c.use_old_data_to_route, " +
Expand All @@ -55,8 +55,8 @@ public ConfigurationServiceSqlMap(IDatabasePlatform platform,

putSql("selectNodeChannelsSql",
"select c.channel_id, nc.node_id, nc.ignore_enabled, nc.suspend_enabled, c.processing_order, "
+ " c.max_batch_size, c.enabled, c.max_batch_to_send, c.max_data_to_route, c.use_old_data_to_route, "
+ " c.use_row_data_to_route, c.use_pk_data_to_route, c.contains_big_lob, c.batch_algorithm, "
+ " c.max_batch_size, c.enabled, c.max_batch_to_send, c.max_data_to_route, c.use_old_data_to_route, "
+ " c.use_row_data_to_route, c.use_pk_data_to_route, c.contains_big_lob, c.batch_algorithm, "
+ " nc.last_extract_time, c.extract_period_millis, c.data_loader_type," +
" last_update_time, last_update_by, create_time "
+ " from $(channel) c left outer join "
Expand All @@ -70,16 +70,16 @@ public ConfigurationServiceSqlMap(IDatabasePlatform platform,

putSql("insertChannelSql",
"insert into $(channel) (channel_id, processing_order, max_batch_size, "
+ " max_batch_to_send, max_data_to_route, use_old_data_to_route, use_row_data_to_route, "
+ " use_pk_data_to_route, contains_big_lob, enabled, batch_algorithm, description, "
+ " max_batch_to_send, max_data_to_route, use_old_data_to_route, use_row_data_to_route, "
+ " use_pk_data_to_route, contains_big_lob, enabled, batch_algorithm, description, "
+ " extract_period_millis, data_loader_type, last_update_time, last_update_by, create_time) "
+ " values (?, ?, ?, ?, ?, ?, ?, ?, ?, ?, ?, null, ?, ?, ?, ?, ?) ");

putSql("updateChannelSql",
"update $(channel) set processing_order=?, max_batch_size=?, "
+ " max_batch_to_send=?, max_data_to_route=?, use_old_data_to_route=?, use_row_data_to_route=?, "
+ " use_pk_data_to_route=?, contains_big_lob=?, enabled=?, batch_algorithm=?, extract_period_millis=?, "
+ " data_loader_type=?, last_update_time=?, last_update_by=?"
+ " use_pk_data_to_route=?, contains_big_lob=?, enabled=?, batch_algorithm=?, extract_period_millis=?, "
+ " data_loader_type=?, last_update_time=?, last_update_by=?"
+ " where channel_id=? ");

putSql("deleteNodeGroupLinkSql",
Expand All @@ -93,7 +93,7 @@ public ConfigurationServiceSqlMap(IDatabasePlatform platform,

putSql("selectNodeGroupChannelWindowSql",
"select node_group_id, channel_id, start_time, end_time, enabled "
+ " from $(node_group_channel_window) where node_group_id=? and channel_id=? ");
+ " from $(node_group_channel_wnd) where node_group_id=? and channel_id=? ");

putSql("insertNodeChannelControlSql", ""
+ "insert into $(node_channel_ctl) (node_id, channel_id, "
Expand All @@ -105,8 +105,8 @@ public ConfigurationServiceSqlMap(IDatabasePlatform platform,

putSql("getRegistrationRedirectSql",
"select registrant_external_id, registration_node_id from $(registration_redirect)");
putSql("selectMaxChannelLastUpdateTime" ,"select max(last_update_time) from $(channel) where last_update_time is not null" );

putSql("selectMaxChannelLastUpdateTime" ,"select max(last_update_time) from $(channel) where last_update_time is not null" );
putSql("selectMaxNodeGroupLastUpdateTime" ,"select max(last_update_time) from $(node_group) where last_update_time is not null" );
putSql("selectMaxNodeGroupLinkLastUpdateTime" ,"select max(last_update_time) from $(node_group_link) where last_update_time is not null" );

Expand Down

0 comments on commit 36741f5

Please sign in to comment.