Mengambil data menggunakan DataReader

2025-04-07

Untuk mengambil data menggunakan DataReader, buat instans objek Perintah , lalu buat DataReader dengan memanggil Command.ExecuteReader untuk mengambil baris dari sumber data. DataReader menyediakan aliran data yang tidak dibuffer yang memungkinkan logika prosedural memproses hasil secara efisien dari sumber data secara berurutan. DataReader adalah pilihan yang baik saat Anda mengambil data dalam jumlah besar karena data tidak di-cache dalam memori.

Contoh berikut mengilustrasikan menggunakan DataReader, di mana reader mewakili DataReader yang valid dan command mewakili objek Perintah yang valid.

reader = command.ExecuteReader();

reader = command.ExecuteReader()

Gunakan metode DataReader.Read untuk mendapatkan baris dari hasil kueri. Anda dapat mengakses setiap kolom baris yang dikembalikan dengan meneruskan nama atau nomor urut kolom ke DataReader. Namun, untuk performa terbaik, DataReader menyediakan serangkaian metode yang memungkinkan Anda mengakses nilai kolom dalam jenis data aslinya (GetDateTime, GetDouble, GetGuid, GetInt32, dan sebagainya). Untuk daftar metode aksesor yang ditik untuk DataReaders khusus penyedia data, lihat OleDbDataReader dan SqlDataReader. Menggunakan metode akses khusus tipe ketika Anda mengetahui tipe data yang mendasarinya dapat mengurangi kebutuhan konversi tipe saat mengambil nilai kolom.

Contoh berikut berulang melalui objek DataReader dan mengembalikan dua kolom dari setiap baris.

static void HasRows(SqlConnection connection)
{
    using (connection)
    {
        SqlCommand command = new(
          "SELECT CategoryID, CategoryName FROM Categories;",
          connection);
        connection.Open();

        SqlDataReader reader = command.ExecuteReader();

        if (reader.HasRows)
        {
            while (reader.Read())
            {
                Console.WriteLine($"{reader.GetInt32(0)}\t{reader.GetString(1)}");
            }
        }
        else
        {
            Console.WriteLine("No rows found.");
        }
        reader.Close();
    }
}

Private Sub HasRows(ByVal connection As SqlConnection)
    Using connection
        Dim command As SqlCommand = New SqlCommand( _
          "SELECT CategoryID, CategoryName FROM Categories;", _
          connection)
        connection.Open()

        Dim reader As SqlDataReader = command.ExecuteReader()

        If reader.HasRows Then
            Do While reader.Read()
                Console.WriteLine(reader.GetInt32(0) _
                  & vbTab & reader.GetString(1))
            Loop
        Else
            Console.WriteLine("No rows found.")
        End If

        reader.Close()
    End Using
End Sub

Menutup DataReader

Selalu panggil metode Tutup setelah Anda selesai menggunakan objek DataReader .

Jika Perintah Anda berisi parameter output atau mengembalikan nilai, nilai tersebut tidak tersedia hingga DataReader ditutup.

Saat DataReader terbuka, Koneksi sedang digunakan secara eksklusif oleh DataReader tersebut. Anda tidak dapat menjalankan perintah apa pun untuk Koneksi, termasuk membuat DataReader lain, hingga DataReader asli ditutup.

Nota

Jangan panggil Tutup atau Buang pada Koneksi, DataReader, atau objek terkelola lainnya dalam metode Finalisasi kelas Anda. Dalam finalizer, hanya lepaskan sumber daya yang tidak dikelola yang secara langsung dimiliki oleh kelas Anda. Jika kelas Anda tidak memiliki sumber daya yang tidak dikelola, jangan sertakan metode Finalisasi dalam definisi kelas Anda. Untuk informasi selengkapnya, lihat Pengumpulan Sampah.

Mengambil beberapa kumpulan hasil menggunakan NextResult

Jika DataReader mengembalikan beberapa kumpulan hasil, panggil metode NextResult untuk melakukan iterasi melalui tataan hasil secara berurutan. Contoh berikut menunjukkan SqlDataReader pemrosesan hasil dua pernyataan SELECT menggunakan ExecuteReader metode .

static void RetrieveMultipleResults(SqlConnection connection)
{
    using (connection)
    {
        SqlCommand command = new(
          "SELECT CategoryID, CategoryName FROM dbo.Categories;" +
          "SELECT EmployeeID, LastName FROM dbo.Employees",
          connection);
        connection.Open();

        SqlDataReader reader = command.ExecuteReader();

        while (reader.HasRows)
        {
            Console.WriteLine($"\t{reader.GetName(0)}\t{reader.GetName(1)}");

            while (reader.Read())
            {
                Console.WriteLine($"\t{reader.GetInt32(0)}\t{reader.GetString(1)}");
            }
            reader.NextResult();
        }
    }
}

