我在许多论坛中搜索了doc,但找不到正确的解决方案。
问题
使用AngularFire2增量值的最佳方法是什么?
我看到我们可以使用[TrassAction()] [],但实际上不是为AngularFire2。还是快照?
user.service.ts
incrementLike(userToIncrementLike){
this.af.database.object('users/' + userToIncrementLike.uid).subscribe((userObject) => {
var newUser = {
likes: userObject.likes + 1
};
});
this.af.database.object('users/' + userToIncrementLike.uid).update(newUser);
}
我也以这种方式尝试了:
incrementLike(userToIncrementLike){
let obs = this.af.database.object('users/' + userToIncrementLike.uid);
obs.subscribe((snapshot) => {
let newValue = (snapshot.$value) ? (snapshot.$value + 1) : 1;
obs.set(newValue);
});
}
非常感谢您的帮助和提示:)路易斯。
firestore现在具有 increment()
,即使多个用户在同一时间竞争
用云firestore在原子上增加值
在AngularFire2
中使用它import { firestore } from 'firebase/app';
incrementLike(userToIncrementLike) {
const increment = firestore.FieldValue.increment(1);
const userLike = this.af.doc(`users/${userToIncrementLike.uid}`);
userLike.update({ likes: increment });
}
我直接使用了Firestore,因为我在AngularFire2中找不到FieldValue
。
无需定义对象或使用update()
方法。该对象已经存在于数据库中,因此您可以在其中进行处理。这实际上是transaction()
的目的 - 在数据位置上处理数据,因此可以防止冲突;例如,两个用户同时更新相同的值。
,如果愿意,您也可以在路径中使用模板。:)(请注意背部而不是单引号。)
incrementLike(userToIncrementLike){
this.af.database.object(`users/${userToIncrementLike.uid}/likes`).query
.ref.transaction(likes => {
if (likes === null) {
return likes = 1;
} else {
return likes + 1;
}
})
}
更新:2019年9月。使用query
代替$ref
。
" angularfire2 v5"解决方案:
incrementLike(userToIncrementLike){
this.af.database.object(`users/${userToIncrementLike.uid}/likes`)
.query.ref.transaction((likes => {
if (likes === null) {
return likes = 1;
} else {
return likes + 1;
}
})};
Angular 14:
使用最新版本,您可以直接从 @angular/fire
直接使用增量功能import { increment } from '@angular/fire/firestore';
,然后
this.firestore.doc("users/"+$id).update({count: increment(1)});
@angular/fire(Angular版本7)
https://firebase.google.com/docs/firestore/manage-data/transactionshttps://firebase.google.com/docs/firestore/query-data/get-data
incrementLike(userToIncrementLike) {
//VARIABLE FOR MANAGING THE SCOPE
var that = this;
this.afs.firestore.collection("users").where("id", "==", userToIncrementLike.uid)
.get()
.then(function(querySnapshot) {
querySnapshot.forEach(function(doc) {
// doc.data() is never undefined for query doc snapshots
console.log(doc.id, " => ", doc.data());
return that.afs.firestore.runTransaction(function(transaction) {
// This code may get re-run multiple times if there are conflicts.
return transaction.get(doc.ref).then(function(doc) {
if (!doc.exists) {
throw "Document does not exist!";
}
//THIS IS WHERE TO DO THE INCREMENT
var new_score = doc.data().score + 1;
transaction.update(doc.ref, { score: new_score });
});
}).then(function() {
console.log("Transaction successfully committed!");
}).catch(function(error) {
console.log("Transaction failed: ", error);
});
});
})
.catch(function(error) {
console.log("Error getting documents: ", error);
});
}
我在firestore上使用它。相同的代码用于实时DB。
"@angular/fire": "^5.1.2"
const login = this.afs.doc(`/users/${uid}`);
login.valueChanges()
.pipe(take(1))
.subscribe((user: User) => {
login.update({ login: user.login as number + 1 });
});