lthn/mining-pool
6
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Moving sql_sync to async each

Browse source 
Updated SQL_MIGRATIONS to pool.
This commit is contained in:
Alexander Blair 2017-02-26 10:49:51 -08:00
parent aa24805056
commit 81a05a64d1
2 changed files with 10 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
SQL_MIGRATIONS.md
View file

@ -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;
```

20
sql_sync/sql_sync.js
View file

@ -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();
});