关于 flask-sqlalchemy 的跨 db 查询

[mashpolo]

今天碰到一个棘手的问题，一个接口需要同时查询两个 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")

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

[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 了解了，看来确实不行，我修改下设计的思路

[houzhiqiang]

可以看看官方文档
http://www.pythondoc.com/flask-sqlalchemy/config.html
有这样一个配置项
SQLALCHEMY_BINDS

[houzhiqiang]

http://www.pythondoc.com/flask-sqlalchemy/binds.html#binds