Události
Vytváření inteligentních aplikací
17. 3. 23 - 21. 3. 23
Připojte se k řadě meetupů a vytvořte škálovatelná řešení AI založená na skutečných případech použití s kolegy vývojáři a odborníky.
ZaregistrovatTento prohlížeč se už nepodporuje.
Upgradujte na Microsoft Edge, abyste mohli využívat nejnovější funkce, aktualizace zabezpečení a technickou podporu.
Chcete-li načíst data pomocí DataReader, vytvořte instanci command objektu a pak vytvořte DataReader voláním Command.ExecuteReader pro načtení řádků ze zdroje dat. DataReader poskytuje nerozbufferovaný datový proud dat, který umožňuje procedurální logiku efektivně zpracovávat výsledky ze zdroje dat postupně. Čtečka dat je dobrou volbou při načítání velkých objemů dat, protože data nejsou uložená v mezipaměti.
Následující příklad ukazuje použití DataReader, kde reader
představuje platný DataReader a command
představuje platný Command objekt.
reader = command.ExecuteReader();
reader = command.ExecuteReader()
K získání řádku z výsledků dotazu použijte metodu DataReader.Read . Ke každému sloupci vráceného řádku můžete přistupovat předáním názvu nebo pořadového čísla sloupce do třídy DataReader. Pro zajištění nejlepšího výkonu však DataReader poskytuje řadu metod, které umožňují přístup k hodnotám sloupců v jejich nativních datových typech (GetDateTime, GetDouble, GetGuid, GetInt32 atd.). Seznam metod typového přístupového objektu pro objekty DataReader specifické pro zprostředkovatele dat naleznete OleDbDataReader a SqlDataReader. Použití metod typového přístupového objektu, pokud víte, že základní datový typ snižuje množství převodu typů vyžadované při načítání hodnoty sloupce.
Následující příklad iteruje objekt DataReader a vrátí dva sloupce z každého řádku.
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("{0}\t{1}", reader.GetInt32(0),
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
Vždy zavolat Close metoda po dokončení pomocí DataReader objektu.
Pokud příkaz obsahuje výstupní parametry nebo návratové hodnoty, nebudou tyto hodnoty k dispozici, dokud čtečka DatReader nezavře.
I když je čtečka dat otevřená, Připojení ion se používá výhradně pro tuto čtečku DatReader. Nelze spustit žádné příkazy pro Připojení ion, včetně vytvoření jiného objektu DataReader, dokud se původní čtečka DatReader neuzavře.
Poznámka
Nevolejte Close nebo Dispose na Připojení ion, DataReader ani žádný jiný spravovaný objekt v metodě Finalize vaší třídy. V finalizátoru uvolněte pouze nespravované prostředky, které vaše třída vlastní přímo. Pokud vaše třída nevlastní žádné nespravované prostředky, nezahrnujte do definice třídy metodu Finalize . Další informace naleznete v tématu Uvolňování paměti.
Pokud DataReader vrátí více sad výsledků, zavolejte NextResult metoda iterovat přes sady výsledků postupně. Následující příklad ukazuje SqlDataReader zpracování výsledků dvou příkazů SELECT pomocí ExecuteReader metody.
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{0}\t{1}", reader.GetName(0),
reader.GetName(1));
while (reader.Read())
{
Console.WriteLine("\t{0}\t{1}", reader.GetInt32(0),
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
Zatímco DataReader je otevřen, můžete načíst informace o schématu o aktuální sadě výsledků pomocí GetSchemaTable metoda. Funkce GetSchemaTable vrátí DataTable objekt naplněný řádky a sloupci, které obsahují informace o schématu pro aktuální sadu výsledků. Tabulka DataTable obsahuje jeden řádek pro každý sloupec sady výsledků. Každý sloupec tabulky schématu se mapuje na vlastnost sloupců vrácených v řádcích sady výsledků, kde ColumnName je název vlastnosti a hodnota sloupce je hodnota vlastnosti. Následující příklad zapíše informace o schématu pro 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
Hierarchické sady řádků nebo kapitoly (typ OLE DB DBTYPE_HCHAPTER, adChapter typu ADO) lze načíst pomocí .OleDbDataReader Pokud je dotaz, který obsahuje kapitolu, vrácen jako DataReader, kapitola je vrácena jako sloupec v objektu DataReader a je vystavena jako Objekt DataReader .
Datovou sadu ADO.NET lze také použít k reprezentaci hierarchických sad řádků pomocí relací nadřazených a podřízených mezi tabulkami. Další informace naleznete v tématu Datové sady, Datové tabulky a DataViews.
Následující příklad kódu používá zprostředkovatel MSDataShape k vygenerování sloupce kapitol objednávek pro každého zákazníka v seznamu zákazníků.
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();
}
}
}
Rozhraní .NET Framework Zprostředkovatel dat pro Oracle podporuje použití oracle REF CURSORs k vrácení výsledku dotazu. Oracle REF CURSOR je vrácen jako OracleDataReader.
Pomocí metody můžete načíst OracleDataReader objekt, který představuje Oracle REF CURSOR ExecuteReader . Můžete také určit OracleCommand , který vrátí jeden nebo více Oracle REF CURSORs jako SelectCommand pro OracleDataAdapter použití k vyplnění DataSet.
Pokud chcete získat přístup k REF CURSOR vrácený ze zdroje dat Oracle, vytvořte OracleCommand pro svůj dotaz a přidejte výstupní parametr, který odkazuje NA REF CURSOR na Parameters kolekci vašeho OracleCommand. Název parametru se musí shodovat s názvem parametru REF CURSOR v dotazu. Nastavte typ parametru na OracleType.Cursorhodnotu . Metoda OracleCommand.ExecuteReader() vrátí OracleCommand OracleDataReader pro REF CURSOR.
Pokud vrátíte OracleCommand více REF CURSORS, přidejte více výstupních parametrů. K různým objektům REF CURSORs se dostanete voláním OracleCommand.ExecuteReader() metody. Volání, které ExecuteReader() vrátí OracleDataReader odkaz na první REF CURSOR. Pak můžete volat metodu OracleDataReader.NextResult() pro přístup k následným REF CURSORs. Přestože parametry v OracleCommand.Parameters kolekci odpovídají výstupním parametrům REF CURSOR podle názvu, OracleDataReader přistupuje k nim v pořadí, v jakém byly přidány do Parameters kolekce.
Představte si například následující balíček Oracle a text balíčku.
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;
Následující kód vytvoří OracleCommand , který vrátí REF CURSORs z předchozího balíčku Oracle přidáním dvou parametrů typu OracleType.Cursor do OracleCommand.Parameters kolekce.
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;
Následující kód vrátí výsledky předchozího příkazu pomocí Read() metod NextResult() a metod OracleDataReader. Parametry REF CURSOR se vrátí v pořadí.
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();
Následující příklad používá předchozí příkaz k naplnění DataSet výsledků balíčku 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);
Poznámka
Chcete-li zabránit overflowException, doporučujeme, abyste před uložením hodnoty do DataRowsouboru .NET Framework zpracovávali také jakýkoli převod z typu Oracle NUMBER na platný typ rozhraní .NET Framework. Událost můžete použít FillError k určení, zda došlo k overflowException . Další informace o FillError události naleznete v tématu Zpracování událostí dataAdapter.
Události
Vytváření inteligentních aplikací
17. 3. 23 - 21. 3. 23
Připojte se k řadě meetupů a vytvořte škálovatelná řešení AI založená na skutečných případech použití s kolegy vývojáři a odborníky.
ZaregistrovatŠkolení
Modul
Use Power Query to load data in Dataverse - Training
Learn how to synchronize data from different sources to a Microsoft Dataverse table using Power Query and create dataflows in Power Apps.
Dokumentace
Naplnění datové sady z adaptéru dat - ADO.NET
Zjistěte, jak naplnit datovou sadu z objektu DataAdapter v ADO.NET, který poskytuje konzistentní relační programovací model nezávislý na zdroji dat.