QRunIO/qqq
2
0
Fork 0
mirror of https://github.com/Kingsrook/qqq.git synced 2025-07-17 12:40:44 +00:00
Code Issues Packages Projects Releases Wiki Activity

CE-2261: qqq updates to table name

Browse Source
This commit is contained in:
Tim Chamberlain
2025-02-21 09:44:29 -06:00
parent a659dc7a02
commit 3114812e34
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
qqq-backend-module-rdbms/src/main/java/com/kingsrook/qqq/backend/module/rdbms/actions/RDBMSInsertAction.java
View File

@ -93,8 +93,8 @@ public class RDBMSInsertAction extends AbstractRDBMSAction implements InsertInte
for(List<QRecord> page : CollectionUtils.getPages(insertInput.getRecords(), getActionStrategy().getPageSize(insertInput))) for(List<QRecord> page : CollectionUtils.getPages(insertInput.getRecords(), getActionStrategy().getPageSize(insertInput)))
{ {
String tableName = escapeIdentifier(getTableName(table)); String backendTableName = escapeIdentifier(getTableName(table));
sql = new StringBuilder("INSERT INTO ").append(tableName).append("(").append(columns).append(") VALUES"); sql = new StringBuilder("INSERT INTO ").append(backendTableName).append("(").append(columns).append(") VALUES");
params = new ArrayList<>(); params = new ArrayList<>();
int recordIndex = 0; int recordIndex = 0;
@ -135,7 +135,7 @@ public class RDBMSInsertAction extends AbstractRDBMSAction implements InsertInte
QRecord outputRecord = new QRecord(record); QRecord outputRecord = new QRecord(record);
if(!StringUtils.hasContent(outputRecord.getTableName())) if(!StringUtils.hasContent(outputRecord.getTableName()))
{ {
outputRecord.setTableName(getTableName(table)); outputRecord.setTableName(table.getName());
} }
outputRecords.add(outputRecord); outputRecords.add(outputRecord);
} }
@ -156,6 +156,10 @@ public class RDBMSInsertAction extends AbstractRDBMSAction implements InsertInte
for(QRecord record : page) for(QRecord record : page)
{ {
QRecord outputRecord = new QRecord(record); QRecord outputRecord = new QRecord(record);
if(!StringUtils.hasContent(outputRecord.getTableName()))
{
outputRecord.setTableName(table.getName());
}
outputRecords.add(outputRecord); outputRecords.add(outputRecord);
if(CollectionUtils.nullSafeIsEmpty(record.getErrors())) if(CollectionUtils.nullSafeIsEmpty(record.getErrors()))