ASP.NET Core 6对接MySQL：如何判断存储过程是否正在运行？

针对你的ASP.NET Core 6+MySQL场景，有两种核心方案可以实现“仅当存储过程未运行时才触发调用”的需求：

方案一：查询MySQL系统视图/表直接判断 #

MySQL提供了多个系统表和视图可以查询当前正在执行的语句，直接检测目标存储过程是否在运行：

1. 使用information_schema.processlist #

这是最常用的方式，查询当前所有活跃连接的执行语句：

SELECT COUNT(*) 
FROM information_schema.processlist 
WHERE COMMAND = 'Query' 
  AND INFO LIKE '%CALL 你的存储过程名()%';

• 返回值大于0说明存储过程正在运行，返回0则可以调用。
• 注意：INFO字段可能截断长语句，若存储过程调用带复杂参数，可能匹配不准确。

2. 使用performance_schema.events_statements_current #

这个视图提供更详细的当前执行语句信息，截断问题更少：

SELECT COUNT(*) 
FROM performance_schema.events_statements_current 
WHERE SQL_TEXT LIKE '%CALL 你的存储过程名()%';

• 需要确保MySQL的performance_schema已启用（默认大部分环境开启）。
• 优点：能更精准匹配带参数的存储过程调用。

方案二：自定义状态表+锁机制（推荐） #

如果需要更可靠的并发控制，尤其是多实例部署的ASP.NET Core应用，建议在MySQL中创建自定义状态表，通过事务锁控制存储过程执行：

1. 创建状态表 #

CREATE TABLE proc_running_status (
    proc_name VARCHAR(100) PRIMARY KEY COMMENT '存储过程名称',
    is_running TINYINT(1) DEFAULT 0 COMMENT '是否正在运行：0=否，1=是',
    last_start_time DATETIME COMMENT '最后启动时间'
);

-- 初始化目标存储过程的状态
INSERT INTO proc_running_status (proc_name) VALUES ('你的存储过程名');

2. 调用存储过程前的判断与锁 #

在ASP.NET Core后端执行存储过程前，通过事务获取悲观锁并更新状态：

public async Task<bool> TryExecuteProcAsync(string procName)
{
    using var transaction = await _dbContext.Database.BeginTransactionAsync();
    try
    {
        // 查询并锁定状态记录
        var status = await _dbContext.ProcRunningStatus
            .FirstOrDefaultAsync(s => s.ProcName == procName, transaction);
        
        if (status == null || status.IsRunning)
        {
            await transaction.RollbackAsync();
            return false;
        }

        // 更新为运行状态
        status.IsRunning = true;
        status.LastStartTime = DateTime.Now;
        await _dbContext.SaveChangesAsync(transaction);

        // 执行存储过程
        await _dbContext.Database.ExecuteSqlRawAsync($"CALL {procName}()", transaction);

        // 重置状态为未运行
        status.IsRunning = false;
        await _dbContext.SaveChangesAsync(transaction);

        await transaction.CommitAsync();
        return true;
    }
    catch
    {
        await transaction.RollbackAsync();
        // 异常时重置状态，防止死锁
        var status = await _dbContext.ProcRunningStatus.FirstOrDefaultAsync(s => s.ProcName == procName);
        if (status != null && status.IsRunning)
        {
            status.IsRunning = false;
            await _dbContext.SaveChangesAsync();
        }
        return false;
    }
}

• 优点：完全可控，避免系统视图查询的延迟或截断问题，支持多实例部署的并发控制。
• 注意：必须处理异常情况，防止存储过程执行失败后状态一直处于“运行中”。

关键注意事项 #

• 无论使用哪种方案，都要避免SQL注入：使用参数化查询代替直接拼接存储过程名称。
• 若存储过程执行时间极短，系统视图查询可能存在瞬时性误差，自定义状态表的方案更可靠。
• 多实例部署时，不能使用ASP.NET Core的内存锁（如lock关键字），必须依赖数据库级别的锁机制。

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