Comment mettre à jour l'entrée de ligne SQLAlchemy?

Supposons que le tableau comporte trois colonnes: username, passwordet no_of_logins.

Lorsque l'utilisateur essaie de se connecter, il recherche une entrée avec une requête telle que

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

Si le mot de passe correspond, il continue. Ce que je voudrais faire, c'est compter le nombre de fois que l'utilisateur s'est connecté. Ainsi, chaque fois qu'il se connecte avec succès, je voudrais incrémenter le no_of_loginschamp et le stocker dans la table des utilisateurs. Je ne sais pas comment exécuter une requête de mise à jour avec SqlAlchemy.

user.no_of_logins += 1
session.commit()

Il existe plusieurs façons d' UPDATEutilisersqlalchemy

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

Exemples pour clarifier la question importante dans les commentaires des réponses acceptées

Je ne l'ai pas compris jusqu'à ce que j'aie joué avec moi-même, alors j'ai pensé qu'il y en aurait d'autres qui seraient également confus. Supposons que vous travaillez sur l'utilisateur dont id == 6et dont no_of_logins == 30vous démarrez.

# 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

Le point

En référençant la classe au lieu de l'instance, vous pouvez rendre SQLAlchemy plus intelligent dans l'incrémentation, en faisant en sorte que cela se produise du côté de la base de données au lieu du côté Python. Le faire dans la base de données est mieux car il est moins vulnérable à la corruption des données (par exemple, deux clients tentent d'incrémenter en même temps avec un résultat net d'un seul incrément au lieu de deux). Je suppose qu'il est possible de faire l'incrémentation en Python si vous définissez des verrous ou augmentez le niveau d'isolement, mais pourquoi vous embêter si vous n'êtes pas obligé?

Une mise en garde

Si vous allez incrémenter deux fois via du code qui produit du type SQL SET no_of_logins = no_of_logins + 1, vous devrez alors valider ou au moins vider entre les incréments, sinon vous n'obtiendrez qu'un seul incrément au total:

# 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

Avec l'aide de la user=User.query.filter_by(username=form.username.data).first()déclaration, vous obtiendrez l'utilisateur spécifié dans la uservariable.

Vous pouvez maintenant changer la valeur de la nouvelle variable objet comme user.no_of_logins += 1et enregistrer les modifications avec la sessionméthode de commit de.

J'ai écrit un robot de télégramme et j'ai des problèmes avec les lignes de mise à jour. Utilisez cet exemple, si vous avez Model

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

Pourquoi utiliser db.session.flush()? C'est pourquoi >>> SQLAlchemy: Quelle est la différence entre flush () et commit ()?