Express连接MySQL及数据库连接池技术实例

Express连接MySQL

 

准备工作

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

创建成功后其页面如下：

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

 

创建配置文件

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

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

 

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

const express = require("express");
const router = express.Router();
//导入MySQL 模块
const mysql = require("mysql");
//导入配置文件
const db = require("../config/configdb");

router.get("test",(req,res)=>{
    //创建数据库连接对象
    let conn = mysql.createConnection(db);
    //查询bookinfo中所有数据
    conn.query("select * from student",(err,results,fieldes)=>{
        //fieldes表示具体的字段
        if(err){
            throw err;
        }
        res.send(results);
    })
    //关闭数据库链接
    conn.end((err)=>{
        console.log(err);
})
module.exports = router;

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

var dbRouter = require("./routes/option")
app.use("/db",dbRouter);

在Postman中测试如下：

 

数据库连接池技术

 

什么是数据库连接池

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

 

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

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

 

数据库连接池技术实例

 

1、导入mysql模块

var mysql = require("mysql"); 

 

2、创建数据库连接池

创建连接池

var pool = mysql.createPool(options);

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

//创建数据库连接池
const pool = 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 {
        let sql = "select * from bookinfo";
        conn.query(sql, (err, results) => {
            if (err) {
                console.log(err)
            } else {
                res.send(results);
                conn.release();
            }
        })
    }
})

 

4、释放数据库连接对象

conn.release();

 

完整实例

const express = require("express");
const pool = require("../config/dbmysql");

const router = express.Router();
/*
* http://localhost:3000/dbmysql/books
* */
router.get("/books",(req,res)=>{
    //从数据库连接池中获取数据库连接对象
    pool.getConnection((err,conn)=>{
        if(err){
            console.log(err)
        }else {
            let sql = "select * from bookinfo";
            conn.query(sql,(err,results)=>{
                if (err) {
                    console.log(err)
                }else {
                    res.send(results);
                    conn.release();
                }
            })
        }
    })
})
module.exports = router;

结果测试：

到此这篇关于Express连接MySQL及数据库连接池技术的文章就介绍到这了,更多相关Express连接mysql内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！

原文链接：https://blog.csdn.net/shao_xuan_/article/details/122969309