1

我有一个存储过程,我将在其中根据条件选择一些行,并且我需要在同一个存储过程中更新这些行的状态。例如

Create Procedure [dbo].[myProcedure]
As
BEGIN
BEGIN TRAN T1
SET NOCOUNT ON
SELECT TOP 5 * INTO #TempTable FROM myTable WHERE ENABLED = 1;
UPDATE myTable SET [Status] = 'Locked' From myTable Inner Join on #TempTable myTable.id = #TempTable.id;
SELECT * FROM #TempTable;
DROP Table #TempTable;
COMMIT TRAN T1
END

当我在 SQL 中调试时,存储过程工作正常。我正在像这样通过 C# 访问 StoredProcedure。

private ProcessData[] ReadFromDb(string StoredProcedure, SqlConnection Connection)
        {
            List<ProcessData> Data = new List<ProcessData>();
            SqlCommand Command = new SqlCommand(StoredProcedure, Connection);
            Command.CommandType = System.Data.CommandType.StoredProcedure;
            try
            {
                Command.CommandTimeout = CONNECTION_TIMEOUT;
                using (SqlDataReader Reader = Command.ExecuteReader())
                {
                    while (Reader.Read())
                    {
                        Data.Add(new ProcessData()
                        {
                              Id = Reader["Id"];
                              ...
                           });
                    }
                }
            }
            catch (Exception ex)
            {}
        }

问题是我在 C# 中获得了所需的行,但存储过程中的更新查询不起作用。任何人都可以在我出错的地方提出一些建议。

4

4 回答 4

1

以下程序行

UPDATE myTable 
SET [Status] = 'Locked' 
From myTable 
Inner Join myTable.id = #TempTable.id;

应该

UPDATE myTable 
SET [Status] = 'Locked' 
From myTable 
Inner Join #TempTable 
   on myTable.id = #TempTable.id;

并且COMMINT TRAN T1应该替换为COMMIT TRAN T1

SELECT TOP最后,你不应该使用ORDER BY

SELECT TOP 5 * INTO #TempTable FROM myTable WHERE ENABLED = 1;
于 2015-05-04T18:51:06.523 回答
1

这工作正常

UPDATE
A
SET
foo = B.bar
FROM
TableA A
JOIN
TableB B ON A.col1 = B.colx
WHERE
...

于 2015-05-04T19:08:46.333 回答
1
UPDATE myTable 
SET [Status] = 'Locked'  
From myTable  
WHERE id in (select TOP 5 * FROM myTable WHERE enabled=1)
于 2015-05-04T21:04:17.180 回答
0

您可以使用 OUTPUT 子句在一个语句中执行此操作,而无需创建临时表。

有关示例,请参阅此帖子

于 2015-05-06T17:41:17.460 回答