如下代碼,我其中使用了多次讀取數據庫,并且獲取到的數據在進行循環(huán),循環(huán)后在進行數據庫查詢,最終resolve后,我得到的結果僅僅只是一小部分數據,還剩余一部分數據并未resolve,但是通過console.log可以打印出所有數據,resolv執(zhí)行的時候,其實for循環(huán)還未執(zhí)行完
getProducts(params) {
return new Promise((resolve, reject) => {
if (params) {
this.getDb().then((db: SQLiteObject) => {
db.transaction((run) => {
var sql = 'SELECT * FROM product_content';
run.executeSql(sql, [],
(run, res) => {
if (res.rows.length != 0) {
let result = {
product_ids: {}
};
let retTmp = []
let exTmp = [1,2,100,600,500,800,900,700,701,300]
let categoryIds = []
for (var i = 0; i < res.rows.length; i++) {
var product = res.rows.item(i);
categoryIds.push(product.categoryIds)
for (var k = 0; k < categoryIds.length; k++) {
var _cid = categoryIds[k]
sql = 'select id FROM product where category like "%,' + _cid + ',%"';
run.executeSql(sql, [],
(run, res_id) => {
if (res_id.rows.length != 0) {
for (var i = 0; i < res_id.rows.length; i++) {
var productId = res_id.rows.item(i).ID
retTmp.push(productId)
}
}
})
}
}
// setTimeout(() => {
let newRetTmp = Array.from(new Set(retTmp))
let newExTmp = Array.from(new Set())
if (newExTmp.length > 0) {
newRetTmp.map((rettmp, index) => {
exTmp.map(extmp => {
if (rettmp != extmp) {
result.product_ids[newRet] = true
}
})
})
}
resolve(result);
// }, 500)
} else {
let result = {
data: {
product_ids: {}
}
};
resolve(result);
}
})
})
})
}
})
}
之前在網上看到使用Promise.all()的方法,我將其修改成如下代碼,代碼看上去沒有什么問題,但是一到Promise.all的地方就一直沒有resolve了:
getProducts(params) {
return new Promise((resolve, reject) => {
if (params) {
this.getDb().then((db: SQLiteObject) => {
db.transaction((run) => {
var sql = 'SELECT * FROM product_content';
run.executeSql(sql, [],
(run, res) => {
if (res.rows.length != 0) {
let result = {
product_ids: {}
};
let retTmp = []
let exTmp = [1,2,100,600,500,800,900,700,701,300]
let categoryIds = []
let promise = []
for (var i = 0; i < res.rows.length; i++) {
promise.push(new Promise((resolve,reject)=>{
var product = res.rows.item(i);
categoryIds.push(product.categoryIds)
for (var k = 0; k < categoryIds.length; k++) {
var _cid = categoryIds[k]
sql = 'select id FROM product where category like "%,' + _cid + ',%"';
run.executeSql(sql, [],
(run, res_id) => {
if (res_id.rows.length != 0) {
for (var i = 0; i < res_id.rows.length; i++) {
var productId = res_id.rows.item(i).ID
retTmp.push(productId)
// this.helperService.console('c0', productId)
}
}
})
}
}))
}
Promise.all(promise).then(res => {
// setTimeout(() => {
let ATmp = Array.from(new Set(retTmp))
if (newExTmp.length > 0) {
exTmp.map((rettmp, index) => {
newExTmp.map(extmp => {
if (rettmp != extmp) {
result.product_ids[newRet] = true
}
})
})
}
resolve(result);
// }, 500)
})
} else {
let result = {
data: {
product_ids: {}
}
};
resolve(result);
}
})
})
})
}
})
}
根據以上代碼,都無法得到想要的結果,第二種方法更是一直處于pendding狀態(tài),真不知道該如何進行解決,望各位大神支招
所以,每一次db查詢都應被包裹在一個promise中,然后外面使用promise.all. 第二個例子,明顯你還少用了一個promise.All:
下面這段代碼處,也需要創(chuàng)建一個promise數組,循環(huán)結束后,執(zhí)行promise.all(promise數組),then 將結果使用最外側的resolve返回。
sql = 'select id FROM product where category like "%,' + _cid + ',%"';
run.executeSql(sql, [], ...
改造后,大概代碼時這個樣子的(并未執(zhí)行過,只是示范):
getProducts(params) {
return new Promise((resolve, reject) =>{
if (params) {
this.getDb().then((db: SQLiteObject) =>{
db.transaction((run) =>{
var sql = 'SELECT * FROM product_content';
run.executeSql(sql, [], (run, res) =>{
if (res.rows.length != 0) {
let result = {
product_ids: {}
};
let retTmp = [];
let exTmp = [1, 2, 100, 600, 500, 800, 900, 700, 701, 300];
let categoryIds = [];
let promise = [];
for (var i = 0; i < res.rows.length; i++) {
promise.push(new Promise((resolve1, reject1) =>{
var product = res.rows.item(i);
categoryIds.push(product.categoryIds);
var innerPromise = [];
for (var k = 0; k < categoryIds.length; k++) {
innerPromise.push(new Promise((resolve2, reject2) => {
var _cid = categoryIds[k];
sql = 'select id FROM product where category like "%,' + _cid + ',%"';
run.executeSql(sql, [], (run, res_id) =>{
if (res_id.rows.length != 0) {
var productids = [];
for (var i = 0; i < res_id.rows.length; i++) {
var productId = res_id.rows.item(i).ID retTmp.push(productId)
// this.helperService.console('c0', productId)
productids.push(productId);
}
resolve2(productids);
} else {
resolve2([]);
}
});
}));
}
Promise.all(innerPromise).then(productIdsArray=>resolve1(productIdsArray));
}))
}
Promise.all(promise).then(res =>{
// setTimeout(() => {
let ATmp = Array.from(new Set(retTmp))
if (newExTmp.length > 0) {
exTmp.map((rettmp, index) =>{
newExTmp.map(extmp =>{
if (rettmp != extmp) {
result.product_ids[newRet] = true
}
})
})
}
resolve(result);
// }, 500)
})
} else {
let result = {
data: {
product_ids: {}
}
};
resolve(result);
}
})
})
})
}
})
}北大青鳥APTECH成立于1999年。依托北京大學優(yōu)質雄厚的教育資源和背景,秉承“教育改變生活”的發(fā)展理念,致力于培養(yǎng)中國IT技能型緊缺人才,是大數據專業(yè)的國家
達內教育集團成立于2002年,是一家由留學海歸創(chuàng)辦的高端職業(yè)教育培訓機構,是中國一站式人才培養(yǎng)平臺、一站式人才輸送平臺。2014年4月3日在美國成功上市,融資1
北大課工場是北京大學校辦產業(yè)為響應國家深化產教融合/校企合作的政策,積極推進“中國制造2025”,實現中華民族偉大復興的升級產業(yè)鏈。利用北京大學優(yōu)質教育資源及背
博為峰,中國職業(yè)人才培訓領域的先行者
曾工作于聯想擔任系統開發(fā)工程師,曾在博彥科技股份有限公司擔任項目經理從事移動互聯網管理及研發(fā)工作,曾創(chuàng)辦藍懿科技有限責任公司從事總經理職務負責iOS教學及管理工作。
浪潮集團項目經理。精通Java與.NET 技術, 熟練的跨平臺面向對象開發(fā)經驗,技術功底深厚。 授課風格 授課風格清新自然、條理清晰、主次分明、重點難點突出、引人入勝。
精通HTML5和CSS3;Javascript及主流js庫,具有快速界面開發(fā)的能力,對瀏覽器兼容性、前端性能優(yōu)化等有深入理解。精通網頁制作和網頁游戲開發(fā)。
具有10 年的Java 企業(yè)應用開發(fā)經驗。曾經歷任德國Software AG 技術顧問,美國Dachieve 系統架構師,美國AngelEngineers Inc. 系統架構師。