nodejs進階(6)—連接MySQL數據庫

1. 建庫連庫

連接MySQL數據庫需要安裝支持

npm install mysql

我們需要提前安裝按mysql sever端

建一個數據庫mydb1

mysql> CREATE DATABASE mydb1;
mysql> SHOW DATABASES;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| mydb1             |
| performance_schema |
+--------------------+
4 rows in set (0.00 sec)

然后建一張表user如下

create table user(  
id int not null primary key auto_increment,  
name VARCHAR(100) not null,  
pwd VARCHAR(100) not null,
create_date TIMESTAMP NULL DEFAULT now()
)ENGINE=InnoDB DEFAULT CHARSET=utf8;  
CREATE UNIQUE INDEX t_quiz_IDX_0 on user(name);

接下來我們利用nodejs連接mysql數據庫

var mysql  = require('mysql');  //調用MySQL模塊
//創建一個connection  
var connection = mysql.createConnection({      
    host: 'localhost',       //主機  
    user: 'root',               //MySQL認證用戶名  
    password: 'root',        //MySQL認證用戶密碼  
    database: 'mydb1',  
    port: '3306'                   //端口號  
});
//創建一個connection  
connection.connect(function(err){  
    if(err){         
        console.log('[query] - :'+err);  
        return;  
    }  
    console.log('[connection connect]  succeed!');  
}); 
//----插入
var userAddSql = 'insert into user (name,pwd) values(?,?)';
var param = ['fff','123'];
connection.query(userAddSql,param,function(err,rs){
    if(err){
        console.log('insert err:',err.message);
        return;
    }
        console.log('insert success');
});
//執行查詢  
connection.query('SELECT * from user where id=?',[2], function(err, rs) {  
    if (err) {  
        console.log('[query] - :'+err);  
        return;  
    } 
    for(var i=0;i<rs.length;i++){
        console.log('The solution is: ', rs[i].uname); 
    }
});   

//關閉connection  
connection.end(function(err){  
    if(err){ 
        console.log(err.toString());
        return;  
    }  
    console.log('[connection end] succeed!');  
}); 

但是實際每次創建連接都需要一定的開銷，執行效率就會有影響。下面介紹一種連接池連mysql的方法：node-mysql

2. 連接池配置使用

node-mysql是目前最火的node下的mysql驅動，是mysqlpool的一個模塊。

下面的代碼是提供一個連接池，getPool函數返回createPool創建的數據庫連接池對象。

var mysql  = require('mysql');  //調用MySQL模塊 
function OptPool(){ 
    this.flag=true; //是否連接過 
    this.pool = mysql.createPool({     
        host: 'localhost',       //主機 
        user: 'root',               //MySQL認證用戶名 
        password: 'root',        //MySQL認證用戶密碼 
        database: 'test', 
        port: '3306'                   //端口號 
    }); 
 
    this.getPool=function(){ 
         return this.pool; 
    } 
}; 
module.exports = OptPool; 

下面的代碼展示如何使用這個連接池，插入和查詢的使用。需要注意的是conn.release(); //釋放一個連接放回連接池 需要再操作結束后再執行，否則后面的數據庫操作會報錯。

 

var OptPool = require('./models/OptPool'); 
 
var optPool = new OptPool(); 
var pool = optPool.getPool(); 

//執行SQL語句 
//從連接池中獲取一個連接
pool.getConnection(function(err,conn){ 
    //----插入 
    var userAddSql = 'insert into user (uname,pwd) values(?,?)'; 
    var param = ['eee','eee'];
    conn.query(userAddSql,param,function(err,rs){
        if(err){ 
            console.log('insert err:',err.message); 
            return; 
        } 
        console.log('insert success'); 
        //conn.release(); //放回連接池
    })
    //查詢 
    conn.query('SELECT * from user', function(err, rs) { 
        if (err) { 
            console.log('[query] - :'+err); 
            return; 
        }   
        for(var i=0;i<rs.length;i++){
            console.log(rs[i].uname); 
        }
        conn.release(); //放回連接池
    });
}); 

下面介紹一個復雜一點的增刪查改的數據庫操作，因相互之間有依賴，所以代碼可讀性就變得特別差。這樣就引出了我們接下來要介紹餓流程控制的內容《nodejs進階(7)—async異步流程控制》

var OptPool = require('./models/OptPool'); 
 
var optPool = new OptPool(); 
var pool = optPool.getPool(); 

var insertSQL = 'insert into table1(name,pwd) values("conan","123"),("fens.me","456")';
var selectSQL = 'select * from table1 limit 10';
var deleteSQL = 'delete from table1';
var updateSQL = 'update table1 set name="conan update"  where name="conan"';

pool.getConnection(function(err,conn){ 
//delete
    conn.query(deleteSQL, function (err0, res0) {
        if (err0) console.log(err0);
        console.log("DELETE Return ==> ");
        console.log(res0);

        //insert
        conn.query(insertSQL, function (err1, res1) {
            if (err1) console.log(err1);
            console.log("INSERT Return ==> ");
            console.log(res1);

            //query
            conn.query(selectSQL, function (err2, rows) {
                if (err2) console.log(err2);

                console.log("SELECT ==> ");
                for (var i in rows) {
                    console.log(rows[i]);
                }

                //update
                conn.query(updateSQL, function (err3, res3) {
                    if (err3) console.log(err3);
                    console.log("UPDATE Return ==> ");
                    console.log(res3);

                    //query
                    conn.query(selectSQL, function (err4, rows2) {
                        if (err4) console.log(err4);

                        console.log("SELECT ==> ");
                        for (var i in rows2) {
                            console.log(rows2[i]);
                        }
                    });
                });
            });
        });
    });
})

 運行結果