@@ -105,19 +105,11 @@ def commit(self):
105
105
"""
106
106
Create entire graph.
107
107
"""
108
- if len (self .nodes ) == 0 and len ( self .edges ) == 0 :
108
+ if not (self .nodes or self .edges ):
109
109
return None
110
110
111
- query = 'CREATE '
112
- for _ , node in self .nodes .items ():
113
- query += str (node ) + ','
114
-
115
- query += ',' .join ([str (edge ) for edge in self .edges ])
116
-
117
- # Discard leading comma.
118
- if query [- 1 ] == ',' :
119
- query = query [:- 1 ]
120
-
111
+ query = f'CREATE '
112
+ query += ',' .join (str (v ) for v in [* self .nodes .values (), * self .edges ])
121
113
return self .query (query )
122
114
123
115
def flush (self ):
@@ -140,7 +132,7 @@ def build_params_header(self, params):
140
132
# Value is None, replace with "null" string.
141
133
elif value is None :
142
134
value = "null"
143
- params_header += str ( key ) + "=" + str ( value ) + " "
135
+ params_header += f" { key } = { value } "
144
136
return params_header
145
137
146
138
def query (self , q , params = None , timeout = None , read_only = False ):
@@ -152,7 +144,7 @@ def query(self, q, params=None, timeout=None, read_only=False):
152
144
query = q
153
145
154
146
# handle query parameters
155
- if params is not None :
147
+ if params :
156
148
query = self .build_params_header (params ) + query
157
149
158
150
# construct query command
@@ -174,7 +166,7 @@ def query(self, q, params=None, timeout=None, read_only=False):
174
166
except redis .exceptions .ResponseError as e :
175
167
if "wrong number of arguments" in str (e ):
176
168
print ("Note: RedisGraph Python requires server version 2.2.8 or above" )
177
- raise e
169
+ raise
178
170
except VersionMismatchException as e :
179
171
# client view over the graph schema is out of sync
180
172
# set client version and refresh local schema
@@ -208,22 +200,18 @@ def merge(self, pattern):
208
200
"""
209
201
Merge pattern.
210
202
"""
211
-
212
- query = 'MERGE '
213
- query += str (pattern )
214
-
215
- return self .query (query )
203
+ return self .query (f'MERGE { pattern } '
216
204
217
205
# Procedures.
218
206
def call_procedure (self , procedure , read_only = False , * args , ** kwagrs ):
219
207
args = [quote_string (arg ) for arg in args ]
220
- q = 'CALL %s(%s)' % ( procedure , ',' .join (args ))
208
+ query = f 'CALL { procedure } ( { "," .join (args )} )'
221
209
222
- y = kwagrs .get ('y' , None )
210
+ y = kwagrs .get ('y' )
223
211
if y :
224
- q += ' YIELD %s' % ',' .join (y )
212
+ query += f ' YIELD { "," .join (y )} '
225
213
226
- return self .query (q , read_only = read_only )
214
+ return self .query (query , read_only = read_only )
227
215
228
216
def labels (self ):
229
217
return self .call_procedure ("db.labels" , read_only = True ).result_set
0 commit comments