SQLAlchemy: Benim SQLAlchemy uygulamasında olmayan benzersiz bir değer

Question

kurtarmaya çalışırken sonra modelin benzersiz alanını yeniden kaydetmek, aşağıdaki modeli vardır:

from sqlalchemy import Column, String 
from sqlalchemy.ext.declarative import declarative_base 
from sqlalchemy.orm import scoped_session, sessionmaker 
from zope.sqlalchemy import ZopeTransactionExtension 

DBSession = scoped_session(sessionmaker(extension=ZopeTransactionExtension())) 

class MyModel(declarative_base()): 
    # ... 
    label = Column(String(20), unique=True) 

    def save(self, force=False): 
     DBSession.add(self) 
     if force: 
      DBSession.flush() 

Daha sonra kodda ben rastgele label oluşturmak istediğiniz her yeni MyModel nesneler için ve oluşturulan değer zaten DB'de mevcutsa, yalnızca yeniden oluşturun. İlk label benzersiz değil oluşturulur ve save() ikinci (veya üstü) yineleme üzerinde çağrıldığında durumunda bu hatayı

# my_model is an object of MyModel 
while True: 
    my_model.label = generate_label() 
    try: 
     my_model.save(force=True) 
    except IntegrityError: 
     # label is not unique - will do one more iteration 
     # (*) 
     pass 
    else: 
     # my_model saved successfully - exit the loop 
     break 

ama olsun:

InvalidRequestError: This Session's transaction has been rolled back due to a previous exception during flush. To begin a new transaction with this Session, first issue Session.rollback(). Original exception was: (IntegrityError) column url_label is not unique... 

aşağıdaki yapmaya çalışıyorum Ben pozisyon (*) içinde DBSession.rollback() eklediğinizde bu alın:

ResourceClosedError: The transaction is closed 

ne yapmalıyım Bu durumu doğru şekilde ele almak için?
Teşekkür

Answer 1

session nesnesiniz geri dönüyorsa, yeniden başlatabilmeniz için yeni bir oturum oluşturmanız ve modellerinizi yenilemeniz gerekir. Ve eğer zope.sqlalchemy kullanıyorsan, kontrol etmek için transaction.commit() ve transaction.abort() kullanıyor olmalısın. Burada nesnenin save yöntemin dışına oturum nesnesi kullanımını çekti ettik

# you'll also need this import after your zope.sqlalchemy import statement 
import transaction 

while True: 
    my_model.label = generate_label() 
    try: 
     transaction.commit() 
    except IntegrityError: 
     # need to use zope.sqlalchemy to clean things up 
     transaction.abort() 
     # recreate the session and re-add your object 
     session = DBSession() 
     session.add(my_model) 
    else: 
     break 

: Yani döngü böyle bir şey olmazdı. Yaptığınız gibi sınıf seviyesinde kullanıldığında, ScopedSession'un kendini nasıl yenilediğinden tam olarak emin değilim. Şahsen, ben senin modelleri içinde SqlAlchemy şeyler gömme sanırım gerçekten herhangi bir şey SqlAlchemy'nin unit of work yaklaşımı ile iyi çalışmıyor.

Etiket nesnesinin gerçekten üretilmiş ve benzersiz bir değeri varsa, TokenMacGuy ile hemfikir olurum ve sadece uuid değerini kullanın.

Bu yardımcı olur umarım.

Answer 2

Veritabanları bir işlem neden başarısız otomasyon erişebileceği bir formda, size söylemek tutarlı bir yol yoktur. İşlemi genellikle denemeyin ve belirli bir nedenle için başarısız olduğundan yeniden deneyin.

Etrafında çalışmak istediğiniz bir durumu biliyorsanız (benzersiz bir kısıtlama gibi), yapmanız gereken kısıtlamayı kendiniz kontrol etmektir. sqlalchemy olarak, bu şuna benzer olacak:

# Find a unique label 
label = generate_label() 
while DBsession.query(
     sqlalchemy.exists(sqlalchemy.orm.Query(Model) 
        .filter(Model.lable == label) 
        .statement)).scalar(): 
    label = generate_label() 

# add that label to the model 
my_model.label = label 
DBSession.add(my_model) 
DBSession.flush() 

---

düzenleme: Bu otomatik işlem yeniden gerektiğidir cevaplamak için başka bir yolu; Bunun yerine, işlemin gerçekten başlatılmaya başlaması için 307 Temporary Redirect (Yönlendirilmiş URL'de bir miktar tuz ile) bir HTTP durum kodu döndürebilirsiniz.

Answer 3

Webramda Pyramid çerçevesinde yazılmış benzer bir sorunla karşılaştım. Bu problem için biraz farklı bir çözüm buldum.my_model önce depolanmış ise

while True: 
    try: 
     my_model.label = generate_label() 
     DBSession.flush() 
     break 
    except IntegrityError: 
     # Rollback will recreate session: 
     DBSession.rollback() 
     # if my_model was in db it must be merged: 
     my_model = DBSession.merge(my_model) 

birleştirme parçası çok önemlidir. Birleştirme oturumu boş bırakılmadan, bu yüzden herhangi bir işlem yapmaz.