version 1.1, 2007/12/05 17:42:22
|
version 1.2, 2007/12/05 18:42:46
|
Line 25 def sql_quote(v):
|
Line 25 def sql_quote(v):
|
v=string.join(string.split(v,dkey),quote_dict[dkey]) |
v=string.join(string.split(v,dkey),quote_dict[dkey]) |
return "'%s'"%v |
return "'%s'"%v |
|
|
def SimpleSearch(curs,query, args=None, ascii=False): |
def SimpleSearch(curs,query, args=None, ascii=False, result=True): |
"""execute sql query and return data""" |
"""execute sql query and return data""" |
#logging.debug("executing: "+query+" "+repr(args)) |
#logging.debug("executing: "+query+" "+repr(args)) |
if ascii: |
if ascii: |
Line 42 def SimpleSearch(curs,query, args=None,
|
Line 42 def SimpleSearch(curs,query, args=None,
|
|
|
curs.execute(query, args) |
curs.execute(query, args) |
#logger.debug("sql done") |
#logger.debug("sql done") |
|
if result: |
try: |
try: |
return curs.fetchall() |
return curs.fetchall() |
except: |
except: |
Line 236 class ASCII_handler:
|
Line 237 class ASCII_handler:
|
# find all not-updated fields |
# find all not-updated fields |
if self.dbIDs[id] == 0: |
if self.dbIDs[id] == 0: |
self.logger.info(" delete:"+id) |
self.logger.info(" delete:"+id) |
SimpleSearch(self.db, delQuery, [id], ascii=self.ascii_db) |
SimpleSearch(self.db, delQuery, [id], ascii=self.ascii_db, result=False) |
sys.exit(1) |
sys.exit(1) |
|
|
elif self.dbIDs[id] > 1: |
elif self.dbIDs[id] > 1: |
Line 295 class ASCII_handler:
|
Line 296 class ASCII_handler:
|
# last argument is ID match |
# last argument is ID match |
args.append(id_val) |
args.append(id_val) |
self.logger.debug("update: %s = %s"%(id_val, args)) |
self.logger.debug("update: %s = %s"%(id_val, args)) |
SimpleSearch(self.db, self.updQuery, args, ascii=self.ascii_db) |
SimpleSearch(self.db, self.updQuery, args, ascii=self.ascii_db, result=False) |
|
|
elif not self.update_mode: |
elif not self.update_mode: |
# create new row |
# create new row |
self.logger.debug("insert: %s"%args) |
self.logger.debug("insert: %s"%args) |
SimpleSearch(self.db, self.addQuery, args, ascii=self.ascii_db) |
SimpleSearch(self.db, self.addQuery, args, ascii=self.ascii_db, result=False) |
|
|
#self.logger.info(" row:"+"%d (%s)"%(self.rowcnt,id_val)) |
#self.logger.info(" row:"+"%d (%s)"%(self.rowcnt,id_val)) |
if (self.rowcnt % 100) == 0: |
if (self.rowcnt % 100) == 0: |