140 |
pass |
pass |
141 |
for iterTable in updTables.keys(): |
for iterTable in updTables.keys(): |
142 |
self._doDeleteStatementWHist(iterTable) |
self._doDeleteStatementWHist(iterTable) |
143 |
self._doInsertStatementWHist(iterTable) |
self._doInsertStatementWHist(iterTable,1) |
144 |
else: |
else: |
145 |
self._doDeleteStatementWHist(auxTable[0]) |
self._doDeleteStatementWHist(auxTable[0]) |
146 |
self._doInsertStatementWHist(auxTable[0]) |
self._doInsertStatementWHist(auxTable[0],1) |
147 |
|
|
148 |
except self._parent._dataObject._DatabaseError, err: |
except self._parent._dataObject._DatabaseError, err: |
149 |
GDebug.printMesg(1, "DBSIG_RecordSet._postChangesWHist ERROR = %s " % err) |
GDebug.printMesg(1, "DBSIG_RecordSet._postChangesWHist ERROR = %s " % err) |
275 |
(table, string.join(fields,','), \ |
(table, string.join(fields,','), \ |
276 |
string.join(vals,',') ) |
string.join(vals,',') ) |
277 |
|
|
278 |
def _doInsertStatementWHist(self, table): |
def _doInsertStatementWHist(self, table, forUpdate=0): |
279 |
statementElement = self._buildInsertStatementWHist(table) |
statementElement = self._buildInsertStatementWHist(table,forUpdate) |
280 |
statement = "INSERT INTO %s (%s) VALUES (%s)" % \ |
statement = "INSERT INTO %s (%s) VALUES (%s)" % \ |
281 |
(statementElement[0], string.join(statementElement[1],','), \ |
(statementElement[0], string.join(statementElement[1],','), \ |
282 |
string.join(statementElement[2],',') ) |
string.join(statementElement[2],',') ) |
292 |
|
|
293 |
return 1 |
return 1 |
294 |
|
|
295 |
def _buildInsertStatementWHist(self, table, field=None): |
def _buildInsertStatementWHist(self, table, field=None,forUpdate=0): |
296 |
if field and field.count('.') > 0: |
if field and field.count('.') > 0: |
297 |
field = field.split('.')[1] |
field = field.split('.')[1] |
298 |
|
|
349 |
|
|
350 |
if self._haveHistory(table): |
if self._haveHistory(table): |
351 |
fields.append("_start_t") |
fields.append("_start_t") |
352 |
vals.append("'%s'" % self._parent._dataObject.triggerExtensions.getTimeStamp()) |
if forUpdate: |
353 |
|
vals.append("'%s'" % self._parent._dataObject.triggerExtensions.getTimeStamp()) |
354 |
|
else: |
355 |
|
vals.append("'1970-01-01'") |
356 |
|
|
357 |
statementElement = [] |
statementElement = [] |
358 |
statementElement.append(table) |
statementElement.append(table) |