Imports MySql.Data.MySqlClient

Public Class DataBase

    Private connectionString As String      'データベース接続文字列
    Private connection As MySqlConnection   'データベースコネクション


    '************************************************************
    'メソッド   ：コンストラクタ
    '概要       ：MySQL接続の初期設定を行う
    '************************************************************
    Sub New(ByVal host As String, ByVal port As String, ByVal databaseName As String, ByVal userId As String, ByVal password As String)

        connectionString = "server=" & host & ";"
        connectionString &= "port=" & port & ";"
        connectionString &= "database=" & databaseName & ";"
        connectionString &= "user id=" & userId & ";"
        connectionString &= "password=" & password

    End Sub

    '************************************************************
    'メソッド   ：Open
    '概要       ：MySQLへ接続する
    '************************************************************
    Public Sub Open()

        Try
            'コネクション生成
            connection = New MySqlConnection(Me.connectionString)

            'MySQLへ接続
            connection.Open()

        Catch mysqle As MySqlException

            'エラー。MySqlExceptionをスロー
            Throw mysqle
        End Try

    End Sub

    '************************************************************
    'メソッド   ：ExecuteQuery
    '概要       ：SELECT文の実行を行う
    '************************************************************
    Public Function ExecuteQuery(ByVal sql As String) As MySqlDataReader

        Dim sqlCommand As MySqlCommand
        Dim dataReader As MySqlDataReader

        Try
            'MySQLCommand作成
            sqlCommand = New MySqlCommand(sql, connection)

            'SQL文実行
            dataReader = sqlCommand.ExecuteReader()

        Catch mysqle As MySqlException

            'エラー。MySqlExceptionをスロー
            Throw mysqle

        End Try

        Return dataReader

    End Function

    '************************************************************
    'メソッド   ：ExecuteNonQuery
    '概要       ：INSERT, UPDATE, DELETE文の実行を行う
    '************************************************************
    Public Function ExecuteNonQuery(ByVal sql As String) As Integer

        Dim sqlCommand As MySqlCommand
        Dim effectRow As Integer

        Try

            'MySQLCommand作成
            sqlCommand = New MySqlCommand(sql, connection)

            'INSERT,UPDATE,DELETEの実行
            effectRow = sqlCommand.ExecuteNonQuery()

        Catch mysqle As MySqlException

            'エラー。MySqlExceptionをスロー
            Throw mysqle

        End Try

        Return effectRow

    End Function

    '************************************************************
    'メソッド   ：Close
    '概要       ：MySQL接続を切断する
    '************************************************************
    Public Sub Close()

        'クローズ
        connection.Close()

    End Sub

End Class