C# で MySQL サーバーに接続したい（実践編）!!!

C# MySql.Data を使用して MySQL サーバーへ接続する方法をまとめます。

目次

やりたいこと

MySQL サーバーへ接続しコマンドを送信する C# コードを作成し、データベースの作成を目指します。

事前準備

手順概要

手順１．MySQL サーバーへコマンドを送信する関数を作成する
手順２．MySQL サーバーへコマンドを送信する

手順１．MySQL サーバーへコマンドを送信する関数を作成する

using を追加する

// 追加
using MySql.Data.MySqlClient;

private static readonly string connectionString = 
string.Format(@"Host={0};User Id={1};Password={2};Persist Security Info=False;",
    "localhost",    // MySQLサーバーのIPアドレスまたはドメイン名を指定
    "testuser",     // ユーザーIDを指定
    "testpsw");     // ユーザーパスワードを指定

/// <summary>
/// MySQLにコマンド送信
/// </summary>
/// <param name="command">MySQLへ送信するコマンド</param>
/// <returns>true:成功, false:失敗</returns>
public static bool Send(string command)
{
    bool ret = true;

    using (MySqlConnection connection = new MySqlConnection(connectionString))
    {
        using (MySqlCommand cmd = new MySqlCommand(command, connection))
        {
            try
            {
                // ポートオープン
                cmd.Connection.Open();
                // 送信
                cmd.ExecuteNonQuery();
            }
            catch (Exception)
            {
                ret = false;
            }
        }
    }
    return ret;
}

/// <summary>
/// MySQLにコマンドを送信し値を取得する
/// </summary>
/// <param name="command">MySQLへ送信するコマンド</param>
/// <param name="dt">受信した値</param>
/// <returns>true:成功, false:失敗</returns>
public static bool SendRead(string command, ref System.Data.DataSet ds)
{
    bool ret = true;

    using (MySqlConnection connection = new MySqlConnection(connectionString))
    {
        using (MySqlDataAdapter da = new MySqlDataAdapter(command, connection))
        {
            try
            {
                // 送受信
                da.Fill(ds);
            }
            catch (Exception)
            {
                ret = false;
            }
        }
    }
    return ret;
}

class MySQL
{
    private static readonly string connectionString = // 手順１で作成した connectionString を追記しましょう。

    ///
    /// MySQL サーバーへコマンドの送信のみを行う
    /// 
    ///MySQLへ送信するコマンド
    /// true:成功, false:失敗
    public static bool Send(string command)
    {
        // 手順１で作成した Send 関数の中身を記載しましょう。
    }

    ///
    /// MySQL サーバーへコマンドを送信し、MySQL サーバーから値を取得する
    /// 
    ///MySQLへ送信するコマンド
    ///受信した値
    /// true:成功, false:失敗
    public static bool SendRead(string command, ref System.Data.DataTable dt)
    {
        // 手順１で作成した SendRead 関数の中身を記載しましょう。
    }
}

手順２．MySQL サーバーへコマンドを送信する

作成したクラスを使って、MySQL サーバーにデータベースを作成してみましょう

// データベース作成
MySQL.Send("CREATE DATABASE testdb;");

mysql -u testuser -h localhost -p

SHOW DATABASES;

まとめ

C＃で MySQL サーバーに対して、実際にデータベースを作成してみました。
今回お見せした２関数は、MySQL コマンドを変更するだけで殆どの MySQL コマンドを実行できます。是非お試しください。

関連するページ

本記事の導入編を以下に記載していますので、よろしければアクセスしてください。

Wantからはじめる備忘録

その他の備忘録も以下のページでまとめていますので、よろしければアクセスしてください。

以上！！