File:  [Repository] / ZSQLExtend / ZSQLExtend.py
Revision 1.67: download - view: text, annotated - select for diffs - revision graph
Tue Oct 11 20:05:06 2005 UTC (18 years, 8 months ago) by dwinter
Branches: MAIN
CVS tags: HEAD
change changed

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

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