sql >> Database >  >> RDS >> PostgreSQL

Hoe gebruik je de functie INSERT...ON CONFLICT (UPSERT) van PostgreSQL met flask_sqlalchemy?

Het blijkt dat je een instructie op een lager niveau kunt uitvoeren op de db.session . Een oplossing ziet er dus ongeveer zo uit:

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()

De as_dict() en props_dict() methoden in mijn modelklasse stellen me in staat om de constructor te gebruiken om ongewenste eigenschappen uit het inkomende HTTP-verzoek te filteren.



  1. MySQL select/insert/update, is de kolomvolgorde van belang?

  2. WAARSCHUWING:Office-versie 2204 kan Access-toepassingen breken

  3. Slaapstand bijwerken van één naar veel trapsgewijs

  4. Herstel na verkeerde MySQL-updatequery?