From 3114812e34b8f9c69123d5343c67de0be69b266d Mon Sep 17 00:00:00 2001 From: Tim Chamberlain Date: Fri, 21 Feb 2025 09:44:29 -0600 Subject: [PATCH] CE-2261: qqq updates to table name --- .../module/rdbms/actions/RDBMSInsertAction.java | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/qqq-backend-module-rdbms/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSInsertAction.java b/qqq-backend-module-rdbms/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSInsertAction.java index d2dbb8f9..d2a78560 100644 --- a/qqq-backend-module-rdbms/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSInsertAction.java +++ b/qqq-backend-module-rdbms/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSInsertAction.java @@ -93,8 +93,8 @@ public class RDBMSInsertAction extends AbstractRDBMSAction implements InsertInte for(List page : CollectionUtils.getPages(insertInput.getRecords(), getActionStrategy().getPageSize(insertInput))) { - String tableName = escapeIdentifier(getTableName(table)); - sql = new StringBuilder("INSERT INTO ").append(tableName).append("(").append(columns).append(") VALUES"); + String backendTableName = escapeIdentifier(getTableName(table)); + sql = new StringBuilder("INSERT INTO ").append(backendTableName).append("(").append(columns).append(") VALUES"); params = new ArrayList<>(); int recordIndex = 0; @@ -135,7 +135,7 @@ public class RDBMSInsertAction extends AbstractRDBMSAction implements InsertInte QRecord outputRecord = new QRecord(record); if(!StringUtils.hasContent(outputRecord.getTableName())) { - outputRecord.setTableName(getTableName(table)); + outputRecord.setTableName(table.getName()); } outputRecords.add(outputRecord); } @@ -156,6 +156,10 @@ public class RDBMSInsertAction extends AbstractRDBMSAction implements InsertInte for(QRecord record : page) { QRecord outputRecord = new QRecord(record); + if(!StringUtils.hasContent(outputRecord.getTableName())) + { + outputRecord.setTableName(table.getName()); + } outputRecords.add(outputRecord); if(CollectionUtils.nullSafeIsEmpty(record.getErrors()))