node操作数据库方法封装

• db.js

/*
    封装通用的方法
*/
const mysql = require('mysql');

exports.base = (sql, data, callback) => {
    // 创建数据库连接
    let connection = mysql.createConnection({
        host: 'localhost', //数据库所在的服务器域名或者IP
        user: 'root', //用户名
        password: '', //密码
        database: 'book' //数据库名称
    });
    // 执行连接动作
    connection.connect();
    // 执行数据库操作
    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);
});