Hóa ra bạn có thể thực thi một câu lệnh cấp thấp hơn trên db.session . Vì vậy, một giải pháp trông giống như sau:
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
from sqlalchemy.dialects.postgresql import insert as pg_insert
app = Flask(__name__)
db = SQLAlchemy(app)
class MyTable(db.Model):
id = db.Column(UUID, primary_key=True)
data = db.Column(db.String)
def __init__(self, _id, *args, **kwargs):
self.id = _id
self.data = kwargs['data']
def as_dict(self):
return {'id': self.id, 'data': self.data}
def props_dict(self):
d = self.as_dict()
d.pop('id')
return d
relation = MyTable(id=1, data='foo')
statement = pg_insert(MyTable)\.
values(**relation.as_dict()).\
on_conflict_do_update(constraint='id',
set_=relation.props_dict())
db.session.execute(statement)
db.session.commit()
as_dict() và props_dict() các phương thức trong lớp mô hình của tôi cho phép tôi sử dụng hàm tạo để lọc ra các thuộc tính không mong muốn từ yêu cầu HTTP đến.
