ノード+mysqlデータベース接続プール接続の方法は何ですか?

Mysql には直接接続とプール接続の 2 つの接続方法がありますが、この記事ではプール接続について説明します。

混乱を解消するために、次のように直接接続のコードを簡単に書きます。

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」モジュール内のクエリ関数のみを取得しますので、他のエクスポート項目を使用する場合は再度取得する必要があります。

• 2 番目の記述方法では、「./db」モジュールによってエクスポートされたすべての項目を取得するため、コード内で異なるエクスポート項目を繰り返し取得する必要はありません。

以上がノード+mysqlデータベース接続プール接続の方法は何ですか?の詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。