《node.js权威指南》（五）node.js在MySQL数据库

接下来，我们以mySQL数据库为例，介绍如何在Node.js中使用数据库。
首先，需要先使用npm包管理工具安装MySQL客户端开发包
npm install mysql

引入数据库

var mysql = require('mysql')

建立连接

案例如下

var mysql = require('mysql')
var connection = mysql.createConnection({
    host:'172.16.20.103',
    port:3308,
    database:'test',
    user:'JRJ_Win',
    password:'FT%^$fjYR56'
})
connection.connect(function(err){
    if(err){
        console.log(err)
        console.log('与mysql数据库连接失败')
    }else{
        console.log('与mysql数据库连接成功')
        connection.end(function(err){
            if (err) {
                console.log('关闭mysql数据库失败')
            }else{
                console.log('关闭mysql数据库成功')
            }
        })
    }
})

案例效果

执行数据库的基本处理

connection.query(sql,[parameters],callback)

案例如下

var mysql = require('mysql')
var connection = mysql.createConnection({
    host:'172.16.20.103',
    port:3308,
    database:'test',
    user:'JRJ_Win',
    password:'FT%^$fjYR56'
})
connection.connect(function(err){
    if(err){
        console.log(err)
        console.log('与mysql数据库连接失败')
    }else{
        console.log('与mysql数据库连接成功')
        connection.query('INSERT INTO win.luck_fine SET?',{username:'范小饭',age:18,sex:'女',dec:'爱吃'},function(err){
            if(err){
                console.log(err)
                console.log('插入数据失败')
            }else{
                console.log('插入数据成功')
                connection.query('SELECT * FROM ??',['win.luck_fine'],function(err,result){
                    if(err){
                        console.log('查询数据失败')
                    }else{
                        console.log(result);
                        connection.end();
                    }
                })
            }
        })
    }
})

案例效果

以数据流的方式处理查询数据

有时，用户也许会查询大量数据并希望单独处理每一条单查询的数据，在mysql模块中，connection对象的query方法返回一个可用于处理数据流数据的对象。如果使用queru方法的对象，那么在query方法中不能使用callback参数指定回调函数

var mysql = require('mysql')
var fs = require('fs')
var connection = mysql.createConnection({
    host:'172.16.20.103',
    port:3308,
    database:'test',
    multipleStatements:true,
    user:'JRJ_Win',
    password:'FT%^$fjYR56'
})
var out = fs.createWriteStream('./message.txt')
out.on('error',function(err){
    console.log('写文件操作失败');
    process.exit();
})
connection.connect(function(err){
    if(err){
        console.log('与mysql数据库连接失败')
    }else{
        console.log('与mysql数据库连接成功')
        var query = connection.query('select * from win.luck_fine') 
        query.on('error',function(err){
            console.log('写文件操作失败');
            process.exit();
        })
        query.on('fields',function(fields){
            var str = '';
            fields.forEach(function(field){
                if(str != ''){
                    str += String.fromCharCode(9);
                }else{
                    str += fields.username;
                }
            })
            out.write(str+'\r\n');
        })
        query.on('result',function(row){
            connection.pause()
            out.write(row.username+row.dec+'\r\n',function(err){
                connection.resume()
            })
        })
        query.on('end',function(row){
            console.log('数据全部写入完毕')
            connection.end();
        })
    }
})

案例效果

创建连接池

在开发一个web应用程序时，建立一个数据库链接所消耗的性能成本是比较高的，在服务器应用程序中，如果为每一个接收到的客户端请求都建立一个或多个数据库连接，将严重降低应用程序的性能，因此，在服务器应用程序中，同城需要为多个成数据连接创建并维护一个连接池，当连接不再需要使用时，这些连接可以缓存在连接池中，当接受到下一个客户端请求时，可以从连接池中取出连接并重新利用，不需要再重新建立数据库连接。
var pool = mysql.createPool(options)

案例如下

var mysql = require('mysql')
var pool = mysql.createPool({
    host:'172.16.20.103',
    port:3308,
    database:'test',
    user:'JRJ_Win',
    password:'FT%^$fjYR56'
})
pool.getConnection(function(err,connection){
    if(err){
        console.log(err)
        console.log('与mysql数据库连接失败')
    }else{
        console.log('与mysql数据库连接成功')
        connection.query('select * from win.luck_fine',function(err,rows){
            if(err){
                console.log('查询数据操作失败')
            }else{
                console.log(rows)
                pool.end();
            }
        })
    }
})

案例效果

---

同志们，点赞不花钱呀! 程序猿不易，且行且珍惜~