Skip to content

Commit d7f5eab

Browse files
committed
adding ability to filter by result id for getDetailedResultInfo
1 parent 8554345 commit d7f5eab

File tree

2 files changed

+16
-5
lines changed

2 files changed

+16
-5
lines changed

src/api/ODM2/services/createService.py

Lines changed: 5 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -469,6 +469,11 @@ def createTimeSeriesResultValues(self, datavalues):
469469
try:
470470
#using Pandas built-in --slow
471471
#changing way values sent --unknown error on insert
472+
#cols = datavalues.columns.tolist()
473+
#['ValueDateTime', 'DataValue', 'TimeAggregationInterval', 'TimeAggregationIntervalUnitsID', 'QualityCodeCV', 'CensorCodeCV', 'ResultID', 'ValueDateTimeUTCOffset']
474+
cols = ['ResultID','DataValue','ValueDateTime','ValueDateTimeUTCOffset','CensorCodeCV','QualityCodeCV','TimeAggregationInterval','TimeAggregationIntervalUnitsID']
475+
datavalues = datavalues[cols]
476+
#print datavalues
472477
datavalues.to_sql(name=TimeSeriesResultValues.__tablename__,
473478
schema=TimeSeriesResultValues.__table_args__['schema'],
474479
if_exists='append',

src/api/ODM2/services/readService.py

Lines changed: 11 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -153,7 +153,7 @@ def getDetailedAffiliationInfo(self):
153153
affiliationList.append(detailedAffiliation)
154154
return affiliationList
155155

156-
def getDetailedResultInfo(self, resultTypeCV):
156+
def getDetailedResultInfo(self, resultTypeCV, resultID=None):
157157
q = self._session.query(Results, SamplingFeatures, Methods, Variables,
158158
ProcessingLevels, Units).filter(Results.VariableID==Variables.VariableID)\
159159
.filter(Results.UnitsID==Units.UnitsID)\
@@ -164,10 +164,16 @@ def getDetailedResultInfo(self, resultTypeCV):
164164
.filter(Results.ProcessingLevelID==ProcessingLevels.ProcessingLevelID)\
165165
.filter(Results.ResultTypeCV==resultTypeCV)
166166
resultList = []
167-
for r,s,m,v,p,u in q.all():
168-
detailedResult = DetailedResult(\
169-
r,s,m,v,p,u)
170-
resultList.append(detailedResult)
167+
if resultID:
168+
for r,s,m,v,p,u in q.filter_by(ResultID=resultID).all():
169+
detailedResult = DetailedResult(\
170+
r,s,m,v,p,u)
171+
resultList.append(detailedResult)
172+
else:
173+
for r,s,m,v,p,u in q.all():
174+
detailedResult = DetailedResult(\
175+
r,s,m,v,p,u)
176+
resultList.append(detailedResult)
171177
return resultList
172178

173179
"""

0 commit comments

Comments
 (0)