equal
deleted
inserted
replaced
268 msgs = [] |
268 msgs = [] |
269 # dict(varname: eid), allowing to check rql expression for variables |
269 # dict(varname: eid), allowing to check rql expression for variables |
270 # which have a known eid |
270 # which have a known eid |
271 varkwargs = {} |
271 varkwargs = {} |
272 if not cnx.transaction_data.get('security-rqlst-cache'): |
272 if not cnx.transaction_data.get('security-rqlst-cache'): |
273 for var in rqlst.defined_vars.itervalues(): |
273 for var in rqlst.defined_vars.values(): |
274 if var.stinfo['constnode'] is not None: |
274 if var.stinfo['constnode'] is not None: |
275 eid = var.stinfo['constnode'].eval(self.args) |
275 eid = var.stinfo['constnode'].eval(self.args) |
276 varkwargs[var.name] = int(eid) |
276 varkwargs[var.name] = int(eid) |
277 # dictionary of variables restricted for security reason |
277 # dictionary of variables restricted for security reason |
278 localchecks = {} |
278 localchecks = {} |
417 self.r_defs.remove(rdef) |
417 self.r_defs.remove(rdef) |
418 return [rdef] |
418 return [rdef] |
419 |
419 |
420 def relation_defs(self): |
420 def relation_defs(self): |
421 """return the list for relation definitions to insert""" |
421 """return the list for relation definitions to insert""" |
422 for rdefs in self._expanded_r_defs.itervalues(): |
422 for rdefs in self._expanded_r_defs.values(): |
423 for rdef in rdefs: |
423 for rdef in rdefs: |
424 yield rdef |
424 yield rdef |
425 for rdef in self.r_defs: |
425 for rdef in self.r_defs: |
426 yield rdef |
426 yield rdef |
427 |
427 |
471 if rtype in relations: |
471 if rtype in relations: |
472 relations[rtype].append((subj, obj)) |
472 relations[rtype].append((subj, obj)) |
473 else: |
473 else: |
474 relations[rtype] = [(subj, obj)] |
474 relations[rtype] = [(subj, obj)] |
475 repo.glob_add_relations(cnx, relations) |
475 repo.glob_add_relations(cnx, relations) |
476 for edited in edited_entities.itervalues(): |
476 for edited in edited_entities.values(): |
477 repo.glob_update_entity(cnx, edited) |
477 repo.glob_update_entity(cnx, edited) |
478 |
478 |
479 |
479 |
480 class QuerierHelper(object): |
480 class QuerierHelper(object): |
481 """helper class to execute rql queries, putting all things together""" |
481 """helper class to execute rql queries, putting all things together""" |