| | |
| | | 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 partition_date = moment().add(2, 'M').format("YYYYMM01"); |
| | | |
| | | 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) {console.log("history_minutely:", error);} }); |
| | | |
| | | mysqlClient.query(sql, function (error, results, fields) { if (error) throw error; }); |
| | | sql = "ALTER TABLE history_10min ADD PARTITION (PARTITION " + partition_name + " VALUES LESS THAN (TO_DAYS('" + partition_date + "')))"; |
| | | mysqlClient.query(sql, function (error, results, fields) { if (error) {console.log("history_10min:", error);} }); |
| | | |
| | | sql = "ALTER TABLE history_hourly ADD PARTITION (PARTITION " + partition_name + " VALUES LESS THAN (TO_DAYS('" + partition_date + "')))"; |
| | | mysqlClient.query(sql, function (error, results, fields) { if (error) {console.log("history_hourly:", error);} }); |
| | | |
| | | sql = "ALTER TABLE history_daily ADD PARTITION (PARTITION " + partition_name + " VALUES LESS THAN (TO_DAYS('" + partition_date + "')))"; |
| | | mysqlClient.query(sql, function (error, results, fields) { if (error) {console.log("history_daily:", error);} }); |
| | | |
| | | mysqlClient.end(); |