11

我正在尝试按照本教程学习SQLAlchemy如何在 python 中创建条目和查询 MYSQL 数据库。当我第一次尝试在添加新对象部分中查询数据库以测试是否已将对象添加到数据库中时（请参阅下面的大代码块），我收到以下错误：AttributeError: 'Connection' object has no attribute 'contextual_connect'

我可以查询数据库。例如，如果我将最后一行代码更改为our_user = session.query(User).filter_by(name='ed')它成功返回一个查询对象，但我无法弄清楚如何从这个查询结果中获取我输入数据库的对象。

同样，如果我尝试按照他们在查询 部分中的建议遍历结果：

for instance in session.query(User).order_by(User.id):
    print instance.name, instance.fullname

我犯了同样的错误。我该如何解决这个特定的错误，还有其他关于在 Python 中使用 MYSQL 和 SQLAlchemy 的教程，您可以指出我吗？

我的代码：

import MySQLdb
from sqlalchemy import create_engine

db1 = MySQLdb.connect(host="127.0.0.1",
                      user="root",
                      passwd="****",
                      db="mydata")



from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

from sqlalchemy import Column, Integer, String

class User(Base):
    __tablename__ = 'users'

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

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

    def __repr__(self):
        return "<User('%s','%s', '%s')>" % (self.name, self.fullname, self.password)


ed_user = User('ed', 'Ed Jones', 'edspassword') 

from sqlalchemy.orm import sessionmaker
Session = sessionmaker()
Session.configure(bind=db1)

session = Session()
session.add(ed_user)

our_user = session.query(User).filter_by(name='ed').first()

更新/工作代码：

(1) 更改为 SQLAlchemy 引擎，如下面的 codeape 所讨论。

（2）记得建表：Base.metadata.create_all(engine)

User(3) 使用SQLAlchemy 教程中类的“万无一失”版本。请注意 SQLAlchemy，我们（至少我）感觉自己像个傻瓜，并希望您在教程的主体中始终使用万无一失的版本，而不是作为忙碌的读者可能跳过的旁白。

所有这些都会产生工作代码：

import MySQLdb
from sqlalchemy import create_engine

engine = create_engine("mysql://user:password@host/database")

from sqlalchemy.ext.declarative import declarative_base

Base = declarative_base()

from sqlalchemy import Column, Integer, String, Sequence

class User(Base):
    __tablename__ = 'users'
    id = Column(Integer, Sequence('user_id_seq'), primary_key=True)
    name = Column(String(50))
    fullname = Column(String(50))
    password = Column(String(12))

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

    def __repr__(self):
        return "<User('%s','%s', '%s')>" % (self.name, self.fullname, self.password)



Base.metadata.create_all(engine)

ed_user = User('ed', 'Ed Jones', 'edspassword') 

from sqlalchemy.orm import sessionmaker
Session = sessionmaker()
Session.configure(bind=engine)

session = Session()
session.add(ed_user)



our_user = session.query(User).filter_by(name='ed').first()

print(our_user is ed_user)
4

2 回答 2

13

您必须将会话绑定到 SQLAlchemy 引擎，而不是直接绑定到 MySQLDb 连接对象。

engine = create_engine("mysql://user:password@host/dbname")
Session.configure(bind=engine)

（您可以删除db1变量。）

从教程：

create_engine() 的返回值是 Engine 的一个实例，它代表数据库的核心接口，通过处理数据库和使用中的 DBAPI 细节的方言进行改编。

另请参阅https://docs.sqlalchemy.org/en/latest/orm/tutorial.html

于 2013-10-09T22:49:00.103 回答
0 
from sqlalchemy.orm import sessionmaker

engine = create_engine("mysql://user:password@host/dbname")
Session = sessionmaker(bind=engine)

session = Session()
于 2017-10-26T13:06:55.563 回答