c# - Window Service - 等待存储过程得到结果

Question

我正在从C#Window Service 运行存储过程。存储过程是一个非常繁重的查询，需要很长时间。

我想等到存储的过程完成并返回值。

有什么方法可以确定存储过程是否完成？

Answer 1

使用Threading.Tasks. 以下代码将使您的线程等待任务完成。

public void CallStoredProcMethod()
{
    var task1 = System.Threading.Tasks.Task.Factory.StartNew(() => RunStoredPro());

    // thread will wait there till the operation finish
    task1.Wait();
}

public void RunStoredPro()
{
    using (var connection = new SqlConnection(sqlConnString))
    {
        // your database call
    }
}

Answer 2

System.Data.Common.DbCommand具有CommandTimeout属性。

获取或设置在终止尝试执行命令并生成错误之前的等待时间。等待命令执行的时间（以秒为单位）。请注意实施者，建议 0 表示没有超时。

请注意，SqlCommand 的默认值为 30 秒。如果您将 CommandTimeout 属性设置为 0，您的调用将花费存储过程执行所需的时间。SqlCommand 上的ExecuteScalar实现的 msdn 页面具有以下示例，稍作修改以设置CommandTimeout：

static public int AddProductCategory(string newName, string connString)
{
    Int32 newProdID = 0;
    string sql =
        "INSERT INTO Production.ProductCategory (Name) VALUES (@Name); "
        + "SELECT CAST(scope_identity() AS int)";
    using (SqlConnection conn = new SqlConnection(connString))
    {
        SqlCommand cmd = new SqlCommand(sql, conn);

        // this will cause the command to wait until the sproc is finished
        cmd.CommandTimeout = 0; 

        cmd.Parameters.Add("@Name", SqlDbType.VarChar);
        cmd.Parameters["@name"].Value = newName;
        try
        {
            conn.Open();
            newProdID = (Int32)cmd.ExecuteScalar();
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }
    }
    return (int)newProdID;
}

Answer 3

在存储过程中使用 return 语句并获取值

例如作为存储过程

set ANSI_NULLS ON
set QUOTED_IDENTIFIER ON
go

ALTER PROCEDURE [dbo].[Validate]
@inputdata varchar(50),
@outputdata varchar(50) output

AS
SET @outputdata = (
SELECT TOP 1 Password FROM dbo.tblUser WHERE Login = @a)

RETURN @outputdata
GO

我这里简单解释一下C#中的核心代码

       string returnValue = string.Empty;
         ...............
        SqlConn.Open();
        sqlcomm.CommandType = CommandType.StoredProcedure;
        SqlParameter param = new SqlParameter("@inputdata", SqlDbType.VarChar);
        param.Direction = ParameterDirection.Input;
        param.Value = Username;
        sqlcomm.Parameters.Add(param);

        SqlParameter retval = sqlcomm.Parameters.Add("@outputdata", SqlDbType.VarChar);
        retval.Direction = ParameterDirection.Output;
        string retunvalue = (string)sqlcomm.Parameters["@outputdata"].Value;
         ......................
         .........