-1

所以我正在做的是从远程 Nettezza 数据库中读取大量数据并将它们插入到另一个远程 Oracle 数据库中。为此,我正在使用 ODBC 驱动程序。问题是有很多数据,而且需要太多时间。我怎样才能加快速度?这是我所做的:

首先,我创建用于插入的连接和命令:

String connect = "Driver={Microsoft ODBC for Oracle};CONNECTSTRING=(DESCRIPTION=(ADDRESS=(PROTOCOL=TCP)(HOST=myhost)(PORT=myprt))(CONNECT_DATA=(SERVICE_NAME=myname)));Uid=uid;Pwd=pass";
        connection = new OdbcConnection(connect);
        connection.Open();
        String q = @"INSERT INTO TEST (id)
        VALUES (?)";
        myCommand = new OdbcCommand(q,connection);

然后我从 netteza 读取数据:

 String connect = "Driver={NetezzaSQL};servername=server;port=5480;database=db; username=user;password=pass;
        string query = @"SELECT T2.LETO_MESEC, T1.* 
                        FROM data T1 
                        JOIN datga2 T2 ON T2.ID = T1.EFT_ID 
                        WHERE T2.LETO_MESEC = '" + mesec + @"'";
            using (OdbcConnection connection = new OdbcConnection(connect))
            {
                try
                {
                    OdbcCommand command = new OdbcCommand(query, connection);
                    connection.Open();
                    OdbcDataReader reader = command.ExecuteReader();
                    int counter=0;
                    while (reader.Read())
                    {
                        int id_first = reader.GetInt32(5);

                        insertOracle(id_first);
                    }
                }
                catch (Exception e)
                {
                    Console.WriteLine("ne dela" + e.ToString());
                }
            }

最后是我的插入:

 public void insertOracle(int id_first)
    {

            try
            {
                myCommand.Parameters.Clear();
                myCommand.Parameters.Add(new OdbcParameter("id", id_first));
                myCommand.ExecuteNonQuery();
            }
            catch (Exception e)
            {
                Console.WriteLine("ne dela" + e.ToString());
            }

    }

我注意到这些提交在每一行,所以如何删除它并加快它。现在,20000 行大约需要 10 分钟。

4

1 回答 1

2

单次插入总是很慢——开始处理数组中的数据,从源系统中选择一批 ID 并将数组加载到目标。

这是一篇可能会有所帮助的文章。http://www.oracle.com/technetwork/issue-archive/2009/09-sep/o59odpnet-085168.html

于 2013-03-18T10:57:54.343 回答