Node鏈接MySQL並封裝其增刪查改

圖片描述

Node鏈接Mysql

說到node,可能你們會想到MOngoDB做爲數據庫,這裏將會介紹node與mysql的鏈接,並分享了封裝好的實例代碼,在項目開發中可直接使用。下一篇博客將會講node鏈接MongoDB。node

安裝Mysql模塊

npm install mysql

鏈接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:鏈接的服務器
user:數據庫用戶名
password:設置的MySQL密碼
database: 要鏈接的數據庫名mysql

經常使用的SQL語句

具體的使用這裏不作詳細說明,包括select、insert、update、delete等語句。web

Node操做Mysql

查詢sql

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

刪除npm

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

結束鏈接函數

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

這兩種都行,第二種是強制結束。ui

封裝

說了這麼多,感受操做起來仍是挺簡單的。在實際開發中,咱們想要操做起來更方便,那就讓咱們本身封裝一下來使用。直接上代碼:spa

封裝好的代碼

1.數據庫配置文件

//配置連接數據庫參數
module.exports = {
    host : 'localhost',
    port : 3306,//端口號
    database : 'nodetest',//數據庫名
    user : 'root',//數據庫用戶名
    password : '123456'//數據庫密碼
};

2.封裝、暴露方法

let mysql = require('mysql');//引入mysql模塊
var databaseConfig = require('./mysql.config');  //引入數據庫配置模塊中的數據

//向外暴露方法
module.exports = {
    query : function(sql,params,callback){
        //每次使用的時候須要建立連接,數據操做完成以後要關閉鏈接
        var connection = mysql.createConnection(databaseConfig);        
        connection.connect(function(err){
            if(err){
                console.log('數據庫連接失敗');
                throw err;
            }
         //開始數據操做
         //傳入三個參數,第一個參數sql語句,第二個參數sql語句中須要的數據,第三個參數回調函數
        connection.query( sql, params, function(err,results,fields ){
           if(err){
                console.log('數據操做失敗');
                throw err;
            }
            //將查詢出來的數據返回給回調函數
            callback && callback(results, fields);
            //results做爲數據操做後的結果,fields做爲數據庫鏈接的一些字段
            //中止連接數據庫,必須再查詢語句後,要否則一調用這個方法,就直接中止連接,數據操做就會失敗
             connection.end(function(err){
                  if(err){
                      console.log('關閉數據庫鏈接失敗!');
                      throw err;
                  }
              });
           });
       });
    }
};

3.演示實例

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

結束

想要使用的朋友,能夠直接把封裝好的兩個文件copy到項目中,改一下配置就可使用了,大大提升開發效率。下一篇將會分享Node鏈接MongoDB。

相關文章
相關標籤/搜索