2010-06-11 10 views
5

Ich versuche herauszufinden, wie man eine einfache schreibgeschützte Eigenschaft abbildet, und lasse diese Eigenschaft auslösen, wenn ich in der Datenbank speichere.SQLAlchemy - wie man gegen eine schreibgeschützte (oder berechnete) Eigenschaft abbildet

Ein künstliches Beispiel sollte dies verdeutlichen. Zuerst wird eine einfache Tabelle:

meta = MetaData() 
foo_table = Table('foo', meta, 
    Column('id', String(3), primary_key=True), 
    Column('description', String(64), nullable=False), 
    Column('calculated_value', Integer, nullable=False), 
    ) 

Was ich tun möchte, eine Klasse mit einer Nur-Lese-Eigenschaft eingerichtet ist, die in die calculated_value Spalte für mich einsetzen, wenn ich session.commit() aufrufen ...

import datetime 
def Foo(object): 
    def __init__(self, id, description): 
     self.id = id 
     self.description = description 

    @property 
    def calculated_value(self): 
     self._calculated_value = datetime.datetime.now().second + 10 
     return self._calculated_value 

nach den sqlalchemy docs, ich denke, soll ich dies abzubilden, wie so:

mapper(Foo, foo_table, properties = { 
    'calculated_value' : synonym('_calculated_value', map_column=True) 
    }) 

Das Problem dabei ist, dass _calculated_ Der Wert ist None, bis Sie auf die Eigenschaft comprected_value zugreifen. Es scheint, dass SQLAlchemy die Eigenschaft beim Einfügen in die Datenbank nicht aufruft, also bekomme ich stattdessen einen None-Wert. Was ist der richtige Weg, dies zuzuordnen, so dass das Ergebnis der Eigenschaft "calcted_value" in die Spalte "calcted_value" der foo-Tabelle eingefügt wird?

OK - Ich bearbeite diesen Beitrag, falls jemand anders dieselbe Frage hat. Was ich getan habe, war eine MapperExtension. Lassen Sie mich Ihnen ein besseres Beispiel zusammen mit Nutzung der Erweiterung:

class UpdatePropertiesExtension(MapperExtension): 
    def __init__(self, properties): 
     self.properties = properties 

    def _update_properties(self, instance): 
     # We simply need to access our read only property one time before it gets 
     # inserted into the database. 
     for property in self.properties: 
      getattr(instance, property) 

    def before_insert(self, mapper, connection, instance): 
     self._update_properties(instance) 

    def before_update(self, mapper, connection, instance): 
     self._update_properties(instance) 

Und das ist, wie Sie diese verwenden. Nehmen wir an, Sie haben eine Klasse mit mehreren schreibgeschützten Eigenschaften, die vor dem Einfügen in die Datenbank ausgelöst werden müssen. Ich gehe hier davon aus, dass Sie für jede dieser schreibgeschützten Eigenschaften eine entsprechende Spalte in der Datenbank haben, die Sie mit dem Wert der Eigenschaft füllen möchten. Sie sind immer noch ein Synonym für jede Eigenschaft einzurichten, aber Sie verwenden, um die Mapper Erweiterung oben, wenn Sie das Objekt Karte:

class Foo(object): 
    def __init__(self, id, description): 
     self.id = id 
     self.description = description 
     self.items = [] 
     self.some_other_items = [] 

    @property 
    def item_sum(self): 
     self._item_sum = 0 
     for item in self.items: 
      self._item_sum += item.some_value 
     return self._item_sum 

    @property 
    def some_other_property(self): 
     self._some_other_property = 0 
     .... code to generate _some_other_property on the fly.... 
     return self._some_other_property 

mapper(Foo, metadata, 
    extension = UpdatePropertiesExtension(['item_sum', 'some_other_property']), 
    properties = { 
     'item_sum' : synonym('_item_sum', map_column=True), 
     'some_other_property' : synonym('_some_other_property', map_column = True) 
    }) 

Antwort

1

Ich bin nicht sicher, es möglich ist, zu erreichen, was Sie mit sqlalchemy.orm wollen. Synonym. Wahrscheinlich nicht die Tatsache, wie SQLlalchemy verfolgt, welche Instanzen sind schmutzig und müssen aktualisiert werden während Flush.

