+
+ def check4commit(self,newSQL,lastdate):
+ logging.info("check4commit 1")
+ if self.concernedRows==None:
+ logging.info("check4commit Updatung concernedRows")
+ sql="SELECT pcdatum,rowid FROM logtable WHERE pcdatum>? ORDER BY pcdatum DESC"
+ self.concernedRows=self.db.ladeSQL(sql,(lastdate,))
+
+
+ if (self.concernedRows!=None)and(len(self.concernedRows)>0):
+ #logging.info("check4commit 2")
+ id1, pcdatum,sql, param, host, rowid = newSQL
+
+ if len(rowid)>0:
+ for x in self.concernedRows:
+ #logging.info("check4commit 3")
+ if (x[1]==rowid):
+ if (x[0]>pcdatum):
+ logging.info("newer sync entry, ignoring old one")
+ #logging.info("check4commit 9.1")
+ return False
+ else:
+ #logging.info("check4commit 9.2")
+ return True
+
+ #logging.info("check4commit 9.3")
+ return True