function dbrequest (param) {
return new Promise(function (resolve, reject) {
query('SELECT * FROM test', [5]).then(function (res) {
resolve(res[0][param])
}).catch(function (err) {
reject(err)
})
})
}
var myParam = 'a'
dbrequest (myParam).then(function (res){
console.log(res)
})query('SELECT * FROM cms_users WHERE id = ?', [5]).then(function (res) {
//Замечательно! Работаем с полученными данными.
//Вы выводите данные по ключу, не вопрос!
console.log(res[0].a);
console.log(res[0].jdsl);
console.log(res[0].hzhz);
}).catch(function (err) {
//Досадно, но нужно обработать ошибку, они случаются, увы
});var pool = require('mysql').createPool({
host: 'localhost',
user: 'user',
password: 'pass',
database: 'dbname',
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);
});