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 f6e6cfa71c
commit 355f06a3cf
1 changed files with 26 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
back/loaders/db.ts
View File

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