Skip to content

Commit

Permalink
Fix schema name of source schema for TRUNCATE statements.
Browse files Browse the repository at this point in the history
  • Loading branch information
chrisknoll committed Aug 26, 2016
1 parent 2fad9ec commit 916632e
Showing 1 changed file with 1 addition and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -244,7 +244,7 @@ private static void createInitFunction(List<String> r, Database database) {
r.add(" insertSql <- c()");
for (Table table : database.getTables()) {
String sqlTableName = convertToSqlName(table.getName());
r.add(" insertSql <- c(insertSql, \"TRUNCATE TABLE @cdm_schema." + sqlTableName + ";\")");
r.add(" insertSql <- c(insertSql, \"TRUNCATE TABLE @source_schema." + sqlTableName + ";\")");
}
r.add(" frameworkContext$insertSql <- insertSql;");

Expand Down

0 comments on commit 916632e

Please sign in to comment.