假设两个用户在离线时对同一个文档进行了更改,但在文档的不同部分。如果用户2在用户1之后重新上线,用户1所做的更改会丢失吗?
在我的数据库中,每一行都包含一个 JS 对象,该对象的一个属性是一个数组。该数组绑定到界面上的一系列复选框。我想要的是,如果两个用户对这些复选框进行了更改,则根据进行更改的时间,而不是同步发生的时间,分别为每个复选框保留最新的更改。GroundDB 是实现这一目标的合适工具吗?有没有办法添加一个事件处理程序,我可以在其中添加一些在同步发生时触发的逻辑,这将负责合并?
简短的回答是“是”,没有任何地面数据库版本具有冲突解决方案,因为逻辑是自定义的,具体取决于冲突解决方案的行为,例如。如果您想自动化或涉及用户。
旧的 Ground DB 只是依靠 Meteor 的冲突解决(服务器的最新数据获胜)我猜你会看到一些问题,具体取决于客户端上线的顺序。
Ground db II 没有恢复方法,它或多或少只是一种离线缓存数据的方法。它在可观察的来源上进行观察。
我猜你可以为 GDB II 创建一个中间件观察者——一个在更新和更新客户端之前检查本地数据或/和调用服务器来更新服务器数据的中间件观察者。这样你就有办法处理冲突。
我想记得为某些类型的冲突处理编写一些支持“deletedAt”/“updatedAt”的代码,但是冲突处理程序应该在大多数情况下是自定义的。(为可重用的冲突处理程序打开大门可能很有用)
如果您不通过诸如使用“deletedAt”实体之类的方式“软”删除,则尤其要知道何时删除数据可能会很棘手。
“rc”分支目前是grounddb-caching-2016版本“2.0.0-rc.4”,
我在考虑类似的事情:(注意它没有经过测试,直接用SO编写)
// Create the grounded collection
foo = new Ground.Collection('test');
// Make it observe a source (it's aware of createdAt/updatedAt and
// removedAt entities)
foo.observeSource(bar.find());
bar.find()
返回一个带有observe
我们中间件应该做的函数的游标。让我们为它创建一个createMiddleWare
助手:
function createMiddleWare(source, middleware) {
const cursor = (typeof (source||{}).observe === 'function') ? source : source.find();
return {
observe: function(observerHandle) {
const sourceObserverHandle = cursor.observe({
added: doc => {
middleware.added.call(observerHandle, doc);
},
updated: (doc, oldDoc) => {
middleware.updated.call(observerHandle, doc, oldDoc);
},
removed: doc => {
middleware.removed.call(observerHandle, doc);
},
});
// Return stop handle
return sourceObserverHandle;
}
};
}
用法:
foo = new Ground.Collection('test');
foo.observeSource(createMiddleware(bar.find(), {
added: function(doc) {
// just pass it through
this.added(doc);
},
updated: function(doc, oldDoc) {
const fooDoc = foo.findOne(doc._id);
// Example of a simple conflict handler:
if (fooDoc && doc.updatedAt < fooDoc.updatedAt) {
// Seems like the foo doc is newer? lets update the server...
// (we'll just use the regular bar, since thats the meteor
// collection and foo is the grounded data
bar.update(doc._id, fooDoc);
} else {
// pass through
this.updated(doc, oldDoc);
}
},
removed: function(doc) {
// again just pass through for now
this.removed(doc);
}
}));