Node.js：鏈接 MySQL

ylbtech-Node.js：鏈接 MySQL

 

1.返回頂部

一、

Node.js 鏈接 MySQL

本章節咱們將爲你們介紹如何使用 Node.js 來鏈接 MySQL，並對數據庫進行操做。

若是你尚未 MySQL 的基本知識，能夠參考咱們的教程：MySQL 教程。

本教程使用到的 Websites 表 SQL 文件：websites.sql。

安裝驅動

本教程使用了淘寶定製的 cnpm 命令進行安裝：

$ cnpm install mysql

鏈接數據庫

在如下實例中根據你的實際配置修改數據庫用戶名、及密碼及數據庫名：

test.js 文件代碼：

var mysql      = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'root',
  password : '123456',
  database : 'test'
});
 
connection.connect();
 
connection.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results[0].solution);
});

執行如下命令輸出就結果爲：

$ node test.js
The solution is: 2

數據庫鏈接參數說明：

參數	描述
host	主機地址 （默認：localhost）
user	用戶名
password	密碼
port	端口號 （默認：3306）
database	數據庫名
charset	鏈接字符集（默認：'UTF8_GENERAL_CI'，注意字符集的字母都要大寫）
localAddress	此IP用於TCP鏈接（可選）
socketPath	鏈接到unix域路徑，當使用 host 和 port 時會被忽略
timezone	時區（默認：'local'）
connectTimeout	鏈接超時（默認：不限制；單位：毫秒）
stringifyObjects	是否序列化對象
typeCast	是否將列值轉化爲本地JavaScript類型值 （默認：true）
queryFormat	自定義query語句格式化方法
supportBigNumbers	數據庫支持bigint或decimal類型列時，須要設此option爲true （默認：false）
bigNumberStrings	supportBigNumbers和bigNumberStrings啓用 強制bigint或decimal列以JavaScript字符串類型返回（默認：false）
dateStrings	強制timestamp,datetime,data類型以字符串類型返回，而不是JavaScript Date類型（默認：false）
debug	開啓調試（默認：false）
multipleStatements	是否許一個query中有多個MySQL語句 （默認：false）
flags	用於修改鏈接標誌
ssl	使用ssl參數（與crypto.createCredenitals參數格式一至）或一個包含ssl配置文件名稱的字符串，目前只捆綁Amazon RDS的配置文件

更多說明可參見：https://github.com/mysqljs/mysql

---

數據庫操做( CURD )

在進行數據庫操做前，你須要將本站提供的 Websites 表 SQL 文件websites.sql 導入到你的 MySQL 數據庫中。

本教程測試的 MySQL 用戶名爲 root，密碼爲 123456，數據庫爲 test，你須要根據本身配置狀況修改。

查詢數據

將上面咱們提供的 SQL 文件導入數據庫後，執行如下代碼便可查詢出數據：

查詢數據

var mysql  = require('mysql');  
 
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'test', 
}); 
 
connection.connect();
 
var  sql = 'SELECT * FROM websites';
//查
connection.query(sql,function (err, result) {
        if(err){
          console.log('[SELECT ERROR] - ',err.message);
          return;
        }
 
       console.log('--------------------------SELECT----------------------------');
       console.log(result);
       console.log('------------------------------------------------------------\n\n');  
});
 
connection.end();

執行如下命令輸出就結果爲：

$ node test.js --------------------------SELECT---------------------------- [ RowDataPacket { id: 1, name: 'Google', url: 'https://www.google.cm/', alexa: 1, country: 'USA' }, RowDataPacket { id: 2, name: '淘寶', url: 'https://www.taobao.com/', alexa: 13, country: 'CN' }, RowDataPacket { id: 3, name: '菜鳥教程', url: 'http://www.runoob.com/', alexa: 4689, country: 'CN' }, RowDataPacket { id: 4, name: '微博', url: 'http://weibo.com/', alexa: 20, country: 'CN' }, RowDataPacket { id: 5, name: 'Facebook', url: 'https://www.facebook.com/', alexa: 3, country: 'USA' } ] ------------------------------------------------------------

插入數據

咱們能夠向數據表 websties 插入數據：

插入數據

var mysql  = require('mysql');  
 
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'test', 
}); 
 
connection.connect();
 
var  addSql = 'INSERT INTO websites(Id,name,url,alexa,country) VALUES(0,?,?,?,?)';
var  addSqlParams = ['菜鳥工具', 'https://c.runoob.com','23453', 'CN'];
//增
connection.query(addSql,addSqlParams,function (err, result) {
        if(err){
         console.log('[INSERT ERROR] - ',err.message);
         return;
        }        
 
       console.log('--------------------------INSERT----------------------------');
       //console.log('INSERT ID:',result.insertId);        
       console.log('INSERT ID:',result);        
       console.log('-----------------------------------------------------------------\n\n');  
});
 
connection.end();

執行如下命令輸出就結果爲：

$ node test.js --------------------------INSERT---------------------------- INSERT ID: OkPacket { fieldCount: 0, affectedRows: 1, insertId: 6, serverStatus: 2, warningCount: 0, message: '', protocol41: true, changedRows: 0 } -----------------------------------------------------------------

執行成功後，查看數據表，便可以看到添加的數據：

更新數據

咱們也能夠對數據庫的數據進行修改：

更新數據

var mysql  = require('mysql');  
 
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'test', 
}); 
 
connection.connect();
 
var modSql = 'UPDATE websites SET name = ?,url = ? WHERE Id = ?';
var modSqlParams = ['菜鳥移動站', 'https://m.runoob.com',6];
//改
connection.query(modSql,modSqlParams,function (err, result) {
   if(err){
         console.log('[UPDATE ERROR] - ',err.message);
         return;
   }        
  console.log('--------------------------UPDATE----------------------------');
  console.log('UPDATE affectedRows',result.affectedRows);
  console.log('-----------------------------------------------------------------\n\n');
});
 
connection.end();

執行如下命令輸出就結果爲：

--------------------------UPDATE---------------------------- UPDATE affectedRows 1 -----------------------------------------------------------------

執行成功後，查看數據表，便可以看到更新的數據：

刪除數據

咱們能夠使用如下代碼來刪除 id 爲 6 的數據:

刪除數據

var mysql  = require('mysql');  
 
var connection = mysql.createConnection({     
  host     : 'localhost',       
  user     : 'root',              
  password : '123456',       
  port: '3306',                   
  database: 'test', 
}); 
 
connection.connect();
 
var delSql = 'DELETE FROM websites where id=6';
//刪
connection.query(delSql,function (err, result) {
        if(err){
          console.log('[DELETE ERROR] - ',err.message);
          return;
        }        
 
       console.log('--------------------------DELETE----------------------------');
       console.log('DELETE affectedRows',result.affectedRows);
       console.log('-----------------------------------------------------------------\n\n');  
});
 
connection.end();

執行如下命令輸出就結果爲：

--------------------------DELETE---------------------------- DELETE affectedRows 1 -----------------------------------------------------------------

執行成功後，查看數據表，便可以看到 id=6 的數據已被刪除：

二、

2.返回頂部

 

3.返回頂部

 

4.返回頂部

 

5.返回頂部

一、

http://www.runoob.com/nodejs/nodejs-mysql.html

二、

 

6.返回頂部

 

做者：ylbtech 出處：http://ylbtech.cnblogs.com/ 本文版權歸做者和博客園共有，歡迎轉載，但未經做者贊成必須保留此段聲明，且在文章頁面明顯位置給出原文鏈接，不然保留追究法律責任的權利。