关于 flask-sqlalchemy 的跨 db 查询

資深大佬 : mashpolo 63

今天碰到一个棘手的问题，一个接口需要同时查询两个 db 的两个表，但其中一个表，sqlalchemy 查找的 db 是另外一个，导致查询找不到该表

model 代码如下

class BusinessGroup(db.Model):     __bind_key__ = 'amp'     __tablename__ = 'business_group'      business_group_id = Column(db.BigInteger, primary_key=True)      class DeployJob(Base):     __tablename__ = 'deploy_job'      id = Column(BIGINT(20), primary_key=True)

数据库连接：

 SQLALCHEMY_BINDS = {'amp': 'mysql+pymysql://{user}:{passwd}@{host}:{port}/{db}'.format(**AMP_MYSQL_CFG)}

查询的接口代码

def getDpJobList():     try:         deploy_jobs_basic = db.session.query(DeployJob.id,                                              BusinessGroup.dept_id)

得到的错误：

(pymysql.err.ProgrammingError) (1146, "Table 'monitor.deploy_job' doesn't exist")

不知道有知道该问题所在的小伙伴没？求指导。多谢

大佬有話說 (7)

資深大佬 : yzongyue

两个 db (schema) 不在一个 db 上？那没办法了，分别查出来 python 处理下吧

主資深大佬 : mashpolo

@yzongyue #1 看文档应该是可以的，使用`__bind_key__`可以定义另外的 model，但我这个，不知道是哪出问题了。查询非 bind 的 table 的时候，结果找到 bind 的 db 中去了

資深大佬 : outoftimeerror

直接 presto 吧

資深大佬 : yzongyue

@mashpolo bind key 可以绑定不同的 db，但 python 代码最终还是要转换成 sql，不在一个 db 当然不能一个 sql 查出来

資深大佬 : tairan2006

直接裸用 sqlalchemy，新建一个 engine…

資深大佬 : whoosy

两个 db 不能用同一个 session，也就是不能用一个 db.session, 但是可以再开一个 db.session 去查

主資深大佬 : mashpolo

@yzongyue #4
@tairan2006 #5
@whoosy #6 了解了，看来确实不行，我修改下设计的思路