Skip to content

Commit

Permalink
clean up embarassing method signature
Browse files Browse the repository at this point in the history
  • Loading branch information
chenson42 committed May 5, 2011
1 parent d753c2d commit b368ee3
Showing 1 changed file with 8 additions and 8 deletions.
Expand Up @@ -98,7 +98,7 @@ public class SqlTemplate {
public String createInitalLoadSql(Node node, IDbDialect dialect, TriggerRouter triggerRouter, Table metaData, TriggerHistory triggerHistory, Channel channel) {
String sql = sqlTemplates.get(INITIAL_LOAD_SQL_TEMPLATE);
Column[] columns = dialect.orderColumns(triggerHistory.getParsedColumnNames(), metaData);
String columnsText = buildColumnString(dialect, dialect.getInitialLoadTableAlias(), dialect.getInitialLoadTableAlias(),
String columnsText = buildColumnString(dialect.getInitialLoadTableAlias(), dialect.getInitialLoadTableAlias(),
"", columns, dialect, DataEventType.INSERT, false, channel).columnString;
sql = AppUtils.replace("columns", columnsText, sql);
sql = AppUtils.replace("whereClause", StringUtils.isBlank(triggerRouter.getInitialLoadSelect()) ? Constants.ALWAYS_TRUE_CONDITION : triggerRouter.getInitialLoadSelect(), sql);
Expand Down Expand Up @@ -136,7 +136,7 @@ public String createCsvDataSql(IDbDialect dialect, Trigger trig, Table metaData,
String sql = sqlTemplates.get(INITIAL_LOAD_SQL_TEMPLATE);

Column[] columns = trig.orderColumnsForTable(metaData);
String columnsText = buildColumnString(dialect, dialect.getInitialLoadTableAlias(), dialect.getInitialLoadTableAlias(),
String columnsText = buildColumnString(dialect.getInitialLoadTableAlias(), dialect.getInitialLoadTableAlias(),
"", columns, dialect, DataEventType.INSERT, false, channel).columnString;
sql = AppUtils.replace("columns", columnsText, sql);

Expand All @@ -153,7 +153,7 @@ public String createCsvPrimaryKeySql(IDbDialect dialect, Trigger trig, Table met
String sql = sqlTemplates.get(INITIAL_LOAD_SQL_TEMPLATE);

Column[] columns = metaData.getPrimaryKeyColumns();
String columnsText = buildColumnString(dialect, dialect.getInitialLoadTableAlias(), dialect.getInitialLoadTableAlias(),
String columnsText = buildColumnString(dialect.getInitialLoadTableAlias(), dialect.getInitialLoadTableAlias(),
"", columns, dialect, DataEventType.INSERT, false, channel).toString();
sql = AppUtils.replace("columns", columnsText, sql);

Expand Down Expand Up @@ -243,14 +243,14 @@ public String replaceTemplateVariables(IDbDialect dialect, DataEventType dml, Tr
ddl = AppUtils.replace("origTableAlias", ORIG_TABLE_ALIAS, ddl);

Column[] columns = trigger.orderColumnsForTable(metaData);
ColumnString columnString = buildColumnString(dialect, ORIG_TABLE_ALIAS, newTriggerValue, newColumnPrefix, columns, dialect, dml, false, channel);
ColumnString columnString = buildColumnString(ORIG_TABLE_ALIAS, newTriggerValue, newColumnPrefix, columns, dialect, dml, false, channel);
ddl = AppUtils.replace("columns", columnString.toString(), ddl);

ddl = replaceDefaultSchemaAndCatalog(dialect, trigger, ddl);

ddl = AppUtils.replace("virtualOldNewTable", buildVirtualTableSql(dialect, oldColumnPrefix, newColumnPrefix, metaData.getColumns()),
ddl);
ddl = AppUtils.replace("oldColumns", buildColumnString(dialect, ORIG_TABLE_ALIAS, oldTriggerValue, oldColumnPrefix, columns, dialect, dml, true, channel).toString(), ddl);
ddl = AppUtils.replace("oldColumns", buildColumnString(ORIG_TABLE_ALIAS, oldTriggerValue, oldColumnPrefix, columns, dialect, dml, true, channel).toString(), ddl);
ddl = eval(columnString.isBlobClob, "containsBlobClobColumns", ddl);

// some column templates need tableName and schemaName
Expand All @@ -261,7 +261,7 @@ public String replaceTemplateVariables(IDbDialect dialect, DataEventType dml, Tr
+ "." : "")), ddl);

columns = metaData.getPrimaryKeyColumns();
ddl = AppUtils.replace("oldKeys", buildColumnString(dialect, ORIG_TABLE_ALIAS, oldTriggerValue, oldColumnPrefix, columns, dialect, dml, true, channel).toString(), ddl);
ddl = AppUtils.replace("oldKeys", buildColumnString(ORIG_TABLE_ALIAS, oldTriggerValue, oldColumnPrefix, columns, dialect, dml, true, channel).toString(), ddl);
ddl = AppUtils.replace("oldNewPrimaryKeyJoin", aliasedPrimaryKeyJoin(oldTriggerValue, newTriggerValue, columns), ddl);
ddl = AppUtils.replace("tableNewPrimaryKeyJoin", aliasedPrimaryKeyJoin(ORIG_TABLE_ALIAS, newTriggerValue, columns), ddl);
ddl = AppUtils.replace("primaryKeyWhereString", getPrimaryKeyWhereString(dml == DataEventType.DELETE ? oldTriggerValue : newTriggerValue, columns), ddl);
Expand Down Expand Up @@ -421,7 +421,7 @@ private String getPrimaryKeyWhereString(String alias, Column[] columns) {
return b.toString();
}

private ColumnString buildColumnString(IDbDialect dialect, String origTableAlias, String tableAlias, String columnPrefix, Column[] columns, IDbDialect dbDialect, DataEventType dml, boolean isOld, Channel channel) {
private ColumnString buildColumnString(String origTableAlias, String tableAlias, String columnPrefix, Column[] columns, IDbDialect dbDialect, DataEventType dml, boolean isOld, Channel channel) {
String columnsText = "";
boolean isLob = false;

Expand Down Expand Up @@ -465,7 +465,7 @@ private ColumnString buildColumnString(IDbDialect dialect, String origTableAlias
isLob = true;
break;
case Types.BLOB:
if (dialect instanceof PostgreSqlDbDialect) {
if (dbDialect instanceof PostgreSqlDbDialect) {
templateToUse = wrappedBlobColumnTemplate;
isLob = true;
break;
Expand Down

0 comments on commit b368ee3

Please sign in to comment.