request="SELECT id,is_integer FROM {0}.quantities WHERE (name,is_vector) = (%s,false)".format(self.base.schema)
curs=self.base.performRequest(request,[name])
item=curs.fetchone()
if(itemisNone):
raiseException("unknown quantity \""+name+"\"")
quantity_id=item[0]
is_integer=item[1]
request="SELECT step,measurement from {0}.{1} WHERE (run_id,quantity_id) = ({2},{3})".format(self.base.schema,"scalar_real"if(is_integer==False)else"scalar_integer",self.id,quantity_id)
if(additional_request):
request+=" and "+" and ".join(additional_request)
request+=" ORDER BY step"
curs.execute(request,[name])
fetch=curs.fetchall()
if(notfetch):
returnNone
return(np.array([(val[0],val[1])forvalinfetch]))
defgetVectorQuantity(self,name,step):
request="SELECT id,is_integer FROM {0}.quantities WHERE (name,is_vector) = (%s,true)".format(self.base.schema)
curs=self.base.performRequest(request,[name])
item=curs.fetchone()
if(itemisNone):
raiseException("unknown quantity \""+name+"\"")
quantity_id=item[0]
is_integer=item[1]
request="SELECT measurement from {0}.{1} WHERE (run_id,quantity_id,step) = ({2},{3},{4})".format(self.base.schema,"vector_real"if(is_integer==False)else"vector_integer",self.id,quantity_id,step)
curs.execute(request,[name])
fetch=curs.fetchone()
if(fetch):
returnnp.array(fetch[0])
returnNone
defgetAllVectorQuantity(self,name):
request="SELECT id,is_integer FROM {0}.quantities WHERE (name,is_vector) = (%s,true)".format(self.base.schema)
curs=self.base.performRequest(request,[name])
item=curs.fetchone()
if(itemisNone):
raiseException("unknown quantity \""+name+"\"")
quantity_id=item[0]
is_integer=item[1]
request="SELECT step,measurement from {0}.{1} WHERE (run_id,quantity_id) = ({2},{3}) order by step".format(self.base.schema,"vector_real"if(is_integer==False)else"vector_integer",self.id,quantity_id)