123456789101112131415161718192021222324252627282930313233 |
- import labkeyInterface
- import json
- class labkeyDB:
- def __init__(self,net):
- self.net=net
- def selectRows(self,project,schemaName, queryName,qfilter):
- debug=False
- url=self.net.GetLabkeyUrl()+'/'+project
- url+='/query-selectRows.api?schemaName='+schemaName+\
- '&query.queryName='+queryName
- for f in qfilter:
- url+="&query."+f['variable']+"~"+f['oper']+"="+f['value']
- if debug:
- print("Sending {}").format(url)
- response=self.net.get(url)
- return json.loads(response.data)
- def modifyRows(self,mode, project,schemaName, queryName, rows):
- #mode can be insert/update/delete
- debug=True
- data={}
- data['schemaName']=schemaName
- data['queryName']=queryName
- data['rows']=rows
- url=self.net.GetLabkeyUrl()+'/'+project
- url+='/query-'+mode+'Rows.api?'
- response=self.net.post(url,json.dumps(data))
- return response.data
|