（34）用连接池来控制mysql（入门版）
①第一步，创建一个连接池：（和之前普通创建mysql的连接对象很像）
var mysql = require("mysql");
var pool = mysql.createPool({
host: '127.0.0.1',
user: 'root',
password: '',
port: '3306',
database: 'test'
})
我们是将其单独放在一个文件，这样的话，如果以后修改mysql的连接属性（比如地址、用户名、密码、端口或者表），就不用满世界找这些东西了，只需要修改这个文件即可。
②第二步，用连接池来连接：
在连接之前，需要说明的是，之前的方法，是三步：连接（connect）、请求（query）、结束（end）。
在使用连接池的时候，也是三步：连接（getConnection），请求（query）、断开连接（release）。但区别在于，query和release可以写在getConnection这个函数里面。
具体如代码：
var db = {};
db.con = function (callback) { //callback是回调函数，连接建立后的connection作为其参数
pool.getConnection(function (err, connection) {
console.log("connect start...")
if (err) { //对异常进行处理
throw err; //抛出异常
} else {
callback(connection); //如果正常的话，执行回调函数（即请求）
}
connection.release(); //释放连接
console.log("connect end...")
})
}
第一步是创建一个空对象db，为了封装，我们把代码都放在db这个对象之中，然后导出的时候只导出db，这样可以避免对连接池属性进行误操作。
第二步是创建一个函数con作为db这个对象的一个方法，然后回调函数作为参数传递给这个con方法，也就是说，当我调用函数时，实际上是这么写的：
db.con(function (connect) {
函数内容暂略
})
这个作为参数的函数，将在con这个函数的内部被执行。
如果不太明白的话，稍后再说；
在con函数里，执行了pool.getConnection这行代码，其作用是连接mysql数据库。
他有一个回调函数，这个回调函数有两个参数，
第一个参数是err，如果出错的话，err将有值，应该对其进行处理；
第二个参数是connection，他实际上就是指连接成功后的对象，用其进行query处理，就像这样：
connection.query(mysql的语句, 可能的参数, 回调函数);
然后也用其进行释放连接：
connection.release();
console.log("connect start...")
回调函数的第一行代码是consoloe.log，通报连接开始；
console.log("connect end...")
最后一行代码通报连接结束（事实上连接可能还没有结束，因为他只是getConnection的回调函数，在其本身内部可能还有一些处理，但我们进行的处理已经结束了）；
if (err) { //对异常进行处理
throw err; //抛出异常
} else {
callback(connection); //如果正常的话，执行回调函数（即请求）
}
connection.release(); //释放连接
这里，分别是：
【1】对异常进行处理；
【2】正常情况下的处理；
【3】释放连接；
正常的处理，将连接作为参数，传递给上面mysql.con函数的参数，作为mysql.con的参数的参数进行处理。因此实际上其流程是这样的：
函数被调用（这里指con这个自定义的函数）
——》回调函数作为参数传入（con(callback)）
——》回调函数获得connection作为参数，并执行自己callback(connection)
——》回调函数内部调用自己的第一个参数（事实上就是connection）进行请求（connection.query）；
③导出封装好的db对象（其只有一个方法，那就是con）；
module.exports = db;
④假设我们把以上代码放在一个叫做db.js的文件之中。然后我们需要引用他：
var db = require('../db')
⑤然后比如我们需要请求一个数据：
db.con(function (connect) {
connect.query('SELECT * FROM bloguser WHERE username = ?', [username], function (err, result) {
if (err) {
console.log("select username:" + username + " error, the err information is " + err);
return
}
console.log(result);
})
})
注意，我们所有请求数据的内容，都写在了这个con的回调函数中，由于封装好了，因此我们不关心他如何去连接数据库，如何断开。只需要关心请求这一步即可。
query是其自带的方法，因此我们按要求调用即可；
在请求后，我们依然是分别对err和结果进行处理；
假如err，提示错误，然后返回（这里的返回指的是返回在调用这个db.con的方法的地方）；
假如正确，那么console.log结果。
⑥当这个时候，我们利用连接池来请求mysql数据库的行为就完毕了。
下面附上完全的代码：
db.js
var mysql = require("mysql");
var pool = mysql.createPool({
host: '127.0.0.1',
user: 'root',
password: '',
port: '3306',
database: 'test'
})
var db = {};
db.con = function (callback) { //callback是回调函数，连接建立后的connection作为其参数
pool.getConnection(function (err, connection) {
console.log("connect start...")
if (err) { //对异常进行处理
throw err; //抛出异常
} else {
callback(connection); //如果正常的话，执行回调函数（即请求）
}
connection.release(); //释放连接
console.log("connect end...")
})
}
module.exports = db;
查询的js文件（需要修改表名，字段名，建议练手时把查询条件写死，能正常运行后再修改）：
var db = require('../db')
db.con(function (connect) {
connect.query('SELECT * FROM bloguser WHERE username = ?', [username], function (err, result) {
if (err) {
console.log("select username:" + username + " error, the err information is " + err);
return callback(err);
}
console.log(result);
})
})
