Node.js查询MySQL并返回结果集给客户端的全过程

下面提供一个完整的“Node.js查询MySQL并返回结果集给客户端的全过程”。

步骤一：安装和配置

首先，在本地安装Node.js和MySQL服务。然后，使用npm安装mysql模块，它是连接到MySQL的标准Node.js库。可以在终端中运行以下命令进行安装：

npm install mysql

接下来，在项目中引入mysql模块，以便使用它的API：

const mysql = require('mysql');

在使用mysql模块前还需要建立与MySQL数据库的连接。可以使用以下代码对连接MySQL数据库：

const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'test_database'
});

connection.connect((err) => {
  if (err) {
    console.error('Unable to connect to the database:', err);
  } else {
    console.log('Connection to MySQL database succeeded.');
  }
});

此处的参数需要根据实际连接的数据库进行配置。

步骤二：查询数据

建立连接之后，就可以根据需要查询数据了。可以使用connection.query()方法执行SQL查询语句，并在回调函数中处理结果集。例如：

connection.query('SELECT * FROM users', (error, results, fields) => {
  if (error) {
    console.error('Error during query execution:', error);
  } else {
    console.log('Query results:', results);
  }
});

在此处的查询语句中，查询了名为users的MySQL表。回调函数中的error参数包含了在查询过程中发生的任何错误信息。results参数包含了查询结果集，它可以是一个对象数组或一个空数组。

步骤三：返回结果

现在已经可以查询数据并且可以在回调函数中处理结果，下一步就是将查询结果返回给客户端。可以使用Express框架来完成这个任务。

需要首先创建一个Express应用程序，并通过HTTP请求响应与之相关的路由。例如：

const express = require('express');
const app = express();
const port = 3000;

app.get('/users', (req, res) => {
  connection.query('SELECT * FROM users', (error, results, fields) => {
    if (error) {
      console.error('Error during query execution:', error);
      res.status(500).send('Server error during query execution.');
    } else {
      console.log('Query results:', results);
      res.json(results);
    }
  });
});

app.listen(port, () => {
  console.log(`Server listening on port ${port}.`);
});

在这里创建一个简单的Express应用程序，它监听3000端口，并有一个GET路由/users，当请求到达该路由时，会执行之前所述的查询语句并返回JSON格式的查询结果。

示例1：查询文章列表

例如，需要返回文章列表和它们的作者，可以先创建与文章和作者表相对应的ORM模型，然后可以使用以下查询：

app.get('/articles', (req, res) => {
  const query = `
    SELECT
      articles.id,
      articles.title,
      authors.name AS author_name
    FROM
      articles
      INNER JOIN authors ON articles.author_id = authors.id
  `;

  connection.query(query, (error, results, fields) => {
    if (error) {
      console.error('Error during query execution:', error);
      res.status(500).send('Server error during query execution.');
    } else {
      console.log('Query results:', results);
      res.json(results);
    }
  });
});

在此示例中，查询了名为articles和authors的两个MySQL表，并且查询结果中包括了文章ID、标题以及作者的名字。

示例2：按条件查询数据

例如，需要根据不同的查询条件对数据库中的表进行查询，可以使用占位符?来表示查询条件，并将查询条件作为数组传递给connection.query()函数。下面是一个示例：

app.get('/usersbyage/:age', (req, res) => {
  const age = req.params.age;
  const query = `
    SELECT
      id,
      name,
      age,
      email
    FROM
      users
    WHERE
      age > ?
  `;

  connection.query(query, [age], (error, results, fields) => {
    if (error) {
      console.error('Error during query execution:', error);
      res.status(500).send('Server error during query execution.');
    } else {
      console.log('Query results:', results);
      res.json(results);
    }
  });
});

在此示例中，将GET请求的URL中的age参数用作查询条件，并获取该参数的值。然后，查询了名为users的MySQL表，并使用?占位符表示查询条件。最后将查询条件放入数组中并作为参数传递给connection.query()函数。

总结

以上就是Node.js查询MySQL并返回结果集给客户端的全过程。首先需要安装和配置相关环境和模块，然后根据需要执行查询操作，并处理查询结果集。最后可以使用Express框架将查询结果返回给客户端。