說到node,可能你們會想到MOngoDB做爲數據庫,這裏將會介紹node與mysql的鏈接,並分享了封裝好的實例代碼,在項目開發中可直接使用。下一篇博客將會講node鏈接MongoDB。node
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:鏈接的服務器
user:數據庫用戶名
password:設置的MySQL密碼
database: 要鏈接的數據庫名mysql
具體的使用這裏不作詳細說明,包括select、insert、update、delete等語句。web
查詢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。