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

Update insert action to do pre-step - e.g., to prime amazon s3 client

Browse Source
This commit is contained in:
darin.kelkhoff
2023-02-21 22:19:50 -06:00
parent 63be3f01a7
commit f28af62c5e
2 changed files with 7 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
qqq-backend-module-filesystem/src/main/java/com/kingsrook/qqq/backend/module/filesystem/base/actions/AbstractBaseFilesystemAction.java
View File

@ -338,6 +338,8 @@ public abstract class AbstractBaseFilesystemAction<FILE>
{ {
try try
{ {
preAction(insertInput.getBackend());
InsertOutput output = new InsertOutput(); InsertOutput output = new InsertOutput();
QTableMetaData table = insertInput.getTable(); QTableMetaData table = insertInput.getTable();
QBackendMetaData backend = insertInput.getBackend(); QBackendMetaData backend = insertInput.getBackend();

7
qqq-backend-module-filesystem/src/test/java/com/kingsrook/qqq/backend/module/filesystem/s3/actions/S3InsertActionTest.java
View File

@ -25,7 +25,6 @@ package com.kingsrook.qqq.backend.module.filesystem.s3.actions;
import java.io.IOException; import java.io.IOException;
import java.util.List; import java.util.List;
import com.amazonaws.services.s3.model.S3Object; import com.amazonaws.services.s3.model.S3Object;
import com.kingsrook.qqq.backend.core.actions.tables.InsertAction;
import com.kingsrook.qqq.backend.core.exceptions.QException; import com.kingsrook.qqq.backend.core.exceptions.QException;
import com.kingsrook.qqq.backend.core.model.actions.tables.insert.InsertInput; import com.kingsrook.qqq.backend.core.model.actions.tables.insert.InsertInput;
import com.kingsrook.qqq.backend.core.model.actions.tables.insert.InsertOutput; import com.kingsrook.qqq.backend.core.model.actions.tables.insert.InsertOutput;
@ -89,7 +88,11 @@ public class S3InsertActionTest extends BaseS3Test
insertInput.setRecords(List.of( insertInput.setRecords(List.of(
new QRecord().withValue("id", "1").withValue("firstName", "Bob") new QRecord().withValue("id", "1").withValue("firstName", "Bob")
)); ));
assertThatThrownBy(() -> new InsertAction().execute(insertInput))
S3InsertAction insertAction = new S3InsertAction();
insertAction.setS3Utils(getS3Utils());
assertThatThrownBy(() -> insertAction.execute(insertInput))
.hasRootCauseInstanceOf(NotImplementedException.class); .hasRootCauseInstanceOf(NotImplementedException.class);
} }
} }