在Razor Pages中正确处理MySQL连接与数据操作的方案咨询

当前配置的隐患 #

你的代码现在能跑，但存在几个关键问题，高并发下大概率会出连接错误：

• 类级别的conn、cmd、reader字段：这些对象属于实例级别的状态，就算用AddTransient每次创建新实例，这种写法也容易导致资源泄漏，而且异常时conn.Close()根本执行不到，连接没法回到连接池。
• 异常处理直接抛出空Exception，原始错误信息全丢了，排查问题会非常麻烦。

高并发下会出现SQL连接错误吗？ #

肯定会。一旦请求量上来，异常场景下未释放的连接会占满连接池，后续请求拿不到可用连接，就会报超时或者连接耗尽的错误。

优化方案 #

1. 用using语句自动释放资源 #

数据库连接、命令、阅读器都实现了IDisposable接口，必须保证它们被及时释放。using语句会自动调用Dispose()，哪怕抛异常也能确保资源回收，同时把这些对象改成局部变量，彻底避免类级别的状态问题。

修改后的SqlDataAccess：

private readonly IConfiguration _config;
public string ConnString { get; private set; }

public SqlDataAccess(IConfiguration config)
{
    _config = config;
    ConnString = _config.GetConnectionString("Default");
}

public List<Product> GetProducts()
{
    var products = new List<Product>();
    
    // using自动释放连接，无需手动Close
    using (var conn = new MySqlConnection(ConnString))
    {
        conn.Open();
        
        // using自动释放命令对象
        using (var cmd = new MySqlCommand("SELECT PartNumber, Name, Stock, Price FROM Products", conn))
        {
            // using自动释放数据阅读器
            using (var reader = cmd.ExecuteReader())
            {
                while (reader.Read())
                {
                    products.Add(new Product(
                        (string)reader["PartNumber"],
                        (string)reader["Name"],
                        (int)reader["Stock"],
                        (decimal)reader["Price"]
                    ));
                }
            }
        }
    }
    
    return products;
}

2. 修复异常处理 #

别直接抛出空异常，要么直接抛原始异常，要么包装后保留错误根源：

public List<Product> GetProducts()
{
    try
    {
        var products = new List<Product>();
        using (var conn = new MySqlConnection(ConnString))
        {
            conn.Open();
            using (var cmd = new MySqlCommand("SELECT PartNumber, Name, Stock, Price FROM Products", conn))
            {
                using (var reader = cmd.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        products.Add(new Product(
                            (string)reader["PartNumber"],
                            (string)reader["Name"],
                            (int)reader["Stock"],
                            (decimal)reader["Price"]
                        ));
                    }
                }
            }
        }
        return products;
    }
    catch (Exception ex)
    {
        // 可以加日志记录，再抛出带原始信息的异常
        throw new Exception("获取产品数据失败", ex);
    }
}

3. 服务注册的合理性 #

你用AddTransient注册ISqlDataAccess和IProductManager是对的，这类无状态的数据访问类，每次请求创建新实例能避免状态共享问题，完全符合场景需求。

4. 进阶：用ORM框架简化开发 #

如果项目复杂度不低，直接用Entity Framework Core这类ORM框架更省心——它会自动处理连接池、资源释放、查询优化，代码量骤减，稳定性也更高：
先定义DbContext：

public class AppDbContext : DbContext
{
    public AppDbContext(DbContextOptions<AppDbContext> options) : base(options)
    {
    }

    public DbSet<Product> Products { get; set; }
}

然后在Program.cs注册：

builder.Services.AddDbContext<AppDbContext>(options =>
    options.UseMySql(builder.Configuration.GetConnectionString("Default"), 
        new MySqlServerVersion(new Version(8, 0, 23))));

最后修改ProductManager：

private readonly AppDbContext _db;
public ProductManager(AppDbContext db)
{
    _db = db;
}

public List<Product> GetProducts()
{
    return _db.Products.ToList();
}

总结 #

• 核心原则：用using确保数据库资源被正确释放，避免连接泄漏。
• 保持数据访问类无状态，别用类级别的字段存连接、命令这类对象。
• 异常处理要保留原始错误信息，方便排查问题。
• 高并发下，正确的资源释放+MySQL自带的连接池，就能避免连接耗尽的问题。
• 进阶用ORM框架能大幅减少重复代码，提升开发效率和稳定性。

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