-
Notifications
You must be signed in to change notification settings - Fork 0
/
database.js
61 lines (49 loc) · 1.76 KB
/
database.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
const mysql = require("mysql2");
const dotenv = require("dotenv");
dotenv.config();
const pool = mysql.createPool({
host: process.env.MYSQL_HOST,
user: process.env.MYSQL_USER,
password: process.env.MYSQL_PASSWORD,
database: process.env.MYSQL_DATABASE
}).promise();
async function checkDatabaseConnection() {
try {
// Attempt to get a connection from the pool and execute a query
const connection = await pool.getConnection();
await connection.query('SELECT 1');
connection.release(); // Release the connection back to the pool
console.log('Database connected successfully');
} catch (error) {
console.error('Database connection error:', error);
}
}
// Call the function to check the database connection
checkDatabaseConnection();
const createUser = async (username, phone, email, password) => {
try {
let sql = `
INSERT INTO user (username, phone, email, password)
VALUES("${username}", "${phone}", "${email}", "${password}")
`;
const result = await pool.query(sql);
return result;
}
catch (err) {
throw new Error("Error adding user in the database");
}
}
const createFirm = async (reg_no, name, proprietor, nominee, phone, email, trade_license, uid) => {
try {
let sql = `
INSERT INTO firm (reg_no, name, proprietor, nominee, phone, email, trade_license, uid)
VALUES("${reg_no}", "${name}", "${proprietor}", "${nominee}", "${phone}", "${email}", "${trade_license}", "${uid}")
`;
const result = await pool.query(sql);
return result;
}
catch (err) {
throw new Error("Error adding firm in the database: " + err);
}
}
module.exports = { createUser, createFirm }