Wie aktualisiere ich den SQLAlchemy-Zeileneintrag?

Angenommen, die Tabelle hat drei Spalten : username, passwordund no_of_logins.

Wenn der Benutzer versucht, sich anzumelden, wird nach einem Eintrag mit einer Abfrage wie gesucht

user = User.query.filter_by(username=form.username.data).first()

Wenn das Passwort übereinstimmt, fährt er fort. Ich möchte zählen, wie oft sich der Benutzer angemeldet hat. Wenn er sich also erfolgreich anmeldet, möchte ich das no_of_loginsFeld erhöhen und in der Benutzertabelle speichern. Ich bin nicht sicher, wie ich die Update-Abfrage mit SqlAlchemy ausführen soll.

user.no_of_logins += 1
session.commit()

Es gibt verschiedene Möglichkeiten zur UPDATEVerwendungsqlalchemy

1) user.no_of_logins += 1
   session.commit()

2) session.query().\
       filter(User.username == form.username.data).\
       update({"no_of_logins": (User.no_of_logins +1)})
   session.commit()

3) conn = engine.connect()
   stmt = User.update().\
       values(no_of_logins=(User.no_of_logins + 1)).\
       where(User.username == form.username.data)
   conn.execute(stmt)

4) setattr(user, 'no_of_logins', user.no_of_logins+1)
   session.commit()

Beispiele zur Klärung des wichtigen Problems in den Kommentaren der akzeptierten Antwort

Ich habe es nicht verstanden, bis ich selbst damit herumgespielt habe, also dachte ich, dass es auch andere geben würde, die verwirrt waren. Angenommen, Sie arbeiten an dem Benutzer, dessen id == 6und dessen no_of_logins == 30beim Start.

# 1 (bad)
user.no_of_logins += 1
# result: UPDATE user SET no_of_logins = 31 WHERE user.id = 6

# 2 (bad)
user.no_of_logins = user.no_of_logins + 1
# result: UPDATE user SET no_of_logins = 31 WHERE user.id = 6

# 3 (bad)
setattr(user, 'no_of_logins', user.no_of_logins + 1)
# result: UPDATE user SET no_of_logins = 31 WHERE user.id = 6

# 4 (ok)
user.no_of_logins = User.no_of_logins + 1
# result: UPDATE user SET no_of_logins = no_of_logins + 1 WHERE user.id = 6

# 5 (ok)
setattr(user, 'no_of_logins', User.no_of_logins + 1)
# result: UPDATE user SET no_of_logins = no_of_logins + 1 WHERE user.id = 6

Der Punkt

Indem Sie auf die Klasse anstelle der Instanz verweisen, können Sie SQLAlchemy beim Inkrementieren intelligenter machen und dies auf der Datenbankseite anstelle der Python-Seite veranlassen. Dies in der Datenbank zu tun ist besser, da es weniger anfällig für Datenbeschädigungen ist (z. B. versuchen zwei Clients gleichzeitig, mit einem Nettoergebnis von nur einem statt zwei Inkrementen zu erhöhen). Ich gehe davon aus, dass es möglich ist, das Inkrementieren in Python durchzuführen, wenn Sie Sperren setzen oder die Isolationsstufe erhöhen. Aber warum sollten Sie sich die Mühe machen, wenn Sie dies nicht müssen?

Eine Einschränkung

Wenn Sie zweimal über Code inkrementieren möchten, der SQL-ähnliche Effekte erzeugt SET no_of_logins = no_of_logins + 1, müssen Sie zwischen den Inkrementen ein Commit durchführen oder zumindest einen Flush durchführen. Andernfalls erhalten Sie insgesamt nur ein Inkrement:

# 6 (bad)
user.no_of_logins = User.no_of_logins + 1
user.no_of_logins = User.no_of_logins + 1
session.commit()
# result: UPDATE user SET no_of_logins = no_of_logins + 1 WHERE user.id = 6

# 7 (ok)
user.no_of_logins = User.no_of_logins + 1
session.flush()
# result: UPDATE user SET no_of_logins = no_of_logins + 1 WHERE user.id = 6
user.no_of_logins = User.no_of_logins + 1
session.commit()
# result: UPDATE user SET no_of_logins = no_of_logins + 1 WHERE user.id = 6

Mit Hilfe der user=User.query.filter_by(username=form.username.data).first()Anweisung erhalten Sie den angegebenen Benutzer in userVariable.

Jetzt können Sie den Wert der neuen Objektvariablen wie ändern user.no_of_logins += 1und die Änderungen mit der sessionFestschreibungsmethode von ' speichern .

Ich habe einen Telegramm-Bot geschrieben und habe ein Problem mit Update-Zeilen. Verwenden Sie dieses Beispiel, wenn Sie über Model verfügen

def update_state(chat_id, state):
    try:
        value = Users.query.filter(Users.chat_id == str(chat_id)).first()
        value.state = str(state)
        db.session.flush()
        db.session.commit()
        #db.session.close()
    except:
        print('Error in def update_state')

Warum verwenden db.session.flush()? Deshalb >>> SQLAlchemy: Was ist der Unterschied zwischen flush () und commit ()?