テーブルデータゲートウェイ

ただ今 PofEAA の勉強中

まずはテーブルデータゲートウェイに挑戦。つっこみ歓迎です。

テーブルデータゲートウェイって？

「エンタープライズアプリケーションアーキテクチャパターン」によると

データベーステーブルに対して「ゲートウェイ」の役割を果たすオブジェクト。１つのインスタンスがテーブル内のすべての行を処理する。

というもの。

開発者みんなが SQL に精通しているとは限らないから、テーブルやビューにアクセス（選択・挿入・更新・削除）するための SQL をテーブルデータゲートウェイがラップして、それらの機能をメソッドで提供する・・・と。

複雑なパターンではないので、サンプルコードを書いた方が理解しやすいかも。

例えばこんなテーブルがあります

items テーブル

列名	型	説明など
id	INTEGER	主キー, UNSIGNED, AUTO INC
title	VARCHAR
description	TEXT

このテーブルにパターンを適用します

public class ItemsGateway
{
    public IDataReader Find(uint id)
    {
        using (DbConnection connection = CreateConnection())
        {
            connection.Open();
            using (DbCommand command = connection.CreateCommand())
            {
                command.CommandText = @"select * from items where id = ?id";
                AddInParameter(command, "?id", DbType.UInt32, id);
                return command.ExecuteReader();
            }
        }
    }

    public void Insert(string title, string description)
    {
        using (DbConnection connection = CreateConnection())
        {
            connection.Open();
            using (DbCommand command = connection.CreateCommand())
            {
                command.CommandText = @"insert into items (title, description) values (?title, ?description)";
                AddInParameter(command, "?title", DbType.String, title);
                AddInParameter(command, "?description", DbType.String, description);
                command.ExecuteNonQuery();
            }
        }
    }

    public void Update(uint id, string title, string description)
    {
        using (DbConnection connection = CreateConnection())
        {
            connection.Open();
            using (DbCommand command = connection.CreateCommand())
            {
                command.CommandText = @"update items set title = ?title, description = ?description where id = ?id";
                AddInParameter(command, "?id", DbType.UInt32, id);
                AddInParameter(command, "?title", DbType.String, title);
                AddInParameter(command, "?description", DbType.String, description);
                command.ExecuteNonQuery();
            }
        }
    }

    public void Delete(uint id)
    {
        using (DbConnection connection = CreateConnection())
        {
            connection.Open();
            using (DbCommand command = connection.CreateCommand())
            {
                command.CommandText = @"delete from items where id = ?id";
                AddInParameter(command, "?id", DbType.UInt32, id);
                command.ExecuteNonQuery();
            }
        }
    }

    private void AddInParameter(DbCommand command, string name, DbType type, object value)
    {
        DbParameter parameter = command.CreateParameter();
        parameter.DbType = type;
        parameter.ParameterName = name;
        parameter.Value = value;
        command.Parameters.Add(parameter);
    }

    // 接続文字列は環境に合わせて変更する必要アリ！！
    private const string CONNECTION_STRING = @"Persist Security Info=False;database=test;server=MySqlServer;user id=myUser;Password=myPass";

    private DbConnection CreateConnection()
    {
        return new MySqlConnection(CONNECTION_STRING);
    }
}

これって・・・

普段データアクセスするクラスを作るときに使っている方法だ！「テーブルデータゲートウェイ」っていう名前が付いてたのかぁ。

あと今回は id で絞り込む Find メソッドだけ書いたけど、実際にこのパターンを使う場合は、title で絞り込むものや description で絞り込むものなど、複数用意するほうが便利。