equal
deleted
inserted
replaced
485 for rtype, rorder, value in self.rdefs: |
485 for rtype, rorder, value in self.rdefs: |
486 if value is _FROM_SUBSTEP: |
486 if value is _FROM_SUBSTEP: |
487 value = row[index] |
487 value = row[index] |
488 index += 1 |
488 index += 1 |
489 if rorder == InsertRelationsStep.FINAL: |
489 if rorder == InsertRelationsStep.FINAL: |
490 edef.rql_set_value(rtype, value) |
490 edef._cw_rql_set_value(rtype, value) |
491 elif rorder == InsertRelationsStep.RELATION: |
491 elif rorder == InsertRelationsStep.RELATION: |
492 self.plan.add_relation_def( (edef, rtype, value) ) |
492 self.plan.add_relation_def( (edef, rtype, value) ) |
493 edef.querier_pending_relations[(rtype, 'subject')] = value |
493 edef.querier_pending_relations[(rtype, 'subject')] = value |
494 else: |
494 else: |
495 self.plan.add_relation_def( (value, rtype, edef) ) |
495 self.plan.add_relation_def( (value, rtype, edef) ) |
582 eid = typed_eid(lhsval) |
582 eid = typed_eid(lhsval) |
583 try: |
583 try: |
584 edef = edefs[eid] |
584 edef = edefs[eid] |
585 except KeyError: |
585 except KeyError: |
586 edefs[eid] = edef = session.entity_from_eid(eid) |
586 edefs[eid] = edef = session.entity_from_eid(eid) |
587 edef.rql_set_value(str(rschema), rhsval) |
587 edef._cw_rql_set_value(str(rschema), rhsval) |
588 else: |
588 else: |
589 repo.glob_add_relation(session, lhsval, str(rschema), rhsval) |
589 repo.glob_add_relation(session, lhsval, str(rschema), rhsval) |
590 result[i] = newrow |
590 result[i] = newrow |
591 # update entities |
591 # update entities |
592 for eid, edef in edefs.iteritems(): |
592 for eid, edef in edefs.iteritems(): |