使用SQLCommand.EndExecuteNonQuery时出现SQL语法错误

Question

我想在后台工作者中异步运行两条SQL语句（MSSQL 2005）。但是，当我在第一个SqlCommand上调用EndExecuteNonQuery方法时，出现'附近的SQL语法错误'错误。

这里是我的代码：

try 
{ 
    SqlCommand sqlCmd = uow.DataLayer.CreateCommand() as SqlCommand; 
    sqlCmd.CommandText = "DELETE FROM dbo.EligibilityRecordKeyValue WHERE EligibilityRecord IN " + 
    "(SELECT EligibilityRecord FROM dbo.EligibilityRecord WHERE Organization = '" + map.Organization.Oid + "')"; 
    IAsyncResult result = sqlCmd.BeginExecuteNonQuery(); 
    while (!result.IsCompleted) 
    { 
     worker.ReportProgress(0, "Deleting existing record keys"); 
     System.Threading.Thread.Sleep(200); 
    } 
    count = sqlCmd.EndExecuteNonQuery(result); 
} 
catch (SqlException ex) 
{ 
} 
catch (InvalidOperationException ex) 
{ 
} 
finally 
{ 
    worker.ReportProgress(2, String.Format("Existing {0} records keys deleted.", count)); 
} 

try 
{ 
    SqlCommand sqlCmd = uow.DataLayer.CreateCommand() as SqlCommand; 
    sqlCmd.CommandText = "DELETE FROM dbo.EligibilityRecord WHERE Organization = '" +  map.Organization.Oid + "'"; 
    IAsyncResult result = sqlCmd.BeginExecuteNonQuery(); 
    while (!result.IsCompleted) 
    { 
     worker.ReportProgress(0, "Deleting existing records"); 
     System.Threading.Thread.Sleep(200); 
    } 
    count = sqlCmd.EndExecuteNonQuery(result); 
} 
catch (SqlException ex) 
{ 
} 
catch (InvalidOperationException ex) 
{ 
} 
finally 
{ 
    worker.ReportProgress(5, String.Format("Existing {0} records deleted.", count)); 
} 

它未能在第一count = sqlCmd.EndExecuteNonQuery(result);

Answer 1

好，加入WAITFOR DELAY的这两个SQL命令似乎已经解决了这个问题。

sqlCmd.CommandText = String.Format("WAITFOR DELAY '00:00:05'; DELETE FROM dbo.EligibilityRecordKeyValue WHERE EligibilityRecord IN " + 
        "(SELECT EligibilityRecord FROM dbo.EligibilityRecord WHERE Organization = '{0}')", map.Organization.Oid); 

sqlCmd.CommandText = String.Format("WAITFOR DELAY '00:00:05'; DELETE FROM dbo.EligibilityRecord WHERE Organization = '{0}'", map.Organization.Oid); 

任何人都知道为什么会发生这种情况？