-
Notifications
You must be signed in to change notification settings - Fork 0
/
index.js
93 lines (76 loc) · 2.47 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
'use strict';
const fs = require('fs');
const path = require('path');
const Sequelize = require('sequelize');
const process = require('process');
const basename = path.basename(__filename);
const env = process.env.NODE_ENV || 'development';
const config = require(__dirname + '/../config/config.json')[env];
const mysql = require('mysql2')
const db = {};
const pool = mysql.createPool({
host: "localhost",
user: "newuser",
database: "steamdb",
password: "password"
})
// let sequelize;
// if (config.use_env_variable) {
// sequelize = new Sequelize(process.env[config.use_env_variable], config);
// } else {
// sequelize = new Sequelize(config.database, config.username, config.password, config);
// }
db.pool = pool.promise();
const executeSql = async (sqlArray, str) => {
let counter = 0
for (const sql of sqlArray) {
if (!sql.length) {
continue
}
console.log(counter++)
try {
const res = await db.pool.query(str + sql)
console.log("1: ", res)
} catch (err) {
console.log("err: ", err)
}
}
console.log("finished!")
return 1
}
const loadDataFromSql = (filePath) => {
let dataSql = fs.readFileSync(path.join(__dirname, filePath)).toString();
dataSql = dataSql.replace(/(\r\n|\n|\r)/gm, "");
// console.log("dataSQL:", dataSql)
// let counter = 0
const sentences = dataSql.split(";")
return executeSql(sentences, "")
}
const insertDataFromSql = (filePath) => {
let dataSql = fs.readFileSync(path.join(__dirname, filePath)).toString();
dataSql = dataSql.replace(/(\r\n|\n|\r)/gm, "");
// console.log("dataSQL:", dataSql)
// let counter = 0
const sentences = dataSql.split("INSERT INTO")
// console.log("sentences: ", sentences)
return executeSql( sentences, "INSERT INTO")
}
loadDataFromSql("../../SQL/createtables.sql").then(result => {
console.log("result outter", result)
db.pool.query(
"select * from game limit 1"
).then(([data, metaData]) => {
console.log("data: ", data)
if (data.length == 0) {
insertDataFromSql("../../SQL/insert.sql").then(result => {
console.log("result inner: ", result)
})
}
}
).catch(err => {
console.log("Errorafa: ", err)
// loadDataFromSql("../../SQL/insert.sql")
}
)
}).catch(err => console.log("outer err: ", err))
module.exports = db;