1 files added
1 files modified
New file |
| | |
| | | { |
| | | "name": "partition", |
| | | "version": "0.0.1", |
| | | "lockfileVersion": 1, |
| | | "requires": true, |
| | | "dependencies": { |
| | | "bignumber.js": { |
| | | "version": "4.0.4", |
| | | "resolved": "https://registry.npmjs.org/bignumber.js/-/bignumber.js-4.0.4.tgz", |
| | | "integrity": "sha512-LDXpJKVzEx2/OqNbG9mXBNvHuiRL4PzHCGfnANHMJ+fv68Ads3exDVJeGDJws+AoNEuca93bU3q+S0woeUaCdg==" |
| | | }, |
| | | "core-util-is": { |
| | | "version": "1.0.2", |
| | | "resolved": "https://registry.npmjs.org/core-util-is/-/core-util-is-1.0.2.tgz", |
| | | "integrity": "sha1-tf1UIgqivFq1eqtxQMlAdUUDwac=" |
| | | }, |
| | | "inherits": { |
| | | "version": "2.0.3", |
| | | "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.3.tgz", |
| | | "integrity": "sha1-Yzwsg+PaQqUC9SRmAiSA9CCCYd4=" |
| | | }, |
| | | "isarray": { |
| | | "version": "1.0.0", |
| | | "resolved": "https://registry.npmjs.org/isarray/-/isarray-1.0.0.tgz", |
| | | "integrity": "sha1-u5NdSFgsuhaMBoNJV6VKPgcSTxE=" |
| | | }, |
| | | "moment": { |
| | | "version": "2.19.2", |
| | | "resolved": "https://registry.npmjs.org/moment/-/moment-2.19.2.tgz", |
| | | "integrity": "sha512-Rf6jiHPEfxp9+dlzxPTmRHbvoFXsh2L/U8hOupUMpnuecHQmI6cF6lUbJl3QqKPko1u6ujO+FxtcajLVfLpAtA==" |
| | | }, |
| | | "mysql": { |
| | | "version": "2.15.0", |
| | | "resolved": "https://registry.npmjs.org/mysql/-/mysql-2.15.0.tgz", |
| | | "integrity": "sha512-C7tjzWtbN5nzkLIV+E8Crnl9bFyc7d3XJcBAvHKEVkjrYjogz3llo22q6s/hw+UcsE4/844pDob9ac+3dVjQSA==", |
| | | "requires": { |
| | | "bignumber.js": "4.0.4", |
| | | "readable-stream": "2.3.3", |
| | | "safe-buffer": "5.1.1", |
| | | "sqlstring": "2.3.0" |
| | | } |
| | | }, |
| | | "process-nextick-args": { |
| | | "version": "1.0.7", |
| | | "resolved": "https://registry.npmjs.org/process-nextick-args/-/process-nextick-args-1.0.7.tgz", |
| | | "integrity": "sha1-FQ4gt1ZZCtP5EJPyWk8q2L/zC6M=" |
| | | }, |
| | | "readable-stream": { |
| | | "version": "2.3.3", |
| | | "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-2.3.3.tgz", |
| | | "integrity": "sha512-m+qzzcn7KUxEmd1gMbchF+Y2eIUbieUaxkWtptyHywrX0rE8QEYqPC07Vuy4Wm32/xE16NcdBctb8S0Xe/5IeQ==", |
| | | "requires": { |
| | | "core-util-is": "1.0.2", |
| | | "inherits": "2.0.3", |
| | | "isarray": "1.0.0", |
| | | "process-nextick-args": "1.0.7", |
| | | "safe-buffer": "5.1.1", |
| | | "string_decoder": "1.0.3", |
| | | "util-deprecate": "1.0.2" |
| | | } |
| | | }, |
| | | "safe-buffer": { |
| | | "version": "5.1.1", |
| | | "resolved": "https://registry.npmjs.org/safe-buffer/-/safe-buffer-5.1.1.tgz", |
| | | "integrity": "sha512-kKvNJn6Mm93gAczWVJg7wH+wGYWNrDHdWvpUmHyEsgCtIwwo3bqPtV4tR5tuPaUhTOo/kvhVwd8XwwOllGYkbg==" |
| | | }, |
| | | "sqlstring": { |
| | | "version": "2.3.0", |
| | | "resolved": "https://registry.npmjs.org/sqlstring/-/sqlstring-2.3.0.tgz", |
| | | "integrity": "sha1-UluKT9Jtb3GqYegipsr5dtMa0qg=" |
| | | }, |
| | | "string_decoder": { |
| | | "version": "1.0.3", |
| | | "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.0.3.tgz", |
| | | "integrity": "sha512-4AH6Z5fzNNBcH+6XDMfA/BTt87skxqJlO0lAh3Dker5zThcAxG6mKz+iGu308UKoPPQ8Dcqx/4JhujzltRa+hQ==", |
| | | "requires": { |
| | | "safe-buffer": "5.1.1" |
| | | } |
| | | }, |
| | | "util-deprecate": { |
| | | "version": "1.0.2", |
| | | "resolved": "https://registry.npmjs.org/util-deprecate/-/util-deprecate-1.0.2.tgz", |
| | | "integrity": "sha1-RQ1Nyfpw3nMnYvvS1KKJgUGaDM8=" |
| | | } |
| | | } |
| | | } |
| | |
| | | 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(); |