Aber es gibt andere Art und Weise, wie Sie diese Funktionalität erhalten - SessionExtensions (man beachte die engine_string Variable an der Spitze, die gefüllt werden muss):

(env)[email protected]:~/stackoverflow$ cat stackoverflow.py 

engine_string = '' 

from sqlalchemy import Table, Column, String, Integer, MetaData, create_engine 
import sqlalchemy.orm as orm 
import datetime 

engine = create_engine(engine_string, echo = True) 
meta = MetaData(bind = engine) 

foo_table = Table('foo', meta, 
    Column('id', String(3), primary_key=True), 
    Column('description', String(64), nullable=False), 
    Column('calculated_value', Integer, nullable=False), 
) 

meta.drop_all() 
meta.create_all() 

class MyExt(orm.interfaces.SessionExtension): 
    def before_commit(self, session): 
     for obj in session: 
      if isinstance(obj, Foo): 
       obj.calculated_value = datetime.datetime.now().second + 10 

Session = orm.sessionmaker(extension = MyExt())() 
Session.configure(bind = engine) 

class Foo(object): 
    def __init__(self, id, description): 
     self.id = id 
     self.description = description 

orm.mapper(Foo, foo_table) 

(env)[email protected]:~/stackoverflow$ ipython 
Python 2.5.2 (r252:60911, Jan 4 2009, 17:40:26) 
Type "copyright", "credits" or "license" for more information. 

IPython 0.10 -- An enhanced Interactive Python. 
?   -> Introduction and overview of IPython's features. 
%quickref -> Quick reference. 
help  -> Python's own help system. 
object? -> Details about 'object'. ?object also works, ?? prints more. 

In [1]: from stackoverflow import * 
2010-06-11 13:19:30,925 INFO sqlalchemy.engine.base.Engine.0x...11cc select version() 
2010-06-11 13:19:30,927 INFO sqlalchemy.engine.base.Engine.0x...11cc {} 
2010-06-11 13:19:30,935 INFO sqlalchemy.engine.base.Engine.0x...11cc select current_schema() 
2010-06-11 13:19:30,936 INFO sqlalchemy.engine.base.Engine.0x...11cc {} 
2010-06-11 13:19:30,965 INFO sqlalchemy.engine.base.Engine.0x...11cc select relname from pg_class c join pg_namespace n on n.oid=c.relnamespace where n.nspname=current_schema() and lower(relname)=%(name)s 
2010-06-11 13:19:30,966 INFO sqlalchemy.engine.base.Engine.0x...11cc {'name': u'foo'} 
2010-06-11 13:19:30,979 INFO sqlalchemy.engine.base.Engine.0x...11cc 
DROP TABLE foo 
2010-06-11 13:19:30,980 INFO sqlalchemy.engine.base.Engine.0x...11cc {} 
2010-06-11 13:19:30,988 INFO sqlalchemy.engine.base.Engine.0x...11cc COMMIT 
2010-06-11 13:19:30,997 INFO sqlalchemy.engine.base.Engine.0x...11cc select relname from pg_class c join pg_namespace n on n.oid=c.relnamespace where n.nspname=current_schema() and lower(relname)=%(name)s 
2010-06-11 13:19:30,999 INFO sqlalchemy.engine.base.Engine.0x...11cc {'name': u'foo'} 
2010-06-11 13:19:31,007 INFO sqlalchemy.engine.base.Engine.0x...11cc 
CREATE TABLE foo (
     id VARCHAR(3) NOT NULL, 
     description VARCHAR(64) NOT NULL, 
     calculated_value INTEGER NOT NULL, 
     PRIMARY KEY (id) 
) 


2010-06-11 13:19:31,009 INFO sqlalchemy.engine.base.Engine.0x...11cc {} 
2010-06-11 13:19:31,025 INFO sqlalchemy.engine.base.Engine.0x...11cc COMMIT 

In [2]: f = Foo('idx', 'foo') 

In [3]: f.calculated_value 

In [4]: Session.add(f) 

In [5]: f.calculated_value 

