Textt

Imports System.Data.Odbc

Public Class MyLib

    Private Shared TargetCsvPath As String

    ' ******************************************************
    ' サンプルの為に、プロパティ用のメソッドを公開(Public)
    ' ******************************************************
    Public Shared Sub GetParam()

        ' CSV のパスを引数から取得する
        ' 空白を指定したい場合は、"文字列 文字列" のように指定する
        Dim arguments As String() = Environment.GetCommandLineArgs()
        ' 引数は一つのみ許可
        if arguments.Length <> 2 then
            Console.WriteLine("引数を指定して下さい")
            Return
        end if

        ' 引数からエクスポート対象テーブル名を取得
        MyLib.TargetCsvPath = arguments(1)

    End Sub

    ' ******************************************************
    ' データ取得のみの ReadOnly
    ' ******************************************************
    Public Shared ReadOnly Property CsvPath() As String
        Get
            MyLib.GetParam()
            Return MyLib.TargetCsvPath
        End Get
    End Property

    ' ******************************************************
    ' エラー処理
    ' ******************************************************
    Public Shared Sub ErrorAction( ex As OdbcException )

        Dim CrLf As String = ControlChars.CrLf
        Dim errorMessages As String = ""
        Dim i As Integer

        For i = 0 To ex.Errors.Count - 1
            errorMessages &= _
                "Index #" & i.ToString() & CrLf _
                & "Message: " & ex.Errors(i).Message & CrLf _
                & "NativeError: " & ex.Errors(i).NativeError.ToString() & CrLf _
                & "Source: " & ex.Errors(i).Source & CrLf _
                & "SQL: " & ex.Errors(i).SQLState & CrLf
        Next i

        Console.WriteLine(errorMessages)

    End Sub

End Class

Partial Class MyLib

    ' 接続用のオブジェクト
    Private myCon As OdbcConnection
    ' 更新用のオブジェクト
    Private execCommand As OdbcCommand

    Private builder As OdbcConnectionStringBuilder

    Private server_string As String
    Private database_string As String
    Private user_string As String
    Private password_string As String

    ' ******************************************************
    ' 初期処理( コンストラクタ )
    ' ******************************************************
    Public Sub New(a As String,b As String,c As String,d As String)

        Me.server_string = a
        Me.database_string = b
        Me.user_string = c
        Me.password_string = d

    End Sub

    ' ******************************************************
    ' 接続作成
    ' ******************************************************
    Function Execute( Query As String ) As Boolean

        ' 接続を開く
        Try
            Me.execCommand.CommandText = Query
            Me.execCommand.ExecuteNonQuery()
        Catch ex As OdbcException
            Console.WriteLine("SQL実行エラーです")
            Call MyLib.ErrorAction( ex )
            Return False
        End Try

        Return True

    End Function

    ' ******************************************************
    ' 接続作成
    ' ******************************************************
    Function CreateConnection( ) As Boolean

        ' 新しい OdbcConnectionStringBuilder オブジェクトを作成
        Me.builder = New OdbcConnectionStringBuilder()

        ' ドライバ文字列をセット ( 波型括弧{} は必要ありません ) 
        ' 文字列を正確に取得するには、レジストリ : HKEY_LOCAL_MACHINE\SOFTWARE\ODBC\ODBCINST.INI
        builder.Driver = "MySQL ODBC 5.1 Driver"

        ' 接続用のパラメータを追加
        builder.Add("SERVER", Me.server_string)
        builder.Add("DATABASE", Me.database_string)
        builder.Add("UID", Me.user_string)
        builder.Add("PWD", Me.password_string)

        ' 内容を確認
        Console.WriteLine(builder.ConnectionString)

        ' 新しい OdbcConnection オブジェクトを作成
        Me.myCon = New OdbcConnection()

        ' 接続文字列を設定
        Me.myCon.ConnectionString = builder.ConnectionString

        ' 接続を開く
        Try
            Me.myCon.Open()
        Catch ex As OdbcException
            Console.WriteLine("接続エラーです")
            ' Console.WriteLine( ex.Message )
            Call MyLib.ErrorAction( ex )
            Return False
        End Try

        ' 同時に実行用のオブジェクトを作成
        execCommand = New OdbcCommand()
        execCommand.Connection = Me.myCon

        Return True

    End Function

    ' ******************************************************
    ' 接続終了
    ' ******************************************************
    Public Sub EndConnection( )

        ' 接続を閉じる
        Me.myCon.Close()

        ' OdbcConnection オブジェクトに使用されているすべてのリソースを解放
        Me.myCon.Dispose()

        Me.execCommand.Dispose()

        ' 処理終了
        Console.WriteLine("処理が終了しました")

        ' 一時停止
        Console.Write("Enterキーを押して下さい : ")
        Console.ReadLine()

    End Sub

End Class