Diff for /ZSQLExtend/importASCII.py between versions 1.1 and 1.2

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:

Removed from v.1.1  
changed lines
  Added in v.1.2


FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>