@@ -179,7 +179,7 @@ def query(self, q, params=None, timeout=None, read_only=False):
179179 self .version = e .version
180180 self ._refresh_schema ()
181181 # re-issue query
182- return self .query (q , params , timeout )
182+ return self .query (q , params , timeout , read_only )
183183
184184 def _execution_plan_to_string (self , plan ):
185185 return "\n " .join (plan )
@@ -214,21 +214,21 @@ def merge(self, pattern):
214214 return self .query (query )
215215
216216 # Procedures.
217- def call_procedure (self , procedure , * args , ** kwagrs ):
217+ def call_procedure (self , procedure , read_only = False , * args , ** kwagrs ):
218218 args = [quote_string (arg ) for arg in args ]
219219 q = 'CALL %s(%s)' % (procedure , ',' .join (args ))
220220
221221 y = kwagrs .get ('y' , None )
222222 if y :
223223 q += ' YIELD %s' % ',' .join (y )
224224
225- return self .query (q )
225+ return self .query (q , read_only = read_only )
226226
227227 def labels (self ):
228- return self .call_procedure ("db.labels" ).result_set
228+ return self .call_procedure ("db.labels" , read_only = True ).result_set
229229
230230 def relationshipTypes (self ):
231- return self .call_procedure ("db.relationshipTypes" ).result_set
231+ return self .call_procedure ("db.relationshipTypes" , read_only = True ).result_set
232232
233233 def propertyKeys (self ):
234- return self .call_procedure ("db.propertyKeys" ).result_set
234+ return self .call_procedure ("db.propertyKeys" , read_only = True ).result_set
0 commit comments