SQLAlchemy - как отобразить против только для чтения (или вычисленный) свойство
Я пытаюсь выяснить, как отобразиться против простого свойства только для чтения и иметь тот огонь свойства, когда я сохраняю к базе данных.
Изобретенный пример должен сделать это более ясным. Во-первых, простая таблица:
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),
)
То, что я хочу сделать, настраивается класс со свойством только для чтения, которое вставит в calculated_value столбец для меня, когда я назову session.commit ()...
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
Согласно sqlalchemy документам, я думаю, что я, как предполагается, отображаю это как так:
mapper(Foo, foo_table, properties = {
'calculated_value' : synonym('_calculated_value', map_column=True)
})
Проблема с этим состоит в том, что _calculated_value не Ни один, пока Вы не получаете доступ к calculated_value свойству. Кажется, что SQLAlchemy не называет свойство на вставке в базу данных, таким образом, я добираюсь, Ни один оценивают вместо этого. Что корректный путь состоит в том, чтобы отобразить это так, чтобы результат "calculated_value" свойства был вставлен в "calculated_value" столбец таблицы нечто?
Хорошо - Я редактирую это сообщение в случае, если у кого-то еще есть тот же вопрос. То, что я закончил тем, что делал, использовало MapperExtension. Позвольте мне дать Вам лучший пример наряду с использованием расширения:
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)
И это - то, как Вы используете это. Позволяет говорят, что у Вас есть класс с несколькими свойствами только для чтения, которые должны стрелять перед вставкой в базу данных. Я предполагаю здесь, что для каждого из этих свойств только для чтения, у Вас есть соответствующий столбец в базе данных, которую Вы хотите заполненный со значением свойства. Вы все еще собираетесь настроить синоним для каждого свойства, но Вы используете расширение картопостроителя выше при отображении объекта:
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)
})
1 ответ
Я не уверен, что можно добиться того, чего вы хотите, используя sqlalchemy.orm.synonym. Скорее всего, нет, учитывая тот факт, как sqlalchemy отслеживает, какие экземпляры грязные и должны быть обновлены во время flush.
Но есть и другой способ получить эту функциональность - SessionExtensions (обратите внимание на переменную engine_string вверху, которую нужно заполнить):
(env)zifot@localhost:~/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)zifot@localhost:~/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
Подробнее о SessionExtensions: sqlalchemy.orm.interfaces.SessionExtension.