1

vb.net (visual studio 2010) で実行可能なアプリケーションを作成しました。全体像は、すべての MSSQL データを MySQL に移動しようとしているということです。

環境: MS Server 2003 R2 上のアプリケーション - x64 SP2 MS Server 2008 R2 上の MSSQL Standard x64 SP1 Ubunto 上の MySql 使用: Connector/Net for 2.0

現在、1000回しか実行しないと正常に動作し、SQLサーバーループから1000回読み取り、レコードごとにinserttable関数を呼び出してレコードを挿入します。問題は、5000 レコードを試したときに発生します。レコード 2932 (およびそれ以降のすべてのエントリ) で、挿入により次が生成されます: Sql エラー:

MySql.Data.MySqlClient.MySqlException: Unable to connect to any of the specified MySQL hosts. ---> System.Net.Sockets.SocketException: Only one usage of each socket address (protocol/network address/port) is normally permitted 192.168.0.14:3306
   at System.Net.Sockets.Socket.EndConnect(IAsyncResult asyncResult)
   at MySql.Data.Common.StreamCreator.CreateSocketStream(IPAddress ip, Boolean unix)
   at MySql.Data.Common.StreamCreator.GetStreamFromHost(String pipeName, String hostName, UInt32 timeout)
   at MySql.Data.Common.StreamCreator.GetStream(UInt32 timeout)
   at MySql.Data.MySqlClient.NativeDriver.Open()
   --- End of inner exception stack trace ---
   at MySql.Data.MySqlClient.NativeDriver.Open()
   at MySql.Data.MySqlClient.Driver.Open()
   at MySql.Data.MySqlClient.Driver.Create(MySqlConnectionStringBuilder settings)
   at MySql.Data.MySqlClient.MySqlConnection.Open()

2900 エントリの後に発生する理由はありますか?

接続文字列

<add name="MSSQLdb" connectionString="Data Source=192.168.0.13; Initial Catalog=sqlserverdb; User ID = IUSR_sqlserverusername; Password=sqlserverpwd"/>
    <add name="MySQLdb" connectionString="server=192.168.0.14;Port=3306;Uid=dbusername; Pwd=dbpassword;database=dbname; pooling=false" providerName="MySql.Data.MySqlClient" />

主な機能

Dim myCon As SqlConnection = New SqlConnection(MSSQLDBConn)
                Dim sSQL As String = 'SELECT TOP 5000 * FROM mssqlservertable'
                Dim myCmd As SqlCommand = New SqlCommand(sSQL, myCon)

                Dim iRetVal As Integer = 0

                Try
                    If myCon.State <> Data.ConnectionState.Open Then
                        myCon.Open()
                    End If

                    Dim drOrder As SqlDataReader = myCmd.ExecuteReader()

                    If drOrder.HasRows Then
                        Dim sOutput As String = ""
                        Do While drOrder.Read()
                            Dim sRetVal As String = ""
                            sRetVal = InsertTable(drOrder("ID"), _
                                                        drOrder("ID2"), _
                                                        drOrder("Resume"), _
                                                        drOrder("DateCreated"), _
                                                        drOrder("DateModified"))

                            If sRetVal.StartsWith("ERROR") = True Then
                                LogIt("ID: " & drOrder("ID") & " iCnt: " & iCnt & " Error: " & sRetVal)
                                ToolStripStatusLabel1.Text = "Error found."
                            End If

                            iCnt += 1
                            If iCnt Mod 100000 = 0 Then
                                ToolStripStatusLabel1.Text = "Current count: " & iCnt
                                Application.DoEvents()
                            End If
                        Loop

                        ToolStripStatusLabel1.Text = "Final count: " & iCnt
                    Else
                        ToolStripStatusLabel1.Text = "No rows"
                    End If

                Catch sqlEx As MySqlException
                    MessageBox.Show("Sql error: " & sqlEx.ToString)
                Catch ex As Exception
                    MessageBox.Show("Regular error: " & ex.ToString)
                Finally
                    myCon.Close()
                    myCon.Dispose()
                End Try
            Catch ex As Exception
                MessageBox.Show("Error: " & ex.ToString)
            End Try

挿入機能

Function InsertTable(ByVal ID As Integer, ByVal ID2 As Integer, _
                                         ByVal Resume As String, ByVal DateCreated As DateTime, _
                                         ByVal DateModified As DateTime) As String
        Dim sRetVal As String = ""
        Dim myCon As MySqlConnection = New MySqlConnection(MySQLDBConn)
        Dim sSQL As String = "INSERT INTO mysqltable (ID, ID2, Resume,DateCreated, DateModified)" _
                             & " VALUES (?ID, ?ID2, ?Resume, ?DateCreated, ?DateModified);"
        Dim myCmd As MySqlCommand = New MySqlCommand(sSQL, myCon)
        myCmd.CommandType = Data.CommandType.Text
        myCmd.Parameters.Add(New MySqlParameter("?ID", MySqlDbType.Int32)).Value = ID
        myCmd.Parameters.Add(New MySqlParameter("?ID2", MySqlDbType.Int32)).Value = ID2
        myCmd.Parameters.Add(New MySqlParameter("?Resume", MySqlDbType.LongText)).Value = Resume
        myCmd.Parameters.Add(New MySqlParameter("?DateCreated", MySqlDbType.DateTime)).Value = DateCreated
        myCmd.Parameters.Add(New MySqlParameter("?DateModified", MySqlDbType.DateTime)).Value = DateModified

        Try
            If myCon.State <> Data.ConnectionState.Open Then
                myCon.Open()
            End If
            myCmd.ExecuteNonQuery()
            myCmd.Dispose()
        Catch sqlEx As MySqlException
            sRetVal = "ERROR: Sql error: " & sqlEx.ToString
        Catch ex As Exception
            sRetVal = "ERROR: Regular error: " & ex.ToString
        Finally
            myCon.Close()
            myCon.Dispose()
        End Try

        Return sRetVal
    End Function
4

1 に答える 1

0

DB 接続のオープン/クローズが急速に連続するため、使用可能なすべてのエフェメラル TCP/IP ポートを使い果たしていると思います。接続を 1 回開き、その接続を各挿入に使用する必要があります。接続は同様の方法で透過的に共有されるため、プールを使用するというスティーブの提案もこの問題を解決するはずです。

于 2013-02-07T13:50:31.133 に答える