C#のMySQLでトランザクション使用する - プログラムを書こう！

この記事は2020年01月17日に投稿しました。

f:id:paveway:20190914064630j:plain

1. はじめに

こんにちは、iOSのエディタアプリPWEditorの開発者の二俣です。
今回は業務で使用しているC#のMySQLでトランザクションを使用する方法についてです。

2. C#のMySQLでトランザクション使用する

C#のMySQLでトランザクションを使用するには、以下のような実装になります。
try～catchがネストしています。
外側のtry～catchはコネクションオブジェクト、コマンドオブジェクトの生成時の例外に対応しています。
内側はtry～catchはデータベース操作での例外に対応しています。

接続情報は、環境により修正してください。

実装例

using MySql.Data.MySqlClient;
using System;

namespace CSharpMySQLTransaction
{
    class Program
    {
        // 接続情報
        private static readonly string Server = "localhost";      // ホスト名
        private static readonly int Port = 3306;                  // ポート番号
        private static readonly string Database = "sample";       // データベース名
        private static readonly string Uid = "user";              // ユーザ名
        private static readonly string Pwd = "password";          // パスワード

        // 接続文字列
        private static readonly string ConnectionString = $"Server={Server}; Port={Port}; Database={Database}; Uid={Uid}; Pwd={Pwd}";

        // データ更新SQL
        private static readonly string UpdateSql = $"UPDATE {Database}.person SET name = @name WHERE id = @id";

        static void Main(string[] args)
        {
            try
            {
                // コネクションオブジェクトとコマンドオブジェクトを生成します。
                using (var connection = new MySqlConnection(ConnectionString))
                using (var command = new MySqlCommand())
                {
                    MySqlTransaction transaction = null;
                    try
                    {
                        // コネクションをオープンします。
                        connection.Open();

                        // コマンドオブジェクトにコネクションを設定します。
                        // トランザクションを使用する場合、設定しないと例外が発生します。
                        command.Connection = connection;

                        // トランザクションを開始します。
                        transaction = connection.BeginTransaction();

                        // データ更新のSQLを実行します。
                        command.CommandText = UpdateSql;
                        command.Parameters.Add(new MySqlParameter("@name", "jiro"));
                        command.Parameters.Add(new MySqlParameter("@id", 1));
                        var result = command.ExecuteNonQuery();
                        // 実行された結果が1行ではない場合
                        if (result != 1)
                        {
                            Console.WriteLine("データを更新できませんでした。");

                            // ロールバックします。
                            transaction.Rollback();
                            return;
                        }

                        // コミットします。
                        transaction.Commit();
                    }

                    // データベース操作で例外が発生した場合
                    catch (Exception e)
                    {
                        // 例外の内容を表示します。
                        Console.WriteLine(e.Message);

                        // トランザクションが有効な場合
                        if (transaction != null)
                        {
                            // ロールバックします。
                            transaction.Rollback();
                        }
                    }
                }
            }

            // コネクションオブジェクト、コマンドオブジェクトの生成で例外が発生した場合
            catch (Exception e)
            {
                // 例外の内容を表示します。
                Console.WriteLine(e.Message);
            }

            Console.ReadKey();
        }
    }
}

目次へ

3. おわりに

前回紹介した

www.paveway.info

と異なり、MySQLでトランザクションを使用する場合、コマンドオブジェクトにコネクションを設定しないと例外が発生します。

リンク

紹介している一部の記事のコードはGitlabで公開しています。
興味のある方は覗いてみてください。

目次へ

私が勤務しているニューラルでは、主に組み込み系ソフトの開発を行っております。
弊社製品のハイブリッドOS Bi-OSは高い技術力を評価されており、特に制御系や通信系を得意としています。
私自身はiOSモバイルアプリやウィンドウズアプリを得意としております。
ソフトウェア開発に関して相談などございましたら、お気軽にご連絡ください。

また一緒に働きたい技術者の方も随時募集中です。
興味がありましたらご連絡ください。

EMAIL : info-nr@newral.co.jp / m-futamata@newral.co.jp
TEL : 042-523-3663
FAX : 042-540-1688

目次へ