mysqldump-async/drop.js at master · andromedarabbit/mysqldump-async · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
#!/usr/bin/env node
var info = require('./info.js');
var dump = require('./dump.js');
var common = require('./common.js');
var shell = require('shelljs');
var path = require('path');
var sprintf = require('sprintf').sprintf;

var servers = info.servers;
// var dumpRootDir = info.dumpRootDir;
var mysqlPath = info.mysqlPath;
var mysqldumpPath = info.mysqldumpPath;


function dropDatabasesAsync() {
	info.verifyAndInitialize();

	var servers = info.servers;
	var backupDir = info.getBackupDir();
	for(var i in servers) {
		var server = servers[i];

		dropDatabaseAsync(server, backupDir);
	}
}

function dropDatabaseAsync(server, dumpRootDir, callback) {
	if(info.backupBeforeDrop) {
		dump.dumpDatabase(server, dumpRootDir);
	}

	var query = sprintf(
		"drop database IF EXISTS %s;",
		server["database"]
	);

	common.executeQueryAsync(query, server, "mysql", callback);
}


exports.dropDatabasesAsync = dropDatabasesAsync;
exports.dropDatabaseAsync = dropDatabaseAsync;