Pool_the_wisdom_and_efforts_of_everyone/NodeMysql/server.js

const express = require('express');
const bodyParser = require('body-parser');
const app = express();
const mysql = require('mysql');

app.use(bodyParser.json()); // 解析JSON请求体

// 创建数据库连接池
const pool  = mysql.createPool({
  host: 'localhost',
  user: 'root',
  password: '123456',
  database: 'class_system'
});

// 处理GET请求的根路径，查询数据库并返回结果，显然为了请求的通用性，则我的查询语句由小程序端完整生成，服务端只负责查询语句的中转
app.get('/', (req, res) => {

  pool.query(req.query.query, (error, results, fields) => {
    if (error) {
      console.error(error);
      return res.status(500).send('Internal Server Error');
    }
    res.json(results); // 返回查询结果
  });
});

// 处理POST请求，用于数据写入数据库
app.post('/insert', (req, res) => {
    const { table, columns, values } = req.body; // 从请求体获取数据
  
    // 构建SQL插入语句
    const placeholders = columns.map(() => '?'); // 原数组映射为新数组，新数组的每个元素均为问号，使用问号作为占位符
    //需要用这种方式来赋值，不然字符串的双引号会丢失
    const sql = `INSERT INTO \`${table}\` (${columns.join(', ')}) VALUES (${placeholders.join(', ')})`;
  
    // 执行SQL插入语句
    pool.query(sql, values, (error, results, fields) => {
    // 返回插入错误的信息
      if (error) {
        console.error(error);
        return res.status(500).send('Database error');
      }
    //   返回提示信息
      res.status(201).json({ message: 'Data inserted successfully', insertId: results.insertId });
    });
  });

// 处理POST请求，用于在数据库中删除指定ID的数据
app.post('/delete', (req, res) => {
    const { table, id } = req.body; // 从请求体获取数据
  
    // 构建SQL插入语句
    const sql = `DELETE FROM \`${table}\` WHERE id = ${id}`;
  
    // 执行SQL插入语句
    pool.query(sql, (error, results, fields) => {
    // 返回插入错误的信息
      if (error) {
        console.error(error);
        return res.status(500).send('Database error');
      }
    //   返回提示信息
      res.status(201).json({ message: 'Data inserted successfully', insertId: results.insertId });
    });
  });

// 处理POST请求，用于在数据库中修改指定ID的数据
app.post('/modify', (req, res) => {
    const { table,id,columns, values } = req.body; // 从请求体获取数据
  
    // 构建SQL插入语句
    const placeholder = columns.map(() => '?'); // 原数组映射为新数组，新数组的每个元素均为问号，使用问号作为占位符
    const placeholders = columns.map((element,index) => element + '=' + placeholder[index]).join(',');
   //组合成 name1=value1,name2=value2,name3=value3......的形式
    const sql = `UPDATE \`${table}\` SET ${placeholders} where id = ${id}`;
  
    // 执行SQL插入语句
    pool.query(sql, values, (error, results, fields) => {
    // 返回插入错误的信息
      if (error) {
        console.error(error);
        return res.status(500).send('Database error');
      }
    //   返回提示信息
      res.status(201).json({ message: 'Data inserted successfully', insertId: results.insertId });
    });
  });

// 启动服务器监听3000端口，并打印启动信息
app.listen(3000, () => {
  console.log('Server running at http://127.0.0.1:3000');
});