Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
0001814: NullPointerException in AbstractTriggerTemplate.createInital…
…LoadSql
  • Loading branch information
chenson42 committed Jul 16, 2014
1 parent 0769edf commit 836b7b3
Showing 1 changed file with 16 additions and 14 deletions.
Expand Up @@ -45,7 +45,6 @@
* Responsible for generating dialect specific SQL such as trigger bodies and
* functions
*/
@SuppressWarnings("deprecation")
abstract public class AbstractTriggerTemplate {

protected static final String ORIG_TABLE_ALIAS = "orig";
Expand Down Expand Up @@ -114,10 +113,9 @@ public String createInitalLoadSql(Node node, TriggerRouter triggerRouter, Table
Table table = originalTable.copyAndFilterColumns(triggerHistory.getParsedColumnNames(),
triggerHistory.getParsedPkColumnNames(), true);

String sql = null;
Column[] columns = table.getColumns();

Column[] columns = symmetricDialect.orderColumns(triggerHistory.getParsedColumnNames(),
table);
String sql = null;

if (symmetricDialect.getParameterService().is(
ParameterConstants.INITIAL_LOAD_CONCAT_CSV_IN_SQL_ENABLED)) {
Expand All @@ -133,16 +131,20 @@ public String createInitalLoadSql(Node node, TriggerRouter triggerRouter, Table
StringBuilder columnList = new StringBuilder();
for (int i = 0; i < columns.length; i++) {
Column column = columns[i];
boolean isLob = symmetricDialect.getPlatform().isLob(column.getMappedTypeCode());
if (!(isLob && triggerRouter.getTrigger().isUseStreamLobs())) {
if (i > 0) {
columnList.append(",");
}

if (dateTimeAsString && TypeMap.isDateTimeType(column.getMappedTypeCode())) {
columnList.append(castDatetimeColumnToString(column.getName()));
} else {
columnList.append(SymmetricUtils.quote(symmetricDialect, column.getName()));
if (column != null) {
boolean isLob = symmetricDialect.getPlatform()
.isLob(column.getMappedTypeCode());
if (!(isLob && triggerRouter.getTrigger().isUseStreamLobs())) {
if (i > 0) {
columnList.append(",");
}

if (dateTimeAsString && TypeMap.isDateTimeType(column.getMappedTypeCode())) {
columnList.append(castDatetimeColumnToString(column.getName()));
} else {
columnList.append(SymmetricUtils.quote(symmetricDialect,
column.getName()));
}
}
}
}
Expand Down

0 comments on commit 836b7b3

Please sign in to comment.