一般的なDbCommandを使用して更新を実行する場合、更新される行がロックされていると、無期限にハングします。
使用される基本的な接続は、DevartのOracleプロバイダーであるDevart.Data.Oracle.OracleConnectionです。
DbCommand.CommandTimeOutを設定してもまったく効果がなく、更新がタイムアウトすることはありません。
DbCommandはBeginExecuteNonQueryを実装していないため、非同期でDbConnection/DbCommandを使用する方法はないようです。
DevartのOracleCommandとBeginExecuteQueryを使用してこれを回避することはできますが、それは可能です。
一般的な方法でこれを行う方法はありますか?
オラクル固有のロジックの簡略化されたコード:
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();
}