Skip to content
Permalink
Browse files

Moving sql_sync to async each

Updated SQL_MIGRATIONS to pool.
  • Loading branch information...
Snipa22 committed Feb 26, 2017
1 parent aa24805 commit 81a05a64d135e3e4fd6efa9d45f5e7c176b2d560
Showing with 10 additions and 12 deletions.
  1. +1 −1 SQL_MIGRATIONS.md
  2. +9 −11 sql_sync/sql_sync.js
@@ -31,5 +31,5 @@ ALTER TABLE pool.xmrtoTxn CONVERT TO CHARACTER SET utf8 COLLATE utf8_general_ci;
2/25/2017
---------
```sql
ALTER TABLE monero_live.users ADD enable_email BOOL DEFAULT true NULL;
ALTER TABLE pool.users ADD enable_email BOOL DEFAULT true NULL;
```
@@ -3,6 +3,7 @@ let mysql = require("promise-mysql");
let fs = require("fs");
let config = fs.readFileSync("../config.json");
let sql_schema = fs.readFileSync("config_entries.json");
let async = require("async");

global.config = JSON.parse(config);
global.mysql = mysql.createPool(global.config.mysql);
@@ -13,21 +14,18 @@ global.schema = JSON.parse(sql_schema);

let loopCount = 0;
let updatedCount = 0;
global.schema.forEach(function(entry){
async.eachSeries(global.schema, function(entry, callback){
global.mysql.query("SELECT * FROM config WHERE module = ? AND item = ?", [entry.module, entry.item]).then(function(rows){
loopCount += 1;
if (rows.length > 0){
if(loopCount === global.schema.length){
console.log("Updated SQL schema with "+updatedCount+" new rows! Exiting!");
process.exit();
}
return;
callback();
}
updatedCount += 1;
global.mysql.query("INSERT INTO config (module, item, item_value, item_type, Item_desc) VALUES (?, ?, ?, ?, ?)", [entry.module, entry.item, entry.item_value, entry.item_type, entry.Item_desc]);
if(loopCount === global.schema.length){
console.log("Updated SQL schema with "+updatedCount+" new rows! Exiting!");
process.exit();
}
global.mysql.query("INSERT INTO config (module, item, item_value, item_type, Item_desc) VALUES (?, ?, ?, ?, ?)", [entry.module, entry.item, entry.item_value, entry.item_type, entry.Item_desc]).then(function(){
callback();
});
});
}, function(){
console.log("Updated SQL schema with "+updatedCount+" new rows! Exiting!");
process.exit();
});

0 comments on commit 81a05a6

Please sign in to comment.
You can’t perform that action at this time.