--- ZSQLExtend/ZSQLExtend.py 2007/04/03 14:44:24 1.109 +++ ZSQLExtend/ZSQLExtend.py 2007/04/20 08:33:17 1.115 @@ -88,7 +88,9 @@ class ZSQLIndex(SimpleItem): return self.index class ZSQLExtendFolder(Folder,Persistent, Implicit): - """Folder""" + """Klasse die Methoden fuer die Abfrage einer SQL-Datenbank zur Verfuegung stellt. + + """ meta_type="ZSQLExtendFolder" def ZSQLQuote(self,str): @@ -97,17 +99,25 @@ class ZSQLExtendFolder(Folder,Persistent def normalizeField(self,table,fieldname, newFieldName=None,mode="alter", RESPONSE=None): - """normalize a field""" + """normalize a field, d.h. entfernt alle diakritischen Zeichen und ersetzt diese + durch den Grundbuchstaben in einer Spalte einer Tabelle + @param table: Tabellename + @param fieldname: Name der Spalte + @param newFieldName: (optional) default ist fieldname+"_normal" + @param mode: (optional) default ist "alter". Mode "alter" aendert ein bestehendes Feld newFieldName, mode "create" erzeugt diese zuerst. + """ import unicodedata if not newFieldName: newFieldName=fieldname+"_normal" - + + #normalisierungs routine def normal(str): if str: return unicodedata.normalize('NFKD', str.decode('utf-8')).encode('ASCII', 'ignore') else: return "" + if mode=="create": # create the field qstr="""alter table %s add %s %s""" self.ZSQLSimpleSearch(qstr%(table,newFieldName,'text')) @@ -443,7 +453,7 @@ class ZSQLExtendFolder(Folder,Persistent options.sync_mode=sync_mode options.replace_table=replace options.lc_names=True - options.ascii_db=ascii_db + options.ascii_db=ascii_db importFMPXML(options) os.remove(filename) @@ -452,9 +462,14 @@ class ZSQLExtendFolder(Folder,Persistent RESPONSE.redirect(redirect_url) def generateIndex(self,field,index_name,table,RESPONSE=None): - """erzeuge index aus feld""" + """erzeuge ein Index Objekt einem Feld (experimental) + @param field: Feldname zu dem ein Index erzeugt werden soll + @param index_name: Name des Index + @param table: Tabellen name""" + + index={} - founds=self.ZSQLSimpleSearch("""SELECT %s,oid FROM %s LIMIT 2000"""%(field,table)) + founds=self.ZSQLSimpleSearch("""SELECT %s,oid FROM %s """%(field,table)) for found in founds: tmp=getattr(found,field,None) @@ -474,26 +489,23 @@ class ZSQLExtendFolder(Folder,Persistent self._getOb(index_name).setIndex(index) def getIndex(self,index_name): - """getIndex""" + """getIndex from index_name + return an indexObject with index_name + """ + founds=self.ZopeFind(self,obj_ids=[index_name]) return founds[0][1].getIndex() - def testneu(self): - """test""" - relStatement="""period like '%s%%'""" - statement="select * from cdli_cat" - wherePart="museum_no like 'VAT%'" - classes=['Uruk III','Uruk IV'] - return self.searchRel(relStatement,statement,wherePart,classes) - def URLquote(self,txt): - """urlquote""" + """urlquote" + @param txt: text der urlgequoted werden soll. + """ return urllib.quote(txt) def searchRel(self,relStatement,statement,wherePart,classes): - """suche relative haufigkeiten""" + """suche relative haufigkeiten (experimental)""" ret={} allRecords=len(self.ZSQLSimpleSearch(statement + " where "+wherePart)) @@ -503,7 +515,7 @@ class ZSQLExtendFolder(Folder,Persistent return (ret,allRecords) def content_html(self): - """template fuer content""" + """template fuer content_html Aufruf, notwendig fuer Kompatibiliaet bei gemeinsamem Einsatz mich ECHO-Produkt""" try: obj=getattr(self,"ZSQLBibliography_template") @@ -516,21 +528,21 @@ class ZSQLExtendFolder(Folder,Persistent def getWeight(self): - """getLabe""" + """getWeight, gewicht notwendig fuer Kompatibiliaet bei gemeinsamem Einsatz mich ECHO-Produkt""" try: return self.weight except: return "" def getLabel(self): - """getLabe""" + """getLabel notwendig fuer Kompatibiliaet bei gemeinsamem Einsatz mich ECHO-Produkt""" try: return self.label except: return "" def getDescription(self): - """getLabe""" + """getDEscription: notwendig fuer Kompatibiliaet bei gemeinsamem Einsatz mich ECHO-Produkt""" try: return self.description except: @@ -547,7 +559,7 @@ class ZSQLExtendFolder(Folder,Persistent def changeZSQLExtend(self,label,description,weight=0,REQUEST=None,connection_id=None): - """change it""" + """change the Konfiguration""" self.connection_id=connection_id self.weight=weight self.label=label @@ -557,7 +569,10 @@ class ZSQLExtendFolder(Folder,Persistent return self.manage_main(self, REQUEST) def formatAscii(self,str,url=None): - """ersetze ascii umbrueche durch
""" + """ersetze ascii umbrueche durch
+ @param str: string der Formatiert werden soll. + @param url: (optional) default ist "None", sonderfall erzeugt einen Link aus String mit unterliegender url + """ #url=None str=str.rstrip().lstrip() @@ -614,15 +629,80 @@ class ZSQLExtendFolder(Folder,Persistent """oinly for demo""" return os.path.splitext(path)[0]+".jpg" - def ZSQLisEmpty(self,field): - """Teste ob Treffer leer""" + def ZSQLisEmpty(self,str): + """Teste ob String leer bzw. none ist. + """ #print "field",field - if not field: + if not str: return 1 - if field.strip()=="": + if str.strip()=="": return 1 return 0 + def ZSQLMultiSearch(self,_table,_searchField,_value,_idField,_additionalStatement="",_select=None,_subselectAddition="",_storename=None): + """ + Durchsucht in einer Tabelle "table" die Spalte "searchfield" nach dem allen Vorkommnissen + von Worten in value und gibt alle Werte mit gleichem id field zurŸck, d.h. es wird die "und" suche Ÿber mehrere Eintrsege in einer + Tabelle mit gleichem idField werd realisiert, + z.B. fŸr simplesearch ueber mehrere Felder + @param _table: Tabelle, die durchsucht werden soll. + @param _searchField: Feld, das durchsucht wird + @param _value: String der gesucht werden soll, gesucht wird nach allen Worten des Strings, die durch " "-getrennt sind. + @param _idField: Feld mit id fŸr die identifikation gleicher EintrŠge + @param _additionalStatement: (optional) Zusaetzliches SQL Statement, dass zwischen dem ersten "select from" und dem ersten "where" eingegefŸgt wird. + @param _select: (optional) Alternativer Wert fŸr den ersten SELECT Aufruf. + @param _storename: (optional) Name fuer die Zwischenspeicherung von Werten in der Session + """ + if _storename: + """store""" + else: + _storename="foundCount" + + queries=[] + #baue jede einzelne abfrage + splitted=_value.split(" ") + if not _select: + _select=_idField + + query="select %s from %s %s where lower(%s) like '%%%s%%'"%(_select,_table,_additionalStatement,_searchField,splitted[0].lower()) + + if len(splitted)>1: # mehr als ein Wort + query+=" and %s in"%_idField # dann einschraenken + for v in splitted[1:]: + queries.append("select %s from %s %s where lower(%s) like '%%%s%%'"%(_idField,_table,_subselectAddition,_searchField,v.lower())) + + + intersect=" intersect ".join(queries) # nun baue sie zusammen + query+="(%s)"%intersect + + + logging.info("ZSQLSimple: %s"%query) + retT=self.ZSQLSimpleSearch(query) + logging.info("ZSQLSimple: %s"%retT) + + #das Ergebis enthaelt unter u.U. eine id mehrfach, dieses wir jetzt vereinheitlicht. + + retFinalT={} + for x in retT: + split=_idField.split(".") + if len(split)>1: + f=split[1] + else: + f=_idField + + retFinalT[getattr(x,f)]=x + + ret=list(retFinalT.values()) + + + #aus Kompatibilaetsgruenen mit ZSQLSearch / ZSQLInlineSeach noch einzelne Felder in der SESSION belegen. + if not self.REQUEST.SESSION.has_key(_storename): + self.REQUEST.SESSION[_storename]={} + + self.REQUEST.SESSION[_storename]['searchFieldsOnly']={} + self.REQUEST.SESSION[_storename]['qs']=query + return ret + def ZSQLsearchOptions(self,fieldname=""): """return HTML Fragment with search options""" @@ -635,7 +715,12 @@ class ZSQLExtendFolder(Folder,Persistent return ret def ZSQLSelectionFromCRList(self,fieldname,listField,boxType="checkbox",checked=None): - """generate select options from a cr seperated list""" + """generate selection HTML Fragemnt from a cr seperated list + @param fieldname: Wert fuer das "name"-Attribute der erzeugten input-Tags + @param listField: "cr" (\n) getrennte Liste der Werte + @param boxType: (optional) default ist "checkbox", moegliche Werte "checkbox" und "radio" + @param checked: "cr" getrennt Liste von Werten aus listField, die als ausgewahlt markiert werden sollen. + """ fields=listField.split("\n") ret="" for field in fields: @@ -646,7 +731,14 @@ class ZSQLExtendFolder(Folder,Persistent return ret def ZSQLSelectionFromSearchList(self,fieldname,results,fieldnameResult,boxType="checkbox",checked=None): - """generate select options from a cr seperated list""" + """generate select options from research-results Objekt + generate selection HTML Fragemnt from a cr seperated list + @param fieldname: Wert fuer das "name"-Attribute der erzeugten input-Tags + @param results: result Object einer SQL-suche + @param fieldNameResult: Feldname des Resultobjekts, das angezeigt werden soll. + @param boxType: (optional) default ist "checkbox", moegliche Werte "checkbox" und "radio" + @param checked: "cr" getrennt Liste von Werten aus results.fieldNameResult, die als ausgewahlt markiert werden sollen. + """ ret="" if not results: return "" @@ -691,7 +783,8 @@ class ZSQLExtendFolder(Folder,Persistent valueName=None,start=None, multiple='',startValue=None, additionalSelect="",size=None, - linelen=None,selected=None): + linelen=None,selected=None, + clear=False): """generate select options form a search list es wird """ return ret @@ -824,6 +921,7 @@ class ZSQLExtendFolder(Folder,Persistent if x: value=x else: + value=str(argTmp[a]) qs.append(aFiltered+"="+urllib.quote(value)) @@ -853,7 +951,7 @@ class ZSQLExtendFolder(Folder,Persistent def ZSQLSimpleSearch(self,query=None,max_rows=1000000): """simple search""" - logging.error(query) + logging.error("ZSQLSimpleSearch X %s"%query) #print query if not query: query=self.query @@ -865,14 +963,17 @@ class ZSQLExtendFolder(Folder,Persistent self._v_searchSQL.max_rows_=max_rows try: - return self._v_searchSQL.__call__(var=query) + logging.error("I am here") + t=self._v_searchSQL.__call__(var=query) + logging.error("I am here %s"%t) + return t except : - + logger("ZSQLSimpleSearch ERROR1",logging.ERROR, '%s %s'%sys.exc_info()[:2]) if sys.exc_info()[0]=="Database Error": try: self.getConnectionObj().manage_open_connection() except: - logger("ZSQLSimpleSearch",logging.ERROR, '%s %s'%sys.exc_info()[:2]) + logger("ZSQLSimpleSearch ERROR2",logging.ERROR, '%s %s'%sys.exc_info()[:2]) else: try: @@ -880,7 +981,7 @@ class ZSQLExtendFolder(Folder,Persistent return self._v_searchSQL.__call__(var=query) except : - + logger("ZSQLSimpleSearch ERROR2",logging.ERROR, '%s %s'%sys.exc_info()[:2]) if sys.exc_info()[0]=="Database Error": try: self.getConnectionObj().manage_open_connection() @@ -1013,7 +1114,7 @@ class ZSQLExtendFolder(Folder,Persistent table=urllib.unquote(value) elif name=="-identify": identify=urllib.unquote(value) - identify=identify.split("=")[0]+"="+sql_quote(identify.split("=")[1]) + identify="lower("+identify.split("=")[0]+")="+sql_quote(identify.split("=")[1].lower()) elif name=="-format": format=urllib.unquote(value) #elif (not (name[0]=="-" or name[0]=="_")) and (not len(value)==0): @@ -1124,9 +1225,11 @@ class ZSQLExtendFolder(Folder,Persistent #print "calling Query with",repr(NoQuery) + ret=self.parseQueryString(qs,"-",select=select,storemax="yes",storename=storename,tableExt=tableExt,NoQuery=NoQuery,NoLimit=NoLimit,restrictField=restrictField,restrictConnect=restrictConnect,filter=filter) #print self.REQUEST.SESSION["foundCount"] + return ret @@ -1174,9 +1277,11 @@ class ZSQLExtendFolder(Folder,Persistent for query in querys: arg=query.split("=")[0] if arg[0]=="_": arg="-"+arg[1:] # sicherstellen, dass an Anfang stets "_" - queryList[arg]=query.split("=")[1] - - + try: + queryList[arg]=query.split("=")[1] + except: + queryList[arg]='' + argList=[] arg="" @@ -1350,6 +1455,7 @@ class ZSQLExtendFolder(Folder,Persistent #something is defined by _op_TABELLE.SUCHFELD_IN_DIESER_TABELLE.SELECT_FIELD.IDENTIFIER_IN_TABELLE elif (not name[0]==iCT) and len(punktsplit)==4: + if opfields.has_key(name): op=opfields[name] else: @@ -1390,10 +1496,10 @@ class ZSQLExtendFolder(Folder,Persistent op="all" + if value!='': #lehre Werte werde nicht hinzugefuegt + searchTmp="""%s in (select %s from %s where %s)"""%(punktsplit[3],punktsplit[2],punktsplit[0],tmp) - searchTmp="""%s in (select %s from %s where %s)"""%(punktsplit[3],punktsplit[2],punktsplit[0],tmp) - - queryTemplate.append(searchTmp) + queryTemplate.append(searchTmp) elif (not name[0]==iCT) and (not len(value)==0): @@ -1440,7 +1546,7 @@ class ZSQLExtendFolder(Folder,Persistent op="all" - if (not tableExt) or (namealt.split('.')[0]==tableExt): + if (value!='') and ((not tableExt) or (namealt.split('.')[0]==tableExt)): #keine leeren werde und keine auschluss if searchFields.has_key(namealt): searchFields[namealt]+=lopfields.get(name,'OR')+" "+tmp searchFieldsOnly[namealt]+=lopfields.get(name,'OR')+" "+value