/*
封裝通用的方法
*/
const mysql = require('mysql');
exports.base = (sql, data, callback) => {
// 創(chuàng)建數據庫連接
let connection = mysql.createConnection({
host: 'localhost', //數據庫所在的服務器域名或者IP
user: 'root', //用戶名
password: '', //密碼
database: 'book' //數據庫名稱
});
// 執(zhí)行連接動作
connection.connect();
// 執(zhí)行數據庫操作
connection.query(sql, data, (err, rows, fields) => {
if (err) throw err;
callback(rows);
});
// 關閉數據庫
connection.end();
}
/*
測試封裝的通用方法
*/
const db = require('./db.js');
let sql = 'select * from user where id = ?';
let data = [9];
db.base(sql,data,(ret) => {
console.log(ret[0]);
});
let sql = 'insert into user set ?';
let data = {
username : 'lisi',
password : '123',
age : 12,
departid : 1
}
db.base(sql,data,(ret) => {
console.log(ret);
});
let sql = 'update user set username=? where id=?';
let data = ['zhaoliu',9];
db.base(sql,data,(ret) => {
console.log(ret);
});
let sql = 'delete from user where id = ?';
let data = [12];
db.base(sql,data,(ret) => {
console.log(ret);
});
