version 1.60, 2005/02/10 16:18:15
|
version 1.67, 2005/10/11 20:05:06
|
Line 11 from Products.PageTemplates.ZopePageTemp
|
Line 11 from Products.PageTemplates.ZopePageTemp
|
from Products.PageTemplates.PageTemplateFile import PageTemplateFile |
from Products.PageTemplates.PageTemplateFile import PageTemplateFile |
|
|
from Products.ZSQLMethods.SQL import SQLConnectionIDs |
from Products.ZSQLMethods.SQL import SQLConnectionIDs |
|
from xml.sax.saxutils import escape |
|
from types import * |
import Shared.DC.ZRDB.DA |
import Shared.DC.ZRDB.DA |
import zLOG |
import zLOG |
import os.path |
import os.path |
import os |
import os |
|
|
|
|
def analyseIntSearch(word): |
def analyseIntSearch(word): |
#analyse integer searches |
#analyse integer searches |
|
|
Line 39 def sql_quote(v):
|
Line 42 def sql_quote(v):
|
quote_dict = {"\'": "''", "\\": "\\\\"} |
quote_dict = {"\'": "''", "\\": "\\\\"} |
for dkey in quote_dict.keys(): |
for dkey in quote_dict.keys(): |
if string.find(v, dkey) >= 0: |
if string.find(v, dkey) >= 0: |
v=join(split(v,dkey),quote_dict[dkey]) |
v=string.join(string.split(v,dkey),quote_dict[dkey]) |
return "'%s'" % v |
return "'%s'" % v |
|
|
def showSQLConnectionIDs(self): |
def showSQLConnectionIDs(self): |
Line 49 class ZSQLExtendFolder(Folder,Persistent
|
Line 52 class ZSQLExtendFolder(Folder,Persistent
|
"""Folder""" |
"""Folder""" |
meta_type="ZSQLExtendFolder" |
meta_type="ZSQLExtendFolder" |
|
|
|
|
def testneu(self): |
def testneu(self): |
"""test""" |
"""test""" |
relStatement="""period like '%s%%'""" |
relStatement="""period like '%s%%'""" |
Line 201 class ZSQLExtendFolder(Folder,Persistent
|
Line 205 class ZSQLExtendFolder(Folder,Persistent
|
return ret |
return ret |
|
|
def ZSQLSelectionFromCRList(self,fieldname,listField,boxType="checkbox",checked=None): |
def ZSQLSelectionFromCRList(self,fieldname,listField,boxType="checkbox",checked=None): |
"""generate select oprions form a cr seperated list""" |
"""generate select options from a cr seperated list""" |
fields=listField.split("\n") |
fields=listField.split("\n") |
ret="" |
ret="" |
for field in fields: |
for field in fields: |
Line 211 class ZSQLExtendFolder(Folder,Persistent
|
Line 215 class ZSQLExtendFolder(Folder,Persistent
|
ret+="""<input name="%s" type="%s" value="%s">%s"""%(fieldname,boxType,field.encode('utf-8'),field.encode('utf-8')) |
ret+="""<input name="%s" type="%s" value="%s">%s"""%(fieldname,boxType,field.encode('utf-8'),field.encode('utf-8')) |
return ret |
return ret |
|
|
|
def ZSQLSelectionFromSearchList(self,fieldname,results,fieldnameResult,boxType="checkbox",checked=None): |
|
"""generate select options from a cr seperated list""" |
|
|
|
ret="" |
|
if not results: return "" |
|
|
|
for result in results: |
|
field=getattr(result,fieldnameResult) |
|
if field: |
|
if checked and (getattr(result,fieldnameResult) in checked.split("\n")): |
|
ret+="""<input name="%s" type="%s" value="%s" checked>%s"""%(fieldname,boxType,field.encode('utf-8'),field.encode('utf-8')) |
|
else: |
|
ret+="""<input name="%s" type="%s" value="%s">%s"""%(fieldname,boxType,field.encode('utf-8'),field.encode('utf-8')) |
|
return ret |
|
|
def ZSQLOptionsFromCRList(self,fieldname,listField, multiple=''): |
|
|
def ZSQLOptionsFromCRList(self,fieldname,listField, multiple='',start=None,startValue=None,size=None): |
"""generate select oprions form a cr seperated list""" |
"""generate select oprions form a cr seperated list""" |
fields=listField.split("\n") |
fields=listField.split("\n") |
|
if size: |
|
ret="""<select name="%s" %s size="%s" > |
|
"""%(fieldname,multiple,size) |
|
|
|
else: |
ret="""<select name="%s" %s> |
ret="""<select name="%s" %s> |
"""%(fieldname,multiple) |
"""%(fieldname,multiple) |
|
if start: |
|
if start==' ': |
|
start='' |
|
if not startValue: |
|
startValue=start |
|
|
|
ret+="""<option value="%s" >%s</option>"""%(startValue,start) |
for field in fields: |
for field in fields: |
ret+="""<option value="%s">%s</option>"""%(field.encode('utf-8'),field.encode('utf-8')) |
ret+="""<option value="%s">%s</option>"""%(field.encode('utf-8'),field.encode('utf-8')) |
ret+="""</select>""" |
ret+="""</select>""" |
return ret |
return ret |
|
|
def ZSQLOptionsFromSearchList(self,fieldname,results,fieldName,valueName=None,start=None, multiple='',startValue=None,additionalSelect=""): |
def ZSQLOptionsFromSearchList(self,fieldname,results,fieldName,valueName=None,start=None, multiple='',startValue=None,additionalSelect="",size=None,linelen=None): |
"""generate select options form a search list |
"""generate select options form a search list |
es wird |
es wird |
<select name=fieldname mutiple> |
<select name=fieldname mutiple> |
Line 239 class ZSQLExtendFolder(Folder,Persistent
|
Line 270 class ZSQLExtendFolder(Folder,Persistent
|
""" |
""" |
if not valueName: |
if not valueName: |
valueName=fieldName |
valueName=fieldName |
|
if size: |
|
ret="""<select name="%s" %s size="%s" %s> |
|
"""%(fieldname,multiple,size,additionalSelect) |
|
else: |
ret="""<select name="%s" %s %s> |
ret="""<select name="%s" %s %s> |
"""%(fieldname,multiple,additionalSelect) |
"""%(fieldname,multiple,additionalSelect) |
if start: |
if start: |
Line 253 class ZSQLExtendFolder(Folder,Persistent
|
Line 287 class ZSQLExtendFolder(Folder,Persistent
|
field=getattr(result,fieldName) |
field=getattr(result,fieldName) |
fieldValue=getattr(result,valueName) |
fieldValue=getattr(result,valueName) |
if fieldValue: |
if fieldValue: |
|
if not linelen: |
ret+="""<option value="%s">%s</option>"""%(field,fieldValue) |
ret+="""<option value="%s">%s</option>"""%(field,fieldValue) |
|
else: |
|
mist = """%s"""%(fieldValue) |
|
if len(mist) > string.atoi(linelen): |
|
mist = mist[:string.atoi(linelen)] |
|
ret+="""<option value="%s">%s</option>"""%(field,mist) |
ret+="""</select>""" |
ret+="""</select>""" |
return ret |
return ret |
|
|
Line 305 class ZSQLExtendFolder(Folder,Persistent
|
Line 345 class ZSQLExtendFolder(Folder,Persistent
|
"""inlinesearch""" |
"""inlinesearch""" |
qs=[] |
qs=[] |
|
|
|
|
|
|
#print "INLINE:",query |
#print "INLINE:",query |
return self.ZSQLSimpleSearch(query) |
return self.ZSQLSimpleSearch(query) |
|
|
|
|
def ZSQLSimpleSearch(self,query=None,max_rows=1000000): |
def ZSQLSimpleSearch(self,query=None,max_rows=1000000): |
"""simple search""" |
"""simple search""" |
|
|
Line 318 class ZSQLExtendFolder(Folder,Persistent
|
Line 357 class ZSQLExtendFolder(Folder,Persistent
|
|
|
if (hasattr(self,"_v_searchSQL") and (self._v_searchSQL == None)) or (not hasattr(self,"_v_searchSQL")): |
if (hasattr(self,"_v_searchSQL") and (self._v_searchSQL == None)) or (not hasattr(self,"_v_searchSQL")): |
self._v_searchSQL=Shared.DC.ZRDB.DA.DA("_v_searchSQL","_v_searchSQL",self.connection_id,"var","<dtml-var var>") |
self._v_searchSQL=Shared.DC.ZRDB.DA.DA("_v_searchSQL","_v_searchSQL",self.connection_id,"var","<dtml-var var>") |
|
|
self._v_searchSQL.max_rows_=max_rows |
self._v_searchSQL.max_rows_=max_rows |
try: |
try: |
|
|
return self._v_searchSQL.__call__(var=query) |
return self._v_searchSQL.__call__(var=query) |
except : |
except : |
if sys.exc_info()[0]=="Database Error": |
if sys.exc_info()[0]=="Database Error": |
try: |
try: |
getattr(self,self.connection_id).manage_open_connection() |
getattr(self,self.connection_id).manage_open_connection() |
except: pass |
except: |
|
zLOG.LOG("ZSQLSimpleSearch",zLOG.ERROR, '%s %s'%sys.exc_info()[:2]) |
else: |
else: |
try: |
try: |
self._v_searchSQL.max_rows_=max_rows |
self._v_searchSQL.max_rows_=max_rows |
|
|
return self._v_searchSQL.__call__(var=query) |
return self._v_searchSQL.__call__(var=query) |
except : |
except : |
if sys.exc_info()[0]=="Database Error": |
if sys.exc_info()[0]=="Database Error": |
try: |
try: |
getattr(self,self.connection_id).manage_open_connection() |
getattr(self,self.connection_id).manage_open_connection() |
except: pass |
except: |
|
zLOG.LOG("ZSQLSimpleSearch",zLOG.ERROR, '%s %s'%sys.exc_info()[:2]) |
|
|
|
|
def ZSQLSimpleSearch2(self,query=None): |
def ZSQLSimpleSearch2(self,query=None): |
""" returrn SQLSearch""" |
""" returrn SQLSearch""" |
#print "hi",query |
|
if not query: |
if not query: |
query=self.query |
query=self.query |
if getattr(self,'_v_search',None): |
if getattr(self,'_v_search',None): |
Line 362 class ZSQLExtendFolder(Folder,Persistent
|
Line 407 class ZSQLExtendFolder(Folder,Persistent
|
|
|
|
|
|
|
def ZSQLAdd(self): |
def ZSQLAdd(self,format=None,RESPONSE=None,**argv): |
"""Neuer Eintrag""" |
"""Neuer Eintrag""" |
qs=self.REQUEST['QUERY_STRING'] |
|
|
qs_temp=[] |
|
|
|
for a in self.REQUEST.form.keys(): |
|
qs_temp.append(a+"="+urllib.quote(str(self.REQUEST.form[a]))) |
|
|
|
qs=string.join(qs_temp,",") |
|
|
|
for field in argv.keys(): |
|
if field[0]=="_": |
|
fieldTmp="-"+field[1:] |
|
else: |
|
fieldTmp=field |
|
|
|
qs+=",%s=%s"%(fieldTmp,argv[field]) |
|
|
|
|
addList={} |
addList={} |
for q in qs.split("&"): |
for q in qs.split(","): |
name=re.sub("r'+'"," ",q.split("=")[0].lower()) |
name=re.sub("r'+'"," ",q.split("=")[0].lower()) |
value=q.split("=")[1] |
value=q.split("=")[1] |
value=re.sub(r'\+'," ",value) |
value=re.sub(r'\+'," ",value) |
Line 375 class ZSQLExtendFolder(Folder,Persistent
|
Line 436 class ZSQLExtendFolder(Folder,Persistent
|
table=urllib.unquote(value) |
table=urllib.unquote(value) |
elif name=="-format": |
elif name=="-format": |
format=urllib.unquote(value) |
format=urllib.unquote(value) |
elif (not name[0]=="-") and (not len(value)==0): |
elif (not (name[0]=="-" or name[0]=="_")) and (not len(value)==0): |
addList[urllib.unquote(name)]=urllib.unquote(value) |
addList[urllib.unquote(name)]=urllib.unquote(value) |
|
|
keyList=[] |
keyList=[] |
Line 388 class ZSQLExtendFolder(Folder,Persistent
|
Line 449 class ZSQLExtendFolder(Folder,Persistent
|
valueString=string.join(valueList,",") |
valueString=string.join(valueList,",") |
|
|
queryString="INSERT INTO %s (%s) VALUES (%s)"%(table,keyString,valueString) |
queryString="INSERT INTO %s (%s) VALUES (%s)"%(table,keyString,valueString) |
|
|
self.ZSQLSimpleSearch(queryString) |
self.ZSQLSimpleSearch(queryString) |
return self.REQUEST.RESPONSE.redirect(format) |
|
|
|
def ZSQLChange(self,**argv): |
if RESPONSE and format: |
|
return RESPONSE.redirect(format) |
|
else: |
|
return True |
|
|
|
def ZSQLChange(self,format=None,RESPONSE=None,**argv): |
"""change entries""" |
"""change entries""" |
#qs=self.REQUEST['QUERY_STRING'] |
#qs=self.REQUEST['QUERY_STRING'] |
# very bad hack |
# very bad hack |
|
|
qs_temp=[] |
qs_temp=[] |
|
|
for a in self.REQUEST.form.keys(): |
# for a in self.REQUEST.form.keys(): |
qs_temp.append(a+"="+urllib.quote(str(self.REQUEST.form[a]))) |
# qs_temp.append(a+"="+urllib.quote(str(self.REQUEST.form[a]))) |
|
|
qs=string.join(qs_temp,"&") |
|
|
|
|
|
#print "CHANGE QS",self.REQUEST |
for field in argv.keys(): |
#return self.REQUEST |
if field[0]=="_": |
|
fieldTmp="-"+field[1:] |
|
else: |
|
fieldTmp=field |
|
|
|
qs_temp.append("%s=%s"%(fieldTmp,argv[field])) |
|
|
|
qs=string.join(qs_temp,",") |
changeList=[] |
changeList=[] |
for q in qs.split("&"): |
|
|
for q in qs.split(","): |
|
|
name=urllib.unquote(re.sub("r'+'"," ",q.split("=")[0].lower())) |
name=urllib.unquote(re.sub("r'+'"," ",q.split("=")[0].lower())) |
value=q.split("=")[1] |
value="=".join(q.split("=")[1:]) |
value=re.sub(r'\+'," ",value) |
value=re.sub(r'\+'," ",value) |
value=urllib.unquote(value) |
value=urllib.unquote(value) |
|
|
if name=="-table": |
if name=="-table": |
table=urllib.unquote(value) |
table=urllib.unquote(value) |
elif name=="-identify": |
elif name=="-identify": |
Line 418 class ZSQLExtendFolder(Folder,Persistent
|
Line 494 class ZSQLExtendFolder(Folder,Persistent
|
identify=identify.split("=")[0]+"="+sql_quote(identify.split("=")[1]) |
identify=identify.split("=")[0]+"="+sql_quote(identify.split("=")[1]) |
elif name=="-format": |
elif name=="-format": |
format=urllib.unquote(value) |
format=urllib.unquote(value) |
elif (not name[0]=="-") and (not len(value)==0): |
elif (not (name[0]=="-" or name[0]=="_")) and (not len(value)==0): |
changeList.append("\""+name+"\"="+sql_quote(urllib.unquote(value))) |
changeList.append("\""+name+"\"="+sql_quote(urllib.unquote(value))) |
|
|
changeString=string.join(changeList,",") |
changeString=string.join(changeList,",") |
queryString="UPDATE %s SET %s WHERE %s"%(table,changeString,identify) |
queryString="UPDATE %s SET %s WHERE %s"%(table,changeString,identify) |
|
|
self.ZSQLSimpleSearch(queryString) |
self.ZSQLSimpleSearch(queryString) |
return self.REQUEST.RESPONSE.redirect(format) |
|
|
|
|
|
|
if RESPONSE and format: |
|
return RESPONSE.redirect(format) |
|
else: |
|
return True |
|
|
|
|
def ZSQLFind2(self,qs="",select="oid,*",storename=None,tableList=['cdli_translit','cdli_cat'],restrictField='id_text',**argv): |
def ZSQLFind2(self,qs="",select="oid,*",storename=None,tableList=['cdli_translit','cdli_cat'],restrictField='id_text',**argv): |
"""find2""" |
"""find2""" |
Line 833 class ZSQLExtendFolder(Folder,Persistent
|
Line 915 class ZSQLExtendFolder(Folder,Persistent
|
if not self.REQUEST.SESSION[storename]['queryString2']==query2: |
if not self.REQUEST.SESSION[storename]['queryString2']==query2: |
#print "HOOOOO",storename |
#print "HOOOOO",storename |
self.REQUEST.SESSION[storename]['queryString2']=query2 |
self.REQUEST.SESSION[storename]['queryString2']=query2 |
|
try: |
self.REQUEST.SESSION[storename]['count']=self.ZSQLSimpleSearch(query2)[0].count |
self.REQUEST.SESSION[storename]['count']=self.ZSQLSimpleSearch(query2)[0].count |
|
except: |
|
self.REQUEST.SESSION[storename]['count']=0 |
#print "QUERY",query2,"::::",self.REQUEST.SESSION[storename]['queryString2'] |
#print "QUERY",query2,"::::",self.REQUEST.SESSION[storename]['queryString2'] |
|
|
else: |
else: |
Line 1256 class ZSQLBibliography(Folder,ZSQLExtend
|
Line 1340 class ZSQLBibliography(Folder,ZSQLExtend
|
|
|
return retdata,fieldlist |
return retdata,fieldlist |
|
|
def createRDFTag(self,tag,content,namespace="ns"): |
def createRDFTag(self,tag,content,namespace="cdli"): |
"""create RDF""" |
"""create RDF""" |
if content: |
if content: |
tag=namespace+":"+tag |
tag=namespace+":"+tag |
|
if (type(content) is StringType) or (type(content) is UnicodeType): |
|
ret=""" <%s>%s</%s>"""%(tag,escape(content),tag) |
|
else: |
ret=""" <%s>%s</%s>"""%(tag,content,tag) |
ret=""" <%s>%s</%s>"""%(tag,content,tag) |
return ret.decode('latin-1') |
return ret.decode('latin-1') |
else: |
else: |
Line 1267 class ZSQLBibliography(Folder,ZSQLExtend
|
Line 1354 class ZSQLBibliography(Folder,ZSQLExtend
|
|
|
def createIndexTag(self,tag,content): |
def createIndexTag(self,tag,content): |
"""create tag""" |
"""create tag""" |
|
|
if content: |
if content: |
|
if (type(content) is StringType) or (type(content) is UnicodeType): |
|
ret=""" <%s>%s</%s>"""%(tag,escape(content),tag) |
|
else: |
ret="""<%s>%s</%s>"""%(tag,content,tag) |
ret="""<%s>%s</%s>"""%(tag,content,tag) |
return ret |
return ret.decode('latin-1') |
|
|
else: |
else: |
return "" |
return "" |
|
|
def getMetaDataXML2(self): |
def getXML2(self): |
"""crate index meta""" |
"""crate index meta""" |
|
|
fn=os.path.splitext(self.REQUEST['fn'])[0]+"." |
fn=os.path.splitext(self.REQUEST['fn'])[0]+"." |