我有一张桌子notifications
。记录是这样插入的:
socket.on('set notif',function(data){
var user = socket.client.user;
if(typeof user !== 'object' && user == '_srv'){
r.table('notifications').insert(data).run().then(function(res){
r.table('notifications').get(res.generated_keys[0]).run().then(function(data){
var user = data.user_id;
io.sockets.in(user).emit('new notif',data);
});
});
}
});
当会议被用户拒绝时,我们必须删除所有相关的会议通知并向null
meeting_id
用户发送通知,通知他们对方已拒绝他们的提议。
socket.on('del meeting notifs',function(data){
var user = socket.client.user;
if(typeof user !== 'object' && user == '_srv'){
r.table('notifications').getAll(data.id,{index:'meeting_id'}).delete().run().then(function(){
});
}
});
相反,表格中的所有通知似乎都被删除了,我不知道为什么。我的查询有问题吗?我发现很难掌握 rethinkdb 的语法。我正在使用rethinkdb-dash
库,但 stackoverflow 不允许我这样标记这个问题。