var mysql = require('mysql'); var moment = require('moment'); var config = require('./config'); var mysqlClient = mysql.createConnection(config.mysql); mysqlClient.connect(function(error) { if (error) return; //console.log("connected to MySQL"); }); var partition_name = "p" + moment().add(config.count, 'd').format("YYYYMMDD"); var partition_date = moment().add(config.count + 1, 'd').format("YYYYMMDD"); var sql = "ALTER TABLE history ADD PARTITION (PARTITION " + partition_name + " VALUES LESS THAN ('" + partition_date + "'))"; console.log(sql); mysqlClient.query(sql, function (error, results, fields) { if (error) throw error; //console.log(results); //console.log(fields); }); mysqlClient.end();