Private Sub RetrieveMultipleResults(ByVal connection As SqlConnection)
    Using connection
        Dim command As SqlCommand = New SqlCommand( _
          "SELECT CategoryID, CategoryName FROM Categories;" & _
          "SELECT EmployeeID, LastName FROM Employees", connection)
        connection.Open()

        Dim reader As SqlDataReader = command.ExecuteReader()

        Do While reader.HasRows
            Console.WriteLine(vbTab & reader.GetName(0) _
              & vbTab & reader.GetName(1))

            Do While reader.Read()
                Console.WriteLine(vbTab & reader.GetInt32(0) _
                  & vbTab & reader.GetString(1))
            Loop

            reader.NextResult()
        Loop
    End Using
End Sub

Mendapatkan informasi skema dari DataReader

Saat DataReader terbuka, Anda dapat mengambil informasi skema tentang kumpulan hasil saat ini menggunakan metode GetSchemaTable . GetSchemaTable mengembalikan objek yang DataTable diisi dengan baris dan kolom yang berisi informasi skema untuk kumpulan hasil saat ini. DataTable berisi satu baris untuk setiap kolom kumpulan hasil. Setiap kolom pada tabel skema merujuk pada properti dari kolom yang dikembalikan dalam baris kumpulan hasil, di mana ColumnName adalah nama properti dan nilai dari kolom tersebut adalah nilai properti. Contoh berikut menuliskan informasi skema untuk DataReader.

static void GetSchemaInfo(SqlConnection connection)
{
    using (connection)
    {
        SqlCommand command = new(
          "SELECT CategoryID, CategoryName FROM Categories;",
          connection);
        connection.Open();

        SqlDataReader reader = command.ExecuteReader();
        DataTable schemaTable = reader.GetSchemaTable();

        foreach (DataRow row in schemaTable.Rows)
        {
            foreach (DataColumn column in schemaTable.Columns)
            {
                Console.WriteLine(string.Format("{0} = {1}",
                   column.ColumnName, row[column]));
            }
        }
    }
}

Private Sub GetSchemaInfo(ByVal connection As SqlConnection)
    Using connection
        Dim command As SqlCommand = New SqlCommand( _
          "SELECT CategoryID, CategoryName FROM Categories;", _
          connection)
        connection.Open()

        Dim reader As SqlDataReader = command.ExecuteReader()
        Dim schemaTable As DataTable = reader.GetSchemaTable()

        Dim row As DataRow
        Dim column As DataColumn

        For Each row In schemaTable.Rows
            For Each column In schemaTable.Columns
                Console.WriteLine(String.Format("{0} = {1}", _
                  column.ColumnName, row(column)))
            Next
            Console.WriteLine()
        Next
        reader.Close()
    End Using
End Sub

Bekerja dengan bab OLE DB

Himpunan baris hierarkis, atau bab (jenis OLE DB DBTYPE_HCHAPTER, jenis ADO adChapter), dapat diambil menggunakan OleDbDataReader. Saat kueri yang menyertakan bab dikembalikan sebagai DataReader, bab dikembalikan sebagai kolom di DataReader tersebut dan diekspos sebagai objek DataReader .

Himpunan Data ADO.NET juga dapat digunakan untuk mewakili kumpulan baris hierarkis dengan menggunakan hubungan induk-turunan antar tabel. Untuk informasi selengkapnya, lihat Himpunan Data, DataTable, dan DataViews.

Contoh kode berikut menggunakan Penyedia MSDataShape untuk menghasilkan kolom bab pesanan untuk setiap pelanggan dalam daftar pelanggan.

Using connection As OleDbConnection = New OleDbConnection(
    "Provider=MSDataShape;Data Provider=SQLOLEDB;" &
    "Data Source=localhost;Integrated Security=SSPI;Initial Catalog=northwind")

    Using custCMD As OleDbCommand = New OleDbCommand(
        "SHAPE {SELECT CustomerID, CompanyName FROM Customers} " &
        "APPEND ({SELECT CustomerID, OrderID FROM Orders} AS CustomerOrders " &
        "RELATE CustomerID TO CustomerID)", connection)

        connection.Open()

        Using custReader As OleDbDataReader = custCMD.ExecuteReader()

            Do While custReader.Read()
                Console.WriteLine("Orders for " & custReader.GetString(1))
                ' custReader.GetString(1) = CompanyName  

                Using orderReader As OleDbDataReader = custReader.GetValue(2)
                    ' custReader.GetValue(2) = Orders chapter as DataReader  

                    Do While orderReader.Read()
                        Console.WriteLine(vbTab & orderReader.GetInt32(1))
                        ' orderReader.GetInt32(1) = OrderID  
                    Loop
                    orderReader.Close()
                End Using
            Loop
            ' Make sure to always close readers and connections.  
            custReader.Close()
        End Using
    End Using
