java分组批量执行,发短信、创建Lucene索引(应用场景)
2014-12-20 17:24
621 查看
//新闻总数
public void method(){ int countNum = LuceneService.getMyLuceneInformationsCount(null); // int count = 100; int groupNum = 1000;//一组1000条 int group = 0; if(countNum%groupNum == 0){ group = countNum/groupNum; }else{ group = countNum/groupNum+1; } for(int a = 1;a<=group;a++){ System.out.println(a+"-----------"+group); createIndex((a-1)*groupNum,groupNum,conn); }
}
//分组创建索引 private void createIndex(int start,int limit,Connection conn){ <span style="white-space:pre"> </span>List<Information> infor = getInforList(start,limit,conn); LuceneInformation.creteIndex(infor,INDEXPATH_Information); } //新闻查询 public static List<Information> getInforList(int start,int limit,Connection conn){ List<Information> list = new ArrayList<Information>(); Statement st = null; ResultSet rs = null; try { st = conn.createStatement(); String sql = "select id,blRecommend,dtCreate,lngReadNum,strOrganName,version" + ",strPID,strInfoID,strInfoTitle,strInfoContent,strCreate,blDeleteState,blPass from information limit "+start+","+limit+""; rs = st.executeQuery(sql); while (rs.next()) { Information info = new Information(); info.setId(rs.getLong("id")); info.setStrRecomState(rs.getString("blRecommend")); info.setDtCreate(rs.getTimestamp("dtCreate")); info.setLngReadNum(rs.getLong("lngReadNum")); info.setStrOrgan(rs.getString("strOrganName")); info.setVersion(rs.getInt("version")); info.setStrPID(rs.getLong("strPID")); info.setStrInfoID(rs.getString("strInfoID")); info.setStrInfoTitle(rs.getString("strInfoTitle")); info.setStrInfoContent(rs.getString("strInfoContent")); info.setFirst_name(rs.getString("strCreate")); info.setBlDeleteState(rs.getBoolean("blDeleteState")); info.setBlPass(rs.getBoolean("blPass")); list.add(info); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); }finally{ if(st != null){ try { st.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } if(rs != null){ try { rs.close(); } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } } } return list; }
相关文章推荐
- 在应用中加入全文检索功能——基于Java的全文索引引擎Lucene简介
- Java的匿名对象的创建,生命周期和应用场景
- 在应用中加入全文检索功能——基于Java的全文索引引擎Lucene简介
- 在应用中加入全文检索功能——基于Java的全文索引引擎Lucene简介
- 在应用中加入全文检索功能——基于Java的全文索引引擎Lucene简介
- lucene创建索引,分组查询
- 在应用中加入全文检索功能——基于Java的全文索引引擎Lucene简介
- 01_java Lucene学习——创建索引
- 在应用中加入全文检索功能 ——基于Java的全文索引引擎Lucene简介
- lucene对数据库创建索引时报错:java.io.IOException: Cannot overwrite: D:\index\_3.fdt的解决办法
- 在应用中加入全文检索功能——基于Java的全文索引引擎Lucene简介 [摘]
- java鬼混笔记:lucene 1、简单的创建索引和查询
- java多线程处理执行solr创建索引示例
- 在应用中加入全文检索功能——基于Java的全文索引引擎Lucene简介
- [转]在应用中加入全文检索功能(基于Java的全文索引引擎Lucene简介)
- JAVAWEB开发之Lucene详解——Lucene入门及使用场景、全文检索、索引CRUD、优化索引库、分词器、高亮、相关度排序、各种查询
- [转]在应用中加入全文检索功能(基于Java的全文索引引擎Lucene简介)
- 使用Lucene对预处理后的文档进行创建索引(可执行)
- 在应用中加入全文检索功能—基于Java的全文索引引擎Lucene简介(收藏)
- java:Mongodb 分组统计应用group的使用(含场景)