diff --git a/json_to_db.js b/json_to_db.js index c092941..9d30dcd 100644 --- a/json_to_db.js +++ b/json_to_db.js @@ -2,16 +2,24 @@ const fs = require('fs'); const path = require('path'); const mysql = require('mysql2/promise'); +//Uncomment for Marco Server +// const pool = mysql.createPool({ +// "host": "127.0.0.1", +// "port": 3306, +// "user": "rw", +// "password": "5Xk8Y7Kz6H3DeCXqcZ#Sb%Nz", +// "ssl": false +// }); +//Uncomment for local test const pool = mysql.createPool({ "host": "127.0.0.1", "port": 3306, - "user": "rw", - "password": "5Xk8Y7Kz6H3DeCXqcZ#Sb%Nz", + "user": "root", + "password": "password", "ssl": false }); - - + // Function to read JSON files recursively in a directory function readJsonFiles(directory) { const files = fs.readdirSync(directory); @@ -68,6 +76,20 @@ async function processJsonFile(filePath) { } } + //TODO: insert city_key into .tMRN_OU + try { + const otherDataString = JSON.stringify(otherData); + //MRN_HWPA for Marco server, mrnValUser on local + const query = 'INSERT INTO mrnValUser.tMRN_OU (M_DATA, M_OU, M_Flag, M_Name, M_Imprint, M_State) VALUES (?, ?, ?, ?, ?, ?);'; + let res = await pool.execute(query, [otherDataString, data.city_key, "T", "test", "test", "test"]); + if (typeof res === 'undefined') { + throw new Error("Database connection error"); + } + console.log('updated database with otherdata', res[0]); + } catch (err) { + console.log(err); + } +/* try { const otherDataString = JSON.stringify(otherData); const query = 'UPDATE MRN_HWPA.tMRN_OU SET M_Data = ? WHERE M_OU = ?'; @@ -79,6 +101,7 @@ async function processJsonFile(filePath) { } catch (err) { console.log(err); } +*/ } // Start processing JSON files in a directory