nodejs mysql模塊簡單封裝

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);
        }          
      }) 
});

根據自己的需求進行調用