如何使用Node.js和MySQL数据库连接池连接数据库?
作者:暮色微凉
时间:2023-05-07
浏览:2
mysql有两种连接方式:一种是直接连接另一种是池化连接,我们这篇讲的是池化连接。为了让解惑,我简答的写份直接连接的代码,如下:varmysql=require('mysql');varconnection=mysql.createConnection({host:'localhost',user:'ac',password:'123456',database:'textPro'});connection.connect();
mysql有两种连接方式:一种是直接连接 另一种是池化连接,我们这篇讲的是池化连接。
为了让解惑,我简答的写份直接连接的代码,如下:
var mysql = require('mysql');
var connection = mysql.createConnection({
host : 'localhost',
user : 'ac',
password : '123456',
database : 'textPro'
});
connection.connect();
connection.query('SELECT * from1 userInfo', function (error, results, fields) {
if (error) throw error;
console.log('The solution is: ', results);
});
connection.end();createConnection和createPool的区别是: createPool(连接池)连接可以更加合理的利用服务器资料,减少资料浪费
安装之后在db/index.js中开始编写:
const mysql = require("mysql")
//创建连接池
const db= mysql.createPool({
host : 'localhost', //连接主机
port : 3306, //端口号
database : 'test', //连接的是哪一个库
user : 'root', //用户名
password : '', //密码
connectionLimit : 50, //用于指定连接池中最大的链接数,默认属性值为10.
//用于指定允许挂起的最大连接数,如果挂起的连接数超过该数值,就会立即抛出一个错误,
//默认属性值为0.代表不允许被挂起的最大连接数。
queueLimit:3
})建立了连接池之后,可以直接使用连接池对象的getConnection方法从连接池中获取一个连接,如果连接池中没有可用连接,将隐式的建立一个数据库连接。
const mysql = require("mysql")
//创建连接池
const db= mysql.createPool({
host : 'localhost', //连接主机
port : 3306, //端口号
database : 'test', //连接的是哪一个库
user : 'root', //用户名
password : '', //密码
connectionLimit : 50, //用于指定连接池中最大的链接数,默认属性值为10.
//用于指定允许挂起的最大连接数,如果挂起的连接数超过该数值,就会立即抛出一个错误,
//默认属性值为0.代表不允许被挂起的最大连接数。
queueLimit:3
})
module.exports.query = (sql, values.callback) => {
//err: 该参数是指操作失败时的错误对象。
//connection: 该值为一个对象,代表获取到的连接对象。当连接失败时,该值为undefined。
db.getConnection(function(err, connection) {
if (err) {
console.log('与mysql数据库建立连接失败');
pool.releaseConnection(); //释放链接
} else {
console.log('与mysql数据库建立连接成功');
connection.query(sql,values,(err, res) => {
if (err) {
console.log('执行sql语句失败,查询数据失败');
//connection.release() 当一个连接不需要使用时,使用该方法将其归还到连接池中 release释放
connection.release();
callback(err,null)
} else {
console.log('执行sql语句成功');
callback(null,res)
//pool.end() 当一个连接池不需要使用时,可以使用该方法关闭连接池
pool.end();
}
})
}
})
}引入 调用db模块
const query=require('./db').query;
let sql='SELECT * FROM class WHERE class_id=? AND class_name=?'
let userId=1;
let userName='阿辰';
query(sql,[userId,userName],(err,res)=>{
if(err){
console.log('发生了错误***',err)
return
}
console.log('找到了',res)
})const query=require('./db').query与const query=require('./db')区别
第一种写法只获取到了"./db"模块中的query函数,如果需要使用其他导出项,则需要再次获取。
第二种写法获取到了"./db"模块导出的所有项,不需要在代码中反复获取不同的导出项。
作者最新文章
3dmax安装失败全是叉怎么回事?原因及解决方法
2026-10-07 10:55
Win11系统WinRAR右键选项找不到怎么解决
2026-10-01 16:58
Photoshop文字外框怎么设置?给文字加边框的实用方法
2026-09-22 16:12
3dmax快捷键失效了怎么办
2026-09-16 13:53
Xiaomi 18 Fold首销数据解读:较上代大折叠增长310%的原因与配置分析
2026-09-08 16:55
热门文章
更多
精品专题
更多
Mac软件
更多
WINDOWS
更多










































