(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); }) })