我无法使用 SQLAlchemy + Pyramid 将行保存到数据库

Question

经过几个小时的调试，并且因为我的组织没有很多 Python 专业知识，所以我转向这个社区寻求帮助。

我正在尝试遵循 this tutorial 的目标是将一些数据提交到数据库。虽然没有报告任何错误，但我也没有保存任何行。我做错了什么？

尝试使用 db2Session 提交时，我得到：

必须使用事务管理器提交事务。

但是在本教程的任何地方，我都没有看到正在使用的事务管理器。我还以为这个manager是用zope.sqlalchemy绑定的？然而，除此之外什么都没有发生。再次提供帮助将不胜感激！

我在金字塔应用程序的主要功能中有以下设置：

from sqlalchemy import engine_from_config
from .models import db1Session, db2Session

def main(global_config, **settings):
""" This function returns a Pyramid WSGI application.
"""
    db1_engine = engine_from_config(settings, 'db1.')
    db2_engine = engine_from_config(settings, 'db2.')

    db1Session.configure(bind=db1_engine)
    db2Session.configure(bind=db2_engine)

在.models/__init__py中，我有：

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import (scoped_session, sessionmaker)
from zope.sqlalchemy import ZopeTransactionExtension

db1Session = scoped_session(sessionmaker(
    extension=ZopeTransactionExtension()))
db2Session =      
    scoped_session(sessionmaker(extension=ZopeTransactionExtension()))

Base = declarative_base()

在 ./model/db2.py 中我有：

class PlateWellResult(Base):
    __tablename__ = 'SomeTable'
    __table_args__ = {"schema": 'some_schema'}

    id = Column("ID", Integer, primary_key=True)
    plate_id = Column("PlateID", Integer)
    hit_group_id = Column("HitID", Integer, ForeignKey(
        'some_schema.HitGroupID.ID'))
    well_loc = Column("WellLocation", String)

我的保存函数的相关部分如下所示。 ./lib/db2_api.py:

def save_selected_rows(input_data, selected_rows, hit_group_id):
    """ Wrapper method for saving selected rows """
    # Assume I have all the right data below.
    new_hit_row = PlateWellResult(
        plate_id=master_plate_id,
        hit_group_id=hit_group_id,
        well_loc=selected_df_row.masterWellLocation)

    db1Session.add(new_hit_row)
    # When I try the row below:
    # db2Session.commit()
    # I get: Transaction must be committed using the transaction manager
    # If I cancel the line above, nothing gets committed.
    return 'Save successful.'

我的查看器调用了该函数：

@view_config(route_name='some_routename', renderer='json',
             permission='create_hit_group')
def save_to_hitgroup(self):
    """ Backend to AJAX call to save selected rows to a hit_group """
    try:
        # Assume that all values were checked and all the right 
        # parameters are passed
        status = save_selected_rows(some_result, 
                                    selected_rows_list,
                                    hitgroup_id)
        json_resp = json.dumps({'errors': [],
                                'status': status})
        return json_resp
    except Exception as e:
        json_resp = json.dumps({'errors': ['Error during saving. {'
                                           '0}'.format(e)],
                                'status': []})
        return json_resp

Answer 1

上面的评论很好。我只是想在这里总结一下。

事务管理器是 begun/committed/aborted 的 pyramid_tm。如果您没有使用它，则可能是问题所在。

您还在压缩可能需要传送给事务管理器的数据库异常。您可以通过异常处理程序中的 transaction.abort() 执行此操作。

我无法使用 SQLAlchemy + Pyramid 将行保存到数据库

I cannot save rows to the DB with SQLAchemy + Pyramid

sqlalchemy

python-3.x

pyramid