为什么需要数据库连接池
数据库连接池，因为数据库连接需要长久保持的，只要服务器还在运行，就要保证数据库能正常操作，但是每个建立起来的连接有效时长都不是无限的，所以我们需要数据库连接池来管理我们的连接，让我们可以同时拥有很多个与数据库的连接，如果其中一个到达时长断开了，我们也可以用其他没有断开的连接操作数据库，并及时建立新的数据库连接补充。
如何使用数据库连接池
如果用SpringBoot，导入了mysql包后如果需要数据库连接池还要用别的框架，而node的mysql模块已经自带了连接池，直接可以使用，可以看出来，其实pool的使用方法和connection没有什么区别，mysql模块已经把繁琐的连接建立、连接保持、重建连接、共享连接等等都帮我们做好了，我们只要用就好了。
var mysql = require('mysql');
var pool = mysql.createPool({
connectionLimit : 10,
host : 'example.org',
user : 'bob',
password : 'secret',
database : 'my_db'
});
pool.query('SELECT 1 + 1 AS solution', function (error, results, fields) {
if (error) throw error;
console.log('The solution is: ', results[0].solution);
});
pool.query()是pool.getConnection() -> connection.query() -> connection.release() 这三步的快捷方式，这个过程就是从线程池取连接，在连接上查询，将连接放回线程池的过程，而使用三步的好处是可以将连接用于有先后顺序的执行过程，因为调用pool.query()可能会导致两个sql在两个连接上并行执行，这样就会失去先后顺序而与预想的结果不一致。
以下是官网原文
This is a shortcut for the pool.getConnection() -> connection.query() -> connection.release() code flow. Using pool.getConnection() is useful to share connection state for subsequent queries. This is because two calls to pool.query() may use two different connections and run in parallel. This is the basic structure:
pool.getConnection() -> connection.query() -> connection.release() 三步曲：
var mysql = require('mysql');
var pool = mysql.createPool(...);
pool.getConnection(function(err, connection) {
if (err) throw err; // not connected!
// Use the connection
connection.query('SELECT something FROM sometable', function (error, results, fields) {
// When done with the connection, release it.
connection.release();
// Handle error after the release.
if (error) throw error;
// Don't use the connection here, it has been returned to the pool.
});
});
使用连接池的增删查改
我们将在Node.js中使用Mysql数据库（二）连接和操作数据库中的例子修改一下，由于使用线程池，我们就不需要手动connect和end了：
var mysql = require('mysql');
var pool = mysql.createPool({
host: "localhost", // 主机名
user: "root", // 数据库用户名
password:"123", // 数据库密码
database:"CodeSharing", // 使用的数据库名
port:3306, // 数据库服务端口
charset:"utf8mb4_general_ci", // 连接字符集，默认：'UTF8_GENERAL_CI'
// 因为线程池默认的连接数等配置完全够用，这里就不修改默认配置了
});
// 增
pool.query(`insert into test(name) values(?)`,"添加成功",(error, results) =>{
if (error) throw error;
console.log(results);
});
// 删
pool.query(`delete from test where id= ?`,17,(error, results) =>{
if (error) throw error;
console.log(results);
});
// 查
pool.query('SELECT * from test', function (error, results, fields) {
if (error) throw error;
console.log("查询结果是");
console.log(results);
});
// 改
pool.query(`update test set name = "修改成功" where id = 19`,(error, results) =>{
if (error) throw error;
console.log(results);
});
// 查
pool.query('SELECT * from test', function (error, results, fields) {
if (error) throw error;
console.log("查询结果是");
console.log(results);
});
执行之前我先单独查询一下当前数据库情况：
查询结果是
[ RowDataPacket { id: 17, name: '测试数据' },
RowDataPacket { id: 18, name: '测试数据' },
RowDataPacket { id: 19, name: '测试数据' } ]
然后我们执行线程池的增删查改，看看结果如何：
咋回事啊？我不是update test set name = "修改成功" ......19修改了id为19的数据，而且看输出也成功了啊，为什么查询结果诈尸老数据？还有我这操作不是先增删后查，再改后查的吗，怎么这顺序不大对啊？
fieldCount: 0,
affectedRows: 1,
insertId: 20,
serverStatus: 2,
warningCount: 0,
message: '',
protocol41: true,
changedRows: 0 }
OkPacket {
fieldCount: 0,
affectedRows: 1,
insertId: 0,
serverStatus: 2,
warningCount: 0,
message: '',
protocol41: true,
changedRows: 0 }
查询结果是
[ RowDataPacket { id: 18, name: '测试数据' },
RowDataPacket { id: 19, name: '测试数据' },
RowDataPacket { id: 20, name: '添加成功' } ]
查询结果是
[ RowDataPacket { id: 18, name: '测试数据' },
RowDataPacket { id: 19, name: '测试数据' },
RowDataPacket { id: 20, name: '添加成功' } ]
OkPacket {
fieldCount: 0,
affectedRows: 1,
insertId: 0,
serverStatus: 2,
warningCount: 0,
message: '(Rows matched: 1 Changed: 1 Warnings: 0',
protocol41: true,
changedRows: 1 }
我们来单独执行一下查询语句：
可以看到，我们的操作的的确确生效了，该删的被删了，该改的被改了，该加的也加进去了，那么问题的答案就很明显了，答案上面提到的，pool.query()会导致sql语句并行执行的问题。
查询结果是
[ RowDataPacket { id: 18, name: '测试数据' },
RowDataPacket { id: 19, name: '修改成功' },
RowDataPacket { id: 20, name: '添加成功' } ]
注意线程池的并行操作问题
pool.query()虽然很简单，但是却可能会导致几个sql语句并行执行的问题，很多情况下我们是希望它以我们代码编写的顺序执行的，这时候就要用到上面的三步曲了，如果是可以并行执行的情况，自然是pool.query()来的简单方便啦~
这里同样给出使用三步曲完成上述操作的实现：
var mysql = require('mysql');
var pool = mysql.createPool({
host: "localhost", // 主机名
user: "root", // 数据库用户名
password:"123", // 数据库密码
database:"CodeSharing", // 使用的数据库名
port:3306, // 数据库服务端口
charset:"utf8mb4_general_ci", // 连接字符集，默认：'UTF8_GENERAL_CI'
// 因为线程池默认的连接数等配置完全够用，这里就不修改默认配置了
});
// 使用三步曲
pool.getConnection(function (err, connection) {
if (err) throw err; // not connected!
// 获取连接后执行语句
// 增
connection.query(`insert into test(name) values(?)`, "使用三步曲添加", (error, results) => {
if (error) throw error;
console.log(results);
});
// 删
connection.query(`delete from test where id= ?`, 22, (error, results) => {
if (error) throw error;
console.log(results);
});
// 查
connection.query('SELECT * from test', function (error, results, fields) {
if (error) throw error;
console.log("查询结果是");
console.log(results);
});
// 改
connection.query(`update test set name = "使用三步曲修改" where id = 24`, (error, results) => {
if (error) throw error;
console.log(results);
});
// 查
connection.query('SELECT * from test', function (error, results, fields) {
if (error) throw error;
console.log("查询结果是");
console.log(results);
// 这是最后一个请求，请求完成将连接放回线程池
connection.release();
// 捕获放回线程池时发生错误
if (error) throw error;
// 这下面无法再使用connection了
});
});
执行前数据：
查询结果是
[ RowDataPacket { id: 22, name: '测试数据' },
RowDataPacket { id: 23, name: '测试数据' },
RowDataPacket { id: 24, name: '测试数据' } ]
执行后输出结果：可以看到效果完全符合我们的预期
OkPacket {
fieldCount: 0,
affectedRows: 1,
insertId: 25,
serverStatus: 2,
warningCount: 0,
message: '',
protocol41: true,
changedRows: 0 }
OkPacket {
fieldCount: 0,
affectedRows: 1,
insertId: 0,
serverStatus: 2,
warningCount: 0,
message: '',
protocol41: true,
changedRows: 0 }
查询结果是
[ RowDataPacket { id: 23, name: '测试数据' },
RowDataPacket { id: 24, name: '测试数据' },
RowDataPacket { id: 25, name: '使用三步曲添加' } ]
OkPacket {
fieldCount: 0,
affectedRows: 1,
insertId: 0,
serverStatus: 2,
warningCount: 0,
message: '(Rows matched: 1 Changed: 1 Warnings: 0',
protocol41: true,
changedRows: 1 }
查询结果是
[ RowDataPacket { id: 23, name: '测试数据' },
RowDataPacket { id: 24, name: '使用三步曲修改' },
RowDataPacket { id: 25, name: '使用三步曲添加' } ]
