NodeJS如何获取支付成功跳转URL参数并插入MySQL数据库？

问题场景 #

支付成功后会重定向至目标URL（示例：http://localhost:8888/success.html?id=3LS234170M9827257），需要提取URL中的id参数，将其插入到MySQL数据库records表的transid字段中。

原代码问题分析 #

你尝试的代码存在以下核心问题：

• SQL语句错误：INSERT INTO records (transid) VALUES (id) 中的id是字符串字面量，数据库会尝试插入字符串"id"而非实际的URL参数值
• 数据库连接变量不匹配：完整代码中数据库连接实例是mysqlConnection，但测试代码里误用了未定义的con
• 路由与重定向URL不匹配：重定向目标是/success.html，但你的路由是/success，导致无法正确捕获参数
• 错误处理不完善：直接throw err会导致服务器崩溃，没有给客户端返回合理响应

修正后的完整Server.js代码 #

import express from "express";
import * as paypal from "./paypal-api.js";
import mysql from "mysql";

const {PORT = 8888} = process.env;

const app = express();

app.use(express.static("public"));

// 解析请求体中的JSON格式参数
app.use(express.json());

// 创建MySQL连接
var mysqlConnection = mysql.createConnection({
  host: "localhost",
  user: "xxx",
  password: "xxx",
  database:"xxx"
});

mysqlConnection.connect(function(err) {
  if (err) {
    return console.error('数据库连接失败: ' + err.message);
  }
  console.log('已连接到MySQL服务器');
});

// 创建PayPal订单接口
app.post("/my-server/create-paypal-order", async (req, res) => {
  try {
    const order = await paypal.createOrder();
    res.json(order);
  } catch (err) {
    res.status(500).send(err.message);
  }
});

// 捕获PayPal支付接口
app.post("/my-server/capture-paypal-order", async (req, res) => {
  const { orderID } = req.body;
  try {
    const captureData = await paypal.capturePayment(orderID);
    res.json(captureData);
  } catch (err) {
    res.status(500).send(err.message);
  }
});

// 处理支付成功重定向的路由
app.get("/success.html", function (req, res) {
  const transId = req.query.id;
  // 参数校验：确保id存在
  if (!transId) {
    return res.status(400).send("缺少必要的交易ID参数");
  }

  // 使用参数化查询防止SQL注入，同时传入实际参数值
  const sql = "INSERT INTO records (transid) VALUES (?)";
  mysqlConnection.query(sql, [transId], function (err, result) {
    if (err) {
      console.error("插入数据库失败:", err.message);
      return res.status(500).send("交易记录保存失败");
    }
    console.log("1条交易记录已插入");
    res.send(`支付成功，交易ID：${transId}`);
  });
});
  
app.listen(PORT, () => {
  console.log(`服务器运行在 http://localhost:${PORT}/`);
});

关键修正说明 #

• 路由匹配：将路由改为/success.html，与重定向URL完全匹配，确保能正确捕获id参数
• 安全的SQL查询：使用?作为占位符的参数化查询，既解决了变量引用问题，又避免了SQL注入风险
• 参数校验：增加transId的存在性检查，避免无效的数据库插入操作
• 完善的错误处理：捕获数据库操作错误，返回对应HTTP状态码并记录日志，防止服务器崩溃
• 正确的连接实例：使用代码中已定义的mysqlConnection执行数据库查询

内容的提问来源于stack exchange，提问作者Lawrence