open-source/qinglong
1
0
Fork 0
mirror of https://github.com/whyour/qinglong.git synced 2025-05-26 00:46:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改数据迁移逻辑

Browse Source
This commit is contained in:
whyour 2022-01-14 23:17:16 +08:00
parent 917a739595
commit fdc97773d1
1 changed files with 26 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
back/loaders/db.ts
View File

@ -66,35 +66,33 @@ export default async () => {
} }
// migrate db to sqlite // migrate db to sqlite
setTimeout(async () => {
try { try {
const count = await CrontabModel.count(); const count = await CrontabModel.count();
if (count !== 0) { if (count !== 0) {
return; return;
} }
db.cronDb.find({}).exec(async (err, docs) => { db.cronDb.find({}).exec(async (err, docs) => {
await CrontabModel.bulkCreate(docs); await CrontabModel.bulkCreate(docs, { ignoreDuplicates: true });
}); });
db.dependenceDb.find({}).exec(async (err, docs) => { db.dependenceDb.find({}).exec(async (err, docs) => {
await DependenceModel.bulkCreate(docs); await DependenceModel.bulkCreate(docs, { ignoreDuplicates: true });
}); });
db.envDb.find({}).exec(async (err, docs) => { db.envDb.find({}).exec(async (err, docs) => {
await EnvModel.bulkCreate(docs); await EnvModel.bulkCreate(docs, { ignoreDuplicates: true });
}); });
db.appDb.find({}).exec(async (err, docs) => { db.appDb.find({}).exec(async (err, docs) => {
await AppModel.bulkCreate(docs); await AppModel.bulkCreate(docs, { ignoreDuplicates: true });
}); });
db.authDb.find({}).exec(async (err, docs) => { db.authDb.find({}).exec(async (err, docs) => {
await AuthModel.bulkCreate(docs); await AuthModel.bulkCreate(docs, { ignoreDuplicates: true });
}); });
} catch (error) { } catch (error) {
console.log(error); console.log(error);
} }
}, 5000);
Logger.info('✌️ DB loaded'); Logger.info('✌️ DB loaded');
} catch (error) { } catch (error) {