sqlalchemy session.refresh nie odświeżyć obiekt

Question

Mam następujący Mapping (prosto z przykładów SA):

class User(Base): 
    __tablename__ = 'users' 

    id = Column(Integer, primary_key=True) 
    name = Column(String) 
    fullname = Column(String) 
    password = Column(String) 

pracuję z MySQL DB i tabela ma silnik InnoDB.

Mam pojedynczy rekord w moim tabeli: 1 | 'user1' | 'test user1' | 'password'

Mam otworzył sesję z następującego kodu:

from sqlalchemy.orm.session import sessionmaker 
from sqlalchemy.engine import create_engine 
from sqlalchemy.orm.scoping import scoped_session 
from sqlalchemy.ext.declarative import declarative_base 

Base = declarative_base() 

db_engine = create_engine('mysql://...@localhost/test_db?charset=utf8',echo=False,pool_recycle=1800) 
session_factory = sessionmaker(bind=db_engine,autocommit=False,autoflush=False) 
session_maker = scoped_session(session_factory) 
session = session_maker() 

user_1 = session.query(User).filter(User.id==1).one() 
user_1.name # This prints: u'user1' 

teraz, kiedy zmienić nazwę rekordu w DB do „user1_change” i zobowiązać go, a następnie odśwież przedmiotu takiego:

session.refresh(user_1) 
user_1.name # This still prints: u'user1' and not u'user1_change' 

nadal drukuje: u'user1' i nie u'user1_change”.

Czego tu brakuje (lub źle się tu ustawia)?

Dzięki!

Answer 1

Z docs:

pamiętać, że bardzo odizolowane transakcja zwróci te same wartości jak wcześniej przeczytać w tej samej transakcji, niezależnie od zmian w stanie bazy poza tą transakcją

SQLAlchemy wykorzystuje transakcyjny model jednostki pracy, w którym zakłada się, że każda transakcja jest wewnętrznie spójna. Sesja to interfejs na szczycie transakcji. Ponieważ zakłada się, że transakcja jest wewnętrznie spójna, SQLAlchemy będzie tylko (dobrze, nie całkiem, ale dla łatwości wyjaśnienia ...) odzyskać dane z bazy danych i zaktualizować stan powiązanych obiektów raz na transakcję. Ponieważ już odpytałeś o obiekt w tej samej transakcji sesji, SQLAlchemy nie zaktualizuje danych w tym obiekcie z bazy danych ponownie w ramach tego zakresu transakcji. Jeśli chcesz odpytać bazę danych, musisz za każdym razem wykonać nową transakcję.

Answer 2

Czy spróbować z „wygaśnie”, jak opisano w oficjalnym dokumencie:

http://docs.sqlalchemy.org/en/rel_0_8/orm/session.html#refreshing-expiring

# expire objects obj1, obj2, attributes will be reloaded 
# on the next access: 
session.expire(user_1) 
session.refresh(user_1) 

Korzystanie obowiązywać w wynikach obiekt w reload, które nastąpi po następnym dostępu.

Answer 3

Scal sesję.

u = session.query(User).get(id) 
u.name = 'user1_changed' 
u = session.merge(u) 

Spowoduje to aktualizację bazy danych i zwrócenie nowszego obiektu.

Answer 4

session.refresh() też nie działa. Mimo że zobaczyłem WYBÓR niskiego poziomu, obiekt nie został zaktualizowany po odświeżeniu.

Ta odpowiedź https://stackoverflow.com/a/11121788/562267 wskazówki do prowadzenia rzeczywistej commit/rollback do zresetowania sesji, i że pracował dla mnie:

user_1 = session.query(User).filter(User.id==1).one() 
user_1.name # This prints: u'user1' 
# update the database from another client here 
session.commit() 
user_1 = session.query(User).filter(User.id==1).one() 
user_1.name # Should be updated now.