Changeset 123

Timestamp:

04/16/08 08:01:47 (4 years ago)

Author:

phil

Message:

rdfalchemy added identifier to create_engine (for sleepycat only right now)

Location:

rdfalchemy/trunk/rdfalchemy

Files:

• engine/__init__.py (modified) (4 diffs)
• sparql.py (modified) (1 diff)

rdfalchemy/trunk/rdfalchemy/engine/__init__.py

@@ -3 +3 @@
 import urllib
 
-def create_engine(url='', create=False):
+def create_engine(url='', identifier="", create=False):
     """
     :returns: returns an open rdflib ConjunctiveGraph
 
     :param url: a string of the url
+    :param identifier: URIRef of the default context for writing
     e.g.:
       
@@ -14 +15 @@
       - create_engine('zodb:///var/rdflib/Data.fs')
       - create_engine('zodb://localhost:8672')
+      - create_engine('sesame://www.example.com:8080/openrdf-sesame/repositories/Test')      
+      - create_engine('sparql://www.example.com:2020/sparql')            
     
     for zodb:
@@ -26 +29 @@
     elif url.lower().startswith('mysql://'):
         from rdflib import ConjunctiveGraph
-        db = ConjunctiveGraph('MySQL')
+        db = ConjunctiveGraph('MySQL',identifier)
         schema,opts = _parse_rfc1738_args(url)
         openstr= 'db=%(database)s,host=%(host)s,user=%(username)s'%opts
@@ -32 +35 @@
     elif url.lower().startswith('sleepycat://'):
         from rdflib import ConjunctiveGraph
-        db = ConjunctiveGraph('Sleepycat')
+        db = ConjunctiveGraph('Sleepycat',identifier=identifier)
         openstr = os.path.abspath(os.path.expanduser(url[12:]))
-        db.open(openstr) #,create=create) 
+        db.open(openstr,create=create)
     elif url.lower().startswith('zodb://'):
         import ZODB

rdfalchemy/trunk/rdfalchemy/sparql.py

@@ -89 +89 @@
         url = self.url+"?"+urlencode(query)
         req = Request(url)
-        log.debug("Request: %s" % req.get_full_url())
         req.add_header('Accept','application/rdf+xml')
-        log.debug("opening url: %s\n  with headers: %s" % (req.get_full_url(), req.header_items()))        
+        log.debug("Request url: %s\n  with headers: %s" % (req.get_full_url(), req.header_items()))        
         subgraph = ConjunctiveGraph('IOMemory')
         subgraph.parse(urlopen(req))