C Sharpとデータベース - 結果の取得

概要

C\#でSQL Serverに対してSELECT文を実行する際のサンプルコードを作成した。
ここでは、下記の2種類を例として取り上げる。

1. SELECT文の実行結果をDataTableを用いてまとめて読み込む方法
2. SELECT文の実行結果を1行ずつ読み込む方法

まとめて読み込む(DataTable)

DataTableへSELECT文の結果を一括で読み込む方法を説明する。この方法は単純で理解しやすい。
DataSetを使用する方法もあるが、DataTableを取り出すためにワンクッション必要となるため、DataTableへ直接代入する方がよい。

一括でDataTableへ読み込む際は、DataAdapterを使用する。

using System;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;

public DataTable GetData()
{
   var table = new DataTable();

   // 接続文字列の取得
   var connectionString = ConfigurationManager.ConnectionStrings["sqlsvr"].ConnectionString;

   using (var connection = new SqlConnection(connectionString))
   using (var command = connection.CreateCommand())
   {
       try
       {
           // データベースの接続開始
           connection.Open();

           // クエリの作成
           command.CommandText = @"SELECT count(*) FROM T_USER";

           // クエリの実行
           var adapter = new SqlDataAdapter(command);
           adapter.Fill(table);
       }
       catch (Exception exception)
       {
           Console.WriteLine(exception.Message);
           throw;
       }
       finally
       {   // データベースの接続終了
           connection.Close();
       }
   }

   return table;
}

１行ずつ読み込む(SqlDataReader)

SELECT文の結果を1行ずつ読み込む場合、DataReaderを使用する。
CommandのExecuteReader()メソッドを実行することで、DataReaderを取得し、1行ずつ読み込んで処理を行う。
実装は面倒だが O/Rマッピングのようなことができる。

以下のサンプルコードにおけるUserModelはT_USERに対応する独自のクラスになる。

using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data.SqlClient;
using WebApplication1.Models;

public List<usermodel> GetData()
{
   var list = new List<usermodel>();

   // 接続文字列の取得
   var connectionString = ConfigurationManager.ConnectionStrings["sqlsvr"].ConnectionString;

   using (var connection = new SqlConnection(connectionString))
   using (var command = connection.CreateCommand())
   {
       try
       {
           // データベースの接続開始
           connection.Open();

           // クエリの作成
           command.CommandText = @"SELECT ID,PASSWORD,ROLE_NAME FROM T_USER";

           // クエリの実行
           using (var reader = command.ExecuteReader())
           {
               while (reader.Read() == true)
               {
                   list.Add(new UserModel()
                   {
                       Id = reader["ID"] as string,
                       Password = reader["PASSWORD"] as string,
                       RoleName = reader["ROLE_NAME"] as string
                   });
               }
           }
       }
       catch (Exception exception)
       {
           Console.WriteLine(exception.Message);
           throw;
       }
       finally
       {   // データベースの接続終了
           connection.Close();
       }
   }

   return list;
}