myt/myvc-dump.js

77 lines
2.0 KiB
JavaScript

const MyVC = require('./myvc');
const fs = require('fs-extra');
const path = require('path');
class Dump {
get usage() {
return {
description: 'Dumps structure and fixtures from remote',
operand: 'remote'
};
}
get localOpts() {
return {
default: {
remote: 'production'
}
};
}
async run(myvc, opts) {
const dumpStream = await myvc.initDump('.dump.sql');
console.log('Dumping structure.');
let dumpArgs = [
'--default-character-set=utf8',
'--no-data',
'--comments',
'--triggers',
'--routines',
'--events',
'--databases'
];
dumpArgs = dumpArgs.concat(opts.schemas);
await myvc.runDump('myvc-dump.sh', dumpArgs, dumpStream);
console.log('Dumping fixtures.');
await myvc.dumpFixtures(dumpStream, opts.fixtures);
console.log('Dumping privileges.');
const privs = opts.privileges;
if (privs && Array.isArray(privs.tables)) {
let args = [
'--no-create-info',
'--skip-triggers',
'--insert-ignore',
'--complete-insert'
];
if (privs.where) args.push('--where', privs.where);
args = args.concat(['mysql'], privs.tables);
await dumpStream.write('USE `mysql`;\n', 'utf8');
await myvc.runDump('mysqldump', args, dumpStream);
}
await dumpStream.end();
console.log('Saving version.');
await myvc.dbConnect();
const version = await myvc.fetchDbVersion();
if (version) {
const dumpDir = path.join(opts.myvcDir, 'dump');
await fs.writeFile(
`${dumpDir}/.dump.json`,
JSON.stringify(version)
);
}
}
}
module.exports = Dump;
if (require.main === module)
new MyVC().run(Dump);