今天碰到一个棘手的问题,一个接口需要同时查询两个 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")
不知道有知道该问题所在的小伙伴没?求指导。 多谢
1
yzongyue 2020-01-16 21:57:33 +08:00
两个 db (schema) 不在一个 db 上?那没办法了,分别查出来 python 处理下吧
|
2
mashpolo OP @yzongyue #1 看文档应该是可以的,使用`__bind_key__`可以定义另外的 model,但我这个,不知道是哪出问题了。查询非 bind 的 table 的时候,结果找到 bind 的 db 中去了
|
3
outoftimeerror 2020-01-16 23:17:08 +08:00
直接 presto 吧
|
4
yzongyue 2020-01-16 23:39:11 +08:00 via Android
@mashpolo bind key 可以绑定不同的 db,但 python 代码最终还是要转换成 sql,不在一个 db 当然不能一个 sql 查出来
|
5
tairan2006 2020-01-17 08:45:19 +08:00 via Android
直接裸用 sqlalchemy,新建一个 engine…
|
6
whoosy 2020-01-17 09:13:12 +08:00
两个 db 不能用同一个 session,也就是不能用一个 db.session, 但是可以再开一个 db.session 去查
|
7
mashpolo OP |
8
houzhiqiang 2021-07-19 15:49:38 +08:00
|
9
houzhiqiang 2021-07-19 15:51:27 +08:00
|