ormapping/0040755000076500007650000000000007266622011012050 5ustar shaneshaneormapping/ORStorage.py0100644000076500007650000003055407252267703014303 0ustar shaneshane """Object Relational Storage. """ __version__='$Revision: 1.1 $'[11:-2] import POSException, string, utils from BaseStorage import BaseStorage from cPickle import Pickler, Unpickler from cStringIO import StringIO from ExtensionClass import Base from thread import get_ident from base64 import encodestring, decodestring root_oid = '\0' * 8 dummy_serial = '\0' * 8 TupleType=type(()) ExtensionKlass=Base.__class__ class HelperClass: pass ClassType=type(HelperClass) class ORMapping: ''' Interface for defining an object relational mapping. ''' def load(self, storage, klass, cursor, oid, version): ''' Returns data, serial. ''' def store(self, storage, klass, cursor, oid, version, do_insert, serial, data, transaction): ''' Returns new serial. ''' class DefaultORMapping (ORMapping): ''' Simply stores and retrieves pickles. ''' def load(self, storage, klass, cursor, oid, version): ''' Returns data, serial. ''' if version: raise POSException.Unsupported, "Versions aren't supported" s = str(oid) if s[-1:] == 'L': s = s[:-1] cursor.execute('SELECT data FROM zodb_pickles ' 'WHERE zoid=%(oid)s', {'oid':s}) if cursor.rowcount < 1: raise 'OID not found', `oid` data = decodestring(cursor.fetchone()[0]) return data, None def store(self, storage, klass, cursor, oid, version, do_insert, serial, data, transaction): ''' Returns new serial. ''' if version: raise POSException.Unsupported, "Versions aren't supported" s = str(oid) if s[-1:] == 'L': s = s[:-1] data = encodestring(data) if do_insert: cursor.execute("INSERT INTO zodb_pickles (zoid, data) " "VALUES (%(oid)s, '%(data)s')", {'oid':s, 'data':data}) else: cursor.execute("UPDATE zodb_pickles SET data='%(data)s' " "WHERE zoid=%(oid)s", {'oid':s, 'data':data}) return None class ORStorage (BaseStorage): ''' ''' def __init__(self, description, connection, dbmodule, create=0, mappings={}, default_mapping=DefaultORMapping()): BaseStorage.__init__(self, description) self._conn = connection self._cursors = {} self._mappings = mappings self._default_mapping = default_mapping self._binary = dbmodule.Binary if create: self._createTables() cursor = connection.cursor() cursor.execute('SELECT oid_seq FROM zodb_misc') if cursor.rowcount < 1: cursor.execute('INSERT INTO zodb_misc VALUES (0)') self._conn.commit() self._oid = 0L else: self._oid = long(cursor.fetchone()[0]) def _createCursor(self): self._cursors[get_ident()] = cursor = self._conn.cursor() return cursor def _getCursor(self): c = self._cursors.get(get_ident(), None) if c is not None: return c else: return self._createCursor() def _clearCursor(self): self._cursors[get_ident()] = None def _createTables(self): cursor = self._conn.cursor() cursor.execute('DROP TABLE zodb_pickles') cursor.execute('DROP TABLE zodb_classes') cursor.execute('DROP TABLE zodb_misc') cursor.execute('CREATE TABLE zodb_misc (oid_seq int8)') cursor.execute('CREATE TABLE zodb_classes ' '(zoid int8 PRIMARY KEY, ' 'module varchar(128), ' 'name varchar(128))') cursor.execute('CREATE TABLE zodb_pickles ' '(zoid int8 PRIMARY KEY, ' 'data varchar)') self._conn.commit() def _abort(self): self._conn.rollback() self._clearCursor() def _begin(self, tid, u, d, e): self._createCursor() def _finish(self, tid, u, d, e): cursor = self._getCursor() s = str(self._oid) if s[-1:] == 'L': s = s[:-1] cursor.execute('UPDATE zodb_misc SET oid_seq=%(oid)s', {'oid':s}) self._conn.commit() self._clearCursor() def getSize(self): return 500 def _clear_temp(self): pass def new_oid(self): self._lock_acquire() try: self._oid = oid = self._oid + 1 return oid finally: self._lock_release() def _getORMapping(self, cursor, oid): s = str(oid) if s[-1:] == 'L': s = s[:-1] cursor.execute('SELECT module, name FROM zodb_classes ' 'WHERE zoid=%(oid)s', {'oid':s}) if cursor.rowcount < 1: raise POSException.POSError, 'No such OID ' + `oid` module, name = cursor.fetchone() _silly=('__doc__',) _globals={} m=__import__(module, _globals, _globals, _silly) klass = getattr(m, name) mapping = self._mappings.get(klass, None) if mapping is None: mapping = self._default_mapping return klass, mapping def _setORMapping(self, cursor, oid, data): # Returns (mapping, do_insert) s = str(oid) if s[-1:] == 'L': s = s[:-1] cursor.execute('SELECT 1 FROM zodb_classes ' 'WHERE zoid=%(oid)s', {'oid':s}) if cursor.rowcount < 1: do_insert = 1 else: do_insert = 0 cursor.fetchone() # Empty the row buffer. file = StringIO(data) unpickler = PersistenceAwareUnpickler(file) klass, args = unpickler.load_type_info() if type(klass) is not TupleType: module = getattr(klass, '__module__', '') if module: name = klass.__name__ else: raise POSException.Unsupported, ( 'Cannot store instances of %s (%s)' % (`klass`, `args`)) else: module, name = klass if do_insert: cursor.execute("INSERT INTO zodb_classes (zoid, module, name) " "VALUES (%(oid)s, '%(module)s', '%(name)s')", {'oid':s, 'module':module, 'name':name}) else: cursor.execute("UPDATE zodb_classes SET module='%(module)s', " "name='%(name)s' WHERE zoid=%(oid)s", {'oid':s, 'module':module, 'name':name}) mapping = self._mappings.get(klass, None) if mapping is None: mapping = self._default_mapping return klass, mapping, do_insert ## def load(self, oid, version): ## if oid == root_oid: ## oid = 0L ## if version: ## raise POSException.Unsupported, "Versions aren't supported" ## cursor = self._conn.cursor() ## s = str(oid) ## if s[-1:] == 'L': s = s[:-1] ## cursor.execute('SELECT module, name FROM zodb_classes ' ## 'WHERE oid=%(oid)s' % {'oid':s}) ## if cursor.rowcount < 1: ## raise POSException.POSError, 'No such OID ' + `oid` ## module, name = cursor.fetchone() ## mapping = self._mappings.get((module, name), None) ## if mapping is None: ## mapping = self._default_mapping ## object = mapping.load(oid, cursor) ## return object def load(self, oid, version): if oid == root_oid: oid = 0L cursor = self._getCursor() klass, mapping = self._getORMapping(cursor, oid) self._lock_acquire() try: data, serial = mapping.load(self, klass, cursor, oid, version) finally: self._lock_release() if serial is None: serial = dummy_serial return data, serial def store(self, oid, serial, data, version, transaction): if transaction is not self._transaction: raise POSException.StorageTransactionError(self, transaction) if oid == root_oid: oid = 0L cursor = self._getCursor() klass, mapping, do_insert = self._setORMapping(cursor, oid, data) self._lock_acquire() try: new_serial = mapping.store(self, klass, cursor, oid, version, do_insert, serial, data, transaction) finally: self._lock_release() return new_serial ## def store(self, oid, object, version, transaction): ## if oid == root_oid: ## oid = 0L ## if version: ## raise POSException.Unsupported, "Versions aren't supported" ## cursor.execute('SELECT module, name FROM zodb_classes ' ## 'WHERE oid=%(oid)s' % {'oid':s}) ## if cursor.rowcount < 1: ## do_insert = 1 ## else: ## do_insert = 0 ## klass = object.__class__ ## mapping = self._mappings.get((klass.__module__, klass.__name__), None) ## if mapping is None: ## mapping = self._default_mapping ## serial = mapping.store(oid, object, cursor, do_insert) ## return serial class PersistenceAwareUnpickler: def __init__(self, file): self.file = file def load_type_info(self): u = Unpickler(self.file) u.persistent_load = self._persistent_load return u.load() def load(self): u = Unpickler(self.file) u.persistent_load = self._persistent_load klass, args = u.load() state = u.load() object = self._createClassInstance(klass, args) if hasattr(object, '__setstate__'): object.__setstate__(state) else: d=object.__dict__ for k,v in state.items(): d[k]=v return object def _persistent_load(self, oid, tt=type(()) ): if type(oid) is tt: oid, klass = oid if type(klass) is tt: module, name = klass klass = self._classFactory(self, module, name) object = klass.__basicnew__() else: object = Persistent() # This actually works. :-) object._p_oid=oid return object def _createClassInstance(self, klass, args): if type(klass) is TupleType: module, name = klass klass=self._classFactory(module, name) if (args is None or not args and not hasattr(klass,'__getinitargs__')): object=klass.__basicnew__() else: object=apply(klass, args) if klass is not ExtensionKlass: object.__dict__.clear() return object def _classFactory(self, module, name, _silly=('__doc__',), _globals={}): m=__import__(module, _globals, _globals, _silly) return getattr(m, name) class PersistenceAwarePickler: def __init__(self, file): self.file = file def dump(self, object): klass = object.__class__ if klass is ExtensionKlass: # Yee Ha! dict={} dict.update(object.__dict__) try: del dict['_p_jar'] except: pass args=object.__name__, object.__bases__, dict state=None else: if hasattr(klass, '__getinitargs__'): args = object.__getinitargs__() len(args) # XXX Assert it's a sequence else: args = None # New no-constructor protocol! module=getattr(klass,'__module__','') if module: klass=module, klass.__name__ __traceback_info__ = klass, oid, version state=object.__getstate__() p = Pickler(self.file) p.persistent_id = self._persistent_id p.dump((klass, args)) p.dump(state) def _persistent_id(self, object): # We may use the version in coptimizations.c later. if not hasattr(object, '_p_oid') or type(object) is ClassType: return None oid = object._p_oid if oid is None: raise POSException.StorageError, ( 'No OID assigned to %s' % `object`) klass = object.__class__ if klass is ExtensionKlass: return oid if hasattr(klass, '__getinitargs__'): return oid module = getattr(klass, '__module__', '') if module: klass = module, klass.__name__ return oid, klass ormapping/ORStorage3.py0100644000076500007650000003055407252307101014351 0ustar shaneshane """Object Relational Storage. """ __version__='$Revision: 1.1 $'[11:-2] import POSException, string, utils from BaseStorage import BaseStorage from cPickle import Pickler, Unpickler from cStringIO import StringIO from ExtensionClass import Base from thread import get_ident from base64 import encodestring, decodestring root_oid = '\0' * 8 dummy_serial = '\0' * 8 TupleType=type(()) ExtensionKlass=Base.__class__ class HelperClass: pass ClassType=type(HelperClass) class ORMapping: ''' Interface for defining an object relational mapping. ''' def load(self, storage, klass, cursor, oid, version): ''' Returns data, serial. ''' def store(self, storage, klass, cursor, oid, version, do_insert, serial, data, transaction): ''' Returns new serial. ''' class DefaultORMapping (ORMapping): ''' Simply stores and retrieves pickles. ''' def load(self, storage, klass, cursor, oid, version): ''' Returns data, serial. ''' if version: raise POSException.Unsupported, "Versions aren't supported" s = str(oid) if s[-1:] == 'L': s = s[:-1] cursor.execute('SELECT data FROM zodb_pickles ' 'WHERE zoid=%(oid)s', {'oid':s}) if cursor.rowcount < 1: raise 'OID not found', `oid` data = decodestring(cursor.fetchone()[0]) return data, None def store(self, storage, klass, cursor, oid, version, do_insert, serial, data, transaction): ''' Returns new serial. ''' if version: raise POSException.Unsupported, "Versions aren't supported" s = str(oid) if s[-1:] == 'L': s = s[:-1] data = encodestring(data) if do_insert: cursor.execute("INSERT INTO zodb_pickles (zoid, data) " "VALUES (%(oid)s, '%(data)s')", {'oid':s, 'data':data}) else: cursor.execute("UPDATE zodb_pickles SET data='%(data)s' " "WHERE zoid=%(oid)s", {'oid':s, 'data':data}) return None class ORStorage (BaseStorage): ''' ''' def __init__(self, description, connection, dbmodule, create=0, mappings={}, default_mapping=DefaultORMapping()): BaseStorage.__init__(self, description) self._conn = connection self._cursors = {} self._mappings = mappings self._default_mapping = default_mapping self._binary = dbmodule.Binary if create: self._createTables() cursor = connection.cursor() cursor.execute('SELECT oid_seq FROM zodb_misc') if cursor.rowcount < 1: cursor.execute('INSERT INTO zodb_misc VALUES (0)') self._conn.commit() self._oid = 0L else: self._oid = long(cursor.fetchone()[0]) def _createCursor(self): self._cursors[get_ident()] = cursor = self._conn.cursor() return cursor def _getCursor(self): c = self._cursors.get(get_ident(), None) if c is not None: return c else: return self._createCursor() def _clearCursor(self): self._cursors[get_ident()] = None def _createTables(self): cursor = self._conn.cursor() cursor.execute('DROP TABLE zodb_pickles') cursor.execute('DROP TABLE zodb_classes') cursor.execute('DROP TABLE zodb_misc') cursor.execute('CREATE TABLE zodb_misc (oid_seq int8)') cursor.execute('CREATE TABLE zodb_classes ' '(zoid int8 PRIMARY KEY, ' 'module varchar(128), ' 'name varchar(128))') cursor.execute('CREATE TABLE zodb_pickles ' '(zoid int8 PRIMARY KEY, ' 'data varchar)') self._conn.commit() def _abort(self): self._conn.rollback() self._clearCursor() def _begin(self, tid, u, d, e): self._createCursor() def _finish(self, tid, u, d, e): cursor = self._getCursor() s = str(self._oid) if s[-1:] == 'L': s = s[:-1] cursor.execute('UPDATE zodb_misc SET oid_seq=%(oid)s', {'oid':s}) self._conn.commit() self._clearCursor() def getSize(self): return 500 def _clear_temp(self): pass def new_oid(self): self._lock_acquire() try: self._oid = oid = self._oid + 1 return oid finally: self._lock_release() def _getORMapping(self, cursor, oid): s = str(oid) if s[-1:] == 'L': s = s[:-1] cursor.execute('SELECT module, name FROM zodb_classes ' 'WHERE zoid=%(oid)s', {'oid':s}) if cursor.rowcount < 1: raise POSException.POSError, 'No such OID ' + `oid` module, name = cursor.fetchone() _silly=('__doc__',) _globals={} m=__import__(module, _globals, _globals, _silly) klass = getattr(m, name) mapping = self._mappings.get(klass, None) if mapping is None: mapping = self._default_mapping return klass, mapping def _setORMapping(self, cursor, oid, data): # Returns (mapping, do_insert) s = str(oid) if s[-1:] == 'L': s = s[:-1] cursor.execute('SELECT 1 FROM zodb_classes ' 'WHERE zoid=%(oid)s', {'oid':s}) if cursor.rowcount < 1: do_insert = 1 else: do_insert = 0 cursor.fetchone() # Empty the row buffer. file = StringIO(data) unpickler = PersistenceAwareUnpickler(file) klass, args = unpickler.load_type_info() if type(klass) is not TupleType: module = getattr(klass, '__module__', '') if module: name = klass.__name__ else: raise POSException.Unsupported, ( 'Cannot store instances of %s (%s)' % (`klass`, `args`)) else: module, name = klass if do_insert: cursor.execute("INSERT INTO zodb_classes (zoid, module, name) " "VALUES (%(oid)s, '%(module)s', '%(name)s')", {'oid':s, 'module':module, 'name':name}) else: cursor.execute("UPDATE zodb_classes SET module='%(module)s', " "name='%(name)s' WHERE zoid=%(oid)s", {'oid':s, 'module':module, 'name':name}) mapping = self._mappings.get(klass, None) if mapping is None: mapping = self._default_mapping return klass, mapping, do_insert ## def load(self, oid, version): ## if oid == root_oid: ## oid = 0L ## if version: ## raise POSException.Unsupported, "Versions aren't supported" ## cursor = self._conn.cursor() ## s = str(oid) ## if s[-1:] == 'L': s = s[:-1] ## cursor.execute('SELECT module, name FROM zodb_classes ' ## 'WHERE oid=%(oid)s' % {'oid':s}) ## if cursor.rowcount < 1: ## raise POSException.POSError, 'No such OID ' + `oid` ## module, name = cursor.fetchone() ## mapping = self._mappings.get((module, name), None) ## if mapping is None: ## mapping = self._default_mapping ## object = mapping.load(oid, cursor) ## return object def load(self, oid, version): if oid == root_oid: oid = 0L cursor = self._getCursor() klass, mapping = self._getORMapping(cursor, oid) self._lock_acquire() try: data, serial = mapping.load(self, klass, cursor, oid, version) finally: self._lock_release() if serial is None: serial = dummy_serial return data, serial def store(self, oid, serial, data, version, transaction): if transaction is not self._transaction: raise POSException.StorageTransactionError(self, transaction) if oid == root_oid: oid = 0L cursor = self._getCursor() klass, mapping, do_insert = self._setORMapping(cursor, oid, data) self._lock_acquire() try: new_serial = mapping.store(self, klass, cursor, oid, version, do_insert, serial, data, transaction) finally: self._lock_release() return new_serial ## def store(self, oid, object, version, transaction): ## if oid == root_oid: ## oid = 0L ## if version: ## raise POSException.Unsupported, "Versions aren't supported" ## cursor.execute('SELECT module, name FROM zodb_classes ' ## 'WHERE oid=%(oid)s' % {'oid':s}) ## if cursor.rowcount < 1: ## do_insert = 1 ## else: ## do_insert = 0 ## klass = object.__class__ ## mapping = self._mappings.get((klass.__module__, klass.__name__), None) ## if mapping is None: ## mapping = self._default_mapping ## serial = mapping.store(oid, object, cursor, do_insert) ## return serial class PersistenceAwareUnpickler: def __init__(self, file): self.file = file def load_type_info(self): u = Unpickler(self.file) u.persistent_load = self._persistent_load return u.load() def load(self): u = Unpickler(self.file) u.persistent_load = self._persistent_load klass, args = u.load() state = u.load() object = self._createClassInstance(klass, args) if hasattr(object, '__setstate__'): object.__setstate__(state) else: d=object.__dict__ for k,v in state.items(): d[k]=v return object def _persistent_load(self, oid, tt=type(()) ): if type(oid) is tt: oid, klass = oid if type(klass) is tt: module, name = klass klass = self._classFactory(self, module, name) object = klass.__basicnew__() else: object = Persistent() # This actually works. :-) object._p_oid=oid return object def _createClassInstance(self, klass, args): if type(klass) is TupleType: module, name = klass klass=self._classFactory(module, name) if (args is None or not args and not hasattr(klass,'__getinitargs__')): object=klass.__basicnew__() else: object=apply(klass, args) if klass is not ExtensionKlass: object.__dict__.clear() return object def _classFactory(self, module, name, _silly=('__doc__',), _globals={}): m=__import__(module, _globals, _globals, _silly) return getattr(m, name) class PersistenceAwarePickler: def __init__(self, file): self.file = file def dump(self, object): klass = object.__class__ if klass is ExtensionKlass: # Yee Ha! dict={} dict.update(object.__dict__) try: del dict['_p_jar'] except: pass args=object.__name__, object.__bases__, dict state=None else: if hasattr(klass, '__getinitargs__'): args = object.__getinitargs__() len(args) # XXX Assert it's a sequence else: args = None # New no-constructor protocol! module=getattr(klass,'__module__','') if module: klass=module, klass.__name__ __traceback_info__ = klass, oid, version state=object.__getstate__() p = Pickler(self.file) p.persistent_id = self._persistent_id p.dump((klass, args)) p.dump(state) def _persistent_id(self, object): # We may use the version in coptimizations.c later. if not hasattr(object, '_p_oid') or type(object) is ClassType: return None oid = object._p_oid if oid is None: raise POSException.StorageError, ( 'No OID assigned to %s' % `object`) klass = object.__class__ if klass is ExtensionKlass: return oid if hasattr(klass, '__getinitargs__'): return oid module = getattr(klass, '__module__', '') if module: klass = module, klass.__name__ return oid, klass ormapping/ORStorageSpec.py0100644000076500007650000000027207251527633015110 0ustar shaneshane spec = { OFS.Folder.Folder: NO_ATTRIBUTES, OFS.ObjectManager.ObjectManager: {'_objects': TUPLE_OF_DICTS, '': PERSISTENT_ATTRIBUTES}, } ormapping/sketch0100644000076500007650000000332007231145127013247 0ustar shaneshane A relational mapping can be represented as a tree of Zope objects. Ex: a user database with roles connected to a database. RelationalMapping (root set to 'users_table') | +-users_table (ORDictionaryInterface; brain=CIMUser; key=userid) | | | +-roles_attribute_join (attribute='roles', | child='roles_table', parent_key='userid', child_key='userid') | +-roles_table (ORListInterface; brain=String) Each branch contains all necessary information to construct the respective objects. user_mapper = RelationalMapping() # 1. Set up the type of object that is fetched at the root. # ?As a mapping? ?A list? roles = user_mapper.addList( ) users.addAttributeRule( attribute='roles', child=roles) user_mapper.attachAttribute( parent=users, attribute='roles', child=roles) # join inferred. user_mapper.addMappingInterfacePattern( table_name='g2_users', brain=CIMUser, key_column='userid' ) user_translation = user_mapper.getRoot().createMappingInterface( table_name='g2_users', brain=CIMUser, key_column='userid' ) user_mapper.setRoot(root) userFolder._dict = relationalTableAsMapping( connection='Oracle_Database_Connection', table_name='g2_users', brain=CIMUser, key_column='userid' ) rolesTable = relationalTableAsList( connection='Oracle_Database_Connection', table_name='g2_roles', brain=StringBrain, column='role' ) joinAttribute( userFolder._dict, attribute='roles', userFolder._dict.addTable( table_name='g2_roles', attribute='roles', join='userid', content = relationalSystem(connection='Oracle_Database_Connection') ormapping/sketch~0100644000076500007650000000006407231140050013435 0ustar shaneshane registerTableAccess('Oracle user table', CIMUser) ormapping/ORStorage.pyc0100644000076500007650000004217507266621715014452 0ustar shaneshane*ë Ão©:csydZddd !ZdkZdkZdkZdklZdklZlZ dk l Z  dk l Z  d k lZ d klZlZd d Zd d ZefƒZe iZd fd„ƒYZeeƒZdfd„ƒYZ'defd„ƒYZOdefd„ƒYZ dfd„ƒYZWdfd„ƒYZdS(sObject Relational Storage. s$Revision: 1.1 $i iN(s BaseStorage(sPicklers Unpickler(sStringIO(sBase(s get_ident(s encodestrings decodestringsis HelperClasscsRS(N((((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pys HelperClassss ORMappingcs&dZd„Z!d„ZRS(s> Interface for defining an object relational mapping. cs dS(s' Returns data, serial. N((sselfsstoragesklassscursorsoidsversion((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pysloadsc s !%dS(s% Returns new serial. N(( sselfsstoragesklassscursorsoidsversions do_insertsserialsdatas transaction((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pysstore!s(s__doc__sloadsstore(((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pys ORMappings  sDefaultORMappingcs&'dZ*+d„Z:d„ZRS(s. Simply stores and retrieves pickles. csÆ+./|o0tid‚n1t|ƒ}2|d djo2|d }n3|id4h|d<ƒ5|idjo6d| ‚n7t |i ƒdƒ}8|t fSdS( s' Returns data, serial. sVersions aren't supportedisLs0SELECT data FROM zodb_pickles WHERE zoid=%(oid)ssoids OID not foundiN( sversions POSExceptions Unsupportedsstrsoidssscursorsexecutesrowcounts decodestringsfetchonesdatasNone(sselfsstoragesklassscursorsoidsversionsdatass((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pysload+s  c sÑ:>?|o@tid‚nAt|ƒ} B| d djoB| d } nCt|ƒ}D|o,E|i dGh| d<|d<ƒn)I|i dKh| d<|d<ƒLt SdS( s% Returns new serial. sVersions aren't supportedisLsBINSERT INTO zodb_pickles (zoid, data) VALUES (%(oid)s, '%(data)s')soidsdatas:UPDATE zodb_pickles SET data='%(data)s' WHERE zoid=%(oid)sN( sversions POSExceptions Unsupportedsstrsoidsss encodestringsdatas do_insertscursorsexecutesNone( sselfsstoragesklassscursorsoidsversions do_insertsserialsdatas transactionss((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pysstore:s     (s__doc__sloadsstore(((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pysDefaultORMapping's  s ORStoragecsÎOdZQSdheƒd„Zfd„Zjd„Zqd„Ztd„Zƒd„Z‡d„ZŠd „Z ’d „Z •d „Z ˜d „Z  d „Z ³d„Zêd„Zûd„ZRS(s icsòSUti||ƒV||_Wh|_X||_Y||_ Z|i |_ [|o\|iƒn]|iƒ}^|idƒ_|idjo0`|idƒa|iiƒbd|_ndt|iƒdƒ|_dS(NsSELECT oid_seq FROM zodb_miscis INSERT INTO zodb_misc VALUES (0)li(s BaseStorages__init__sselfs descriptions connections_conns_cursorssmappingss _mappingssdefault_mappings_default_mappingsdbmodulesBinarys_binaryscreates _createTablesscursorsexecutesrowcountscommits_oidslongsfetchone(sselfs descriptions connectionsdbmodulescreatesmappingssdefault_mappingscursor((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pys__init__Ss     cs.fg|iiƒ|itƒ<}h|SdS(N(sselfs_connscursors_cursorss get_ident(sselfscursor((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pys _createCursorfs csJjk|iitƒtƒ}l|tj o m|Sno|iƒSdS(N(sselfs_cursorssgets get_identsNonescs _createCursor(sselfsc((s2/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage.pys _getCursorjs csqrt|itƒ Interface for defining an object relational mapping. cs dS(s' Returns data, serial. N((sselfsstoragesklassscursorsoidsversion((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pysloadsc s !%dS(s% Returns new serial. N(( sselfsstoragesklassscursorsoidsversions do_insertsserialsdatas transaction((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pysstore!s(s__doc__sloadsstore(((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pys ORMappings  sDefaultORMappingcs&'dZ*+d„Z:d„ZRS(s. Simply stores and retrieves pickles. csÆ+./|o0tid‚n1t|ƒ}2|d djo2|d }n3|id4h|d<ƒ5|idjo6d| ‚n7t |i ƒdƒ}8|t fSdS( s' Returns data, serial. sVersions aren't supportedisLs0SELECT data FROM zodb_pickles WHERE zoid=%(oid)ssoids OID not foundiN( sversions POSExceptions Unsupportedsstrsoidssscursorsexecutesrowcounts decodestringsfetchonesdatasNone(sselfsstoragesklassscursorsoidsversionsdatass((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pysload+s  c sÑ:>?|o@tid‚nAt|ƒ} B| d djoB| d } nCt|ƒ}D|o,E|i dGh| d<|d<ƒn)I|i dKh| d<|d<ƒLt SdS( s% Returns new serial. sVersions aren't supportedisLsBINSERT INTO zodb_pickles (zoid, data) VALUES (%(oid)s, '%(data)s')soidsdatas:UPDATE zodb_pickles SET data='%(data)s' WHERE zoid=%(oid)sN( sversions POSExceptions Unsupportedsstrsoidsss encodestringsdatas do_insertscursorsexecutesNone( sselfsstoragesklassscursorsoidsversions do_insertsserialsdatas transactionss((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pysstore:s     (s__doc__sloadsstore(((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pysDefaultORMapping's  s ORStoragecsÎOdZQSdheƒd„Zfd„Zjd„Zqd„Ztd„Zƒd„Z‡d„ZŠd „Z ’d „Z •d „Z ˜d „Z  d „Z ³d„Zêd„Zûd„ZRS(s icsòSUti||ƒV||_Wh|_X||_Y||_ Z|i |_ [|o\|iƒn]|iƒ}^|idƒ_|idjo0`|idƒa|iiƒbd|_ndt|iƒdƒ|_dS(NsSELECT oid_seq FROM zodb_miscis INSERT INTO zodb_misc VALUES (0)li(s BaseStorages__init__sselfs descriptions connections_conns_cursorssmappingss _mappingssdefault_mappings_default_mappingsdbmodulesBinarys_binaryscreates _createTablesscursorsexecutesrowcountscommits_oidslongsfetchone(sselfs descriptions connectionsdbmodulescreatesmappingssdefault_mappingscursor((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pys__init__Ss     cs.fg|iiƒ|itƒ<}h|SdS(N(sselfs_connscursors_cursorss get_ident(sselfscursor((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pys _createCursorfs csJjk|iitƒtƒ}l|tj o m|Sno|iƒSdS(N(sselfs_cursorssgets get_identsNonescs _createCursor(sselfsc((s3/home/shane/cvs/Zope2/lib/python/ZODB/ORStorage3.pys _getCursorjs csqrt|itƒ