MySQL Node.js通过SSH连接

在本文中，我们将介绍如何使用Node.js通过SSH连接MySQL数据库。

阅读更多：MySQL 教程

什么是SSH？

SSH（Secure Shell）是一种从远程计算机安全地访问另一台计算机的协议。它允许用户使用加密的网络协议连接到远程计算机并进行管理、文件传输和其他操作。通过SSH，用户可以在不暴露敏感信息的情况下，从本地计算机安全地访问服务器。

MySQL的SSH连接

下面是通过SSH连接MySQL的步骤。

确保SSH服务器和MySQL服务器都已启动并运行。您需要知道SSH服务器和MySQL服务器的IP地址。
安装Node.js mysql和ssh2模块。使用npm命令安装这些模块。

   npm install mysql ssh2
   ```

3. 在Node.js代码的顶部引入所需的库。

   ```javascript
   const mysql = require('mysql');
   const ssh2 = require('ssh2');
   ```

4. 创建一个SSH连接实例。您需要提供SSH服务器的连接信息和凭证。

   ```javascript
   const ssh = new ssh2.Client();
   ssh.connect({
     host: 'ssh.example.com',
     username: 'your_ssh_username',
     password: 'your_ssh_password'
   });
   ```

5. 创建一个MySQL连接实例，同时将SSH连接实例传递给其构造函数。

   ```javascript
   const mysqlConfig = {
     host: 'localhost',
     user: 'your_mysql_username',
     password: 'your_mysql_password',
     database: 'your_mysql_database'
   };

   const mysqlConnection = mysql.createConnection({
     stream: ssh.forwardOut(
       // SSH连接的配置
       '127.0.0.1',
       22,
       // MySQL连接的配置
       '127.0.0.1',
       3306
     ),
     ...mysqlConfig
   });
   ```

6. 现在，您可以使用`mysqlConnection`对象执行MySQL查询。

   ```javascript
   mysqlConnection.query('SELECT * FROM users', (err, rows, fields) => {
     if (err) throw err;
     console.log(rows);
   });
   ```

   这将查询MySQL数据库中的用户表，并将结果打印到控制台。

## 示例代码

完整的示例代码如下。

```javascript
const mysql = require('mysql');
const ssh2 = require('ssh2');

const ssh = new ssh2.Client();
ssh.connect({
  host: 'ssh.example.com',
  username: 'your_ssh_username',
  password: 'your_ssh_password'
});

const mysqlConfig = {
  host: 'localhost',
  user: 'your_mysql_username',
  password: 'your_mysql_password',
  database: 'your_mysql_database'
};

const mysqlConnection = mysql.createConnection({
  stream: ssh.forwardOut(
    // SSH连接的配置
    '127.0.0.1',
    22,
    // MySQL连接的配置
    '127.0.0.1',
    3306
  ),
  ...mysqlConfig
});

mysqlConnection.query('SELECT * FROM users', (err, rows, fields) => {
  if (err) throw err;
  console.log(rows);
});

mysqlConnection.end(() => {
  ssh.end();
});