// Подключение к базе файл mysql.js
var pool = require('mysql').createPool({
host: 'localhost',
user: 'user',
password: 'pass',
database: 'fregate',
socketPath: '/var/run/mysqld/mysqld.sock', // общаемся с mysql через сокеты
connectionLimit: 100
});
exports.query = function (sql, props) {
return new Promise(function (resolve, reject) {
pool.getConnection(function (err, connection) {
connection.query(
sql, props,
function (err, res) {
if (err) reject(err);
else resolve(res);
}
);
connection.release();
});
});
};
Пример использования другой файл
var query = require('./mysql').query;
query('SELECT * FROM cms_users WHERE id = ?', [5]).then(function (res) {
// здесь код будет выполнятся после запроса
console.log('Result');
console.log(res);
}).catch(function (err) {
// здесь будет сообщение об ошибке
console.log('Error');
console.log(err);
});