End Using

using (OleDbConnection connection = new OleDbConnection(
    "Provider=MSDataShape;Data Provider=SQLOLEDB;" +
    "Data Source=localhost;Integrated Security=SSPI;Initial Catalog=northwind"))
{
    using (OleDbCommand custCMD = new OleDbCommand(
        "SHAPE {SELECT CustomerID, CompanyName FROM Customers} " +
        "APPEND ({SELECT CustomerID, OrderID FROM Orders} AS CustomerOrders " +
        "RELATE CustomerID TO CustomerID)", connection))
    {
        connection.Open();

        using (OleDbDataReader custReader = custCMD.ExecuteReader())
        {

            while (custReader.Read())
            {
                Console.WriteLine("Orders for " + custReader.GetString(1));
                // custReader.GetString(1) = CompanyName  

                using (OleDbDataReader orderReader = (OleDbDataReader)custReader.GetValue(2))
                {
                    // custReader.GetValue(2) = Orders chapter as DataReader  

                    while (orderReader.Read())
                        Console.WriteLine("\t" + orderReader.GetInt32(1));
                    // orderReader.GetInt32(1) = OrderID  
                    orderReader.Close();
                }
            }
            // Make sure to always close readers and connections.  
            custReader.Close();
        }
    }
}

Mengembalikan hasil dengan ORACLE REF CURSOR

Penyedia Data .NET Framework untuk Oracle mendukung penggunaan CURSOR Oracle REF untuk mengembalikan hasil kueri. Oracle REF CURSOR dikembalikan sebagai OracleDataReader.

Anda dapat mengambil objek OracleDataReader yang mewakili ORACLE REF CURSOR dengan menggunakan metode ExecuteReader. Anda juga dapat menentukan OracleCommand yang mengembalikan satu atau beberapa CURSOR REF Oracle sebagai SelectCommand untuk digunakan OracleDataAdapter untuk mengisi DataSet.

Untuk mengakses REF CURSOR yang dikembalikan dari sumber data Oracle, buat OracleCommand untuk kueri Anda dan tambahkan parameter output yang mereferensikan REF CURSOR ke Parameters koleksi Anda OracleCommand. Nama parameter harus cocok dengan nama parameter REF CURSOR dalam kueri Anda. Atur jenis parameter ke OracleType.Cursor. Metode OracleCommand.ExecuteReader() Anda OracleCommand mengembalikan OracleDataReader untuk REF CURSOR.

Jika Anda OracleCommand mengembalikan beberapa REF CURSORS, tambahkan beberapa parameter output. Anda dapat mengakses BERBAGAI CURSOR REF dengan memanggil OracleCommand.ExecuteReader() metode . Panggilan untuk ExecuteReader() mengembalikan OracleDataReader referensi KURSOR REF pertama. Anda kemudian dapat memanggil OracleDataReader.NextResult() metode untuk mengakses CURSOR REF berikutnya. Meskipun parameter dalam koleksi Anda OracleCommand.Parameters cocok dengan parameter output REF CURSOR berdasarkan nama, OracleDataReader mengakses parameter dalam urutan di mana mereka ditambahkan ke koleksi Parameters.

Misalnya, pertimbangkan paket Oracle dan isi paket berikut.

CREATE OR REPLACE PACKAGE CURSPKG AS
  TYPE T_CURSOR IS REF CURSOR;
  PROCEDURE OPEN_TWO_CURSORS (EMPCURSOR OUT T_CURSOR,
    DEPTCURSOR OUT T_CURSOR);
END CURSPKG;  
  
CREATE OR REPLACE PACKAGE BODY CURSPKG AS
  PROCEDURE OPEN_TWO_CURSORS (EMPCURSOR OUT T_CURSOR,
    DEPTCURSOR OUT T_CURSOR)
  IS
  BEGIN
    OPEN EMPCURSOR FOR SELECT * FROM DEMO.EMPLOYEE;
    OPEN DEPTCURSOR FOR SELECT * FROM DEMO.DEPARTMENT;
  END OPEN_TWO_CURSORS;
END CURSPKG;

