当使用通用dbcommand执行更新时,如果要更新的行被锁定,它将不确定地挂起。
使用的基础连接是Devart的Oracle提供程序devart.data.oracle.oracleConnection
设置dbcommand.commandTimeout根本没有效果,更新永远不会超时。
dbcommand不实现beginExecutionQuery,因此似乎没有办法以异步方式使用dbconnection/dbcommand。
我可以通过使用devart的oraclecommand和beginExecuteQuery来解决这个问题,但确实如此。
有没有一种通用的方法来实现这一点?
Oracle特定逻辑的简化代码:
public bool TestAsyncUpdateRowOracle(string key, OracleConnection con, string sql)
{
const int timoutIterations=10;
bool updateOk=false;
OracleCommand cmd = new OracleCommand(sql, con);
cmd.Parameters.Add(Util.CreateParameter(dbSrcFactory, DbType.String, 16, "key"));
cmd.CommandType = CommandType.Text;
cmd.Parameters[0].Value = key.ToString();
IAsyncResult result = cmd.BeginExecuteNonQuery();
int asyncCount = 0;
while (!result.IsCompleted)
{
asyncCount++;
if (asyncCount > timeoutIterations)
{
break;
}
System.Threading.Thread.Sleep(10);
}
if (result.IsCompleted)
{
int rowsAffected = cmd.EndExecuteNonQuery(result);
Console.WriteLine("Done. Rows affected: " + rowsAffected.ToString());
}
else
{
try
{
cmd.Cancel();
Console.WriteLine("Update timed out, row is locked");
}
catch (Exception e)
{
Console.WriteLine(e.ToString());
Console.WriteLine("Unable to cancel update");
}
}
cmd.Dispose();
}