python - cursor.execute(statement, parameters) sqlalchemy.exc.OperationalError : (sqlite3. OperationalError) 没有这样的表

Question

我正在尝试通过 flask 中的 sqlalchemy 执行原始 sql 查询。在 psql 中运行时，原始 sql 查询会给出正确的输出。

    postgres=# SELECT  distinct(user_id) FROM user_event_details WHERE  age >=19 AND granular_timestamp >=1493596800 AND granular_timestamp <=1517356800 AND event_name ='IB_TRANS' GROUP BY user_id;

    user_id 
  ---------
       6206
       5468
       5544
       4349
   (4 rows)

但是当从 sqlalchemy 执行时说 no such table:'user_event_details'

sqlalchemy代码如下:

from flask import Flask, jsonify, request
from flask_cors import CORS,cross_origin
from flask_restplus import Resource, Api

#from config import postgresURI
from flask_sqlalchemy import SQLAlchemy
from v3.setup.config import config

# flask application initializing
application = Flask(__name__)

# Cross origin resource sharing instantiation
CORS(application)

# wrapping around rest-plus api
application2 = Api(application, prefix="/api/v1", version='1.0', title='Rest-API', default='Version 1', default_label='API')

# SQLAlchemy binding
postgresURI = config['db']['db_url']
application.config['SQLALCHEMY_BINDS'] = {
                                        'bind_db': postgresURI
                                        }
application.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = True
application.config['CORS_HEADERS'] = 'Content-Type'

# SQLAlchemy instantiation
db = SQLAlchemy(application)
db.create_all(bind=['bind_db'])
db.create_all()

然后在其中一个路由文件中:

raw_sql = text(SELECT  distinct(user_id) FROM user_event_details WHERE  age >=19 AND granular_timestamp >=1493596800 AND granular_timestamp <=1517356800 AND event_name ='IB_TRANS' GROUP BY user_id;)
filtered_users = db.engine.execute(raw_sql)

它给出的错误是:

cursor.execute(statement, parameters)
sqlalchemy.exc.OperationalError: (sqlite3.OperationalError) no such table: user_event_details [SQL: "SELECT  distinct(user_id) FROM user_event_details WHERE age >=19 AND granular_timestamp >=1493596800 AND granular_timestamp <=1517356800 AND event_name ='IB_TRANS'  GROUP BY user_id,event_id;'] (Background on this error at: http://sqlalche.me/e/e3q8)

Answer 1

使用 Flask-SQLAlchemy，默认引擎由 SQLALCHEMY_DATABASE_URI 配置.然后，您可以使用 SQLALCHEMY_BINDS 配置其他 引擎，但您的默认引擎是 SQLALCHEMY_DATABASE_URI 中的引擎。

据推测，在您的工作 ORM 代码中，您正在使用绑定(bind)。 (您没有显示工作代码，可能是因为它正在工作……)所以它与 Postgres 对话。

但是您没有在原始 SQL db.engine 代码中传递绑定(bind)，因此它使用默认数据库。而且您还没有配置默认数据库 URI。文档没有解释如果你不设置任何东西它默认是什么，但从错误信息来看，它显然是一个 sqlite3 数据库。这显然不会包含您的架构或任何其他有用的内容。

来自 a github issue for Flask-Migrate ，看起来默认是sqlite3://，它打开了一个sqlite3非持久性:memory:数据库，并且没有警告这样做(可能是因为它对初始探索性​​开发很方便？)。

参见 Multiple Databases with Binds了解更多详情。

无论如何，您可以更改您的原始 SQL 代码以也使用绑定(bind)，但实际上，最好的解决方案可能只是添加以下内容:

application.config['SQLALCHEMY_DATABASE_URI'] = postgresURI

…甚至可能考虑摆脱绑定(bind)，因为您不需要多个数据库连接，它们只会导致困惑。