Express连接MySQL及数据库连接池的示例分析

魁首哥

作者

Express连接MySQL及数据库连接池的示例分析

这篇文章主要介绍Express连接MySQL及数据库连接池的示例分析，文中介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们一定要看完！

Express连接MySQL

准备工作

打开webstorm新建项目选择express创建一个express项目。

创建成功后其页面如下：

为了连接mysql数据库还需要导入mysql模块。

创建配置文件

在项目中创建config文件，在config文件中创建congfigdb.js文件用来连接数据库，在文件中写入：

varmysql={host:"127.0.0.1",//这是数据库的地址user:"root",//需要用户的名字password:"root23",//用户密码，如果你没有密码，直接双引号就是database:"info",//数据库名字port:3306//数据库使用的端口号}module.exports=mysql;//用module.exports暴露出这个接口

创建操作数据库的接口文件

constexpress=require('express');constrouter=express.Router();//导入MySQL模块constmysql=require('mysql');//导入配置文件constdb=require('../config/configdb');router.get('test',(req,res)=>{//创建数据库连接对象letconn=mysql.createConnection(db);//查询bookinfo中所有数据conn.query('select*fromstudent',(err,results,fieldes)=>{//fieldes表示具体的字段if(err){throwerr;}res.send(results);})//关闭数据库链接conn.end((err)=>{console.log(err);})module.exports=router;

完成之后在app.js文件中添加：

vardbRouter=require('./routes/option')app.use('/db',dbRouter);

在Postman中测试如下：

数据库连接池技术

什么是数据库连接池

数据库连接池是程序启动时建立足够数量的数据库连接对象，并将这些连接对象组成一个池，由程序动态地对池中的连接对象进行申请、使用和释放。

数据库连接池的作用是什么？

数据库的连接池负责分配、管理和释放数据库连接对象的。它允许应用程序重复使用一个现有的数据库的连接对象。而不是重新创建一个。

数据库连接池技术实例

1、导入mysql模块

varmysql=require('mysql');

2、创建数据库连接池

创建连接池

varpool=mysql.createPool(options);

options 参数是一个对象，该对象中有很多属性配置，该对象的作用是用于指定该连接池中连接统一使用的各种选项。

//创建数据库连接池constpool=mysql.createPool({connectionLimit:20,host:'localhost',port:3306,user:'root',password:'123456',database:'info'})//导出数据库连接池对象module.exports=pool;

connectionLimit：用于指定连接池中最大的链接数，默认属性值为10.
queueLimit：用于指定允许挂起的最大连接数，如果挂起的连接数超过该数值，就会立即抛出一个错误，默认属性值为0.代表不允许被挂起的最大连接数。
multipleStatements ：是否允许执行多条sql语句，默认值为false
host：数据库服务器的地址
user：连接数据库的用户名
password：连接数据库的密码
database：数据库名

3、获取数据库链接对象

pool.getConnection((err,conn)=>{if(err){console.log(err)}else{letsql='select*frombookinfo';conn.query(sql,(err,results)=>{if(err){console.log(err)}else{res.send(results);conn.release();}})}})

4、释放数据库连接对象

conn.release();

完整实例

constexpress=require('express');constpool=require('../config/dbmysql');constrouter=express.Router();/**http://localhost:3000/dbmysql/books**/router.get('/books',(req,res)=>{//从数据库连接池中获取数据库连接对象pool.getConnection((err,conn)=>{if(err){console.log(err)}else{letsql='select*frombookinfo';conn.query(sql,(err,results)=>{if(err){console.log(err)}else{res.send(results);conn.release();}})}})})module.exports=router;

结果测试：