/**

* npm install mysql -save

*/

var mysql = require('mysql');

const conf = {

host: 'localhost',

user: 'root',

password: '123456',

database: 'test_db',

charset: 'utf8mb4',

};

function XMysql() {

/**

* 批量插入

* @sql insert into `user_tab`(`name`, `gender`, `age`, created`) values ?

* @params [[name1, gender1, age1, created1],[name2, gender2, age2, created2],[name3, gender3, age3, created3]];

*/

this.insert = function (sql, params) {

return new Promise((resolve, reject) => {

var connection = mysql.createConnection(conf);

connection.connect();

connection.query(sql, [params], function (error, results, fields) {

connection.end();

if (error) {

reject(error);

} else {

resolve(results);

}

});

});

};

/**

* 更新

* @sql update tab_tmp set tmp_field = ? where id = ?

* @params [field, id]

*/

this.update = function (sql, params) {

return new Promise((resolve, reject) => {

var connection = mysql.createConnection(conf);

connection.connect();

connection.query(sql, params, function (error, results, fields) {

if (error) {

reject(error);

} else {

resolve(results);

}

});

connection.end();

});

};

/**

* 根据SQL进行查询

* @sql select * from user_tab where id = 1

*/

this.select = function (sql) {

return new Promise((resolve, reject) => {

var connection = mysql.createConnection(conf);

connection.connect();

connection.query(sql, function (error, results, fields) {

if (error) {

reject(error);

} else {

resolve(results);

}

});

connection.end();

});

};

}

module.exports = new XMysql();

使用方式:

const xm = require('./xmysql');

xm.select("select * from user_tab where id = 1", res => {

console.log(res);

});

这样就可以查询出来内容啦,还可以把数据库连接优化一下,做个连接池..但是我这里就随便写一下 做个小工具使用 因此没有这个需求...

==LOG-Footer Start==================================

作者公众号:Loyomer

简洁：Kxvz的生活记账本。技术，生活，随笔，文摘...

欢迎大家关注...

==LOG-Footer End==================================