--- ZSQLExtend/ZSQLExtend.py 2007/11/05 18:45:35 1.120 +++ ZSQLExtend/ZSQLExtend.py 2008/02/15 13:05:41 1.124 @@ -357,7 +357,7 @@ class ZSQLExtendFolder(Folder,Persistent return ret - def importXMLFileFMP(self,table,dsn=None,uploadfile=None,update_fields=None,id_field=None,sync_mode=False, + def importXMLFileFMP(self,tables,dsn=None,uploadfile=None,update_fields=None,id_field=None,sync_mode=False, lc_names=True,keep_fields=False,ascii_db=False,replace=False,backup=False, debug=False,log_to_response=False, redirect_url=None,RESPONSE=None): @@ -389,46 +389,53 @@ class ZSQLExtendFolder(Folder,Persistent if not dsn: dsn=self.getConnectionObj().connection_string - - options=Options() - options.dsn=dsn - options.table=table - options.filename=filename - options.update_fields=update_fields - options.id_field=id_field - options.sync_mode=sync_mode - options.lc_names=lc_names - options.replace_table=replace - options.keep_fields=keep_fields - options.ascii_db=ascii_db - options.replace_table=replace - options.backup_table=backup - options.debug=debug - - if RESPONSE and log_to_response: - # set up logging to response as plain text - RESPONSE.setHeader("Content-Type","text/plain; charset=utf-8") - RESPONSE.write("Import FMPXML file...\n\n") - loghandler = logging.StreamHandler(RESPONSE) - if debug: - loghandler.setLevel(logging.DEBUG) - else: - loghandler.setLevel(logging.INFO) - logger = logging.getLogger('db.import.fmpxml') - logger.addHandler(loghandler) - options.use_logger_instance = logger + + tablelist=tables.split(',') + logging.debug("tablelist: %s" %tablelist) + #table=tables + + for table in tablelist : + logging.debug("table: %s" %table) + options=Options() + options.dsn=dsn + options.table=table + options.filename=filename + options.update_fields=update_fields + options.id_field=id_field + options.sync_mode=sync_mode + options.lc_names=lc_names + options.replace_table=replace + options.keep_fields=keep_fields + options.ascii_db=ascii_db + options.replace_table=replace + options.backup_table=backup + options.debug=debug + + if RESPONSE and log_to_response: + # set up logging to response as plain text + RESPONSE.setHeader("Content-Type","text/plain; charset=utf-8") + RESPONSE.write("Import FMPXML file...\n\n") + loghandler = logging.StreamHandler(RESPONSE) + if debug: + loghandler.setLevel(logging.DEBUG) + else: + loghandler.setLevel(logging.INFO) + logger = logging.getLogger('db.import.fmpxml') + logger.addHandler(loghandler) + options.use_logger_instance = logger - importFMPXML(options) + importFMPXML(options) + + + if RESPONSE and log_to_response: + loghandler.flush() + RESPONSE.write("\n\n DONE!") + + elif RESPONSE and redirect_url: + RESPONSE.redirect(redirect_url) + os.remove(filename) - - if RESPONSE and log_to_response: - loghandler.flush() - RESPONSE.write("\n\n DONE!") - return - - if RESPONSE and redirect_url: - RESPONSE.redirect(redirect_url) def generateIndex(self,field,index_name,table,RESPONSE=None): @@ -477,6 +484,7 @@ class ZSQLExtendFolder(Folder,Persistent def createIdSet(self, resultset, idField=None): """returns a (frozen)set of IDs from a SQL-resultset (using idField) or a list (if idField=None)""" + logging.debug("createidset for idfield %s"%idField) if idField is None: return frozenset(resultset) else: @@ -485,6 +493,7 @@ class ZSQLExtendFolder(Folder,Persistent def opIdSet(self, a, b, op): """operate on sets a and b""" + logging.debug("opidset with op %s"%op) if (op == 'intersect'): return a.intersection(b) elif (op == 'union'): @@ -1266,30 +1275,25 @@ class ZSQLExtendFolder(Folder,Persistent """suche mit alten parametern bis auf die in argv getauschten""" if args: argv=args - + #get the old queries qs=self.REQUEST.SESSION[storename]['qs'] querys=qs.split(",") #which arguments are in the old query string - queryList={} for query in querys: arg=query.split("=")[0] if arg[0]=="_": arg="-"+arg[1:] # sicherstellen, dass an Anfang stets "_" try: - queryList[arg]=query.split("=")[1] + queryList[arg]=urllib.unquote_plus(query.split("=")[1]) except: queryList[arg]='' argList=[] arg="" - - - #gehe durch die zu aendernden Argumente for argTmp in argv.keys(): - arg=argTmp[0:]# sicherstellen, dass der string auh kopiert wird if arg[0]=="_": arg="-"+arg[1:] # sicherstellen, dass an Anfang stets "_" @@ -1301,6 +1305,7 @@ class ZSQLExtendFolder(Folder,Persistent str="ZSQLSearch?"+urllib.urlencode(queryList) return str + def parseQueryString(self,qs,iCT,storemax="no",select=None,nostore=None,storename="foundCount",tableExt=None,NoQuery=None,NoLimit=None,restrictField=None,restrictConnect=None,filter=None): """analysieren den QueryString"""