Dexie JS 嵌套集合未在 Promise 链中解析
Dexie JS Nested Collections Not Resolving in Promise Chain
我一直在使用 Dexie JS 来管理 IndexDB 数据存储,现在想将数据存储与远程数据库同步。我遇到的问题是我想将所有 relational/child 记录嵌套在集合中它们各自的父记录下,然后使用一些 AJAX 将整个 group/list 发送到远程服务器.
实际上,我看到的是子记录在被推送到远程服务器时不存在。但是,我确实在 console.log() 中看到了它们。我知道这是因为 console.log() 获取实际数据的时间比远程推送数据要晚得多。我也知道这是 promise 链的一个常见问题,但我无法解决它。
这是我目前的情况。
function PushRemote(items, modelName) {
console.log(items);
$.ajax({
type: 'POST',
url: '/' + modelName + '/AsyncSave',
contentType: 'application/json; charset=utf-8',
dataType: 'json',
data: JSON.stringify(DataTransferItemList),
success: function (response) {
iDB.open().then(function () {
return iDB.table(modelName).update(response, { isNotSynced: "false" });
});
},
error: function (response) {
console.error(response);
}
});
}
function PushTableToRemote(modelName) {
iDB.transaction('rw',
iDB.Comments,
iDB.CommentRatings,
iDB.Posts,
iDB.PostRatings,
iDB.Reviews,
() => {
iDB.table(modelName).where({ isNotSynced: "true" }).toArray(items => {
items.forEach(item => {
if (modelName == 'Comments') {
iDB.CommentRatings.where({ CommentId: item.CommentId }).toArray(c => item.CommentRatings = c);
}
if (modelName == 'Posts') {
iDB.PostRatings.where({ PostId: item.PostId }).toArray(p => item.PostRatings = p);
}
})
return items;
})
.then(items => {
if (items && items.length > 0) {
PushRemote(item, modelName);
}
});
});
}
pushTableToRemote('Comments');
好吧,事实证明如果你不能通过承诺链,那么你就绕过承诺链。 ;)
最终使用生成器函数而不是承诺链 (https://dexie.org/docs/Simplify-with-yield.html) 实现了 spawn()
和 yield
。这更直接,至少对我而言。工作起来很有魅力。您的里程可能会有所不同。
function PushTableToRemote(modelName) {
spawn(function* () {
var items = yield iDB.table(modelName).where({ isNotSynced: "true" }).toArray();
if (items && items.length > 0) {
if (modelName == 'Comments') {
for (var i = 0; i < items.length; i++) {
var CommentRatings = yield iDB.CommentRatings.where({ CommentId: items[i].CommentId }).toArray();
items[i].CommentRatings = CommentRatings;
}
}
if (modelName == 'Posts') {
for (var i = 0; i < items.length; i++) {
var PostRatings = yield iDB.PostRatings.where({ PostId: items[i].PostId }).toArray();
items[i].PostRatings = PostRatings;
}
}
PushRemote(items, modelName);
}
});
}
我一直在使用 Dexie JS 来管理 IndexDB 数据存储,现在想将数据存储与远程数据库同步。我遇到的问题是我想将所有 relational/child 记录嵌套在集合中它们各自的父记录下,然后使用一些 AJAX 将整个 group/list 发送到远程服务器.
实际上,我看到的是子记录在被推送到远程服务器时不存在。但是,我确实在 console.log() 中看到了它们。我知道这是因为 console.log() 获取实际数据的时间比远程推送数据要晚得多。我也知道这是 promise 链的一个常见问题,但我无法解决它。
这是我目前的情况。
function PushRemote(items, modelName) {
console.log(items);
$.ajax({
type: 'POST',
url: '/' + modelName + '/AsyncSave',
contentType: 'application/json; charset=utf-8',
dataType: 'json',
data: JSON.stringify(DataTransferItemList),
success: function (response) {
iDB.open().then(function () {
return iDB.table(modelName).update(response, { isNotSynced: "false" });
});
},
error: function (response) {
console.error(response);
}
});
}
function PushTableToRemote(modelName) {
iDB.transaction('rw',
iDB.Comments,
iDB.CommentRatings,
iDB.Posts,
iDB.PostRatings,
iDB.Reviews,
() => {
iDB.table(modelName).where({ isNotSynced: "true" }).toArray(items => {
items.forEach(item => {
if (modelName == 'Comments') {
iDB.CommentRatings.where({ CommentId: item.CommentId }).toArray(c => item.CommentRatings = c);
}
if (modelName == 'Posts') {
iDB.PostRatings.where({ PostId: item.PostId }).toArray(p => item.PostRatings = p);
}
})
return items;
})
.then(items => {
if (items && items.length > 0) {
PushRemote(item, modelName);
}
});
});
}
pushTableToRemote('Comments');
好吧,事实证明如果你不能通过承诺链,那么你就绕过承诺链。 ;)
最终使用生成器函数而不是承诺链 (https://dexie.org/docs/Simplify-with-yield.html) 实现了 spawn()
和 yield
。这更直接,至少对我而言。工作起来很有魅力。您的里程可能会有所不同。
function PushTableToRemote(modelName) {
spawn(function* () {
var items = yield iDB.table(modelName).where({ isNotSynced: "true" }).toArray();
if (items && items.length > 0) {
if (modelName == 'Comments') {
for (var i = 0; i < items.length; i++) {
var CommentRatings = yield iDB.CommentRatings.where({ CommentId: items[i].CommentId }).toArray();
items[i].CommentRatings = CommentRatings;
}
}
if (modelName == 'Posts') {
for (var i = 0; i < items.length; i++) {
var PostRatings = yield iDB.PostRatings.where({ PostId: items[i].PostId }).toArray();
items[i].PostRatings = PostRatings;
}
}
PushRemote(items, modelName);
}
});
}