Mysql 对象NotExecutabletry 在远程SQL服务器上执行SQL时出错，并使用SQLAchemy.Create_engine

发布于04月17日

我可以远程访问MySQL服务器，并且能够使用工作台正确执行SQL以获得所需的结果.然而，当我使用SQL在同一台机器上执行相同的SQL时，我会得到一个错误:

ObjectNotExecutableError

下面是我的代码:

from sqlalchemy import create_engine
db_user = os.environ['USER']
db_password = os.environ['PWD']
db_host = os.environ['HOST']
engine = create_engine(f"mysql+pymysql://{db_user}:{db_password}@{db_host}")

with engine.connect() as con:

  rs = con.execute('SELECT schema_name FROM information_schema.schemata;')
  for row in rs:
    print(row)

有什么 idea 吗？

推荐答案

你必须像con.execute(text("SELECT schema_name FROM information_schema.schemata;"))一样使用sqlalchemy.text

完整代码

from sqlalchemy import create_engine, text

db_user = os.environ["USER"]
db_password = os.environ["PWD"]
db_host = os.environ["HOST"]
engine = create_engine(f"mysql+pymysql://{db_user}:{db_password}@{db_host}")

with engine.connect() as con:
    rs = con.execute(text("SELECT schema_name FROM information_schema.schemata;"))
    for row in rs:
        print(row)