File:  [Repository] / ZSQLExtend / ZSQLExtend.py
Revision 1.66: download - view: text, annotated - select for diffs - revision graph
Tue Oct 11 13:15:01 2005 UTC (18 years, 8 months ago) by dwinter
Branches: MAIN
CVS tags: HEAD
ZSQLAdd and ZSQLchange corrected

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

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