var mysql = require('mysql2/promise'); require('dotenv').config() // var connection = mysql.createConnection({ // host: process.env.DB_HOST, // user: process.env.DB_USER, // password: process.env.DB_PASSWORD, // port: process.env.DB_PORT, // database: 'travopti' // }); const pool = mysql.createPool({ connectionLimit: 10, host: process.env.DB_HOST, user: process.env.DB_USER, password: process.env.DB_PASSWORD, port: process.env.DB_PORT, database: 'travopti', // typeCast: function (field, next) { // if (field.type == "INT") { // var value = field.string(); // return (value === null) ? null : Number(value); // } // return next(); // } decimalNumbers: true }); pool.getConnection() .then(function (connection) { console.log(`Connected to database: ${process.env.DB_HOST}`); //pool.releaseConnection(connection) }) .catch(function (error) { console.error(error.message); }); module.exports = pool; // let travoptidb = {} // travoptidb.all = () => { // return new Promise((resolve, reject) => { // pool.query(`SELECT * FROM regions`, (err, results) => { // if (err) { // return reject(err) // } // return resolve(results) // }) // }) // } // connection.connect((err) => { // if (err) throw err; // console.log('Database connected!') // }); // exports.getRegions = () => { // let sql = `SELECT * FROM regions`; // console.log(connection.state) // if (connection.state === 'disconnected') { // setTimeout(() => console.log('waiting...'), 1000); // } // console.log('executed') // let res = {} // connection.query(sql, (error, results, fields) => { // if (error) { // return console.error(error.message); // } // console.log('innercallback(1)') // res = results[0] // }); // console.log('outsidecallback(2)') // return res; // } // exports.getBYTdata = () => { // connection.query(`SELECT * FROM regions_byt`, (error, results, fields) => { // if (error) { // return console.error(error.message); // } // console.log(results[0]) // nres = results.map((obj) => { // return obj.region // }) // //console.log(nres); // }); // } // exports.end = () => connection.end(); // module.exports = connection;