191 |
|
|
192 |
def execute (self, classname): |
def execute (self, classname): |
193 |
if self._deleteList.has_key (classname): |
if self._deleteList.has_key (classname): |
194 |
result = self._dataCon._sm.delete (self._dataCon._sess_id, classname, |
self._dataCon._sm.delete (self._dataCon._sess_id, classname, |
195 |
self._deleteList [classname]) |
self._deleteList [classname]) |
196 |
del self._deleteList [classname] |
del self._deleteList [classname] |
197 |
|
|
198 |
if self._updateList.has_key (classname): |
if self._updateList.has_key (classname): |
201 |
dict = self._updateList[classname].pop() |
dict = self._updateList[classname].pop() |
202 |
# TODO: merge calls with similar updated fields (=dict.values()) |
# TODO: merge calls with similar updated fields (=dict.values()) |
203 |
data = [self._to_utf_8 (x) for x in dict.values ()] |
data = [self._to_utf_8 (x) for x in dict.values ()] |
204 |
result = self._dataCon._sm.store (self._dataCon._sess_id, classname, |
new_ids = self._dataCon._sm.store (self._dataCon._sess_id, classname, |
205 |
[id], dict.keys(), [data]) |
[id], dict.keys(), [data]) |
206 |
|
dict ["gnue_id"] = new_ids [0] |
207 |
del self._updateList [classname] |
del self._updateList [classname] |
208 |
del self._updateKeyList [classname] |
del self._updateKeyList [classname] |
209 |
|
|