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

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
RDS MySQL Serverless 高可用系列,价值2615元额度,1个月
简介: (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数据库
开始实验后,系统会自动创建一台自建MySQL的 源数据库 ECS 实例和一台 目标数据库 RDS。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助     相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
目录
相关文章
|
2月前
|
安全 关系型数据库 MySQL
PHP与MySQL交互:从入门到实践
【9月更文挑战第20天】在数字时代的浪潮中,掌握PHP与MySQL的互动成为了开发动态网站和应用程序的关键。本文将通过简明的语言和实例,引导你理解PHP如何与MySQL数据库进行对话,开启你的编程之旅。我们将从连接数据库开始,逐步深入到执行查询、处理结果,以及应对常见的挑战。无论你是初学者还是希望提升技能的开发者,这篇文章都将为你提供实用的知识和技巧。让我们一起探索PHP与MySQL交互的世界,解锁数据的力量!
|
2月前
|
关系型数据库 MySQL 数据库
MySQL基本操作入门指南
MySQL基本操作入门指南
70 0
|
4月前
|
JavaScript 关系型数据库 MySQL
创建nodejs项目并接入mysql,完成用户相关的增删改查的详细操作
创建nodejs项目并接入mysql,完成用户相关的增删改查的详细操作
60 0
|
5天前
|
数据采集 存储 JavaScript
如何使用Puppeteer和Node.js爬取大学招生数据:入门指南
本文介绍了如何使用Puppeteer和Node.js爬取大学招生数据,并通过代理IP提升爬取的稳定性和效率。Puppeteer作为一个强大的Node.js库,能够模拟真实浏览器访问,支持JavaScript渲染,适合复杂的爬取任务。文章详细讲解了安装Puppeteer、配置代理IP、实现爬虫代码的步骤,并提供了代码示例。此外,还给出了注意事项和优化建议,帮助读者高效地抓取和分析招生数据。
如何使用Puppeteer和Node.js爬取大学招生数据:入门指南
|
13天前
|
SQL JavaScript 关系型数据库
node博客小项目:接口开发、连接mysql数据库
【10月更文挑战第14天】node博客小项目:接口开发、连接mysql数据库
|
22天前
|
SQL JavaScript 关系型数据库
Node.js 连接 MySQL
10月更文挑战第9天
17 0
|
2月前
|
SQL JavaScript 关系型数据库
Node服务连接Mysql数据库
本文介绍了如何在Node服务中连接MySQL数据库,并实现心跳包连接机制。
38 0
Node服务连接Mysql数据库
|
27天前
|
Web App开发 JSON JavaScript
深入浅出:Node.js后端开发入门与实践
【10月更文挑战第4天】在这个数字信息爆炸的时代,了解如何构建一个高效、稳定的后端系统对于开发者来说至关重要。本文将引导你步入Node.js的世界,通过浅显易懂的语言和逐步深入的内容组织,让你不仅理解Node.js的基本概念,还能掌握如何使用它来构建一个简单的后端服务。从安装Node.js到实现一个“Hello World”程序,再到处理HTTP请求,文章将带你一步步走进Node.js的大门。无论你是初学者还是有一定经验的开发者,这篇文章都将为你打开一扇通往后端开发新世界的大门。
|
2月前
|
SQL 关系型数据库 MySQL
MySQL入门到精通
MySQL入门到精通
|
3月前
|
JavaScript 关系型数据库 MySQL
node连接mysql,并实现增删改查功能
【8月更文挑战第26天】node连接mysql,并实现增删改查功能
50 3