In [6]: Session.commit() 
2010-06-11 13:19:57,668 INFO sqlalchemy.engine.base.Engine.0x...11cc BEGIN 
2010-06-11 13:19:57,674 INFO sqlalchemy.engine.base.Engine.0x...11cc INSERT INTO foo (id, description, calculated_value) VALUES (%(id)s, %(description)s, %(calculated_value)s) 
2010-06-11 13:19:57,675 INFO sqlalchemy.engine.base.Engine.0x...11cc {'description': 'foo', 'calculated_value': 67, 'id': 'idx'} 
2010-06-11 13:19:57,683 INFO sqlalchemy.engine.base.Engine.0x...11cc COMMIT 

In [7]: f.calculated_value 
2010-06-11 13:20:00,755 INFO sqlalchemy.engine.base.Engine.0x...11cc BEGIN 
2010-06-11 13:20:00,759 INFO sqlalchemy.engine.base.Engine.0x...11cc SELECT foo.id AS foo_id, foo.description AS foo_description, foo.calculated_value AS foo_calculated_value 
FROM foo 
WHERE foo.id = %(param_1)s 
2010-06-11 13:20:00,761 INFO sqlalchemy.engine.base.Engine.0x...11cc {'param_1': 'idx'} 
Out[7]: 67 

In [8]: f.calculated_value 
Out[8]: 67 

In [9]: Session.commit() 
2010-06-11 13:20:08,366 INFO sqlalchemy.engine.base.Engine.0x...11cc UPDATE foo SET calculated_value=%(calculated_value)s WHERE foo.id = %(foo_id)s 
2010-06-11 13:20:08,367 INFO sqlalchemy.engine.base.Engine.0x...11cc {'foo_id': u'idx', 'calculated_value': 18} 
2010-06-11 13:20:08,373 INFO sqlalchemy.engine.base.Engine.0x...11cc COMMIT 

In [10]: f.calculated_value 
2010-06-11 13:20:10,475 INFO sqlalchemy.engine.base.Engine.0x...11cc BEGIN 
2010-06-11 13:20:10,479 INFO sqlalchemy.engine.base.Engine.0x...11cc SELECT foo.id AS foo_id, foo.description AS foo_description, foo.calculated_value AS foo_calculated_value 
FROM foo 
WHERE foo.id = %(param_1)s 
2010-06-11 13:20:10,481 INFO sqlalchemy.engine.base.Engine.0x...11cc {'param_1': 'idx'} 
Out[10]: 18 

Mehr auf SessionExtensions: sqlalchemy.orm.interfaces.SessionExtension.

+1

Interessant.Auch wenn ich das etwas anders gelöst habe, habe ich dies als Antwort markiert, weil es funktionieren sollte. Je mehr ich über SQLAlchemy lerne, desto mehr mag ich es! –

5

Danke für die Bearbeitung mit Ihrer Antwort, Jeff. Ich hatte genau das gleiche Problem und löste es mit Ihrem Code, hier ist etwas ähnliches für diejenigen, die eine deklarative Basis verwenden. Könnten Sie ein paar Minuten Zeit sparen aufzublicken, wie die Mapper Argumente und Synonyme zu spezifizieren:

from sqlalchemy.ext.declarative import declarative_base 

class Users(Base): 
    __tablename__ = 'users' 

    id = Column(Integer, primary_key=True) 
    name = Column(String) 
    _calculated_value = Column('calculated_value', String) 

    __mapper_args__ = {'extension': UpdatePropertiesExtension(['calculated_value'])} 

    def __init__(self, name): 
    self.name = name 

    @property 
    def calculated_value(self): 
    self._calculated_value = "foobar" 
    return self._calculated_value 

    calculated_value = synonym('_calculated_value', descriptor=calculated_value) 
+0

Danke! Hat mich in der Tat einige Zeit gerettet. –

0

Neuere Versionen von SQLAlchemy Unterstützung etwas Hybrid Eigenschaften genannt, die Sie Methoden als Einrichter für das Speichern von berechneten Werte an die DB definieren lassen.

Ich bin mir nicht sicher, ob ich das Problem verstehe, das Sie versuchen, gut genug zu lösen, um Beispielcode zu geben, aber hier für jeden zu veröffentlichen, der durch Google hindurch stolpert.

Verwandte Themen