Java中怎么处理大文本文件

今天就跟大家聊聊有关Java中怎么处理大文本文件，可能很多人都不太了解，为了让大家更加了解，小编给大家总结了以下内容，希望大家根据这篇文章可以有所收获。

专注于为中小企业提供成都做网站、网站制作服务,电脑端+手机端+微信端的三站合一,更高效的管理,为中小企业颍东免费做网站提供优质的服务。我们立足成都，凝聚了一批互联网行业人才，有力地推动了上千家企业的稳健成长，帮助中小企业通过网站建设实现规模扩充和转变。

集算器与Java应用程序的集成结构如下：

下面举例说明集算器协助JAVA查询大文本的基本过程。源数据sOrder.txt如下：

要查询起止时间是startDate、endDate之间，金额大于argAmount的订单，只需使用如下代码：

A1:以游标方式打开文件。@t表示将第1行读为列名。

A2:进行结构化查询，结果为游标。

A3:执行游标，将结果读入内存，如下：

JAVA主程序可以JDBC的方式调用集算器脚本，代码如下：

Class.forName("com.esproc.jdbc.InternalDriver");

con=DriverManager.getConnection("jdbc:esproc:local://");

//调用集算器脚本（类似存储过程），其中searchbig是dfx的文件名

st=(com. esproc.jdbc.InternalCStatement)con.prepareCall("call searchbig");

//设置参数

st.setObject(1,"2010-01-01");

st.setObject(2,"2010-12-31");

st.setObject(3,2000);

//执行脚本

st.execute;

//获取结果集

ResultSetrs = st.getResultSet;

……

返回值是符合JDBC标准的ResultSet对象，调用集算器脚本和访问数据库的方法完全一样，熟悉JDBC的程序员可以很快掌握。

对于上面这类较简单的代码，还可以直接将脚本写在JDBC调用中，多行语句之间用\n分隔即可，类似执行一句较复杂的SQL，这样可以不必再保存一个脚本文件。

st = (com.esproc.jdbc.InternalCStatement)con.createStatement;

ResultSet  rs1 =st.executeQuery("=file(\"D:\\sOrder.txt\").import@t\n"  +"=A1.select(OrderDate>=date(\"2010-01-01\")  &&OrderDate<=date(\"2010-12-31\") &&  Amount>2000)\n"+

"=A2.fetch");

集算器会返回最后一个表达式的值。

如果查询结果内存装不下，可以在集算器中直接返回游标（即去掉A3代码），在JAVA中只需设置每批次读取的记录数即可正常读取，具体代码如下：

st.setFetchSize(1000)

关于集算器JDBC的部署和调用的更详细信息可参考集算器集成应用之被JAVA调用。

集算器还可以实现多线程并行计算，最简单方法就是在上述代码的cursor函数中使用@m，这表示多线程读取文件。

也可以手工分段，在读取和计算部分都使用多线程并行计算，代码如下：

A1：用8个游标打开文件，每次读取文件的指定部分。~表示循环变量，依次是1、2…8，@z表示将文件按字节数大致分为几部分，只读取其中一部分，集算器会自动去头补尾，以保证取出的数据是整行。

A2：针对每个游标执行查询。

A3：并行执行游标，并合并结果。@x表示合并的对象是游标，@m表示并行计算。需要注意的是，函数conj无法保证结果顺序和源数据一致。

上述代码使用了集算器内置的并行计算函数，如果计算过程较复杂，或内存可以装下计算结果，则适合用显式并行计算语句。代码如下：

A1:设定并行数。

A2:并行执行代码，作用范围是缩进的B2-B3。to(A1)=[1,2…8]表示每个线程的入口参数。线程内部可用A2来获取入口参数，线程外部可用A2获取所有线程的计算结果。

B3:查询游标，将结果读入内存，并返回给主线程。

A4:按顺序合并各线程的计算结果。

对于有序数据，可以用二分法来提高查询性能。比如数据已按Client和OrderID排序，现在要根据参数argClient和argOrder找出相应的记录，可以使用下面的代码：

begin,end是二分法的起止位置，m是中间位置。

B4:按字节数定位到中间位置，打开游标读入一条记录，集算器会自动实现去头补尾，取出完整记录。@x表示取出记录后立即关闭游标。

B5-C6:如果定位成功，则将当前记录存储在C5。

B7-C8:如果定位不成功，则继续比较集合大小并重新设置begin,end。

A9：将C5中的计算结果显式地返回给JDBC。

看完上述内容，你们对Java中怎么处理大文本文件有进一步的了解吗？如果还想了解更多知识或者相关内容，请关注创新互联行业资讯频道，感谢大家的支持。