nodejs mysql模块简单封装

2018-09-10 01:07:37来源：博客园阅读 ()

nodejs 简单的封装一些mysql模块实现一个方法根据不同传参进行增删改查

首先要 npm install mysql

代码如下

function data(objHost,sql,callback,add=null){
    let mysql = require('mysql');
    var connection = mysql.createConnection(objHost);
      connection.connect();
      //增删改查
      if(add != null){
        connection.query(sql,add,callback);
      }else{
        connection.query(sql,callback);
      }
      connection.end(); 
}
module.exports = data;

传入参数如下 objHost 数据库的基本信息如下

let host = {
    host     : '192.168.199.154',
    user     : 'root',
    password : 'c123321',
    database : 'forums'
  };

sql 就是sql语句添加修改删除查找

callback回调操作完成后拿到数据的回调

add 在添加时候需要添加的内容

然后就是导入mysql模块

调用

createConnection(传入数据库的基本参数);

在调用connect方法连接到数据库

然后判断一下传了添加的数据没没传默认为null

如果传了就调用mysql的query方法吧sql语句传入的数据和回调给它

这是新增

如果是删除、修改和查找走else 只传sql语句和一个回调

mysql模块里面会根据sql语句进行相关操作并且返回给回调

最后就是操作完成结束

connection.end();

模块导出

module.exports = data;

开始使用

　let express=require('express');

let data = require('./modules/data');
let host = {
    host     : '192.168.199.154',
    user     : 'root',
    password : 'c123321',
    database : 'forums'
  };
//写个接口
app.get('/',function(req,res){
    data(host,'SELECT * FROM BBStopic',function(err, results) { 
        if (err) { 
          throw err; 
        } 
        if(results){
            res.status(200);
            res.json(results);
        }          
      }) 
});