Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion flow/src/org/labkey/flow/data/FlowProtocol.java
Original file line number Diff line number Diff line change
Expand Up @@ -625,7 +625,7 @@ public FCSFilesGroupedBySample getFCSFilesGroupedBySample(User user, Container c
Map<Long, Pair<Long, String>> fcsFileRuns = new LongHashMap<>();
int linkedFcsFileCount = 0;

try (TableResultSet rs = QueryService.get().select(schema, sql, tableMap, false, false))
try (TableResultSet rs = QueryService.get().getSelectBuilder(schema, sql, false, tableMap).select())
{
for (Map<String, Object> row : rs)
{
Expand Down
8 changes: 4 additions & 4 deletions flow/src/org/labkey/flow/data/FlowRun.java
Original file line number Diff line number Diff line change
Expand Up @@ -124,7 +124,7 @@ public FlowWell[] getWells(boolean realFiles)
{
_allDatas = getDatas(null);
}

List<FlowWell> wells = new ArrayList<>();
for (FlowDataObject obj : _allDatas)
{
Expand Down Expand Up @@ -181,7 +181,7 @@ public FlowCompensationMatrix getCompensationMatrix()
return null;
return new FlowCompensationMatrix(datas.getFirst());
}

public long getRunId()
{
return getExperimentRun().getRowId();
Expand Down Expand Up @@ -384,7 +384,7 @@ static public List<FlowRun> getRunsForPath(Container container, FlowProtocolStep
childProtocol = childFlowProtocol.getProtocol();
}

ExperimentService.get().getExpRuns(container, null, childProtocol, run ->
ExperimentService.get().getExpRuns(container, null, childProtocol, run ->
runFilePathRoot == null || (run.getFilePathRoot() != null && runFilePathRoot.toNioPathForRead().toFile().equals(run.getFilePathRoot()))
).forEach( run -> ret.add(new FlowRun(run)));

Expand Down Expand Up @@ -433,7 +433,7 @@ public FlowFCSFile[] getFCSFilesToBeAnalyzed(FlowProtocol protocol, ScriptSettin
filter.addAllClauses(protocol.getFCSAnalysisFilter());
if (settings != null)
filter.addAllClauses(settings.getFilter());
try (ResultSet rs = QueryService.get().select(table, new ArrayList<>(Arrays.asList(colRowId)), filter, null))
try (ResultSet rs = QueryService.get().getSelectBuilder(table).columns(new ArrayList<>(Arrays.asList(colRowId))).filter(filter).select())
{
while (rs.next())
{
Expand Down
13 changes: 7 additions & 6 deletions flow/src/org/labkey/flow/persist/PersistTests.java
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,7 @@
import org.junit.Test;
import org.labkey.api.collections.CaseInsensitiveHashMap;
import org.labkey.api.data.Container;
import org.labkey.api.data.Results;
import org.labkey.api.data.SimpleFilter;
import org.labkey.api.data.SqlSelector;
import org.labkey.api.data.Table;
Expand Down Expand Up @@ -154,13 +155,13 @@ public void keywordAliases() throws Exception
// verify query
FlowSchema schema = new FlowSchema(user, c);

try (ResultSet results = QueryService.get().select(schema, "SELECT " +
try (ResultSet results = QueryService.get().getSelectBuilder(schema, "SELECT " +
"A.Name, " +
"A.Keyword.keyword1 AS k1, " +
"A.Keyword.\"keyword1-alias\" AS k1_alias, " +
"A.Keyword('keyword1') AS k1_method, " +
"A.Keyword('keyword1-alias') AS k1_alias_method " +
"FROM flow.FCSFiles AS A"))
"FROM flow.FCSFiles AS A").select())
{
assertTrue(results.next());
assertEquals(this.getClass().getSimpleName(), results.getString("Name"));
Expand Down Expand Up @@ -221,13 +222,13 @@ public void keywordAliases() throws Exception
// verify query
FlowSchema schema = new FlowSchema(user, c);

try (ResultSet results = QueryService.get().select(schema, "SELECT " +
try (ResultSet results = QueryService.get().getSelectBuilder(schema, "SELECT " +
"A.Name, " +
"A.Keyword.keyword2 AS k2, " +
"A.Keyword.\"keyword2-alias\" AS k2_alias, " +
"A.Keyword('keyword2') AS k2_method, " +
"A.Keyword('keyword2-alias') AS k2_alias_method " +
"FROM flow.FCSFiles AS A"))
"FROM flow.FCSFiles AS A").select())
{
assertTrue(results.next());
assertEquals(this.getClass().getSimpleName(), results.getString("Name"));
Expand Down Expand Up @@ -301,14 +302,14 @@ public void statisticAliases() throws Exception
// verify stat values
FlowSchema schema = new FlowSchema(user, c);

try (TableResultSet rs = (TableResultSet)QueryService.get().select(schema, "SELECT " +
try (Results rs = QueryService.get().getSelectBuilder(schema, "SELECT " +
"A.Name, " +
"A.Statistic.\"X:Count\" AS stat, " +
"A.Statistic.\"x:count\" AS stat_lowercase, " +
"A.Statistic.\"X-alias:Count\" AS stat_alias, " +
"A.Statistic('X:Count') AS stat_method, " +
"A.Statistic('X-alias:Count') AS stat_alias_method " +
"FROM flow.FCSAnalyses AS A ORDER BY Name"))
"FROM flow.FCSAnalyses AS A ORDER BY Name").select(true))
{
assertEquals(2, rs.getSize());

Expand Down
3 changes: 2 additions & 1 deletion flow/src/org/labkey/flow/reports/FilterFlowReport.java
Original file line number Diff line number Diff line change
Expand Up @@ -385,7 +385,8 @@ else if ("fieldkey".equals(f.type))
}

_query = query.toString();
Results results = QueryService.get().getSelectBuilder(flow, _query).select();
// Pass true to get a CachedResultSet, which this code requires (see getWrapped() and date manipulation below)
Results results = QueryService.get().getSelectBuilder(flow, _query).select(true);
// This still breaks encapsulation, but it's better than a direct cast.
CachedResultSet rs = results.getWrapped(CachedResultSet.class);
if (null == rs)
Expand Down
Loading