Imports System
Imports System.Data
Imports MySql.Data.MySqlClient
 
' öffentliche Klasse, über die auf die Datenbank zugegriffen werden kann
Public Class clsDBmySQL
    ' erben von der Klasse Config, um an die Konfiguration aus der Regestry zu 
    ' kommen
    Inherits clsConfig
 
    ' private (Klassen)Variablen
    Dim sSQL As String = ""
    Dim lInsertID As Long = 0
    Dim lRows As Long = 0
 
    ' öffentliche Eigenschaft, über die die Aüsführung eines SQL Queries ohne
    ' Ergebniss ausgeführt werden kann
    Public WriteOnly Property ExecuteQuery() As String
        Set(ByVal Value As String)
            sSQL = Value
            If sSQL <> "" Then
                _ExecuteQuery(sSQL)
            End If
        End Set
    End Property
 
    ' öffentliche Eigenschaft, über die die Anzahl der vom letzten Query
    ' betroffenen Zeilen ausgelesen werden kann
    Public ReadOnly Property AffectedRows() As Long
        Get
            Return lRows
        End Get
    End Property
 
    ' öffentliche Eigenschaft, über die die letzte ID ausgelesen werden
    ' kann, die bei einem INSERT erzeugt wurde
    Public ReadOnly Property LastInsertID() As Long
        Get
            Return lInsertID
        End Get
    End Property
 
    ' Private Methode, mit der ein Query ohne Ergebniss ausgeführt werden kann
    Private Function _ExecuteQuery(ByRef sSQL As String)
        Dim cmdSQL As MySqlCommand
        Dim oConn As MySqlConnection
        Dim oRead As MySqlDataReader
 
        ' wir versuchen, den query auszuführen
        Try
            ' offenen verbindung holen
            oConn = getConnection()
 
            ' query ausführen
            cmdSQL = New MySqlCommand(sSQL, oConn)
            lRows = cmdSQL.ExecuteNonQuery()
 
            ' Insert id holen
            ' # todo, abfrage, ob es überhaupt ein INSERT query ist
            sSQL = "SELECT LAST_INSERT_ID() AS id"
            cmdSQL = New MySqlCommand(sSQL, oConn)
            oRead = cmdSQL.ExecuteReader()
 
            If oRead.Read() = True Then
                If oRead.Item("id") > 0 Then
                    lInsertID = oRead.Item("id")
                Else
                    lInsertID = 0
                End If
            End If
 
            oConn.Close()
        Catch ex As Exception
        End Try
    End Function
 
    ' diese private Funktion lädt die Konfiguration der Datenbank 
    ' und gibt diese als Connection-String zurück
    Private Function loadMySQLConfig()
        ' dieser zwischenschritt ist eigentlich unnötig
        ' erleichtert mir aber die übersichtlichkeit ;)
        Try
            Return "Database=" & sDbName & ";Data Source=" & sDbServerName & _
              ";User Id=" & sDbUserName & ";Password=" & sDbPasswort & ";"
        Catch ex As Exception
            Return ""
        End Try
    End Function
 
    ' diese öffentliche Function soll die Verbindung herstellen und im 
    ' Erfolgsfall zurückgeben
    ' #todo - richtige fehlerbehandlung
    Public Function getConnection() As MySqlConnection
        Dim sConn As String
        Dim oConn As MySqlConnection
 
        ' connection string holen
        sConn = loadMySQLConfig()
 
        ' erst mal sehen, ob wir überhaupt einen Connection String bekommen 
        ' haben
        If sConn <> "" Then
            Try
                ' versuchen, mit dem Connection String eine Verbindung 
                ' aufzubauen
                oConn = New MySqlConnection(sConn)
                oConn.Open()
                ' wenn alles geklappt hat, die neue offene verbindung 
                ' zurückgeben
                Return oConn
            Catch ex As Exception
                ' irgendwo ist ein fehler aufgetreten
                Return getConnection
            End Try
        Else
            ' wir haben keinen connection string erhalten
            Return getConnection
        End If
    End Function
 
End Class