From 69b84ac737d53c00bf801eccca774535b0a9610c Mon Sep 17 00:00:00 2001 From: James Ahlborn Date: Tue, 12 Jan 2016 22:41:43 +0000 Subject: [PATCH] Fix missing column names in AppendQuery SQL strings. Fixes #131 git-svn-id: https://svn.code.sf.net/p/jackcess/code/jackcess/trunk@977 f203690c-595d-4dc9-a70b-905162fa7fd2 --- src/changes/changes.xml | 5 +++ .../jackcess/impl/query/AppendQueryImpl.java | 32 +++++++++++++++---- .../jackcess/query/AppendQuery.java | 2 ++ .../jackcess/query/QueryTest.java | 23 ++++++++++++- 4 files changed, 55 insertions(+), 7 deletions(-) diff --git a/src/changes/changes.xml b/src/changes/changes.xml index 621dd17..208fb9c 100644 --- a/src/changes/changes.xml +++ b/src/changes/changes.xml @@ -4,6 +4,11 @@ Tim McCune + + + Fix missing column names in AppendQuery SQL strings. + + Throw a prettier exception when maxing out the row size during row diff --git a/src/main/java/com/healthmarketscience/jackcess/impl/query/AppendQueryImpl.java b/src/main/java/com/healthmarketscience/jackcess/impl/query/AppendQueryImpl.java index 8fb3296..140fde3 100644 --- a/src/main/java/com/healthmarketscience/jackcess/impl/query/AppendQueryImpl.java +++ b/src/main/java/com/healthmarketscience/jackcess/impl/query/AppendQueryImpl.java @@ -40,6 +40,14 @@ public class AppendQueryImpl extends BaseSelectQueryImpl implements AppendQuery return getTypeRow().name1; } + public List getTargetColumns() { + return new RowFormatter(getTargetRows()) { + @Override protected void format(StringBuilder builder, Row row) { + toOptionalQuotedExpr(builder, row.name2, true); + } + }.format(); + } + public String getRemoteDbPath() { return getTypeRow().name2; } @@ -48,6 +56,14 @@ public class AppendQueryImpl extends BaseSelectQueryImpl implements AppendQuery return getTypeRow().expression; } + public List getValues() { + return new RowFormatter(getValueRows()) { + @Override protected void format(StringBuilder builder, Row row) { + builder.append(row.expression); + } + }.format(); + } + protected List getValueRows() { return filterRowsByFlag(super.getColumnRows(), APPEND_VALUE_FLAG); } @@ -57,12 +73,12 @@ public class AppendQueryImpl extends BaseSelectQueryImpl implements AppendQuery return filterRowsByNotFlag(super.getColumnRows(), APPEND_VALUE_FLAG); } - public List getValues() { - return new RowFormatter(getValueRows()) { - @Override protected void format(StringBuilder builder, Row row) { - builder.append(row.expression); - } - }.format(); + protected List getTargetRows() { + return new RowFilter() { + @Override protected boolean keep(Row row) { + return (row.name2 != null); + } + }.filter(super.getColumnRows()); } @Override @@ -70,6 +86,10 @@ public class AppendQueryImpl extends BaseSelectQueryImpl implements AppendQuery { builder.append("INSERT INTO "); toOptionalQuotedExpr(builder, getTargetTable(), true); + List columns = getTargetColumns(); + if(!columns.isEmpty()) { + builder.append(" (").append(columns).append(')'); + } toRemoteDb(builder, getRemoteDbPath(), getRemoteDbType()); builder.append(NEWLINE); List values = getValues(); diff --git a/src/main/java/com/healthmarketscience/jackcess/query/AppendQuery.java b/src/main/java/com/healthmarketscience/jackcess/query/AppendQuery.java index a62c286..ab4935c 100644 --- a/src/main/java/com/healthmarketscience/jackcess/query/AppendQuery.java +++ b/src/main/java/com/healthmarketscience/jackcess/query/AppendQuery.java @@ -30,6 +30,8 @@ public interface AppendQuery extends BaseSelectQuery public String getTargetTable(); + public List getTargetColumns(); + public String getRemoteDbPath(); public String getRemoteDbType(); diff --git a/src/test/java/com/healthmarketscience/jackcess/query/QueryTest.java b/src/test/java/com/healthmarketscience/jackcess/query/QueryTest.java index 3af50ec..b9a284c 100644 --- a/src/test/java/com/healthmarketscience/jackcess/query/QueryTest.java +++ b/src/test/java/com/healthmarketscience/jackcess/query/QueryTest.java @@ -206,7 +206,7 @@ public class QueryTest extends TestCase "WHERE (((Table1.col1)>\"blah\"));")); expectedQueries.put( "AppendQuery",multiline( - "INSERT INTO Table3", + "INSERT INTO Table3 (col2, col2, col3)", "SELECT [Table1].[col2], [Table2].[col2], [Table2].[col3]", "FROM Table3, Table1 INNER JOIN Table2 ON [Table1].[col1]=[Table2].[col1];")); expectedQueries.put( @@ -257,6 +257,27 @@ public class QueryTest extends TestCase } } + public void testAppendQuery() throws Exception + { + AppendQuery query = (AppendQuery)newQuery( + Query.Type.APPEND, null, "Table2", + // newRow(TABLE_ATTRIBUTE, null, "Table1", null), + newRow(COLUMN_ATTRIBUTE, "54", APPEND_VALUE_FLAG, null, null), + newRow(COLUMN_ATTRIBUTE, "'hello'", APPEND_VALUE_FLAG, null, null)); + + assertEquals(multiline("INSERT INTO Table2", + "VALUES (54, 'hello');"), query.toSQLString()); + + query = (AppendQuery)newQuery( + Query.Type.APPEND, null, "Table2", + // newRow(TABLE_ATTRIBUTE, null, "Table1", null), + newRow(COLUMN_ATTRIBUTE, "54", APPEND_VALUE_FLAG, null, "ID"), + newRow(COLUMN_ATTRIBUTE, "'hello'", APPEND_VALUE_FLAG, null, "Field 3")); + + assertEquals(multiline("INSERT INTO Table2 (ID, [Field 3])", + "VALUES (54, 'hello');"), query.toSQLString()); + } + private void doTestColumns(SelectQuery query) throws Exception { addRows(query, newRow(COLUMN_ATTRIBUTE, "Table1.id", null, null)); -- 2.39.5