使用.Net从Oracle数据库读取数据的速度是使用Java的10倍



我正在使用.Net和Java从Oracle数据库读取100万条记录。在.Net中,我使用的是ODP.Net,在Java ojdbc6瘦客户端中。在.Net中读取数据大约需要10秒,而在Java中则需要近2分钟。为什么会有如此巨大的差异?

这是一个代码:

.Net:

      try
        {
            DateTime dt1 = DateTime.Now;
            OracleConnection con = new OracleConnection();
            con.ConnectionString = "Data Source=(DESCRIPTION=(ADDRESS_LIST=(ADDRESS=(PROTOCOL=TCP)(HOST=myHost)(PORT=myPort)))(CONNECT_DATA=(SERVER=DEDICATED)(SERVICE_NAME=myService)));User Id=myId;Password=myPass;";
            con.Open();
            string cmdQuery = "SELECT * FROM DROPME";
            OracleCommand cmd = new OracleCommand(cmdQuery);
            cmd.Connection = con;
            cmd.CommandType = CommandType.Text;
            int i = 0;
            OracleDataReader reader = cmd.ExecuteReader();
            while (reader.Read())
            {
                Object o1 = reader.GetValue(0);
                Object o2 = reader.GetValue(1);
                Object o3 = reader.GetValue(2);
                Object o4 = reader.GetValue(3);
                Object o5 = reader.GetValue(4);
                Object o6 = reader.GetValue(5);
                Object o7 = reader.GetValue(6);                    
                i++;
            }
            DateTime dt2 = DateTime.Now;
            double elapsed = (dt2 - dt1).TotalSeconds;
        }
        catch (Exception ex)
        {
            Console.WriteLine(ex.Message);
        }

Java:

    try
    {
        long t0 = System.currentTimeMillis();
        oracleDataSource = new OracleDataSource();
        oracleDataSource.setURL("jdbc:oracle:thin:myId/myPass@myHost:myPort:myService");
        Connection connection = oracleDataSource.getConnection();
        PreparedStatement statement = connection.prepareStatement("SELECT * FROM DROPME");
        ResultSet result = statement.executeQuery();
        int i = 0;
        while (result.next())
        {
            result.getObject(1);
            result.getObject(2);
            result.getObject(3);
            result.getObject(4);
            result.getObject(5);
            result.getObject(6);
            result.getObject(7);
            i++;
        }
        long t1 = System.currentTimeMillis();
        long elapsed = (t1 - t0)/1000;
        int t = 0;
    }
    catch (Exception ex)
    {
        ex.printStackTrace();
    }

编辑:setFetchSize()完成了任务,谢谢。

在Java中,默认情况下,ResultSet完全检索并存储在内存中。这对于具有大型结果集的查询不太好。要使用流式结果,您必须使用:

stmt = conn.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
stmt.setFetchSize(Integer.MIN_VALUE);

我没有比较所花的时间,但我想这会快得多。

根据我的经验,Oracle JDBC驱动程序在批量传输方面的开箱即用配置很差。默认情况下,它一次只在网络上传输10条记录。因此,如果您有1000000条记录,驱动程序将导致100000次网络访问。

您可以用以下代码告诉ResultSet一次要获取多少记录:

result.setFetchSize(1000);

随意尝试不同尺寸。它极大地减少了我处理过的至少一个应用程序的处理时间(从几分钟到几秒钟)。

相关内容

最新更新