Devart Forums

Code: Select all

Public Function tabellensync(ByVal table As String, Optional ByVal whereklausel As String = "", Optional ByVal auswahl As String = "*", Optional ByVal ignore As String = " IGNORE ") As Boolean
        Dim sr As System.IO.StreamReader
        Dim sw As System.IO.StreamWriter
        Dim neu As String
        Dim datei As String
        datei = "C:\ticket_sync\" & table & Now.Ticks & ".sql"
        tabellensync = True
        dumpsave.IncludeDrop = True
        dumpsave.GenerateHeader = True
        dumpsave.Connection = conentfernt
        dumpsave.UseExtSyntax = True
        dumpsave.QuoteIdentifier = True
        dumpsave.BackupQuery("select " & auswahl & " from " & table & " " & whereklausel, datei)
        sr = New System.IO.StreamReader(datei)
        neu = sr.ReadToEnd
        sr.Close()
'with ignore i ignore duplicate id`s and with the second i Replace duplicate
then is ignore = " REPLACE " 
        If ignore = " IGNORE " Then
            neu = Replace(neu, "INSERT INTO", "INSERT " & ignore & " INTO")
        Else
            neu = Replace(neu, "INSERT INTO", ignore & " INTO")
        End If

        sw = New System.IO.StreamWriter(datei)
        sw.Write(neu)
        sw.Close()
        conlokal.open()
 AddHandler dumpeinspiel.[Error], New Devart.Common.ScriptErrorEventHandler(AddressOf dump_error)
        dumpeinspiel.Connection = conlokal
        dumpeinspiel.Restore(datei)
        My.Computer.FileSystem.DeleteFile(datei)
        Return 1
    End Function

Code: Select all

Public Property options As New MySqlLoaderOptions

sub test ()
        Dim cmd As New MySqlCommand
        Dim datatable As New MySqlDataTable
        Dim mloader As New MySqlLoader
        options.ConflictOption = MySqlLoaderConflictOption.Replace
        cmd.Connection = con
        cmd.open
        cmd.CommandText = "Select " & auswahl & " from " & table & " where id > 10 "
        datatable.SelectCommand = cmd
        datatable.Fill()
        mloader.Connection = conlokal
        mloader.TableName = table
        mloader.Open()
        mloader.CreateColumns()
        mloader.LoadTable(datatable)
        mloader.Close()
end sub

Code: Select all

dump.UseExtSyntax = True
dump.backup(datei)
sr = New System.IO.StreamReader(datei)
       neu = sr.ReadToEnd
            sr.Close()
            neu = Replace(neu, "INSERT INTO", "INSERT IGNORE INTO")
            sw = New System.IO.StreamWriter(datei)
            sw.Write(neu)
       sw.Close()
dump.restore(datei)