当前位置：首页 > article >正文

expressjs，MySQL，实现分页查询接口

article 2024/10/7 5:39:58

在 Express.js 中实现一个分页查询接口，并使用 MySQL 作为数据库，你可以按照以下步骤进行。我们将使用 mysql2 库来连接 MySQL 数据库，并使用 sequelize 或直接编写 SQL 查询来实现分页功能。

1. 安装必要的依赖

首先，你需要安装 express 和 mysql2 库。如果你打算使用 Sequelize ORM，也可以安装 sequelize。

npm install express mysql2
# 如果你打算使用 Sequelize
# npm install sequelize mysql2

2. 设置 Express 应用和 MySQL 连接

创建一个 app.js 文件，并设置 Express 应用和 MySQL 连接。

const express = require('express');
const mysql = require('mysql2/promise');

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

// MySQL 连接配置
const dbConfig = {
  host: 'localhost',
  user: 'root',
  password: 'yourpassword',
  database: 'yourdatabase'
};

let connection;

// 连接到 MySQL 数据库
mysql.createConnection(dbConfig)
  .then(conn => {
    connection = conn;
    console.log('Connected to MySQL');
    app.listen(port, () => {
      console.log(`Server is running on http://localhost:${port}`);
    });
  })
  .catch(err => {
    console.error('Error connecting to MySQL:', err);
  });

// 定义一个关闭服务器的函数，以便在进程退出时关闭数据库连接
const shutdown = () => {
  connection.end();
  process.exit(0);
};

process.on('SIGTERM', shutdown);
process.on('SIGINT', shutdown);

3. 实现分页查询接口

接下来，我们实现一个分页查询接口。假设我们有一个名为 users 的表，并且我们想要分页查询用户数据。

app.get('/users', async (req, res) => {
  const { page = 1, limit = 10 } = req.query;
  const offset = (page - 1) * limit;

  try {
    const [rows, fields] = await connection.execute(
      'SELECT * FROM users LIMIT ? OFFSET ?',
      [limit, offset]
    );

    const totalRows = await connection.execute('SELECT COUNT(*) AS total FROM users')[0][0].total;
    const totalPages = Math.ceil(totalRows / limit);

    res.json({
      page: parseInt(page),
      limit: parseInt(limit),
      totalPages: parseInt(totalPages),
      totalRows: parseInt(totalRows),
      data: rows
    });
  } catch (err) {
    console.error('Error executing query:', err);
    res.status(500).json({ error: 'Internal Server Error' });
  }
});

4. 完整代码

将上述代码片段组合在一起，得到完整的 app.js 文件：

const express = require('express');
const mysql = require('mysql2/promise');

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

// MySQL 连接配置
const dbConfig = {
  host: 'localhost',
  user: 'root',
  password: 'yourpassword',
  database: 'yourdatabase'
};

let connection;

// 连接到 MySQL 数据库
mysql.createConnection(dbConfig)
  .then(conn => {
    connection = conn;
    console.log('Connected to MySQL');
    app.listen(port, () => {
      console.log(`Server is running on http://localhost:${port}`);
    });
  })
  .catch(err => {
    console.error('Error connecting to MySQL:', err);
  });

// 分页查询接口
app.get('/users', async (req, res) => {
  const { page = 1, limit = 10 } = req.query;
  const offset = (page - 1) * limit;

  try {
    const [rows, fields] = await connection.execute(
      'SELECT * FROM users LIMIT ? OFFSET ?',
      [limit, offset]
    );

    const totalRows = await connection.execute('SELECT COUNT(*) AS total FROM users')[0][0].total;
    const totalPages = Math.ceil(totalRows / limit);

    res.json({
      page: parseInt(page),
      limit: parseInt(limit),
      totalPages: parseInt(totalPages),
      totalRows: parseInt(totalRows),
      data: rows
    });
  } catch (err) {
    console.error('Error executing query:', err);
    res.status(500).json({ error: 'Internal Server Error' });
  }
});

// 定义一个关闭服务器的函数，以便在进程退出时关闭数据库连接
const shutdown = () => {
  connection.end();
  process.exit(0);
};

process.on('SIGTERM', shutdown);
process.on('SIGINT', shutdown);