92 |
|
|
93 |
try: |
try: |
94 |
print "statement: %s" % statement |
print "statement: %s" % statement |
95 |
self._parent._update_cursor.execute(statement) |
self._parent._update_cursor.execute("BEGIN; "+statement+"; COMMIT;") |
96 |
|
|
97 |
# Set _initialData to be the just-now posted values |
# Set _initialData to be the just-now posted values |
98 |
if not self._deleteFlag: |
if not self._deleteFlag: |
100 |
self._initialData.update(self._fields) |
self._initialData.update(self._fields) |
101 |
|
|
102 |
except self._parent._dataObject._DatabaseError, err: |
except self._parent._dataObject._DatabaseError, err: |
103 |
|
GDebug.printMesg(1, "DBSIG_RecordSet._postChanges ERROR %s " % err) |
104 |
raise GDataObjects.ConnectionError, err |
raise GDataObjects.ConnectionError, err |
105 |
|
|
106 |
self._updateFlag = 0 |
self._updateFlag = 0 |
317 |
self._parent._update_cursor.execute("COMMIT") |
self._parent._update_cursor.execute("COMMIT") |
318 |
|
|
319 |
except self._parent._dataObject._DatabaseError, err: |
except self._parent._dataObject._DatabaseError, err: |
320 |
GDebug.printMesg(5, "_doInsertStatementWHist: ERROR = %s" % err) |
GDebug.printMesg(1, "_doInsertStatementWHist: ERROR = %s" % err) |
321 |
raise GDataObjects.ConnectionError, err |
raise GDataObjects.ConnectionError, err |
322 |
|
|
323 |
return 1 |
return 1 |