Показать сообщение отдельно
  #2 (permalink)  
Старый 27.07.2015, 01:51
Аватар для Vlasenko Fedor
Профессор
Отправить личное сообщение для Vlasenko Fedor Посмотреть профиль Найти все сообщения от Vlasenko Fedor
 
Регистрация: 13.03.2013
Сообщений: 1,572

// Подключение к базе файл 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);
});

Последний раз редактировалось Vlasenko Fedor, 27.07.2015 в 02:16.
Ответить с цитированием