使用 Node.js 管理 MySQL 数据库连接：针对多用户数据库的策略-js教程-PHP中文网

使用 Node.js 管理 MySQL 数据库连接：针对多用户数据库的策略

霞舞

发布： 2025-07-22 17:04:10

原创

366人浏览过

使用 node.js 管理 mysql 数据库连接：针对多用户数据库的策略

本文探讨了在 Node.js 环境下，针对每个用户拥有独立数据库的 MySQL 实例，如何高效地管理数据库连接。我们将分析 mysql Node.js 包提供的两种主要连接管理方式：使用单个连接池配合 changeUser 方法，以及使用 PoolCluster 为每个数据库创建独立的连接池。同时，我们还会讨论不使用连接池的场景，并提供基于表名添加数据库名前缀的连接方案，帮助开发者根据实际应用场景选择最佳的数据库连接管理策略。

在构建 API 或 Web 服务时，针对每个用户拥有独立数据库的 MySQL 实例，数据库连接管理是一个需要仔细考虑的问题。mysql Node.js 包提供了多种连接管理方式，本文将深入探讨这些方式，并分析其优缺点，帮助开发者选择最适合自己应用的方案。

1. 单个连接池配合 changeUser 方法

这种方式创建一个全局的连接池，所有用户共享这个连接池。当需要连接到特定用户的数据库时，使用 connection.changeUser() 方法切换数据库。

示例代码：

const mysql = require('mysql');

const pool = mysql.createPool({
    connectionLimit: 10,
    user: process.env.DB_USER,
    password: process.env.DB_PASSWORD,
    port: 3306, // default
    host: process.env.SQL_INSTANCE_HOST,
});

async function connectToUserDatabase(userDatabase) {
  const connection = await pool.getConnection();
  try {
    await new Promise((resolve, reject) => {
      connection.changeUser({ database: userDatabase }, (err) => {
        if (err) {
          reject(new Error(`Could not connect to database: ${err}`));
        } else {
          resolve();
        }
      });
    });
    return connection;
  } catch (error) {
    connection.release();
    throw error;
  }
}

// 使用示例
async function queryUserDatabase(userDatabase, query) {
  let connection;
  try {
    connection = await connectToUserDatabase(userDatabase);
    const [rows, fields] = await connection.execute(query);
    return rows;
  } catch (error) {
    console.error("Error querying database:", error);
    throw error;
  } finally {
    if (connection) {
      connection.release();
    }
  }
}

// 示例调用
queryUserDatabase('USER1', 'SELECT * FROM mytable')
  .then(results => console.log(results))
  .catch(err => console.error(err));

登录后复制

优点：

资源利用率高：所有用户共享一个连接池，可以减少连接资源的开销。
配置简单：只需要配置一个连接池。

缺点：

安全性：如果连接池配置错误，可能会导致用户访问到其他用户的数据库。
性能：频繁切换数据库可能会影响性能，尤其在高并发场景下。

2. PoolCluster 为每个数据库创建独立的连接池

PoolCluster 允许为不同的数据库创建独立的连接池，每个连接池拥有自己的配置。

示例代码：

const mysql = require('mysql');

const poolCluster = mysql.createPoolCluster();

poolCluster.add('USER1', {
  connectionLimit: 10,
  user: process.env.DB_USER,
  password: process.env.DB_PASSWORD,
  port: 3306,
  host: process.env.SQL_INSTANCE_HOST,
  database: 'USER1'
});

poolCluster.add('USER2', {
  connectionLimit: 10,
  user: process.env.DB_USER,
  password: process.env.DB_PASSWORD,
  port: 3306,
  host: process.env.SQL_INSTANCE_HOST,
  database: 'USER2'
});

// 使用示例
async function queryUserDatabase(userKey, query) {
  return new Promise((resolve, reject) => {
    poolCluster.getConnection(userKey, (err, connection) => {
      if (err) {
        reject(err);
        return;
      }

      connection.query(query, (error, results, fields) => {
        connection.release(); // Always release the connection!

        if (error) {
          reject(error);
          return;
        }

        resolve(results);
      });
    });
  });
}

// 示例调用
queryUserDatabase('USER1', 'SELECT * FROM mytable')
  .then(results => console.log(results))
  .catch(err => console.error(err));

登录后复制

优点：

安全性：每个数据库拥有独立的连接池，可以避免用户访问到其他用户的数据库。
性能：避免了频繁切换数据库的开销，可以提高性能。

缺点：

资源开销大：每个数据库都需要创建一个连接池，会增加资源开销。
配置复杂：需要为每个数据库配置连接池。

3. 不使用连接池

如果用户对 API 的访问频率很低，可以考虑不使用连接池，每次请求都创建一个新的连接。

库宝AI

库宝AI是一款功能多样的智能伙伴助手，涵盖AI写作辅助、智能设计、图像生成、智能对话等多个方面。

109

查看详情

示例代码：

const mysql = require('mysql');

async function queryUserDatabase(userDatabase, query) {
  const connection = mysql.createConnection({
    user: process.env.DB_USER,
    password: process.env.DB_PASSWORD,
    port: 3306,
    host: process.env.SQL_INSTANCE_HOST,
    database: userDatabase
  });

  return new Promise((resolve, reject) => {
    connection.connect(err => {
      if (err) {
        reject(err);
        return;
      }

      connection.query(query, (error, results, fields) => {
        connection.end(); // Close the connection!

        if (error) {
          reject(error);
          return;
        }

        resolve(results);
      });
    });
  });
}

// 示例调用
queryUserDatabase('USER1', 'SELECT * FROM mytable')
  .then(results => console.log(results))
  .catch(err => console.error(err));

登录后复制

优点：

简单：不需要配置连接池。
资源利用率：当用户访问频率低时，能避免连接池占用资源。

缺点：

性能：每次请求都需要创建和关闭连接，会增加延迟。
不适合高并发场景。

4. 使用表名前缀

如果可以使用相同的用户名/密码访问所有数据库，可以在查询时使用表名前缀来指定数据库。

示例代码：

const mysql = require('mysql');

const pool = mysql.createPool({
    connectionLimit: 10,
    user: process.env.DB_USER,
    password: process.env.DB_PASSWORD,
    port: 3306, // default
    host: process.env.SQL_INSTANCE_HOST,
});

async function queryUserDatabase(userDatabase, query) {
  const connection = await pool.getConnection();
  try {
    const prefixedQuery = query.replace(/tablename/g, `${userDatabase}.tablename`); // Replace tablename with database.tablename
    const [rows, fields] = await connection.execute(prefixedQuery);
    return rows;
  } catch (error) {
    console.error("Error querying database:", error);
    throw error;
  } finally {
    connection.release();
  }
}

// 示例调用
queryUserDatabase('USER1', 'SELECT * FROM tablename')
  .then(results => console.log(results))
  .catch(err => console.error(err));

登录后复制

优点：