49 |
return 1 |
return 1 |
50 |
return 0 |
return 0 |
51 |
|
|
52 |
|
def getPostType(self): |
53 |
|
tmpPostType = "" |
54 |
|
if hasattr(self._parent._dataObject,"posttype"): |
55 |
|
tmpPostType =self._parent._dataObject.posttype.lower() |
56 |
|
return tmpPostType |
57 |
|
|
58 |
def _postChanges(self,autoCommit=1): |
def _postChanges(self,autoCommit=1): |
59 |
if not self.isPending(): return |
if not self.isPending(): return |
60 |
auxTable = map(lambda x: x.strip(), self._parent._dataObject.table.split(',')) |
auxTable = map(lambda x: x.strip(), self._parent._dataObject.table.split(',')) |
61 |
|
|
62 |
if self._haveHistory(): |
if self._haveHistory() and self.getPostType() == "" or self.getPostType() == "transactional": |
63 |
return self._postChangesWHist(autoCommit) |
return self._postChangesWHist(autoCommit) |
64 |
|
|
65 |
statements = [] |
statements = [] |
267 |
vals.append (self._parent._dataObject._toSqlString(\ |
vals.append (self._parent._dataObject._toSqlString(\ |
268 |
self._fields[self._parent._dataObject._joinConditions[iterField]])) |
self._fields[self._parent._dataObject._joinConditions[iterField]])) |
269 |
|
|
270 |
|
if self._haveHistory(table): |
271 |
|
fields.append("_start_t") |
272 |
|
vals.append("'%s'" % self._parent._dataObject.triggerExtensions.getTimeStamp()) |
273 |
|
|
274 |
return "INSERT INTO %s (%s) VALUES (%s)" % \ |
return "INSERT INTO %s (%s) VALUES (%s)" % \ |
275 |
(table, string.join(fields,','), \ |
(table, string.join(fields,','), \ |
276 |
string.join(vals,',') ) |
string.join(vals,',') ) |