开发者社区> 零零水> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

NodeJs——(13)用连接池来控制mysql(入门版)

简介: (34)用连接池来控制mysql(入门版) ①第一步,创建一个连接池:(和之前普通创建mysql的连接对象很像) var mysql = require("mysql"); var pool = mysql.createPool({ host: '127.0.0.1', user: 'root', password: '', port: '3306',
+关注继续查看

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


版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
mysql的连接查询
首先创建两张表,一个student_table,一个salary。表名起的不是合乎情景,就这样吧。 use mysql; create table student_table( id varchar(25), name varchar(25), brith varchar(25), sex varchar(25) ); insert into student_table values ('1004' , '张三' ,'2000-08-06' , '男'), ('1009' , '李四', '2000-01-01', '男'), ('1010' , '李四', '2001-01-01', '男'
24 0
MySQL连接查询
MySQL连接查询
30 0
node.js连接数据库(mysql)
node 连接数据库 这里默认你安装了Node 安装 express 依赖 npm install express --save 安装mysql npm install mysql --save 创建项目 express myapp cd myapp 在myapp 目录下npm install 安装mysql数据库http://www.
1032 0
mysql连接查询
以前查询都是随便查到结果就行了,因为发现每次查询的数量都很少,当然现在也是。不过效率一直是程序员执着的追求,我就多了解下差距。 首先是多张表联合,一张模板种类category,一张模板表template,一张橱窗表shopwin,一张橱窗类型表type     现在要查询一个橱窗类型为1,即shopwin中type=1的模板信息。
560 0
MySQL 连接
MySQL 连接 使用mysql二进制方式连接 您可以使用MySQL二进制方式进入到mysql命令提示符下来连接MySQL数据库。 实例 以下是从命令行中连接mysql服务器的简单实例: [root@host]# mysql -u root -pEnter password:****** 在登录成功后会出现 mysql> 命令提示窗口,你可以在上面执行任何 SQL 语句。
827 0
MySQL 连接
MySQL 连接 使用mysql二进制方式连接 您可以使用MySQL二进制方式进入到mysql命令提示符下来连接MySQL数据库。 实例 以下是从命令行中连接mysql服务器的简单实例: [root@host]# mysql -u root -pEnter password:****** 在登录成功后会出现 mysql> 命令提示窗口,你可以在上面执行任何 SQL 语句。
992 0
+关注
零零水
主攻JS
234
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载