.net - OracleDataReader.Read メソッドのタイムアウト

Question

ODP.NET OracleCommand クラスには、コマンドの実行にタイムアウトを適用するために使用できる CommandTimeout プロパティがあります。このプロパティは、CommandText が SQL ステートメントである状況で機能するようです。サンプル コードは、このプロパティの動作を説明するために使用されます。コードの初期バージョンでは、CommandTimeout はゼロに設定されており、タイムアウトを強制しないように ODP.NET に指示しています。

using System;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.Text;
using Oracle.DataAccess.Client;

namespace ConsoleApplication3
{
    class Program
    {
        static void Main(string[] args)
        {
            using (OracleConnection con = new OracleConnection("User ID=xxxx; Password=xxxx; Data Source=xxxx;"))
            using (OracleCommand cmd = new OracleCommand())
            {
                con.Open();                
                cmd.Connection = con;

                Console.WriteLine("Executing Query...");

                try
                {
                    cmd.CommandTimeout = 0;

                    // Data set SQL:
                    cmd.CommandText = "<some long running SQL statement>";
                    cmd.CommandType = System.Data.CommandType.Text;

                    Stopwatch watch1 = Stopwatch.StartNew();
                    OracleDataReader reader = cmd.ExecuteReader();
                    watch1.Stop();
                    Console.WriteLine("Query complete.  Execution time: {0} ms", watch1.ElapsedMilliseconds);

                    int counter = 0;
                    Stopwatch watch2 = Stopwatch.StartNew();
                    if (reader.Read()) counter++;
                    watch2.Stop();
                    Console.WriteLine("First record read: {0} ms", watch2.ElapsedMilliseconds);

                    Stopwatch watch3 = Stopwatch.StartNew();
                    while (reader.Read())
                    {
                        counter++;
                    }
                    watch3.Stop();
                    Console.WriteLine("Records 2..n read: {0} ms", watch3.ElapsedMilliseconds);
                    Console.WriteLine("Records read: {0}", counter);
                }
                catch (OracleException ex)
                {
                    Console.WriteLine("Exception was thrown: {0}", ex.Message);
                }

                Console.WriteLine("Press any key to continue...");
                Console.Read();
            }
        }
    }
}

上記のコードの出力例を以下に示します。

Executing Query...
Query complete.  Execution time: 8372 ms
First record read: 3 ms
Records 2..n read: 1222 ms
Records read: 20564
Press any key to continue...

CommandTimeout を 3 などに変更すると...

cmd.CommandTimeout = 3;

...次に、同じコードを実行すると、次の出力が生成されます。

Executing Query...
Exception was thrown: ORA-01013: user requested cancel of current operation
Press any key to continue...

ただし、ref カーソルを返すストアド プロシージャの呼び出しは別の問題です。以下のテスト プロシージャを検討してください (純粋にテスト目的のため)。

PROCEDURE PROC_A(i_sql VARCHAR2, o_cur1 OUT SYS_REFCURSOR)
is
begin

    open o_cur1
    for
    i_sql;

END PROC_A;

以下のサンプル コードを使用して、ストアド プロシージャを呼び出すことができます。CommandTimeout の値が 3 に設定されていることに注意してください。

using System;
using System.Collections.Generic;
using System.Data;
using System.Diagnostics;
using System.Linq;
using System.Text;
using Oracle.DataAccess.Client;

namespace ConsoleApplication3
{
    class Program
    {
        static void Main(string[] args)
        {
            using (OracleConnection con = new OracleConnection("User ID=xxxx; Password=xxxx; Data Source=xxxx;"))
            using (OracleCommand cmd = new OracleCommand())
            {
                con.Open();                
                cmd.Connection = con;

                Console.WriteLine("Executing Query...");

                try
                {
                    cmd.CommandTimeout = 3;

                    string sql = "<some long running sql>";
                    cmd.CommandText = "PROC_A";
                    cmd.CommandType = System.Data.CommandType.StoredProcedure;
                    cmd.Parameters.Add(new OracleParameter("i_sql", OracleDbType.Varchar2) { Direction = ParameterDirection.Input, Value = sql });
                    cmd.Parameters.Add(new OracleParameter("o_cur1", OracleDbType.RefCursor) { Direction = ParameterDirection.Output });

                    Stopwatch watch1 = Stopwatch.StartNew();
                    OracleDataReader reader = cmd.ExecuteReader();
                    watch1.Stop();
                    Console.WriteLine("Query complete.  Execution time: {0} ms", watch1.ElapsedMilliseconds);

                    int counter = 0;
                    Stopwatch watch2 = Stopwatch.StartNew();
                    if (reader.Read()) counter++;
                    watch2.Stop();
                    Console.WriteLine("First record read: {0} ms", watch2.ElapsedMilliseconds);

                    Stopwatch watch3 = Stopwatch.StartNew();
                    while (reader.Read())
                    {
                        counter++;
                    }
                    watch3.Stop();
                    Console.WriteLine("Records 2..n read: {0} ms", watch3.ElapsedMilliseconds);
                    Console.WriteLine("Records read: {0}", counter);
                }
                catch (OracleException ex)
                {
                    Console.WriteLine("Exception was thrown: {0}", ex.Message);
                }

                Console.WriteLine("Press any key to continue...");
                Console.Read();
            }
        }
    }
}

上記のコードからの出力例を以下に示します。

Executing Query...
Query complete.  Execution time: 34 ms
First record read: 8521 ms
Records 2..n read: 1014 ms
Records read: 20564
Press any key to continue...

実行時間が非常に短く (34 ミリ秒)、タイムアウト例外がスローされていないことに注意してください。ここで見られるパフォーマンスは、ref カーソルの SQL ステートメントが OracleDataReader.Read メソッドへの最初の呼び出しまで実行されないためです。refcursor から最初のレコードを読み取るために最初の Read() 呼び出しが行われると、実行時間の長いクエリによるパフォーマンス ヒットが発生します。

ここで説明した動作は、OracleCommand.CommandTimeout プロパティを使用して、ref カーソルに関連付けられた実行時間の長いクエリをキャンセルできないことを意味します。この状況で参照カーソルSQLの実行時間を制限するために使用できるODP.NETのプロパティを知りません。長時間実行されている ref カーソル SQL ステートメントの実行が一定時間後に短絡する可能性がある方法について、誰か提案がありますか?