@@ -179,7 +179,7 @@ def query(self, q, params=None, timeout=None, read_only=False):
179
179
self .version = e .version
180
180
self ._refresh_schema ()
181
181
# re-issue query
182
- return self .query (q , params , timeout )
182
+ return self .query (q , params , timeout , read_only )
183
183
184
184
def _execution_plan_to_string (self , plan ):
185
185
return "\n " .join (plan )
@@ -214,21 +214,21 @@ def merge(self, pattern):
214
214
return self .query (query )
215
215
216
216
# Procedures.
217
- def call_procedure (self , procedure , * args , ** kwagrs ):
217
+ def call_procedure (self , procedure , read_only = False , * args , ** kwagrs ):
218
218
args = [quote_string (arg ) for arg in args ]
219
219
q = 'CALL %s(%s)' % (procedure , ',' .join (args ))
220
220
221
221
y = kwagrs .get ('y' , None )
222
222
if y :
223
223
q += ' YIELD %s' % ',' .join (y )
224
224
225
- return self .query (q )
225
+ return self .query (q , read_only = read_only )
226
226
227
227
def labels (self ):
228
- return self .call_procedure ("db.labels" ).result_set
228
+ return self .call_procedure ("db.labels" , read_only = True ).result_set
229
229
230
230
def relationshipTypes (self ):
231
- return self .call_procedure ("db.relationshipTypes" ).result_set
231
+ return self .call_procedure ("db.relationshipTypes" , read_only = True ).result_set
232
232
233
233
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