Use maxRows in SelectRowsCommand

bbimber · bbimber · commit a93767f9c833 · 2025-08-10T05:49:09.000-07:00
diff --git a/primeseq/src/org/labkey/primeseq/etl/VerifyRowCount.java b/primeseq/src/org/labkey/primeseq/etl/VerifyRowCount.java
@@ -153,6 +153,7 @@ private long getSourceTableCount(PipelineJob job) throws PipelineJobException
             DataIntegrationService.RemoteConnection rc = getRemoteDataSource(_settings.get(Settings.sourceRemoteSource.name()), _containerUser.getContainer(), job.getLogger());
             SelectRowsCommand sr = new SelectRowsCommand(_settings.get(Settings.sourceSchema.name()), _settings.get(Settings.sourceQuery.name()));
             sr.setColumns(Collections.singletonList(_settings.get(Settings.sourceColumn.name())));
+            sr.setMaxRows(1); // Ensures we get rowCount
 
             if (_settings.get(Settings.sourceAdditionalFilters.name()) != null)
             {

Original file line number	Diff line number	Diff line change
`@@ -153,6 +153,7 @@ private long getSourceTableCount(PipelineJob job) throws PipelineJobException`
`153`	`153`	`DataIntegrationService.RemoteConnection rc = getRemoteDataSource(_settings.get(Settings.sourceRemoteSource.name()), _containerUser.getContainer(), job.getLogger());`
`154`	`154`	`SelectRowsCommand sr = new SelectRowsCommand(_settings.get(Settings.sourceSchema.name()), _settings.get(Settings.sourceQuery.name()));`
`155`	`155`	`sr.setColumns(Collections.singletonList(_settings.get(Settings.sourceColumn.name())));`
	`156`	`+ sr.setMaxRows(1); // Ensures we get rowCount`
`156`	`157`
`157`	`158`	`if (_settings.get(Settings.sourceAdditionalFilters.name()) != null)`
`158`	`159`	`{`