Set bulkLoad in more ETLs

Author: bbimber

mGAP/src/org/labkey/mgap/etl/UpdatePedigreeStep.java

@@ -16,6 +16,7 @@
 import org.labkey.api.query.InvalidKeyException;
 import org.labkey.api.query.QueryException;
 import org.labkey.api.query.QueryService;
+import org.labkey.api.query.QueryUpdateService;
 import org.labkey.api.query.QueryUpdateServiceException;
 import org.labkey.api.query.UserSchema;
 import org.labkey.api.util.PageFlowUtil;
@@ -129,7 +130,9 @@ public RecordedActionSet run(@NotNull PipelineJob job) throws PipelineJobExcepti
 
             try
             {
-                subjectsTable.getUpdateService().updateRows(job.getUser(), job.getContainer(), toUpdate, oldKeys, null, new HashMap<>());
+                QueryUpdateService qus = subjectsTable.getUpdateService();
+                qus.setBulkLoad(true);
+                qus.updateRows(job.getUser(), job.getContainer(), toUpdate, oldKeys, null, new HashMap<>());
             }
             catch (QueryException | BatchValidationException | SQLException | InvalidKeyException | QueryUpdateServiceException e)
             {

mcc/src/org/labkey/mcc/etl/PopulateGeneticDataStep.java

@@ -17,6 +17,7 @@
 import org.labkey.api.query.DuplicateKeyException;
 import org.labkey.api.query.FieldKey;
 import org.labkey.api.query.QueryService;
+import org.labkey.api.query.QueryUpdateService;
 import org.labkey.api.query.QueryUpdateServiceException;
 import org.labkey.api.util.PageFlowUtil;
 import org.labkey.api.writer.ContainerUser;
@@ -118,12 +119,15 @@ private void populateGeneticData(PipelineJob job) throws PipelineJobException
                 TableInfo gd = QueryService.get().getUserSchema(job.getUser(), child, "study").getTable("genomicDatasets");
                 try
                 {
-                    gd.getUpdateService().truncateRows(job.getUser(), child, null, null);
+                    QueryUpdateService qus = gd.getUpdateService();
+                    qus.setBulkLoad(true);
+
+                    qus.truncateRows(job.getUser(), child, null, null);
 
                     if (toInsert.containsKey(child))
                     {
                         BatchValidationException bve = new BatchValidationException();
-                        gd.getUpdateService().insertRows(job.getUser(), child, toInsert.get(child), bve, null, null);
+                        qus.insertRows(job.getUser(), child, toInsert.get(child), bve, null, null);
                         if (bve.hasErrors())
                         {
                             throw bve;

mcc/src/org/labkey/mcc/etl/PopulateIdsStep.java

@@ -18,6 +18,7 @@
 import org.labkey.api.query.DuplicateKeyException;
 import org.labkey.api.query.FieldKey;
 import org.labkey.api.query.QueryService;
+import org.labkey.api.query.QueryUpdateService;
 import org.labkey.api.query.QueryUpdateServiceException;
 import org.labkey.api.query.UserSchema;
 import org.labkey.api.util.PageFlowUtil;
@@ -146,7 +147,9 @@ private void populateForField(PipelineJob job, TableInfo sourceTi, String fieldN
                 job.getLogger().info("Total IDs to alias for field " + fieldName + " in container: " + c.getPath() + ": " + toAdd.get(c).size());
                 TableInfo ti = QueryService.get().getUserSchema(_containerUser.getUser(), c, MccSchema.NAME).getTable(MccSchema.TABLE_ANIMAL_MAPPING);
                 BatchValidationException bve = new BatchValidationException();
-                ti.getUpdateService().insertRows(_containerUser.getUser(), c, toAdd.get(c), bve, null, null);
+                QueryUpdateService qus = ti.getUpdateService();
+                qus.setBulkLoad(true);
+                qus.insertRows(_containerUser.getUser(), c, toAdd.get(c), bve, null, null);
                 if (bve.hasErrors())
                 {
                     throw bve;