mysql - 选择 localhost 的语句并插入网络数据库

Question

本地主机连接模块

这是我用于连接本地主机的模块

    Function connect()
    con.ConnectionString = "Driver={MySQL ODBC 3.51 Driver};server=localhost;database=tablelocal;uid=root;pwd=root;option=0"     
    con.Open()
    End Function

    Function Disconnect()
    con.Close()
    End Function

网络连接模块

这是我通过网络连接的模块

    Function connectnetwork()
    con.ConnectionString = "Driver={MySQL ODBC 3.51 Driver};server=192.168.0.1;database=samplenetwork;uid=root;pwd=root;option=0"     
    con.Open()
    End Function

    Function Disconnectnetwork()
    con.Close()
    End Function

请查看我的编辑

    Dim sourceConnection As New OdbcConnection(connect())
    Dim destinationConnection As New OdbcConnection(connectNetwork())
    Dim adapter As New OdbcDataAdapter("SELECT * from local ", sourceConnection)
    Dim insertCommand As New OdbcCommand("INSERT INTO network", destinationConnection)

    With insertCommand.Parameters
        OdbcCommand = New Odbc.OdbcCommand("Insert into network select * from local ", con)
        OdbcCommand.ExecuteNonQuery()   
    End With

    adapter.InsertCommand = insertCommand

    'Keep the RowState of each row as Added so it is ready to be inserted.'
     adapter.AcceptChangesDuringFill = False

    Dim table As New DataTable

    'Retrieve data from source database.'
     adapter.Fill(table)

    'Save data to destination database.'
     adapter.Update(table)

Answer 1

只需使用数据适配器的两个不同连接，例如

Dim sourceConnection As New OdbcConnection("source connection string here")
Dim destinationConnection As New OdbcConnection("destination connection string here")
Dim adapter As New OdbcDataAdapter("SELECT ...", sourceConnection)
Dim insertCommand As New OdbcCommand("INSERT ...", destinationConnection)

With insertCommand.Parameters
    'Add parameters here.'
End With

adapter.InsertCommand = insertCommand

'Keep the RowState of each row as Added so it is ready to be inserted.'
adapter.AcceptChangesDuringFill = False

Dim table As New DataTable

'Retrieve data from source database.'
adapter.Fill(table)

'Save data to destination database.'
adapter.Update(table)