const mysql = require('mysql');
const dotenv = require('dotenv').config().parsed;
let connection = undefined;
let connected = false;
let onConnect = [];
const dbConnection = async () => {
return new Promise((resolve, reject) => {
try {
connection = mysql.createConnection({
host: dotenv.DB_HOST,
user: dotenv.DB_USERNAME,
password: dotenv.DB_PASSWORD,
database: dotenv.DB_NAME
});
connection.connect();
if (connection) {
resolve(connection);
} else {
reject(connectionFail());
}
} catch(e) {
console.log(e);
}
});
//return connection;
};
const connectionFail = () => {
console.log("A conexão com o banco de dados não conseguiu ser estabelecida.");
}
const consultarCasas = async () => {
return new Promise((resolve, reject) => {
let query = sqlQuery("SELECT * FROM vrp_home_permissions").then(row => {
}).catch((err) => {
});
});
}
const sqlQuery = (sql, args = []) => {
return new Promise((resolve, reject) => {
if(!connection) {
return;
}
connection.query(sql, args, (err, rows) => {
if (err)
reject(err);
else
resolve(rows);
});
});
};
let consultaCasas = await consultarCasas();
consultaCasas.then((obj) => {
console.log(obj());
});
module.exports = () => {
return dbConnection;
};
//# sourceMappingURL=dbCon.js.map
