SQLAlchemy执行原生语句
程序员文章站
2024-03-02 22:47:22
...
1. 为什么使用session
-
您的所有查询都应该通过会话对象，无论它们是否是原始SQL。这可确保查询由事务正确管理，从而允许将同一请求中的多个查询作为单个单元提交或回滚。
-
使用引擎或在事务之外会使您面临更大的微妙风险，可能很难检测到可能导致数据损坏的错误。
-
每个请求应该只与一个事务相关联，并且使用db.session将确保您的应用程序就是这种情况。
2. 在FLASK-SQLAlchemy中执行Raw SQL
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from sqlalchemy import text
app = Flask(__name__)
db = SQLALCHEMY(app)
# 1
with db.session.connection() as conn:
conn.execute(text(<sql here>).execution_options(autocommit=True)) # 如果不在自动提交模式下， 修改在数据库中不会生效
# 2
class User(db.Model):
name = db.Column(db.String(64))
db.session.query(User).from_statement(
text("SELECT * FROM users where name=:name")).\
params(name='ed').all()
3. 使用sqlalchemy
import sqlalchemy
from sqlalchemy.orm import sessionmaker, scoped_session
engine = sqlalchemy.create_engine('my connection string')
Session = scoped_session(sessionmaker(bind=engine))
s = Session()
result = s.execute('SELECT * FROM my_table WHERE my_column = :val', {'val': 5})
4. sqlite3
SQLAlchemy中一个引擎同时支持多个连接， 但sqlite3 只支持一个连接。