New file |
| | |
| | | var mysql = require('mysql'); |
| | | var moment = require('moment'); |
| | | var config = require('./config'); |
| | | |
| | | var mysqlClient = mysql.createConnection(config.mysql_2); |
| | | |
| | | mysqlClient.connect(function(error) { |
| | | if (error) return; |
| | | //console.log("connected to MySQL"); |
| | | }); |
| | | |
| | | 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); |
| | | |
| | | mysqlClient.query(sql, function (error, results, fields) { |
| | | if (error) throw error; |
| | | //console.log(results); |
| | | //console.log(fields); |
| | | }); |
| | | |
| | | mysqlClient.end(); |