File:  [Repository] / ZSQLExtend / ZSQLExtend.py
Revision 1.68: download - view: text, annotated - select for diffs - revision graph
Wed Oct 12 19:36:56 2005 UTC (18 years, 8 months ago) by dwinter
Branches: MAIN
CVS tags: HEAD
changes in ZSQLOptions

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

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