File:  [Repository] / ZSQLExtend / ZSQLExtend.py
Revision 1.69: download - view: text, annotated - select for diffs - revision graph
Fri Oct 14 15:08:18 2005 UTC (18 years, 7 months ago) by dwinter
Branches: MAIN
CVS tags: HEAD
getConnectionIdObj() added

    1: from OFS.Folder import Folder
    2: from Acquisition import Implicit
    3: from Globals import DTMLFile,package_home,Persistent
    4: import urllib
    5: import re
    6: import string
    7: import sys
    8: #from pyPgSQL import libpq
    9: from AccessControl import getSecurityManager
   10: from Products.PageTemplates.ZopePageTemplate import ZopePageTemplate
   11: from Products.PageTemplates.PageTemplateFile import PageTemplateFile
   12: 
   13: from Products.ZSQLMethods.SQL import SQLConnectionIDs
   14: from xml.sax.saxutils import escape
   15: from types import *
   16: import Shared.DC.ZRDB.DA
   17: import zLOG
   18: import os.path
   19: import os
   20: 
   21: 
   22: def analyseIntSearch(word):
   23:     #analyse integer searches
   24: 
   25:     splitted=word.split("-")
   26: 
   27:     if len(splitted)==1:
   28:         return "="+splitted[0]
   29:     
   30:     if splitted[0]=="":
   31:         return "< "+splitted[1]
   32: 
   33:     if splitted[1]=='':
   34:         return "> "+splitted[0]
   35:     else:
   36:         return "BETWEEN "+splitted[0]+" AND "+splitted[1]
   37: 
   38:         
   39: 
   40: def sql_quote(v):
   41:     # quote dictionary
   42:     quote_dict = {"\'": "''", "\\": "\\\\"}
   43:     for dkey in quote_dict.keys():
   44:         if string.find(v, dkey) >= 0:
   45:             v=string.join(string.split(v,dkey),quote_dict[dkey])
   46:     return "'%s'" % v
   47: 
   48: def showSQLConnectionIDs(self):
   49:     return SQLConnectionIDs(self)
   50: 
   51: class ZSQLExtendFolder(Folder,Persistent, Implicit):
   52:     """Folder"""
   53:     meta_type="ZSQLExtendFolder"
   54: 
   55: 
   56:     def testneu(self):
   57:         """test"""
   58:         relStatement="""period like '%s%%'"""
   59:         statement="select * from cdli_cat"
   60:         wherePart="museum_no like 'VAT%'"
   61:         classes=['Uruk III','Uruk IV']
   62:         return self.searchRel(relStatement,statement,wherePart,classes)
   63: 
   64:     def URLquote(self,txt):
   65:         """urlquote"""
   66:         return urllib.quote(txt)
   67:     def searchRel(self,relStatement,statement,wherePart,classes):
   68:         """suche relative haufigkeiten"""
   69:         ret={}
   70:         allRecords=len(self.ZSQLSimpleSearch(statement + " where "+wherePart))
   71:         
   72:         for oneclass in classes:
   73:             ret[oneclass]=len(self.ZSQLSimpleSearch(statement + " where ("+wherePart+") and "+ relStatement%oneclass))
   74:         
   75:         return (ret,allRecords)
   76:                   
   77:     def content_html(self):
   78:         """template fuer content"""
   79:         
   80:         try:
   81:             obj=getattr(self,"ZSQLBibliography_template")
   82:             return obj()
   83:         except:
   84:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','ZSQLBibliography_template_standard.zpt'),content_type='text/html').__of__(self)
   85:             pt.content_type="text/html"
   86:             
   87:             return pt()
   88: 
   89:         
   90:     def getWeight(self):
   91:         """getLabe"""
   92:         try:
   93:             return self.weight
   94:         except:
   95:             return ""
   96: 
   97:     def getLabel(self):
   98:         """getLabe"""
   99:         try:
  100:             return self.label
  101:         except:
  102:             return ""
  103: 
  104:     def getDescription(self):
  105:         """getLabe"""
  106:         try:
  107:             return self.description
  108:         except:
  109:             return ""
  110: 
  111:     manage_options=Folder.manage_options+(
  112:         {'label':'Main Config','action':'changeZSQLExtendForm'},
  113:        )
  114: 
  115:     def changeZSQLExtendForm(self):
  116:         """change folder config"""
  117:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','changeZSQLExtendForm.zpt')).__of__(self)
  118:         return pt()
  119: 
  120: 
  121:     def changeZSQLExtend(self,label,description,weight=0,REQUEST=None,connection_id=None):
  122:         """change it"""
  123:         self.connection_id=connection_id
  124:         self.weight=weight
  125:         self.label=label
  126:         self.description=description
  127:         
  128:         if REQUEST is not None:
  129:             return self.manage_main(self, REQUEST)
  130: 
  131:     def formatAscii(self,str,url=None):
  132:         """ersetze ascii umbrueche durch <br>"""
  133:         #url=None
  134:         if url and str:
  135:             
  136:             retStr=""
  137:             words=str.split("\n")
  138:             
  139:             for word in words:
  140:                 strUrl=url%word
  141:                 #print "str",strUrl
  142:                 retStr+="""<a href="%s">%s</a><br/>"""%(strUrl,word)
  143:             str=retStr
  144:         if str:
  145:             return re.sub(r"[\n]","<br/>",str)
  146:         else:
  147:             return ""
  148:         
  149:     def getSAttribute(self,obj,atribute,pref=''):
  150:         """get Attribute or emptystring"""
  151:         
  152:         #print "obj",obj
  153:         try:
  154:             return pref+getattr(obj,atribute)
  155:         except:
  156:             return ""
  157:         
  158:     def getS(self,str):
  159:         """make none to empty string"""
  160:         if str:
  161:             return str
  162:         else:
  163:             return ""
  164: 
  165:     def actualPath(self,url=None):
  166: 	"""path"""
  167: 
  168:         if self.REQUEST['HTTP_X_FORWARDED_SERVER']=='':
  169:             host=self.REQUEST['HTTP_HOST']
  170:         else:
  171:             host=self.REQUEST['HTTP_X_FORWARDED_SERVER']
  172: 	if not url:
  173: 		return "http://"+host+self.REQUEST['PATH_TRANSLATED']
  174:     	else:
  175: 		temp=self.REQUEST[url].split("/")
  176: 		temp[2]=host
  177: 		return string.join(temp,"/")
  178: 
  179:     def getRequest(self):
  180: 	"""request"""
  181: 	return self.REQUEST
  182: 
  183:     def lowerEnd(self,path):
  184:         """oinly for demo"""
  185:         return os.path.splitext(path)[0]+".jpg"
  186:         
  187:     def ZSQLisEmpty(self,field):
  188:         """Teste ob Treffer leer"""
  189:         #print "field",field
  190:         if not field:
  191:             return 1
  192:         if field=="":
  193:             return 1
  194:         return 0
  195: 
  196:     def ZSQLsearchOptions(self,fieldname=""):
  197:         """return HTML Fragment with search options"""
  198: 	
  199:         ret="""<select name="-op_%s">
  200: 	<option value="bw">begins with</option>          	<!-- begins with / beginnt mit, "Wort*" -->
  201: 	<option value="ew">ends with</option>
  202:    	<option value="ct" selected>contains</option>          		<!-- contains / enthaellt, "Wort" -->
  203:     <option value="eq">equals</option>          		<!-- equals / ist, =Wort -->
  204: </select>"""%fieldname
  205:         return ret
  206: 
  207:     def ZSQLSelectionFromCRList(self,fieldname,listField,boxType="checkbox",checked=None):
  208:         """generate select options from a cr seperated list"""
  209:         fields=listField.split("\n")
  210:         ret=""
  211:         for field in fields:
  212:             if checked and (field in checked.split("\n")):
  213:                 ret+="""<input name="%s" type="%s" value="%s" checked>%s"""%(fieldname,boxType,field.encode('utf-8'),field.encode('utf-8'))
  214:             else:
  215:                 ret+="""<input name="%s" type="%s" value="%s">%s"""%(fieldname,boxType,field.encode('utf-8'),field.encode('utf-8'))
  216:         return ret
  217: 
  218:     def ZSQLSelectionFromSearchList(self,fieldname,results,fieldnameResult,boxType="checkbox",checked=None):
  219:         """generate select options from a cr seperated list"""
  220: 
  221:         ret=""
  222:         if not results: return ""
  223:         
  224:         for result in results:
  225:             field=getattr(result,fieldnameResult)
  226:             if field:
  227:                 if checked and (getattr(result,fieldnameResult) in checked.split("\n")):
  228:                     ret+="""<input name="%s" type="%s" value="%s" checked>%s"""%(fieldname,boxType,field.encode('utf-8'),field.encode('utf-8'))
  229:                 else:
  230:                     ret+="""<input name="%s" type="%s" value="%s">%s"""%(fieldname,boxType,field.encode('utf-8'),field.encode('utf-8'))
  231:         return ret
  232: 
  233: 
  234:     def ZSQLOptionsFromCRList(self,fieldname,listField, multiple='',start=None,startValue=None,size=None,selected=None):
  235:         """generate select oprions form a cr seperated list"""
  236:         fields=listField.split("\n")
  237:         if size:
  238:             ret="""<select name="%s" %s size="%s" >
  239:             """%(fieldname,multiple,size)
  240: 
  241:         else:
  242:             ret="""<select name="%s" %s >
  243:             """%(fieldname,multiple)
  244:         if start:
  245: 	    if start==' ':
  246: 		start=''
  247:                 if not startValue:
  248:                     startValue=start
  249:                     
  250:             ret+="""<option value="%s" >%s</option>"""%(startValue,start)
  251:         for field in fields:
  252:             if selected and (field in selected.split("\n")):
  253:                  ret+="""<option selected value="%s">%s</option>"""%(field.encode('utf-8'),field.encode('utf-8'))
  254:             else:
  255:                  ret+="""<option value="%s">%s</option>"""%(field.encode('utf-8'),field.encode('utf-8'))
  256:         ret+="""</select>"""
  257:         return ret
  258: 
  259:     def ZSQLOptionsFromSearchList(self,fieldname,results,fieldName,valueName=None,start=None, multiple='',startValue=None,additionalSelect="",size=None,linelen=None):
  260:         """generate select options form a search list
  261:         es wird
  262:         <select name=fieldname mutiple>
  263:         <option value=startValue>start</option>
  264:         <option value=result.fieldName>result.fieldValue</option>
  265:         erzeugt.
  266:         
  267:         @parameter fieldname: Name fuer name-wert im select-tag
  268:         @results results: Resultobject einer SQL-suche
  269:         @parameter fieldName: Name des Feldes, das als value in den option-tag geschrieben werden soll.
  270:         @parameter valueName: (optional) Name des Feldes, dass als im option-tag ausgegeben wird, default wert ist valueName=fieldName
  271:         @start: (optional) falls zusaetzliches option tag erzeugt werden soll, gibt start an was im option tag steht
  272:         @startValue: gibt den entsprechenden Wert an.
  273:         """
  274:         if not valueName:
  275:             valueName=fieldName
  276:         if size:
  277:             ret="""<select name="%s" %s size="%s" %s>
  278:             """%(fieldname,multiple,size,additionalSelect)
  279:         else:
  280:             ret="""<select name="%s" %s %s>
  281:             """%(fieldname,multiple,additionalSelect)
  282:         if start:
  283: 	    if start==' ':
  284: 		start=''
  285:                 if not startValue:
  286:                     startValue=start
  287:                     
  288:             ret+="""<option value="%s" >%s</option>"""%(startValue,start)
  289:         for result in results:
  290:             field=getattr(result,fieldName)
  291:             fieldValue=getattr(result,valueName)
  292:             if fieldValue:
  293:                 if not linelen:
  294:                     ret+="""<option value="%s">%s</option>"""%(field,fieldValue)
  295:                 else:
  296:                     mist = """%s"""%(fieldValue)
  297:                     if len(mist) > string.atoi(linelen):
  298:                         mist = mist[:string.atoi(linelen)]
  299:                     ret+="""<option value="%s">%s</option>"""%(field,mist)
  300:         ret+="""</select>"""
  301:         return ret
  302: 
  303:             
  304:     def ZSQLInlineSearchU(self,storename=None,**argv):
  305:         """one element if exists"""
  306:         qs=[]
  307:         if storename:
  308:             """store"""
  309:         else:
  310:             storename="foundCount"
  311:             
  312:     
  313: 
  314:         #print "INLINE:",argv
  315:         for a in argv.keys():
  316:             qs.append(a+"="+urllib.quote(str(argv[a])))
  317:         #return []  
  318:         ret = self.parseQueryString(string.join(qs,","),"_",storename=storename)
  319: 
  320:         try:
  321:             return ret[0]
  322:         except:
  323:             return None
  324:         
  325:     def ZSQLInlineSearch(self,storename=None,**argv):
  326:         """inlinesearch"""
  327:         
  328:         qs=[]
  329:         if storename:
  330:             """store"""
  331:         else:
  332:             storename="foundCount"
  333:             
  334:     
  335: 
  336:         #print "INLINE:",argv
  337:         for a in argv.keys():
  338:             try:
  339:                 qs.append(a+"="+urllib.quote(str(argv[a])))
  340:             except:
  341:                 import urllib
  342:                 qs.append(a+"="+urllib.quote(str(argv[a])))
  343:                 
  344:         #return []  
  345:         return self.parseQueryString(string.join(qs,","),"_",storename=storename)
  346: 
  347:     def ZSQLInlineSearch2(self,query):
  348:         """inlinesearch"""
  349:         qs=[]
  350:         
  351:         #print "INLINE:",query
  352:         return self.ZSQLSimpleSearch(query)
  353:     
  354:     
  355:     def ZSQLSimpleSearch(self,query=None,max_rows=1000000):
  356:         """simple search"""
  357:         
  358:         if not query:
  359:             query=self.query
  360:         
  361:         if (hasattr(self,"_v_searchSQL") and (self._v_searchSQL == None)) or (not hasattr(self,"_v_searchSQL")):
  362:             
  363:             self._v_searchSQL=Shared.DC.ZRDB.DA.DA("_v_searchSQL","_v_searchSQL",self.getConnectionObj().getId(),"var","<dtml-var var>")
  364:             
  365:             self._v_searchSQL.max_rows_=max_rows
  366:             try:
  367:                 
  368:                 return self._v_searchSQL.__call__(var=query)
  369:             except :
  370:                 if sys.exc_info()[0]=="Database Error":
  371:                     try:
  372:                         self.getConnectionObj().manage_open_connection()
  373:                     except:
  374:                         zLOG.LOG("ZSQLSimpleSearch",zLOG.ERROR, '%s %s'%sys.exc_info()[:2])
  375:         else:
  376:             try:
  377:                 self._v_searchSQL.max_rows_=max_rows
  378:                 
  379:                 return self._v_searchSQL.__call__(var=query)
  380:             except :
  381:                 if sys.exc_info()[0]=="Database Error":
  382:                     try:
  383:                         self.getConnectionObj().manage_open_connection()
  384:                     except:
  385:                         zLOG.LOG("ZSQLSimpleSearch",zLOG.ERROR, '%s %s'%sys.exc_info()[:2])
  386: 
  387:     def getConnectionObj(self):
  388:         if hasattr(self,'connection_id'):
  389:             return getattr(self,self.connection_id)
  390:        
  391:                     
  392:     def ZSQLSimpleSearch2(self,query=None):
  393:         """ returrn SQLSearch"""
  394:        
  395:         if not query:
  396:             query=self.query
  397:         if getattr(self,'_v_search',None):
  398:             
  399:             return self._v_search(var=query)
  400:         
  401:         if hasattr(self,'search') and (self.search.meta_type=="Z SQL Method"):
  402:             self._v_search=self.search
  403:             return self.search(var=query)
  404:         else:
  405:             if hasattr(self.aq_parent.aq_parent,'search') and (self.aq_parent.aq_parent.search.meta_type=="Z SQL Method"):
  406:                 self._v_search=self.aq_parent.aq_parent.search
  407:                 return self.aq_parent.aq_parent.search(var=query)
  408:             else:
  409:                 search=self.ZopeFind(self,obj_metatypes=["Z SQL Method"],search_sub=1)
  410:                 if search:
  411:                     self._v_search=search[0][1]
  412:                     return search[0][1](var=query)
  413:                 else:
  414:                     return []
  415:     
  416:         
  417:         
  418:     def ZSQLAdd(self,format=None,RESPONSE=None,**argv):
  419:         """Neuer Eintrag"""
  420:             
  421:         qs_temp=[]
  422:     
  423:         for a in self.REQUEST.form.keys():
  424:             qs_temp.append(a+"="+urllib.quote(str(self.REQUEST.form[a])))
  425: 
  426:         qs=string.join(qs_temp,",")
  427:         
  428:         for field in argv.keys():
  429:                    if field[0]=="_":
  430:                        fieldTmp="-"+field[1:]
  431:                    else:
  432:                        fieldTmp=field
  433:                        
  434:                    qs+=",%s=%s"%(fieldTmp,argv[field])
  435:         
  436:         
  437:         addList={}
  438:         for q in qs.split(","):
  439:             name=re.sub("r'+'"," ",q.split("=")[0].lower())
  440:             value=q.split("=")[1]
  441:             value=re.sub(r'\+'," ",value)
  442:             value=urllib.unquote(value)	
  443:             if name=="-table":
  444:                 table=urllib.unquote(value)
  445:             elif name=="-format":
  446:                 format=urllib.unquote(value)
  447:             elif (not (name[0]=="-" or name[0]=="_")) and (not len(value)==0):
  448:                 addList[urllib.unquote(name)]=urllib.unquote(value)
  449: 
  450:         keyList=[]
  451:         valueList=[]
  452:         for x in addList.keys():
  453:             keyList.append("\""+x+"\"")
  454:             valueList.append(sql_quote(addList[x]))
  455: 
  456:         keyString=string.join(keyList,",")
  457:         valueString=string.join(valueList,",")
  458:         
  459:         queryString="INSERT INTO %s (%s) VALUES (%s)"%(table,keyString,valueString)
  460: 
  461:         self.ZSQLSimpleSearch(queryString)
  462:         
  463:         if RESPONSE and format:
  464:             return RESPONSE.redirect(format)
  465:         else:
  466:             return True
  467:         
  468:     def ZSQLChange(self,format=None,RESPONSE=None,USE_FORM=None,**argv):
  469:         """change entries"""
  470:         #qs=self.REQUEST['QUERY_STRING']
  471:         # very bad hack
  472:         
  473:         qs_temp=[]
  474:         if USE_FORM or RESPONSE:
  475:             for a in self.REQUEST.form.keys():
  476:                 qs_temp.append(a+"="+urllib.quote(str(self.REQUEST.form[a])))
  477: 
  478:         
  479:         
  480:         for field in argv.keys():
  481:                 
  482:                    if field[0]=="_":
  483:                        fieldTmp="-"+field[1:]
  484:                    else:
  485:                        fieldTmp=field
  486:                        
  487:                    qs_temp.append("%s=%s"%(fieldTmp,argv[field]))
  488:         
  489:         qs=string.join(qs_temp,",")
  490:         changeList=[]
  491:         
  492:         for q in qs.split(","):
  493:             
  494:             name=urllib.unquote(re.sub("r'+'"," ",q.split("=")[0].lower()))
  495:             value="=".join(q.split("=")[1:])
  496:             value=re.sub(r'\+'," ",value)
  497:             value=urllib.unquote(value)
  498:         
  499:             if name=="-table":
  500:                     table=urllib.unquote(value)
  501:             elif name=="-identify":
  502:                 identify=urllib.unquote(value)
  503:                 identify=identify.split("=")[0]+"="+sql_quote(identify.split("=")[1])
  504:             elif name=="-format":
  505:                 format=urllib.unquote(value)
  506:             elif (not (name[0]=="-" or name[0]=="_")) and (not len(value)==0):
  507:                 changeList.append("\""+name+"\"="+sql_quote(urllib.unquote(value)))
  508:                 
  509:         changeString=string.join(changeList,",")
  510:         queryString="UPDATE %s SET %s WHERE %s"%(table,changeString,identify)
  511:         
  512:         self.ZSQLSimpleSearch(queryString)
  513:         
  514:         
  515:         if RESPONSE and format:
  516:             return RESPONSE.redirect(format)
  517:         else:
  518:             return True
  519:    
  520: 
  521:     def ZSQLFind2(self,qs="",select="oid,*",storename=None,tableList=['cdli_translit','cdli_cat'],restrictField='id_text',**argv):
  522:         """find2"""
  523: 
  524:         search1= self.ZSQLFind(qs=qs,select=select,storename=storename,tableExt=tableList[1],restrictField=restrictField,NoQuery='yes',NoLimit='yes',**argv)
  525:      
  526:         search2 = self.ZSQLFind(tableExt=tableList[0],qs=qs,select=select,storename=storename,restrictConnect=(tableList[0]+"."+restrictField,search1),**argv)
  527:         return search2
  528:     
  529:       
  530:     
  531:     def ZSQLFind(self,qs="",select="oid,*",storename=None,tableExt=None,NoQuery=None,NoLimit=None,restrictField=None,restrictConnect=None,filter=None,**argv):
  532:         """Find"""
  533: 
  534:         def delEmpty(list):
  535:             ret=[]
  536:             for x in list:
  537:                 splitted=x.split("=")
  538:                 if (len(splitted)>1) and not (splitted[1]==' '):
  539:                     ret.append(x)
  540:             return ret
  541: 
  542: 
  543: 
  544:         #self.REQUEST.SESSION['come_from_search']="no" # zuruecksetzen
  545:         if qs=="":
  546:            
  547:            if self.REQUEST['QUERY_STRING']:
  548:                qs=self.REQUEST['QUERY_STRING']
  549: 
  550:                
  551:                qs=string.join(qs.split("&"),",")
  552: 
  553:                for field in argv.keys():
  554:                    if field[0]=="_":
  555:                        fieldTmp="-"+field[1:]
  556:                    else:
  557:                        fieldTmp=field
  558:                        
  559:                    qs+=",%s=%s"%(fieldTmp,argv[field])
  560:                    
  561:            else:
  562: 
  563:                qs=self.REQUEST.SESSION.get('query','')
  564:                
  565:                for field in argv.keys():
  566:                    if field[0]=="_":
  567:                        fieldTmp="-"+field[1:]
  568:                    else:
  569:                        fieldTmp=field
  570:                    
  571:                    qs+=",%s=%s"%(fieldTmp,argv[field])
  572: 
  573:          
  574: 
  575:         else:
  576:             self.REQUEST['QUERY_STRING']=qs
  577: 
  578:             qs=string.join(qs.split("&"),",")
  579:             
  580:         
  581:         
  582:         qs=re.sub("\\+"," ",qs)# Austauschen da Leerzeichen bei http-get durch + ersetzt wird, generell sollte alles auf post umgeschrieben werden. vom search formular.
  583: 
  584:         qs=string.join(delEmpty(qs.split(",")),",")
  585: 
  586:         if storename:
  587:             """store"""
  588:         else:
  589:             storename="foundCount"
  590: 
  591:         #store query for further usage
  592:         self.REQUEST.SESSION['query']=qs
  593: 
  594:         #print "calling Query with",repr(NoQuery)
  595:         ret=self.parseQueryString(qs,"-",select=select,storemax="yes",storename=storename,tableExt=tableExt,NoQuery=NoQuery,NoLimit=NoLimit,restrictField=restrictField,restrictConnect=restrictConnect,filter=filter)
  596:         #print self.REQUEST.SESSION["foundCount"]
  597:         
  598:         
  599: 
  600:         return ret
  601: 
  602:     def ZSQLFoundCountLen(self,var):
  603:         return len(var)
  604:             
  605:     def ZSQLFoundCount(self,qs="",select="*",storename=None):
  606:         
  607:        ##  if qs=="":
  608:             
  609: ##             if self.REQUEST['QUERY_STRING']:
  610:             
  611: ##                 qs=self.REQUEST['QUERY_STRING']
  612: ##                 qs=string.join(qs.split("&"),",")
  613: ##             else:
  614:             
  615: ##                 qs=self.REQUEST.SESSION['query']
  616: ##         else:
  617: ##             qs=string.join(qs.split("&"),",")
  618: 
  619: 
  620: ##         temp= self.parseQueryString(qs,"-",select=select,storemax="yes",nostore="yes")
  621:         if storename:
  622:             """store"""
  623:         else:
  624:             storename="foundCount"
  625:         
  626:         return self.REQUEST.SESSION[storename]['count']
  627: 
  628:     def ZSQLRangeStart(self,storename=None):
  629:         
  630:         if storename:
  631:             """store"""
  632:         else:
  633:             storename="foundCount"
  634:         
  635:         return int(self.REQUEST.SESSION[storename]['rangeStart'])+1
  636:     
  637:     def ZSQLRangeSize(self,storename=None):
  638:         
  639:         if storename:
  640:             """store"""
  641:         else:
  642:             storename="foundCount"
  643:             
  644:         return self.REQUEST.SESSION[storename]['rangeSize']
  645: 
  646:     def ZSQLRangeEnd(self,storename=None):
  647:         
  648:         if storename:
  649:             """store"""
  650:         else:
  651:             storename="foundCount"
  652:         
  653:         return str(min(int(self.REQUEST.SESSION[storename]['rangeEnd']),int(self.REQUEST.SESSION[storename]['count'])))
  654: 
  655:     def ZSQLNewQuery(self,linkText,storename=None,**argv):
  656:         """suche neu"""
  657:         return self.ZSQLNewSearch(linkText,storename,url=self.REQUEST['URL'],args=argv)
  658:     
  659:     def ZSQLNewSearch(self,linkText,storename=None,url=None,args=None,**argv):
  660:         """suche mit alten parametern bis auf die in argv getauschten"""
  661: 
  662:         if storename: 
  663:             """store"""  
  664:         else:
  665:             storename="foundCount"
  666:         qs=self.REQUEST.SESSION[storename]['qs']
  667: 
  668:         if args:
  669:             argv=args
  670:             
  671:         querys=qs.split(",")
  672:         argList=[]
  673:         arg=""
  674:         queryList=[x.split("=")[0] for x in querys]
  675:         
  676:         for argTmp in argv.keys():
  677:             
  678:             
  679:             arg=argTmp[0:]
  680:             if arg[0]=="_":arg="-"+argTmp[1:] # aender _ in - als standard
  681: 
  682:             if arg not in queryList: # noch nicht drin
  683:                 querys.append("%s=%s"%(arg,argv[argTmp]))
  684:             argList.append(arg)
  685: 
  686: 
  687:         
  688:         newquery=[]
  689:         for query in querys:
  690:             queryArg=query.split("=")[0]
  691:             qarg=queryArg[0:]
  692:             if qarg[0]=="-":qarg="_"+queryArg[1:] # aender _ in - als standard
  693:             
  694:             if  queryArg in argList:
  695:                 newquery.append("%s=%s"%(queryArg,argv[qarg]))
  696:             else:
  697:                 newquery.append(query)
  698: 
  699:         if url:
  700:             str=url+"?"+"&".join(newquery)
  701:         else:
  702:             str="ZSQLSearch?"+"&".join(newquery)
  703:         
  704:         return """<a href="%s"> %s</a>"""%(str,linkText)
  705:     
  706:     def parseQueryString(self,qs,iCT,storemax="no",select=None,nostore=None,storename=None,tableExt=None,NoQuery=None,NoLimit=None,restrictField=None,restrictConnect=None,filter=None):
  707:         """analysieren den QueryString"""
  708:         
  709:         
  710:         lop="AND" # standardsuche mit and
  711:         max="ALL" #standard alle auswaehlen
  712:         maxstr=""
  713:         whereList=[]
  714:         sort=""
  715:         op="bw"
  716:         opfields={}
  717:         lopfields={} #Verknuepfung bei mehrfachauswahl von einem feld
  718:         sortfields={} #order of sortfields
  719:         sortAllFields=None
  720:         skip=""
  721:         rangeStart=0
  722:         limit=0
  723:         searchFields={}
  724:         searchFieldsOnly={}
  725:         if not select:
  726:             select="oid,*"
  727:         #print "Q",nostore,qs
  728:         #check for op 
  729: 
  730: 
  731: 
  732:         
  733: 	splitted=qs.split(",")
  734:         if tableExt:
  735:             table=tableExt
  736: 
  737:         if restrictField:
  738:                     select=restrictField
  739:             
  740:         for q in splitted:
  741:                 
  742:                 name=re.sub("r'+'"," ",q.split("=")[0].lower())
  743:                 try:
  744:                     value=urllib.unquote(q.split("=",1)[1])
  745:                 except:
  746:                     value=""
  747:                 #print "Hi",name[0:3],q
  748:                 if name[0:3]==iCT+"op":
  749:                     op=value
  750: 
  751:                     field=name[4:]
  752:                     opfields[field]=op
  753: 
  754:                 if name[0:4]==iCT+"lop":
  755:                     lop=value
  756: 
  757:                     field=name[5:]
  758:                     lopfields[field]=lop
  759:                     
  760:                 if name[0:10]==iCT+"sortorder":
  761:                     #sort=value
  762:                     
  763:                     field=name[11:]
  764:                     sortAllFields=None
  765:                     #no field selected
  766:                     if field=="":
  767:                         sortAllFields=value
  768:                     else:
  769:                         sortfields[field]=value
  770:                     
  771:                     #print "HI",op,field
  772: 	#print opfieldsa
  773:         #now analyse the querystring
  774:        
  775:         for q in qs.split(","):
  776:        
  777:             
  778:             #try:
  779: 
  780:             name=re.sub("r'+'"," ",q.split("=")[0].lower())
  781:             try:
  782:                 value=urllib.unquote(q.split("=",1)[1])
  783:             except:
  784:                 value=""
  785:             
  786:             #value=sql_quote(value)
  787:             
  788: 
  789:             if name==iCT+"lop":
  790:                 lop=value
  791:             elif name==iCT+"table":
  792:                 if not tableExt: 
  793:                     table=value
  794:             elif name==iCT+"select":
  795:                 if not restrictField:
  796:                     select=value
  797:             elif name==iCT+"max":
  798:                 if not NoLimit:
  799:                     maxstr="LIMIT "+str(value)
  800:                     limit=str(value)
  801:             elif name==iCT+"skip":
  802:                 skip="OFFSET "+str(value)
  803:                 rangeStart=str(value)
  804:             elif name==iCT+"join":
  805:                 whereList.append(value)
  806:             elif name==iCT+"sort":
  807:                 sortstrs=[]
  808:                 for word in value.split(','):
  809:                     wordstr=word.lstrip().rstrip()
  810:                     if sortAllFields:
  811:                         order=sortAllFields
  812:                     else:
  813:                         order=sortfields.get(wordstr,'ASC')
  814:                         
  815:                     if not (wordstr == ""):
  816:                         sortstrs.append(wordstr+" "+order)
  817:                 if len(sortstrs)>0:
  818:                     sort="ORDER BY "+string.join(sortstrs,',')
  819:                     
  820:                     
  821:             elif name==iCT+"token":
  822:                 if not nostore=="yes":
  823:                     self.REQUEST.SESSION['token']=value
  824: 
  825:             elif name==iCT+"op":
  826:                 op=value
  827: 
  828: 
  829: 
  830:             elif (not name[0]==iCT) and (not len(value)==0):
  831: 
  832: 		#print "OP",op,name
  833:                 value=value.lower()
  834:                 tmp=""
  835:                 if opfields.has_key(name):
  836:                     op=opfields[name]
  837:                 else:
  838:                     op="ct"
  839:                 namealt=name
  840:                 name="LOWER("+name+")"    
  841:                 if op=="ct":
  842:                     tmp=(name+" LIKE "+sql_quote("%"+value+"%"))
  843:                 elif op=="gt":
  844:                     tmp=(name+">"+sql_quote(value))
  845:                 elif op=="lt":
  846:                     tmp=(name+"<"+sql_quote(value))
  847:                 elif op=="eq":
  848:                     tmp=(name+"="+sql_quote(value))
  849:                 elif op=="bw":
  850:                     tmp=(name+" LIKE "+sql_quote(value+"%"))
  851:                 elif op=="ew":
  852:                     tmp=(name+" LIKE "+sql_quote("%"+value))
  853:                 elif op=="all":
  854:                     tmps=[]
  855:                     for word in value.split(" "):
  856:                         tmps.append(name+" LIKE "+sql_quote("%"+word+"%"))
  857:                         
  858:                     tmp=string.join(tmps,' AND ')
  859: 
  860:                 elif op=="numerical":
  861:                     term=analyseIntSearch(value)
  862:                     tmp=(name+" "+term)
  863:                 elif op=="grep":
  864:                     tmp=(name+" ~* "+sql_quote(value))
  865:                 elif op=="one":
  866:                     tmps=[]
  867:                     for word in value.split(" "):
  868:                         tmps.append(name+" LIKE "+sql_quote("%"+word+"%"))
  869:                         
  870:                     tmp=string.join(tmps,' OR ')
  871: 
  872:                 op="all"
  873: 
  874:                 if (not tableExt) or (namealt.split('.')[0]==tableExt):
  875:                     if searchFields.has_key(namealt):
  876:                         searchFields[namealt]+=lopfields.get(name,'OR')+" "+tmp
  877:                         searchFieldsOnly[namealt]+=lopfields.get(name,'OR')+" "+value
  878:                     else: 
  879:                         searchFields[namealt]=tmp
  880:                         searchFieldsOnly[namealt]=value
  881: 
  882: 
  883:         whereList=["("+searchFields[x]+")" for x in searchFields.keys()]
  884:         
  885:         if len(whereList)>0:
  886:             if filter:
  887:                 whereStr="("+string.join(whereList," "+lop+" ")+") AND "+filter
  888:             else:
  889:                 whereStr=string.join(whereList," "+lop+" ")
  890:             where="WHERE "+whereStr
  891:         else:
  892:             if filter:
  893:                 where="WHERE "+filter
  894:             else:
  895:                 where=""
  896: 
  897:         if restrictConnect:
  898: 
  899:             if len(where)==0:
  900:                 where="WHERE "+restrictConnect[0]+" in ("+restrictConnect[1]+")"
  901:             else:
  902:                 where+="and "+restrictConnect[0]+" in ("+restrictConnect[1]+")"
  903:                 
  904:         #print "QE",table
  905:         #print (select,table,where,sort,maxstr,skip)
  906:         query="SELECT %s FROM %s %s %s %s %s"%(select,table,where,sort,maxstr,skip)
  907:         
  908:         if not nostore=="yes":
  909:             
  910:             self.REQUEST.SESSION['qs']=opfields
  911:         #print "IAMHERE again:", query
  912: 
  913:         if storename and (not NoQuery):
  914:             query2="SELECT count(*) FROM %s %s"%(table,where)
  915:             
  916:             #print "QUERYSTRING:",self.REQUEST.SESSION[storename]['queryString2']
  917:             if not self.REQUEST.SESSION.has_key(storename):
  918:                 self.REQUEST.SESSION[storename]={}
  919: 
  920:             self.REQUEST.SESSION[storename]['qs']=qs #sichere Querystring
  921: 
  922:             if self.REQUEST.SESSION[storename].has_key('queryString2'):
  923: 
  924:                 if not self.REQUEST.SESSION[storename]['queryString2']==query2:
  925:                     #print "HOOOOO",storename
  926:                     self.REQUEST.SESSION[storename]['queryString2']=query2
  927:                     try:
  928:                         self.REQUEST.SESSION[storename]['count']=self.ZSQLSimpleSearch(query2)[0].count
  929:                     except:
  930:                         self.REQUEST.SESSION[storename]['count']=0
  931:                     #print "QUERY",query2,"::::",self.REQUEST.SESSION[storename]['queryString2']
  932:                 
  933:             else:
  934: 
  935:                 self.REQUEST.SESSION[storename]['queryString2']=query2
  936:                 if self.ZSQLSimpleSearch(query2):
  937:                     self.REQUEST.SESSION[storename]['count']=self.ZSQLSimpleSearch(query2)[0].count
  938:                 else:
  939:                     self.REQUEST.SESSION[storename]['count']=0
  940:                 #print "QUERYNEW",self.REQUEST.SESSION[storename]['queryString2']
  941:             
  942:             
  943:             self.REQUEST.SESSION[storename]['rangeStart']=rangeStart
  944:             if limit=="all":
  945:                 self.REQUEST.SESSION[storename]['rangeEnd']=self.REQUEST.SESSION[storename]['count']
  946:             else:
  947:                 self.REQUEST.SESSION[storename]['rangeEnd']=int(rangeStart)+int(limit)
  948:             self.REQUEST.SESSION[storename]['rangeSize']=limit
  949:             self.REQUEST.SESSION[storename]['searchFields']=searchFields
  950:             self.REQUEST.SESSION[storename]['searchFieldsOnly']=searchFieldsOnly
  951: 
  952:         if not NoQuery:
  953: 
  954:             return self.ZSQLQuery(query)
  955:         else:
  956: 
  957:             return query
  958: 
  959:     def ZSQLUniqueQuery(self,value,returns):
  960:         """unique relation"""
  961:         if returns:
  962:             statement="""select %s from %s where %s = '%s' """%(returns[1],returns[0],returns[2],value)
  963:             founds=self.ZSQLSimpleSearch(statement)
  964:             if founds:
  965:                 return getattr(founds[0],returns[1])
  966:             else:
  967:                 return value
  968:         else:
  969:             return value
  970:         
  971:     def ZSQLQuery(self,query,debug=None):
  972:         """query"""
  973:         if debug:
  974:             zLOG.LOG("ZSQLQuery", zLOG.INFO, query)
  975:             
  976:         return self.ZSQLSimpleSearch(query)
  977: 
  978:     
  979:     def ZSQLSearch(self):
  980:         """To be done"""
  981:         rq=self.REQUEST['QUERY_STRING']
  982: 
  983:         querys=rq.split("&")
  984:         
  985:         
  986:         formatfile=self.REQUEST['URL1'] #generisch redirect zur gleichen url
  987:         
  988:         for querytemp in querys:
  989:             query=querytemp.split("=")
  990:             
  991:             
  992: 
  993:             
  994:             try:
  995:                 if query[0].lower()=="-format":
  996:                     formatfile=query[1]
  997:             except:
  998:                 """nothing"""
  999: 
 1000:                 
 1001:         #print formatfile
 1002:         
 1003:         
 1004:         self.REQUEST.SESSION['query']=string.join(self.REQUEST['QUERY_STRING'].split("&"),",")
 1005:         self.REQUEST.SESSION['come_from_search']="yes"
 1006:         
 1007:         return self.REQUEST.RESPONSE.redirect(urllib.unquote(formatfile))
 1008: 
 1009:     
 1010:     def ZSQLint(self,string):
 1011:         try:
 1012: 
 1013:             return(int(string))
 1014:         except:
 1015:             return 0
 1016: 
 1017:     def getZSQLSearchFieldsList(self,storename="foundCount"):
 1018:         """get searchfieldList"""
 1019:         #print self.REQUEST.SESSION[storename]['searchFields'].keys()
 1020:         return  self.REQUEST.SESSION[storename]['searchFieldsOnly'].keys()
 1021: 
 1022:     def getZSQLSearchFields(self,field,storename="foundCount"):
 1023:         """get searchfield"""
 1024:         #print "SF",self.REQUEST.SESSION[storename]['searchFields']
 1025:         
 1026:         return  self.REQUEST.SESSION[storename]['searchFieldsOnly'][field]
 1027: 
 1028:                                                 
 1029:     def nextLink(self,html,storename="foundCount"):
 1030:         """nextLink"""
 1031: 
 1032:         try:
 1033:             limit=self.REQUEST.SESSION[storename]['rangeSize']
 1034:             if int(limit)==0 :
 1035:                 limit="1"
 1036:             newRangeStart=int(self.REQUEST.SESSION[storename]['rangeStart'])+int(limit)
 1037:         except:
 1038:             limit=1
 1039:             newRangeStart=0
 1040:             
 1041:         if newRangeStart>=self.REQUEST.SESSION[storename]['count']:
 1042:             #newRangeStart=self.REQUEST.SESSION[storename]['count']-1
 1043:             return ""
 1044:         
 1045:         #create new query string
 1046:         
 1047:         if self.REQUEST['QUERY_STRING']=="":
 1048:             qs=self.REQUEST.SESSION['query']
 1049:             
 1050:             queries=string.split(qs,",")[0:]
 1051:             
 1052:             
 1053:         else:
 1054:             qs=self.REQUEST['QUERY_STRING']
 1055:             queries=string.split(qs,"&")[0:]
 1056:             
 1057:             
 1058:             
 1059:         newquery=[]
 1060: 
 1061:         skipFound=0
 1062:         
 1063:         for query in queries:
 1064:                         
 1065:             if query[0]=="_" : query="-"+query[1:]
 1066:             
 1067:             if query.split("=")[0].lower()=="-skip":
 1068: 
 1069:                 skipFound=1
 1070:                 query="-skip=%i"%newRangeStart
 1071:             newquery.append(query)
 1072: 
 1073:         if skipFound==0 :
 1074:             query="-skip=%i"%newRangeStart
 1075:             newquery.append(query)
 1076:                 
 1077:         newquerystring=string.join(newquery,"&")
 1078: 	return "<a href='%s'>%s</a>"%(self.REQUEST['URL']+"?"+newquerystring,html)
 1079: 
 1080:             
 1081:         
 1082:     def prevLink(self,html,storename="foundCount"):
 1083:         """prev link"""
 1084: 
 1085:         try:
 1086:             limit=self.REQUEST.SESSION[storename]['rangeSize']
 1087:             if int(limit)==0 :
 1088:                 limit="1"
 1089:             newRangeStart=int(self.REQUEST.SESSION[storename]['rangeStart'])-int(limit)
 1090:         except:
 1091:             limit=1
 1092:             newRangeStart=0
 1093:         if newRangeStart <0:
 1094:             return ""
 1095: 
 1096:         #print "limit",limit,newRangeStart,int(self.REQUEST.SESSION[storename]['rangeStart'])
 1097:         
 1098:         if newRangeStart<0:
 1099:                 newRangeStart=0
 1100: 
 1101:         #create new query string
 1102:         
 1103:         if self.REQUEST['QUERY_STRING']=="":
 1104:             qs=self.REQUEST.SESSION['query']
 1105:             #qs=re.sub(r'_','-',qs) #aendern fuer query
 1106:             queries=string.split(qs,",")
 1107:             
 1108:             
 1109:         else:
 1110:             qs=self.REQUEST['QUERY_STRING']
 1111:             queries=string.split(qs,"&")
 1112:             
 1113:             
 1114:             
 1115:         newquery=[]
 1116:         
 1117:         skipFound=0
 1118: 
 1119:         for query in queries:
 1120:             #print query.split("=")[0]
 1121: 
 1122:             if query[0]=="_" : query[0]="-"
 1123:             
 1124:             if query.split("=")[0].lower()=="-skip":
 1125:                 #print"HI"
 1126:                 query="-skip=%i"%newRangeStart
 1127:                 skipFound=1
 1128:             newquery.append(query)
 1129: 
 1130:         if skipFound==0 :
 1131:             query="-skip=%i"%newRangeStart
 1132:             newquery.append(query)
 1133:             
 1134:         newquerystring=string.join(newquery,"&")
 1135: 
 1136:         return "<a href='%s'>%s</a>"%(self.REQUEST['URL']+"?"+newquerystring,html)
 1137: 
 1138: 
 1139:     
 1140:     def prevLink_old(self,html):
 1141:         """prev link"""
 1142:         if self.REQUEST['QUERY_STRING']=="":
 1143:             qs=self.REQUEST.SESSION['query']
 1144:         else:
 1145:             qs=self.REQUEST['QUERY_STRING']
 1146:         max=re.search(r'max\=(.*)\,',qs.lower())
 1147:         offset=re.search(r'offset\=(.*)\,',qs.lower())
 1148:         if not offset:
 1149:             offsetnew=0
 1150:         else:
 1151:             offsetnew=int(offset)-max
 1152:             if offsetnew<0:
 1153:                 offsetnew=0
 1154:         queries=string.split(qs,",")
 1155:         newquery=[]
 1156:         if offset:
 1157:             for query in queries:
 1158:                 if query.split("=")[0].lower()=="offset":
 1159:                     query="-offset=%i"%offsetnew
 1160:                 newquery.append(query)
 1161:                 newquerystring=string.join(newquery,"&")
 1162:         else:
 1163:             queries.append("-offset=%i"%offsetnew)
 1164:             newquerystring=string.join(queries,"&")
 1165:         return "<a href='%s'>%s</a>"%(self.actualPath()+"?"+newquerystring,html)
 1166:         
 1167:     def nextLink_old(self,html):
 1168:         """prev link"""
 1169:         if self.REQUEST['QUERY_STRING']=="":
 1170:             qs=self.REQUEST.SESSION['query']
 1171:         else:
 1172:             qs=self.REQUEST['QUERY_STRING']
 1173:         max=re.search(r'max\=(.*)\,',qs.lower())
 1174:     
 1175:         offset=re.search(r'offset\=(.*)\,',qs.lower())
 1176:         if not offset:
 1177:             offsetnew=1
 1178:         else:
 1179:             offsetnew=int(offset)+int(max)
 1180:             if offsetnew<0:
 1181:                 offsetnew=0
 1182:         queries=string.split(qs,",")
 1183:         newquery=[]
 1184:         if offset:
 1185:             for query in queries:
 1186: 
 1187:                 if query.split("=")[0].lower()=="-offset":
 1188:                     query="-offset=%i"%offsetnew
 1189:                 newquery.append(query)
 1190:                 newquerystring=string.join(newquery,"&")
 1191:         else:
 1192:             queries.append("-offset=%i"%offsetnew)
 1193:             newquerystring=string.join(queries,"&")
 1194:         
 1195:         return "<a href='%s'>%s</a>"%(self.actualPath()+"?"+newquerystring,html)
 1196:         
 1197:     
 1198: manage_addZSQLExtendFolderForm=DTMLFile('ZSQLExtendFolderAdd', globals())
 1199: 
 1200: def manage_addZSQLExtendFolder(self, id, title='', label='', description='',
 1201:                      createPublic=0,
 1202:                      createUserF=0,
 1203:                      connection_id=None,
 1204:                      REQUEST=None):
 1205:     """Add a new Folder object with id *id*.
 1206: 
 1207:     If the 'createPublic' and 'createUserF' parameters are set to any true
 1208:     value, an 'index_html' and a 'UserFolder' objects are created respectively
 1209:     in the new folder.
 1210:     """
 1211:     
 1212:     
 1213:     ob=ZSQLExtendFolder()
 1214:     ob.id=str(id)
 1215:     ob.title=title
 1216:     self._setObject(id, ob)
 1217:     ob=self._getOb(id)
 1218:     setattr(ob,'label',label)
 1219:     setattr(ob,'description',description)
 1220:     setattr(ob,'connection_id',connection_id)
 1221:     
 1222:     checkPermission=getSecurityManager().checkPermission
 1223: 
 1224:     if createUserF:
 1225:         if not checkPermission('Add User Folders', ob):
 1226:             raise Unauthorized, (
 1227:                   'You are not authorized to add User Folders.'
 1228:                   )
 1229:         ob.manage_addUserFolder()
 1230: 
 1231:     if createPublic:
 1232:         if not checkPermission('Add Page Templates', ob):
 1233:             raise Unauthorized, (
 1234:                   'You are not authorized to add Page Templates.'
 1235:                   )
 1236:         ob.manage_addProduct['PageTemplates'].manage_addPageTemplate(
 1237:             id='index_html', title='')
 1238: 
 1239:     if REQUEST is not None:
 1240:         return self.manage_main(self, REQUEST, update_menu=1)
 1241: 
 1242: 
 1243: 
 1244: class ZSQLBibliography(Folder,ZSQLExtendFolder):
 1245:     """Bibliography"""
 1246:     meta_type="ZSQLBibliography"
 1247:     def getLabel(self):
 1248:         try:
 1249:             return self.label
 1250:         except:
 1251:             return ""
 1252: 
 1253:     def getDescription(self):
 1254:         try:
 1255:             return self.description
 1256:         except:
 1257:             return ""
 1258:             
 1259:     def changeZSQLBibliographyForm(self):
 1260:         """change folder config"""
 1261:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','changeZSQLBibliographyForm.zpt')).__of__(self)
 1262:         return pt()
 1263: 
 1264: 
 1265:     def content_html(self):
 1266:         """template fuer content"""
 1267:         
 1268:         try:
 1269:             obj=getattr(self,"ZSQLBibliography_template")
 1270:             return obj()
 1271:         except:
 1272:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','ZSQLBibliography_template_standard.zpt')).__of__(self)
 1273:             pt.content_type="text/html"
 1274:             return pt()
 1275: 
 1276:     def changeZSQLBibliography(self,tableName,label,description,connection_id=None,REQUEST=None):
 1277:         """change it"""
 1278:         self.connection_id=connection_id
 1279:         self.tableName=tableName
 1280:         self.label=label
 1281:         self.description=description
 1282:         
 1283:         if REQUEST is not None:
 1284:             return self.manage_main(self, REQUEST)
 1285: 
 1286:     manage_options=Folder.manage_options+(
 1287:         {'label':'Main Config','action':'changeZSQLBibliographyForm'},
 1288:         {'label':'Generate RDF Template','action':'generateRDFTemplate'},
 1289:         {'label':'Generate XML Template','action':'generateXMLTemplate'},
 1290:        )
 1291: 
 1292: 
 1293:     def getFieldLabel(self,fields,field):
 1294:         """get labels"""
 1295:         try:
 1296:             ret =fields[0][field]
 1297:             if ret == "":
 1298:                 return field
 1299:             else:
 1300:                 return ret
 1301:         except:
 1302:             return field
 1303:         
 1304:     def getFieldValue(self,found,field):
 1305:         """get value"""
 1306:         try:
 1307:             ret=getattr(found,field)
 1308:             if ret == "":
 1309:                 return None
 1310:             else:
 1311:                 return ret
 1312:         except:
 1313:             return None
 1314: 
 1315:     def findTagsFromMapping(self,referenceType):
 1316:         """gib hash mit label -> generic zurueck"""
 1317:         self.referencetypes=self.ZopeFind(self.standardMD)
 1318:         bibdata={}
 1319:         retdata={}
 1320:         fieldlist=self.standardMD.fieldList
 1321:         
 1322: 	for referenceTypeF in self.referencetypes:
 1323: 		#print referenceType,referenceTypeF[1].title
 1324: 		if referenceTypeF[1].title == referenceType: 
 1325: 			bibdata[referenceTypeF[1].title]=referenceTypeF[1].fields
 1326: 			bibdata['data']=referenceTypeF[1]
 1327: 			self.fields=bibdata[referenceType]
 1328:                         for field in fieldlist:
 1329: 		            if referenceTypeF[1].getValue(field)[0]==None:
 1330: 				retdata[field]=field
 1331: 			    else:
 1332:                                 retdata[field]=referenceTypeF[1].getValue(field)[0]
 1333: 
 1334:         return retdata,fieldlist
 1335:         
 1336:     def findLabelsFromMapping(self,referenceType):
 1337:         """gib hash mit label -> generic zurueck"""
 1338:         self.referencetypes=self.ZopeFind(self.standardMD)
 1339:         bibdata={}
 1340:         retdata={}
 1341:         fieldlist=self.standardMD.fieldList
 1342:         
 1343: 	for referenceTypeF in self.referencetypes:
 1344: 		#print referenceType,referenceTypeF[1].title
 1345: 		if referenceTypeF[1].title == referenceType: 
 1346: 			bibdata[referenceTypeF[1].title]=referenceTypeF[1].fields
 1347: 			bibdata['data']=referenceTypeF[1]
 1348: 			self.fields=bibdata[referenceType]
 1349:                         for field in fieldlist:
 1350:                             retdata[field]=referenceTypeF[1].getValue(field)[1]
 1351: 
 1352:         return retdata,fieldlist
 1353: 
 1354:     def createRDFTag(self,tag,content,namespace="cdli"):
 1355:         """create RDF"""
 1356:         if content:
 1357:             tag=namespace+":"+tag
 1358:             if (type(content) is StringType) or (type(content) is UnicodeType):
 1359:                 ret=""" <%s>%s</%s>"""%(tag,escape(content),tag)
 1360:             else:
 1361:                 ret=""" <%s>%s</%s>"""%(tag,content,tag)
 1362:             return ret.decode('latin-1')
 1363:         else:
 1364:             return ""
 1365:     
 1366:     def createIndexTag(self,tag,content):
 1367:         """create tag"""
 1368:         
 1369:         if content:
 1370:             if (type(content) is StringType) or (type(content) is UnicodeType):
 1371:                 ret=""" <%s>%s</%s>"""%(tag,escape(content),tag)
 1372:             else:
 1373:                 ret=""" <%s>%s</%s>"""%(tag,content,tag)
 1374:             return ret.decode('latin-1')
 1375: 
 1376:         else:
 1377:             return ""
 1378:     
 1379:     def getXML2(self):
 1380:         """crate index meta"""
 1381: 
 1382:         fn=os.path.splitext(self.REQUEST['fn'])[0]+"."
 1383:         self.REQUEST['fn']=fn
 1384: 
 1385:         pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','record2.xml')).__of__(self)
 1386:         pt.content_type="text/xml"
 1387:         return pt()
 1388: 
 1389: 
 1390:     def generateRDFTemplate(self,REQUEST=None):
 1391:         """generateRDFtemplate"""
 1392:         zt=ZopePageTemplate('record.rdf')
 1393:         self._setObject('record.rdf',zt)
 1394:         default_content_fn = os.path.join(package_home(globals()),
 1395:                                           'zpt','record.rdf')
 1396:         text = open(default_content_fn).read()
 1397:         zt.pt_edit(text, 'text/xml')
 1398: 
 1399: 
 1400:         if REQUEST is not None:
 1401:             return self.manage_main(self, REQUEST)
 1402: 
 1403:     def generateXMLTemplate(self,REQUEST=None):
 1404:         """generateXMLtemplate"""
 1405:         zt=ZopePageTemplate('record.xml')
 1406:         self._setObject('record.xml',zt)
 1407:         default_content_fn = os.path.join(package_home(globals()),
 1408:                                           'zpt','record.xml')
 1409:         text = open(default_content_fn).read()
 1410:         zt.pt_edit(text, 'text/xml')
 1411: 
 1412: 
 1413:         if REQUEST is not None:
 1414:             return self.manage_main(self, REQUEST)
 1415:     def getMetaDataRDF(self):
 1416:         """crate index meta"""
 1417:         find=self.ZopeFind(self,obj_ids=["record.rdf"])
 1418:         if not find:
 1419:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','record.rdf')).__of__(self)
 1420:             pt.content_type="text/xml"
 1421:             return pt()
 1422:         else:
 1423:             return find[0][1]()
 1424: 
 1425:     def getMetaDataXML(self):
 1426:         """crate index meta"""
 1427:         find=self.ZopeFind(self,obj_ids=["record.xml"])
 1428:         if not find:
 1429:             pt=PageTemplateFile(os.path.join(package_home(globals()),'zpt','record.xml')).__of__(self)
 1430:             pt.content_type="text/xml"
 1431:             return pt()
 1432:         else:
 1433:             return find[0][1]()
 1434: 
 1435: 
 1436:     def getMetaDatasXML(self):
 1437:         """index"""
 1438:         # check if the request's host part was OK
 1439:         http_host = self.REQUEST['HTTP_HOST']
 1440:         host_port = self.REQUEST['SERVER_PORT']
 1441:         fix_host = None
 1442:         if http_host and http_host.rfind(host_port) == -1:
 1443:             print "HTTP_HOST needs fixing!"
 1444:             fix_host = http_host + ":" + host_port
 1445:         
 1446:         ret="""<?xml version="1.0" ?>
 1447: 	             <index>"""
 1448:         for found in self.ZSQLSimpleSearch("select oid from %s limit ALL"%self.tableName):
 1449:             base_url = self.absolute_url()
 1450:             if fix_host:
 1451:                 #print "replacing ", http_host, " by ", fix_host
 1452:                 base_url = string.replace(base_url, http_host, fix_host, 1)
 1453:                 
 1454:             link=base_url+"/"+"record.html?oid=%i"%found.oid
 1455:             metalink=base_url+"/"+"getMetaDataXML?oid=%i"%found.oid
 1456:             
 1457:             ret+="""<resource resourceLink="%s" metaLink="%s"/>\n"""%(link,metalink)
 1458:             
 1459:         return ret+"\n</index>"
 1460: 
 1461:     
 1462: manage_addZSQLBibliographyForm=DTMLFile('ZSQLBibliographyAdd', globals())
 1463: 
 1464: def manage_addZSQLBibliography(self, id, tableName,label,description,title='',
 1465:                      createPublic=0,
 1466:                      createUserF=0,
 1467:                      connection_id=None,
 1468:                      REQUEST=None):
 1469:     """Add a new Folder object with id *id*.
 1470: 
 1471:     If the 'createPublic' and 'createUserF' parameters are set to any true
 1472:     value, an 'index_html' and a 'UserFolder' objects are created respectively
 1473:     in the new folder.
 1474:     """
 1475:     
 1476:     
 1477:     ob=ZSQLBibliography()
 1478:     ob.id=str(id)
 1479:     ob.title=title
 1480:     self._setObject(id, ob)
 1481:     ob=self._getOb(id)
 1482:     setattr(ob,'tableName',tableName)
 1483:     setattr(ob,'label',label)
 1484:     setattr(ob,'description',description)
 1485:     setattr(ob,'connection_id',connection_id)
 1486:     
 1487:     checkPermission=getSecurityManager().checkPermission
 1488: 
 1489:     if createUserF:
 1490:         if not checkPermission('Add User Folders', ob):
 1491:             raise Unauthorized, (
 1492:                   'You are not authorized to add User Folders.'
 1493:                   )
 1494:         ob.manage_addUserFolder()
 1495: 
 1496:     if createPublic:
 1497:         if not checkPermission('Add Page Templates', ob):
 1498:             raise Unauthorized, (
 1499:                   'You are not authorized to add Page Templates.'
 1500:                   )
 1501:         ob.manage_addProduct['PageTemplates'].manage_addPageTemplate(
 1502:             id='index_html', title='')
 1503: 
 1504:     if REQUEST is not None:
 1505:         return self.manage_main(self, REQUEST, update_menu=1)
 1506: 
 1507:     
 1508: 
 1509:     

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