test

沈斌

2018-04-09 3e53fc1b2448962c8602a61f1ddf08067cee7b80

test

 server2.js

@@ -3,7 +3,6 @@
var config = require('./config');

var mysqlClient = mysql.createConnection(config.mysql_2);

mysqlClient.connect(function(error) { if (error) return; });

var partition_name1 = "p" + moment().add(1, 'd').format("YYYYMMDD");
@@ -14,7 +13,7 @@

mysqlClient.query(sql, function (error, results, fields) { if (error) throw error; });

var partition_name2 = "p" + moment().add(-6, 'd').format("YYYYMMDD");
var partition_name2 = "p" + moment().add(-7, 'd').format("YYYYMMDD");

sql = "ALTER TABLE history DROP PARTITION " + partition_name2;
// console.log(sql);

 server3.js

@@ -3,22 +3,14 @@
var config = require('./config');

var mysqlClient = mysql.createConnection(config.mysql_2);

mysqlClient.connect(function(error) {
    if (error) return;
    //console.log("connected to MySQL");
});
mysqlClient.connect(function(error) { if (error) return; });

var partition_name = "p" + moment().add(1, 'M').format("YYYYMM");
var partition_date = moment().add(2, 'M').format("YYYYMM");

var sql = "ALTER TABLE history_minutely ADD PARTITION (PARTITION " + partition_name + " VALUES LESS THAN ('" + partition_date + "'))";
console.log(sql);
// console.log(sql);

mysqlClient.query(sql, function (error, results, fields) {
    if (error) throw error;
    //console.log(results);
    //console.log(fields);
});
mysqlClient.query(sql, function (error, results, fields) { if (error) throw error; });

mysqlClient.end();

 test.js

@@ -2,25 +2,17 @@
var moment = require('moment');
var config = require('./config');

var mysqlClient = mysql.createConnection(config.mysql);
var mysqlClient = mysql.createConnection(config.mysql_2);
mysqlClient.connect(function(error) { if (error) return; });

mysqlClient.connect(function(error) {
    if (error) return;
    //console.log("connected to MySQL");
});

for(var i = 0; i < 12; i++) {
    var partition_name = "p" + moment().add(-64 + i, 'd').format("YYYYMMDD");
for(var i = 0; i < 3; i++) {
    var partition_name = "p" + moment().add(-8 + i, 'd').format("YYYYMMDD");
    console.log(partition_name);

    sql = "ALTER TABLE history DROP PARTITION " + partition_name;
    console.log(sql);

    mysqlClient.query(sql, function (error, results, fields) {
        if (error) throw error;
        //console.log(results);
        //console.log(fields);
    });
    // mysqlClient.query(sql, function (error, results, fields) { if (error) throw error; });
}

mysqlClient.end();