本地与服务器执行同一存储过程返回结果不一致（本地正常/服务器返回Null）

问题概述 #

本地机器调用存储过程apUserSyncEndPointPollingLogCreate可正常返回新生成的日志ID，但服务器环境调用时输出参数返回Null，两个环境连接同一SQL Server数据库。

存储过程与调用代码 #

存储过程代码 #

CREATE PROCEDURE [dbo].[apUserSyncEndPointPollingLogCreate] 
    (@UserSync_EndpointPollActivityLogId int OUTPUT,
     @EndpointPollTime DateTime,
     @NumberOfUsersReturned int,
     @EndpointResponse varchar(max),
     @ActivityLogDetails varchar(max))
AS
BEGIN
    INSERT INTO tblUserSync_EndpointPollActivityLog (EndpointPollTime, NumberOfUsersReturned, EndpointResponse, ActivityLogDetails)
    VALUES (@EndpointPollTime, @NumberOfUsersReturned, @EndpointResponse, @ActivityLogDetails)

    SELECT @UserSync_EndpointPollActivityLogId = SCOPE_IDENTITY()
END

当前服务器环境异常的C#代码 #

public int AddEndpointPollActivityLog(DateTime endpointPollTime, int numberOfUsersReturned, string endpointResponse, string activityLogDetails)
{
    using (var connection = new SqlConnection(_connectionStrings.Alton))
    {
        try
        {
            var p = new DynamicParameters();
            p.Add("@UserSync_EndpointPollActivityLogId", dbType: System.Data.DbType.Int32, direction: System.Data.ParameterDirection.Output);
            p.Add("@EndpointPollTime", endpointPollTime);
            p.Add("@NumberOfUsersReturned", numberOfUsersReturned);
            p.Add("@EndpointResponse", endpointResponse);
            p.Add("@ActivityLogDetails", activityLogDetails);

            var result = connection.Query("[dbo].[apUserSyncEndpointPollingLogCreate]", p, commandTimeout: 300, commandType: System.Data.CommandType.StoredProcedure);

            int UserSync_EndpointPollActivityLogId = p.Get<int>("@UserSync_EndpointPollActivityLogId");

            return UserSync_EndpointPollActivityLogId;
        }
        catch (SqlException ex)
        {
            _logger.LogError("AddEndpointPollActivityLog: SQL Exception occurred: " + ex.Message);
            throw;
        }
        catch (Exception ex)
        {
            _logger.LogError("AddEndpointPollActivityLog: An error occurred: " + ex.Message);
            throw;
        }
    }
}

此前正常运行的C#代码 #

public int AddEndpointPollActivityLog(DateTime endpointPollTime, int numberOfUsersReturned, string endpointResponse, string activityLogDetails)
{
    using (var connection = new SqlConnection(_connectionStrings.Alton))
    {
        var p = new DynamicParameters();
        p.Add("@UserSync_EndpointPollActivityLogId", dbType: System.Data.DbType.Int32, direction: System.Data.ParameterDirection.Output);
        p.Add("@EndpointPollTime", endpointPollTime);
        p.Add("@NumberOfUsersReturned", numberOfUsersReturned);
        p.Add("@EndpointResponse", endpointResponse);
        p.Add("@ActivityLogDetails", activityLogDetails);

        var result = connection.Query("[dbo].[apUserSyncEndpointPollingLogCreate]", p, commandTimeout: 300, commandType: System.Data.CommandType.StoredProcedure);

        int UserSync_EndpointPollActivityLogId = p.Get<int>("UserSync_EndpointPollActivityLogId");

        return UserSync_EndpointPollActivityLogId;
    }
}

可能的原因与解决办法 #

1. 参数名称的@符号兼容性问题 #

Dapper在不同版本或环境下，对输出参数名称是否带@符号的解析逻辑可能存在差异。当前代码使用p.Get<int>("@UserSync_EndpointPollActivityLogId")，而旧代码不带@符号可正常运行，说明服务器环境的Dapper或SQL驱动可能不兼容带@的参数名称写法。

解决办法：
改回旧代码的参数名称写法，去掉@符号：

int UserSync_EndpointPollActivityLogId = p.Get<int>("UserSync_EndpointPollActivityLogId");

同时确保本地与服务器环境使用相同版本的Dapper和SQL Server驱动。

2. 数据库连接未显式打开的隐含差异 #

虽然Dapper会自动打开连接，但不同环境下的自动打开逻辑可能存在细微差异，导致输出参数未被正确填充。

解决办法：
在调用connection.Query前显式打开连接：

connection.Open();
var result = connection.Query("[dbo].[apUserSyncEndpointPollingLogCreate]", p, commandTimeout: 300, commandType: System.Data.CommandType.StoredProcedure);

3. 触发器干扰SCOPE_IDENTITY()的返回值 #

如果tblUserSync_EndpointPollActivityLog表存在INSERT触发器，且触发器中执行了其他INSERT操作，SCOPE_IDENTITY()会返回触发器中插入的ID，而非当前存储过程插入的记录ID，极端情况下可能返回Null（如果触发器未插入记录）。

解决办法：

• 检查目标表是否存在触发器，若有则调整触发器逻辑，或改用IDENT_CURRENT('tblUserSync_EndpointPollActivityLog')获取当前表的最后生成ID（注意并发场景下的准确性）：

  SELECT @UserSync_EndpointPollActivityLogId = IDENT_CURRENT('tblUserSync_EndpointPollActivityLog')
  

• 或者修改存储过程，额外返回ID值，C#代码同时通过结果集和输出参数获取，双重验证：
  存储过程末尾添加：

  SELECT @UserSync_EndpointPollActivityLogId AS UserSync_EndpointPollActivityLogId
  

  C#代码修改：

  var result = connection.QueryFirst<int>("[dbo].[apUserSyncEndpointPollingLogCreate]", p, commandTimeout: 300, commandType: System.Data.CommandType.StoredProcedure);
  int logId = p.Get<int>("UserSync_EndpointPollActivityLogId") == 0 ? result : p.Get<int>("UserSync_EndpointPollActivityLogId");
  return logId;
  

4. 服务器环境数据库权限问题 #

服务器环境的数据库用户可能缺少tblUserSync_EndpointPollActivityLog表的INSERT权限，或存储过程的执行权限，导致插入操作未成功，SCOPE_IDENTITY()返回Null。

解决办法：
检查服务器环境的数据库用户权限，确保其拥有：

• tblUserSync_EndpointPollActivityLog表的INSERT权限
• apUserSyncEndPointPollingLogCreate存储过程的EXECUTE权限

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