Skip to content

Instantly share code, notes, and snippets.

@amulyakashyap09
Created May 18, 2017 18:45
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save amulyakashyap09/b8f6f777e767c919a7977739cf96a6bf to your computer and use it in GitHub Desktop.
Save amulyakashyap09/b8f6f777e767c919a7977739cf96a6bf to your computer and use it in GitHub Desktop.
can create all mongo databases backup && restore
var exec = require('child_process').exec;
var fs = require('fs');
var path = require('path').resolve('.');
exports.createBackup = function (credentials, options, callback) {
if ("dbName" in options && "path" in options) {
exec("pgrep mongod", function (err) {
if (err) {
callback({
error: 404,
message: "Please start mongo server"
});
} else {
var command, fileName;
if ("fileName" in options) {
fileName = options.path + "/" + options.fileName;
} else {
fileName = options.path + "/" + (new Date()).getTime() + ".gz";
}
if (!("host" in credentials)) {
credentials.host = "127.0.0.1";
}
if (!("port" in credentials)) {
credentials.port = 27017;
}
if (options.dbName == "*") {
if ("userName" in credentials && "password" in credentials) {
command = "mongodump --host " + credentials.host + " --port " + credentials.port + " --username " + credentials.userName + " --password " + credentials.password + " --archive=" + fileName + " --gzip";
} else {
command = "mongodump --host " + credentials.host + " --port " + credentials.port + " --archive=" + fileName + " --gzip";
}
} else {
if ("userName" in credentials && "password" in credentials) {
command = "mongodump --host " + credentials.host + " --port " + credentials.port + " --username " + credentials.userName + " --password " + credentials.password + " --archive=" + fileName + " --gzip --db " + options.dbName;
} else {
command = "mongodump --host " + credentials.host + " --port " + credentials.port + " --archive=" + fileName + " --gzip --db " + options.dbName;
}
}
exec(command, function (err) {
if (err) {
callback({
error: 404,
message: err
});
} else {
callback(null, {
statusCode: 200,
message: options.dbName + " dump created successfully!!!"
});
}
});
}
});
} else {
if (!("path" in options)) {
return callback({
error: 404,
message: "Path for dump is required!!!!"
});
}
if (!("dbName" in options)) {
return callback({
error: 404,
message: "Database name for dump is required!!!!"
});
}
}
};
exports.restoreBackup = function (credentials, options, callback) {
if ("dumpPath" in options) {
exec("pgrep mongod", function (err) {
if (err) {
callback({
error: 404,
message: "Please start mongo server"
});
} else {
var command;
var fileName = options.dumpPath.substring(options.dumpPath.lastIndexOf("/") + 1, options.dumpPath.length);
if (!("host" in credentials)) {
credentials.host = "127.0.0.1";
}
if (!("port" in credentials)) {
credentials.port = 27017;
}
if ("userName" in credentials && "password" in credentials) {
command = "mongorestore --host " + credentials.host + " --port " + credentials.port + " --username " + credentials.userName + " --password " + credentials.password + " --archive=" + options.dumpPath + " --gzip";
} else {
command = "mongorestore --host " + credentials.host + " --port " + credentials.port + " --archive=" + options.dumpPath + " --gzip";
}
exec(command, function (err) {
if (err) {
callback({
error: 404,
message: err
});
} else {
if ("deleteDumpAfterRestore" in options && options.deleteDumpAfterRestore == true) {
fs.unlinkSync(options.dumpPath);
}
callback(null, {
statusCode: 200,
message: fileName + " Restored successfully!!!"
});
}
});
}
});
} else {
return callback({
error: 404,
message: "Specify Dump Path for restoration!!!"
});
}
};
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment