devtools/dataimport.py
branchstable
changeset 4734 4ae30c9ca11b
parent 4721 8f63691ccb7f
child 4818 9f9bfbcdecfd
equal deleted inserted replaced
4733:022290f7503d 4734:4ae30c9ca11b
   430         self.types.setdefault(args[0], []).append(entity.eid)
   430         self.types.setdefault(args[0], []).append(entity.eid)
   431         return entity
   431         return entity
   432 
   432 
   433     def _put(self, type, item):
   433     def _put(self, type, item):
   434         query = ('INSERT %s X: ' % type) + ', '.join('X %s %%(%s)s' % (k, k)
   434         query = ('INSERT %s X: ' % type) + ', '.join('X %s %%(%s)s' % (k, k)
   435                                                      for k in item])
   435                                                      for k in item)
   436         return self.rql(query, item)[0][0]
   436         return self.rql(query, item)[0][0]
   437 
   437 
   438     def relate(self, eid_from, rtype, eid_to):
   438     def relate(self, eid_from, rtype, eid_to):
   439         # if reverse relation is found, eids are exchanged
   439         # if reverse relation is found, eids are exchanged
   440         eid_from, rtype, eid_to = super(RQLObjectStore, self).relate(
   440         eid_from, rtype, eid_to = super(RQLObjectStore, self).relate(