Kode berikut membuat OracleCommand yang mengembalikan CURSOR REF dari paket Oracle sebelumnya dengan menambahkan dua parameter jenis OracleType.Cursor ke OracleCommand.Parameters koleksi.

Dim cursCmd As OracleCommand = New OracleCommand("CURSPKG.OPEN_TWO_CURSORS", oraConn)  
cursCmd.Parameters.Add("EMPCURSOR", OracleType.Cursor).Direction = ParameterDirection.Output  
cursCmd.Parameters.Add("DEPTCURSOR", OracleType.Cursor).Direction = ParameterDirection.Output

OracleCommand cursCmd = new OracleCommand("CURSPKG.OPEN_TWO_CURSORS", oraConn);  
cursCmd.Parameters.Add("EMPCURSOR", OracleType.Cursor).Direction = ParameterDirection.Output;  
cursCmd.Parameters.Add("DEPTCURSOR", OracleType.Cursor).Direction = ParameterDirection.Output;

Kode berikut mengembalikan hasil dari perintah sebelumnya menggunakan metode Read() dan NextResult() dari OracleDataReader. Parameter REF CURSOR dikembalikan secara berurutan.

oraConn.Open()  
  
Dim cursCmd As OracleCommand = New OracleCommand("CURSPKG.OPEN_TWO_CURSORS", oraConn)  
cursCmd.CommandType = CommandType.StoredProcedure  
cursCmd.Parameters.Add("EMPCURSOR", OracleType.Cursor).Direction = ParameterDirection.Output  
cursCmd.Parameters.Add("DEPTCURSOR", OracleType.Cursor).Direction = ParameterDirection.Output  
  
Dim reader As OracleDataReader = cursCmd.ExecuteReader()  
  
Console.WriteLine(vbCrLf & "Emp ID" & vbTab & "Name")  
  
Do While reader.Read()  
  Console.WriteLine("{0}" & vbTab & "{1}, {2}", reader.GetOracleNumber(0), reader.GetString(1), reader.GetString(2))  
Loop  
  
reader.NextResult()  
  
Console.WriteLine(vbCrLf & "Dept ID" & vbTab & "Name")  
  
Do While reader.Read()  
  Console.WriteLine("{0}" & vbTab & "{1}", reader.GetOracleNumber(0), reader.GetString(1))  
Loop  
' Make sure to always close readers and connections.  
reader.Close()  
oraConn.Close()

oraConn.Open();  
  
OracleCommand cursCmd = new OracleCommand("CURSPKG.OPEN_TWO_CURSORS", oraConn);  
cursCmd.CommandType = CommandType.StoredProcedure;  
cursCmd.Parameters.Add("EMPCURSOR", OracleType.Cursor).Direction = ParameterDirection.Output;  
cursCmd.Parameters.Add("DEPTCURSOR", OracleType.Cursor).Direction = ParameterDirection.Output;  
  
OracleDataReader reader = cursCmd.ExecuteReader();  
  
Console.WriteLine("\nEmp ID\tName");  
  
while (reader.Read())  
  Console.WriteLine("{0}\t{1}, {2}", reader.GetOracleNumber(0), reader.GetString(1), reader.GetString(2));  
  
reader.NextResult();  
  
Console.WriteLine("\nDept ID\tName");  
  
while (reader.Read())  
  Console.WriteLine("{0}\t{1}", reader.GetOracleNumber(0), reader.GetString(1));  
// Make sure to always close readers and connections.  
reader.Close();  
oraConn.Close();

Contoh berikut menggunakan perintah sebelumnya untuk mengisi DataSet dengan hasil paket Oracle.

Dim ds As DataSet = New DataSet()  
  
Dim adapter As OracleDataAdapter = New OracleDataAdapter(cursCmd)  
adapter.TableMappings.Add("Table", "Employees")  
adapter.TableMappings.Add("Table1", "Departments")  
  
adapter.Fill(ds)

DataSet ds = new DataSet();  
  
OracleDataAdapter adapter = new OracleDataAdapter(cursCmd);  
adapter.TableMappings.Add("Table", "Employees");  
adapter.TableMappings.Add("Table1", "Departments");  
  
adapter.Fill(ds);

Nota

Untuk menghindari OverflowException, kami sarankan Anda juga menangani konversi apa pun dari jenis Oracle NUMBER ke jenis .NET Framework yang valid sebelum menyimpan nilai dalam DataRow. Anda dapat menggunakan FillError peristiwa untuk menentukan apakah OverflowException telah terjadi. Untuk informasi selengkapnya tentang peristiwa FillError, lihat Menangani Peristiwa DataAdapter.

Bagikan melalui