DataReaderオブジェクト

■　データソースごとのクラス

接続の種類 クラス名
System.Data.SqlClient SqlDataReaderクラス
System.Data.OracleClient OracleDataReaderクラス
System.Data.OleDb OleDbDataReaderクラス
System.Data.Odbc OdbcDataReaderクラス
DataReaderオブジェクトの種類

　SqlDataReaderクラスは、データベースからSQL文の実行結果を読み込む際に使用するクラスです。データベースに接続した状態で使います。このクラスのメソッドを使って1件ずつ読み込むことができます。読み込むときにはカーソル(指し棒)の考え方を使います。カーソルを動かして、カーソルが指す行を読み込みます。

■　主なプロパティ

プロパティ名 概要
Connection SqlDataReaderオブジェクトに関連付けられているSqlConnectionオブジェクトを取得する
FieldCount 現在の行の列数を取得する
HasRows SqlDataReaderオブジェクトに1行以上の行が格納されているかどうかを取得する
Item[Int32] 列の順番を指定して値を取得する
Item[String] 列名を指定して値を取得する
SqlDataReaderの主なプロパティ

■　主なメソッド

メソッド名 概要
Close SqlDataReaderオブジェクトを閉じる
GetDouble 指定した列の値をdouble型として取得する
GetInt32 指定した列の値をint型として取得する
GetName 指定した列の名前を取得する
GetString 指定した列の値をstring型として取得する
GetValues 現在の行の値をオブジェクト配列に設定する
Read カーソルを次のレコードに進める
SqlDataReaderの主なメソッド

○　プロジェクト

　プロジェクトを作成して確認してみましょう。Usersテーブルからデータを読み込むプログラムを作成してみましょう。

プロジェクトの種類 コンソール アプリケーション
プロジェクト名 DataReaderTest

サンプルダウンロード

○　プログラム

　Mainメソッドに次のように記述してください。

Program.cs

  1. using System;
  2. using System.Collections.Generic;
  3. using System.Linq;
  4. using System.Text;
  5. using System.Threading.Tasks;
  6. using System.Data.SqlClient;
  8. namespace CommandTest
  9. {
  10. 　class Program
  11. 　{
  12. 　　static void Main(string[] args)
  13. 　　{
  14. 　　　//接続文字列
  15. 　　　string constr = @"Data Source=(LocalDB)¥v11.0;AttachDbFilename=C:¥Work¥Books.mdf;Integrated Security=True;Connect Timeout=30";
  17. 　　　//SqlConnectionオブジェクトを生成
  18. 　　　SqlConnection con = new SqlConnection(constr);
  20. 　　　//Usersテーブルのデータを取得するSQL文を作成
  21. 　　　string sql = "SELECT * FROM Users";
  23. 　　　//SqlCommandオブジェクトを生成
  24. 　　　SqlCommand cmd = new SqlCommand(sql, con);
  26. 　　　//データベースを開く
  27. 　　　con.Open();
  29. 　　　//SQL文を実行する
  30. 　　　SqlDataReader dr = cmd.ExecuteReader();
  32. 　　　//データリーダーの情報を表示する
  33. 　　　Console.WriteLine("列数：{0}", dr.FieldCount);
  34. 　　　Console.WriteLine("データがあるか？：{0}", dr.HasRows);
  35. 　　　Console.WriteLine();
  37. 　　　//データを取得する
  38. 　　　while (dr.Read())
  39. 　　　{
  40. 　　　　Console.Write("ID：{0}　", dr[0]);
  41. 　　　　Console.Write("ユーザー名：{0}　", dr["UserName"]);
  42. 　　　　Console.Write("パスワード：**　");
  43. 　　　　Console.Write("氏名：{0}", dr.GetString(3));
  44. 　　　　Console.WriteLine();
  45. 　　　}
  47. 　　　//データリーダーを閉じる
  48. 　　　dr.Close();
  50. 　　　//データベースを閉じる
  51. 　　　con.Close();
  52. 　　　Console.ReadLine();
  53. 　　}
  54. 　}
  55. }

○　実行結果

列数：4
データがあるか？：True

ID：1　ユーザー名：sato　パスワード：**　氏名：佐藤
ID：2　ユーザー名：suzuki　パスワード：**　氏名：鈴木
ID：3　ユーザー名：takahashi　パスワード：**　氏名：高橋
ID：4　ユーザー名：tanaka　パスワード：**　氏名：田中

○　解説

　21行目で、Usersテーブルから全件取得するSQL文を作成しています。そして、30行目でSQL文を実行しています。ExecuteReaderメソッドはSqlDataReaderオブジェクトを返します。このオブジェクトを使って、SQL文の実行結果を取り出します。このオブジェクトは、初期状態でカーソルは1件目の前を指しています。データを読み込む場合は、38行目にあるようにReadメソッドを呼び出してカーソルをずらします。今回はWhile文の条件でReadメソッドを使っていますが、Readメソッドはカーソルで指すデータがなくなるとFalseを返すので、レコードがある間繰り返すようになります。

　40~43行目でカーソルが指しているレコードのデータを読み込んでいます。それぞれの行でデータの読み込み方を変えています。データを読み込み終わったのち、48行目でSqlDataReaderを閉じています。これ以降、SqlDataReaderを使ってSQL文の実行結果を読み込むことができなくなります。

データベースとDataReaderオブジェクトの関係
データベースとDataReaderオブジェクトの関係

　ここまで見てきたデータベースからデータを読み取る方法は接続型を利用しました。つまり、データベースに接続して処理をしました。データベースへの接続を閉じた後は処理ができません。

前へ   次へ