diff --git a/symmetric-db/src/main/java/org/jumpmind/db/platform/sqlite/SqliteDdlReader.java b/symmetric-db/src/main/java/org/jumpmind/db/platform/sqlite/SqliteDdlReader.java index 7291495cf4..d71cfd5d84 100644 --- a/symmetric-db/src/main/java/org/jumpmind/db/platform/sqlite/SqliteDdlReader.java +++ b/symmetric-db/src/main/java/org/jumpmind/db/platform/sqlite/SqliteDdlReader.java @@ -98,10 +98,15 @@ public Table readTable(String catalog, String schema, String tableName, String s throw new NotImplementedException(); } + private String quote(String name) { + String quote = platform.getDatabaseInfo().getDelimiterToken(); + return quote + name + quote; + } + public Table readTable(String catalog, String schema, String tableName) { Table table = null; - List columns = platform.getSqlTemplate().query("pragma table_info(" + tableName + ")", COLUMN_MAPPER); + List columns = platform.getSqlTemplate().query("pragma table_info(" + quote(tableName) + ")", COLUMN_MAPPER); checkForAutoIncrementColumn(columns, tableName); @@ -111,7 +116,7 @@ public Table readTable(String catalog, String schema, String tableName) { table.addColumn(column); } - List indexes = platform.getSqlTemplate().query("pragma index_list(" + tableName + ")", INDEX_MAPPER); + List indexes = platform.getSqlTemplate().query("pragma index_list(" + quote(tableName) + ")", INDEX_MAPPER); for (IIndex index : indexes) { List indexColumns = platform.getSqlTemplate().query("pragma index_info(" + index.getName() + ")", @@ -135,7 +140,7 @@ public Table readTable(String catalog, String schema, String tableName) { } Map keys = new HashMap(); - List rows = platform.getSqlTemplate().query("pragma foreign_key_list(" + tableName + ")", new RowMapper()); + List rows = platform.getSqlTemplate().query("pragma foreign_key_list(" + quote(tableName) + ")", new RowMapper()); for (Row row : rows) { Integer id = row.getInt("id"); ForeignKey fk = keys.get(id);