OracleDataReader クラス
メモ : この名前空間、クラス、およびメンバは、.NET Framework Version 1.1 だけでサポートされています。
データ ソースからデータ行の前方向ストリームを読み取る方法を提供します。このクラスは継承できません。
この型のすべてのメンバの一覧については、OracleDataReader メンバ を参照してください。
System.Object
System.MarshalByRefObject
System.Data.OracleClient.OracleDataReader
NotInheritable Public Class OracleDataReader
Inherits MarshalByRefObject
Implements IDataReader, IDisposable, IDataRecord, IEnumerable
[C#]
public sealed class OracleDataReader : MarshalByRefObject,
IDataReader, IDisposable, IDataRecord, IEnumerable
[C++]
public __gc __sealed class OracleDataReader : public
MarshalByRefObject, IDataReader, IDisposable, IDataRecord,
IEnumerable
[JScript]
public class OracleDataReader extends MarshalByRefObject implements
IDataReader, IDisposable, IDataRecord, IEnumerable
スレッドセーフ
この型の public static (Visual Basicでは Shared) のすべてのメンバは、マルチスレッド操作で安全に使用できます。インスタンスのメンバの場合は、スレッドセーフであるとは限りません。
解説
OracleDataReader を作成するには、コンストラクタを直接使用せずに、 OracleCommand オブジェクトの ExecuteReader メソッドを呼び出す必要があります。
データの読み取り中に別のプロセスまたはスレッドが結果セットに加えた変更が、 OracleDataReader のユーザーに表示されることがあります。
OracleDataReader を閉じた後に呼び出すことができるのは、 IsClosed プロパティと RecordsAffected プロパティだけです。場合によっては、 RecordsAffected を呼び出す前に Close を呼び出す必要があります。
OracleDataReader はいつでも複数開くことができます。
OracleDataReader を使用して Oracle の REF CURSOR を取得する、2 つの Visual Basic の例を次に示します。この例では、Oracle の Scott/Tiger スキーマで定義されたテーブルを使用し、次の PL/SQL パッケージとパッケージ本体を必要とします。例で使用するために、これらをサーバー側で作成する必要があります。
Oracle サーバーで、次の Oracle パッケージを作成します。
CREATE OR REPLACE PACKAGE CURSPKG AS
TYPE T_CURSOR IS REF CURSOR;
PROCEDURE OPEN_ONE_CURSOR (N_EMPNO IN NUMBER,
IO_CURSOR IN OUT T_CURSOR);
PROCEDURE OPEN_TWO_CURSORS (EMPCURSOR OUT T_CURSOR,
DEPTCURSOR OUT T_CURSOR);
END CURSPKG;
/
Oracle サーバーで、次の Oracle パッケージ本体を作成します。
CREATE OR REPLACE PACKAGE BODY CURSPKG AS
PROCEDURE OPEN_ONE_CURSOR (N_EMPNO IN NUMBER,
IO_CURSOR IN OUT T_CURSOR)
IS
V_CURSOR T_CURSOR;
BEGIN s
THEN
OPEN V_CURSOR FOR
SELECT EMP.EMPNO, EMP.ENAME, DEPT.DEPTNO, DEPT.DNAME
FROM EMP, DEPT
WHERE EMP.DEPTNO = DEPT.DEPTNO
AND EMP.EMPNO = N_EMPNO;
ELSE
OPEN V_CURSOR FOR
SELECT EMP.EMPNO, EMP.ENAME, DEPT.DEPTNO, DEPT.DNAME
FROM EMP, DEPT
WHERE EMP.DEPTNO = DEPT.DEPTNO;
END IF;
IO_CURSOR := V_CURSOR;
END OPEN_ONE_CURSOR;
PROCEDURE OPEN_TWO_CURSORS (EMPCURSOR OUT T_CURSOR,
DEPTCURSOR OUT T_CURSOR)
IS
V_CURSOR1 T_CURSOR;
V_CURSOR2 T_CURSOR;
BEGIN
OPEN V_CURSOR1 FOR SELECT * FROM EMP;
OPEN V_CURSOR2 FOR SELECT * FROM DEPT;
EMPCURSOR := V_CURSOR1;
DEPTCURSOR := V_CURSOR2;
END OPEN_TWO_CURSORS;
END CURSPKG;
/
REF CURSOR パラメータを返す PL/SQL ストアド プロシージャを実行し、値を OracleDataReader として読み取る Visual Basic の例を示します。
Private Sub Button1_Click(ByVal sender As Object, ByVal e As System.EventArgs) Handles Button1.Click
Dim connString As New String("Data Source=Oracle8i;Integrated Security=yes")
Dim conn As New OracleConnection(connString)
conn.Open()
Dim cmd As New OracleCommand()
cmd.Connection = conn
cmd.CommandText = "CURSPKG.OPEN_ONE_CURSOR"
cmd.CommandType = CommandType.StoredProcedure
cmd.Parameters.Add(New OracleParameter("N_EMPNO", OracleType.Number)).Value = 7369
cmd.Parameters.Add(New OracleParameter("IO_CURSOR", OracleType.Cursor)).Direction = ParameterDirection.Output
Dim rdr As OracleDataReader
rdr = cmd.ExecuteReader()
While (rdr.Read())
REM do something with the values
End While
rdr.Close()
conn.Close()
End Sub
2 つの REF CURSOR パラメータを返す PL/SQL ストアド プロシージャを実行し、 OracleDataReader を使用して値を読み取る Visual Basic の例を示します。
Private Sub Button1_Click(ByVal sender As Object, ByVal e As System.EventArgs) Handles Button1.Click
Dim connString As New String("Data Source=Oracle8i;Integrated Security=yes")
Dim ds As New DataSet()
Dim conn As New OracleConnection(connString)
Dim cmd As New OracleCommand()
conn.Open()
cmd.Connection = conn
cmd.CommandText = "CURSPKG.OPEN_TWO_CURSORS"
cmd.CommandType = CommandType.StoredProcedure
cmd.Parameters.Add(New OracleParameter("EMPCURSOR", OracleType.Cursor)).Direction = ParameterDirection.Output
cmd.Parameters.Add(New OracleParameter("DEPTCURSOR", OracleType.Cursor)).Direction = ParameterDirection.Output
Dim rdr As OracleDataReader
rdr = cmd.ExecuteReader(CommandBehavior.CloseConnection)
While (rdr.Read())
REM do something with the values from the EMP table
End While
rdr.NextResult()
While (rdr.Read())
REM do something with the values from the DEPT table
End While
rdr.Close()
End Sub
Oracle テーブルを作成し、作成したテーブルにデータを読み込む C# の例を示します。この後の例 (OracleType 構造体を使用したデータに、 OracleDataReader を使用してアクセスする例) を実行する前に、この例を実行する必要があります。
public void Setup(string connectionString)
{
OracleConnection conn = new OracleConnection(connectionString);
try
{
conn.Open();
OracleCommand cmd = conn.CreateCommand();
cmd.CommandText ="CREATE TABLE OracleTypesTable (MyVarchar2 varchar2(3000),MyNumber number(28,4) PRIMARY KEY ,MyDate date, MyRaw raw(255))";
cmd.ExecuteNonQuery();
cmd.CommandText ="INSERT INTO OracleTypesTable VALUES ( 'test', 2, to_date('2000-01-11 12:54:01','yyyy-mm-dd hh24:mi:ss'), '0001020304' )";
cmd.ExecuteNonQuery();
cmd.CommandText="SELECT * FROM OracleTypesTable";
}
catch(Exception)
{
}
finally
{
conn.Close();
}
}
OracleDataReader を使用してデータにアクセスし、複数の OracleType 構造体を使用してデータを表示する C# の例を示します。
public void ReadOracleTypesExample(string connectionString)
{
OracleConnection myConnection = new OracleConnection(connectionString);
myConnection.Open();
OracleCommand myCommand = myConnection.CreateCommand();
try
{
myCommand.CommandText = "SELECT * from OracleTypesTable";
OracleDataReader oracledatareader1 = myCommand.ExecuteReader();
oracledatareader1.Read();
//Using the oracle specific getters for each type is faster than
//using GetOracleValue.
//First column, MyVarchar2, is a VARCHAR2 data type in Oracle Server
//and maps to OracleString.
OracleString oraclestring1 = oracledatareader1.GetOracleString(0);
Console.WriteLine("OracleString " + oraclestring1.ToString());
//Second column, MyNumber, is a NUMBER data type in Oracle Server
//and maps to OracleNumber.
OracleNumber oraclenumber1 = oracledatareader1.GetOracleNumber(1);
Console.WriteLine("OracleNumber " + oraclenumber1.ToString());
//Third column, MyDate, is a DATA data type in Oracle Server
//and maps to OracleDateTime.
OracleDateTime oracledatetime1 = oracledatareader1.GetOracleDateTime(2);
Console.WriteLine("OracleDateTime " + oracledatetime1.ToString());
//Fourth column, MyRaw, is a RAW data type in Oracle Server and
//maps to OracleBinary.
OracleBinary oraclebinary1 = oracledatareader1.GetOracleBinary(3);
//Calling value on a null OracleBinary throws
//OracleNullValueException; therefore, check for a null value.
if (oraclebinary1.IsNull==false)
{
foreach(byte b in oraclebinary1.Value)
{
Console.WriteLine("byte " + b.ToString());
}
}
oracledatareader1.Close();
}
catch(Exception e)
{
Console.WriteLine(e.ToString());
}
finally
{
myConnection.Close();
}
}
使用例
[Visual Basic, C#, C++] OracleConnection 、 OracleCommand 、および OracleDataReader を作成する例を次に示します。この例では、データを読み取り、コンソールに出力します。最後に、 OracleDataReader を閉じ、 OracleConnection を閉じます。
Public Sub ReadMyData(myConnString As String)
Dim mySelectQuery As String = "SELECT EmpNo, EName FROM Emp"
Dim myConnection As New OracleConnection(myConnString)
Dim myCommand As New OracleCommand(mySelectQuery, myConnection)
myConnection.Open()
Dim myReader As OracleDataReader
myReader = myCommand.ExecuteReader()
' Always call Read before accessing data.
While myReader.Read()
Console.WriteLine(myReader.GetInt32(0).ToString() + ", " _
+ myReader.GetString(1))
End While
' always call Close when done reading.
myReader.Close()
' Close the connection when done with it.
myConnection.Close()
End Sub
[C#]
public void ReadMyData(string myConnString) {
string mySelectQuery = "SELECT EmpNo, EName FROM Emp";
OracleConnection myConnection = new OracleConnection(myConnString);
OracleCommand myCommand = new OracleCommand(mySelectQuery,myConnection);
myConnection.Open();
OracleDataReader myReader;
myReader = myCommand.ExecuteReader();
// Always call Read before accessing data.
while (myReader.Read()) {
Console.WriteLine(myReader.GetInt32(0) + ", " + myReader.GetString(1));
}
// always call Close when done reading.
myReader.Close();
// Close the connection when done with it.
myConnection.Close();
}
[C++]
public:
void ReadMyData(String* myConnString) {
String* mySelectQuery = S"SELECT EmpNo, EName FROM Emp";
OracleConnection* myConnection = new OracleConnection(myConnString);
OracleCommand* myCommand = new OracleCommand(mySelectQuery,myConnection);
myConnection->Open();
OracleDataReader* myReader;
myReader = myCommand->ExecuteReader();
// Always call Read before accessing data.
while (myReader->Read()) {
Console::WriteLine(S"{0}, {1}", __box(myReader->GetInt32(0)), myReader->GetString(1));
}
// always call Close when done reading.
myReader->Close();
// Close the connection when done with it.
myConnection->Close();
}
[JScript] JScript のサンプルはありません。Visual Basic、C#、および C++ のサンプルを表示するには、このページの左上隅にある言語のフィルタ ボタン をクリックします。
必要条件
名前空間: System.Data.OracleClient
プラットフォーム: Windows 98, Windows NT 4.0, Windows Millennium Edition, Windows 2000, Windows XP Home Edition, Windows XP Professional, Windows Server 2003 ファミリ
アセンブリ: System.Data.Oracleclient (System.Data.Oracleclient.dll 内)