摘要：連接說(shuō)到，可能大家會(huì)想到作為數(shù)據(jù)庫(kù)，這里將會(huì)介紹與的連接，并分享了封裝好的實(shí)例代碼，在項(xiàng)目開(kāi)發(fā)中可直接使用。操作查詢(xún)添加刪除更新結(jié)束連接這兩種都行，第二種是強(qiáng)制結(jié)束。

說(shuō)到node，可能大家會(huì)想到MOngoDB作為數(shù)據(jù)庫(kù)，這里將會(huì)介紹node與mysql的連接，并分享了封裝好的實(shí)例代碼，在項(xiàng)目開(kāi)發(fā)中可直接使用。下一篇博客將會(huì)講node連接MongoDB。

npm install mysql

    const mysql = require("mysql");
    
    let connection = mysql.createConnection({
        host : "localhost",
        user : "root", 
        password : "password",
        database : "test"
    });

connection.connect(function(err) {
  if (err) {
    console.error("連接失敗: " + err.stack);
    return;
  }

  console.log("連接成功 id " + connection.threadId);
});

host：連接的服務(wù)器
user：數(shù)據(jù)庫(kù)用戶(hù)名
password：設(shè)置的MySQL密碼
database： 要連接的數(shù)據(jù)庫(kù)名

具體的使用這里不做詳細(xì)說(shuō)明，包括select、insert、update、delete等語(yǔ)句。

查詢(xún)

connection.query("SELECT * FROM t_user WHERE username = "whg"", (err, results, fields) => {
    if(err){
        console.log(err);
    }
    console.log(results);
})

添加

connection.query("INSERT INTO t_user(username, pass) VALUES(?, ?)",["whg", "123"], (err, results) => {
    if(err){
        console.log(err);
    }
    console.log(results);
})

刪除

connection.query("DELETE FROM t_user  WHERE id = 1", (err, results) => {
    if(err){
        console.log(err);
    }
    console.log(results);
})

更新

connection.query("UPDATE t_user SET pass = "321" WHERE username = "whg"", (err, results) => {
    if(err){
        console.log(err);
    }
    console.log(results);
})

結(jié)束連接

connection.end(function(err) {
  
});
connection.destroy();

這兩種都行，第二種是強(qiáng)制結(jié)束。

說(shuō)了這么多，感覺(jué)操作起來(lái)還是挺簡(jiǎn)單的。在實(shí)際開(kāi)發(fā)中，我們想要操作起來(lái)更方便，那就讓我們自己封裝一下來(lái)使用。直接上代碼：

封裝好的代碼

1.數(shù)據(jù)庫(kù)配置文件

//配置鏈接數(shù)據(jù)庫(kù)參數(shù)
module.exports = {
    host : "localhost",
    port : 3306,//端口號(hào)
    database : "nodetest",//數(shù)據(jù)庫(kù)名
    user : "root",//數(shù)據(jù)庫(kù)用戶(hù)名
    password : "123456"http://數(shù)據(jù)庫(kù)密碼
};

2.封裝、暴露方法

let mysql = require("mysql");//引入mysql模塊
var databaseConfig = require("./mysql.config");  //引入數(shù)據(jù)庫(kù)配置模塊中的數(shù)據(jù)

//向外暴露方法
module.exports = {
    query : function(sql,params,callback){
        //每次使用的時(shí)候需要?jiǎng)?chuàng)建鏈接，數(shù)據(jù)操作完成之后要關(guān)閉連接
        var connection = mysql.createConnection(databaseConfig);        
        connection.connect(function(err){
            if(err){
                console.log("數(shù)據(jù)庫(kù)鏈接失敗");
                throw err;
            }
         //開(kāi)始數(shù)據(jù)操作
         //傳入三個(gè)參數(shù)，第一個(gè)參數(shù)sql語(yǔ)句，第二個(gè)參數(shù)sql語(yǔ)句中需要的數(shù)據(jù)，第三個(gè)參數(shù)回調(diào)函數(shù)
        connection.query( sql, params, function(err,results,fields ){
           if(err){
                console.log("數(shù)據(jù)操作失敗");
                throw err;
            }
            //將查詢(xún)出來(lái)的數(shù)據(jù)返回給回調(diào)函數(shù)
            callback && callback(results, fields);
            //results作為數(shù)據(jù)操作后的結(jié)果，fields作為數(shù)據(jù)庫(kù)連接的一些字段
            //停止鏈接數(shù)據(jù)庫(kù)，必須再查詢(xún)語(yǔ)句后，要不然一調(diào)用這個(gè)方法，就直接停止鏈接，數(shù)據(jù)操作就會(huì)失敗
             connection.end(function(err){
                  if(err){
                      console.log("關(guān)閉數(shù)據(jù)庫(kù)連接失敗！");
                      throw err;
                  }
              });
           });
       });
    }
};

3.演示實(shí)例

var db=require("../model/mysql.js");
// 查詢(xún)實(shí)例
db.query("select * from t_user", [],function(result,fields){
    console.log("查詢(xún)結(jié)果：");
    console.log(result);
});
//添加實(shí)例
var  addSql = "INSERT INTO websites(username,password) VALUES(?,?)";
var  addSqlParams =["咕嚕先森", "666"];
db.query(addSql,addSqlParams,function(result,fields){
    console.log("添加成功")
})

想要使用的朋友，可以直接把封裝好的兩個(gè)文件copy到項(xiàng)目中，改一下配置就可以使用了，大大提高開(kāi)發(fā)效率。下一篇將會(huì)分享Node連接MongoDB。