次のセクションでは、DbCommand やDbDataAdapter などのADO.NET 基本クラスを使用してコマンドを実行する方法を示します。

Spark SQL へのコマンドの実行

次のコードは、既存のDbConnection オブジェクトを指定して、Spark SQL に"SELECT *" クエリを実行します。

using (connection) {

  // Create the DbCommand.
  DbCommand command = factory.CreateCommand();
  command.CommandText = 
    "SELECT * FROM Customers";

  command.Connection = connection;

  // Create the DbDataAdapter.
  DbDataAdapter adapter = factory.CreateDataAdapter();
  adapter.SelectCommand = command;

  // Fill the DataTable.
  DataTable table = new DataTable();
  adapter.Fill(table);

  //  Display each row and column value.
  foreach (DataRow row in table.Rows) {
    foreach (DataColumn column in table.Columns) {
      Console.WriteLine(row[column]);
    }
  }
}