一、lucene简单的增删改查,如果是新项目,在做完对数据库的DAO操作时,紧跟着做对索引库的增删改查,在维护以前的项目时,再不允许修改源代码的情况下,只能做定时创建索引
package com.lucene.luceneutil;
import org.apache.lucene.document.Document;
import org.apache.lucene.document.Field;
import org.apache.lucene.document.Field.Index;
import org.apache.lucene.document.Field.Store;
import com.lucene.entity.ArticleEntity;
public class ArticleDocumentUtils {
/**
* 把ArticleEntity转换成Document对象
* @param article ArticleEntity对象
* @return 转换后的doc对象
*/
public static Document Article2Document(ArticleEntity article){
String strId = article.getId().toString();
Document doc = new Document();
doc.add(new Field("id",strId,Store.YES,Index.NOT_ANALYZED));
doc.add(new Field("title",article.getTitle(),Store.YES,Index.ANALYZED));
doc.add(new Field("content",article.getContent(),Store.YES,Index.ANALYZED));
return doc ;
}
public static ArticleEntity Document2Article(Document doc){
ArticleEntity article = new ArticleEntity();
Integer id = Integer.parseInt(doc.get("id")) ;
article.setId(id);
article.setTitle(doc.get("title"));
article.setContent(doc.get("content"));
return article ;
}
}
package com.lucene.luceneutil;
import java.io.File;
import org.apache.lucene.analysis.Analyzer;
import org.apache.lucene.analysis.standard.StandardAnalyzer;
import org.apache.lucene.store.Directory;
import org.apache.lucene.store.FSDirectory;
import org.apache.lucene.util.Version;
public class Configuration {
private static Directory directory ;
private static Analyzer analyzer ;
static {
try {
directory = FSDirectory.open(new File("./filepath"));
analyzer = new StandardAnalyzer(Version.LUCENE_30 );
} catch (Exception e) {
new RuntimeException(e);
}
}
public static Directory getDirectory() {
return directory;
}
public static Analyzer getAnalyzer() {
return analyzer;
}
}
package com.lucene.entity;
import java.util.List;
public class QueryResult<T> {
private int count ;
private List<T> list ;
public QueryResult(int count, List<T> list) {
this.count = count;
this.list = list;
}
public int getCount() {
return count;
}
public void setCount(int count) {
this.count = count;
}
public List<T> getList() {
return list;
}
public void setList(List<T> list) {
this.list = list;
}
}
package com.lucene.indexdao;
import com.lucene.entity.ArticleEntity;
import com.lucene.entity.QueryResult;
public interface ArticleEntityIndexDao {
/**
* 建立索引(保存到索引库)
*
* @param article
*/
public void save(ArticleEntity article);
/**
* 删除索引
* @param id
*/
public void delete(Integer id);
/**
* 更新文章
* @param article 要更新的文章
*/
public void update(ArticleEntity article) ;
/**
*
* @param query 查询条件
* @param firstResult 每页开始的条数
* @param number 每页显示的条数
* @return 返回符合条件的结果
*/
public QueryResult<ArticleEntity> search(String query,int firstResult ,int number);
}
package com.lucene.indexdao.impl;
import java.util.ArrayList;
import java.util.List;
import org.apache.lucene.document.Document;
import org.apache.lucene.index.IndexWriter;
import org.apache.lucene.index.IndexWriter.MaxFieldLength;
import org.apache.lucene.index.Term;
import org.apache.lucene.queryParser.MultiFieldQueryParser;
import org.apache.lucene.queryParser.QueryParser;
import org.apache.lucene.search.IndexSearcher;
import org.apache.lucene.search.Query;
import org.apache.lucene.search.ScoreDoc;
import org.apache.lucene.search.TopDocs;
import org.apache.lucene.util.Version;
import com.lucene.entity.ArticleEntity;
import com.lucene.entity.QueryResult;
import com.lucene.indexdao.ArticleEntityIndexDao;
import com.lucene.luceneutil.ArticleDocumentUtils;
import com.lucene.luceneutil.Configuration;
public class ArticleEntityIndexDaoImpl implements ArticleEntityIndexDao {
@Override
public void save(ArticleEntity article) {
// 1,把Article转为Document
Document doc = ArticleDocumentUtils.Article2Document(article);
// 2,把Document存到索引库中
IndexWriter indexWrite = null ;
try {
indexWrite = new IndexWriter(Configuration.getDirectory(), Configuration.getAnalyzer(), MaxFieldLength.LIMITED);
indexWrite.addDocument(doc);// 建立索引
} catch (Exception e) {
throw new RuntimeException(e);
}finally{
try {
indexWrite.close();
} catch (Exception e) {
throw new RuntimeException();
}
}
}
/**
* Term:就是某Field中的某个关键词。
*/
@Override
public void delete(Integer id) {
IndexWriter indexWrite = null ;
try {
Term term = new Term("id",id.toString());
indexWrite = new IndexWriter(Configuration.getDirectory(), Configuration.getAnalyzer(), MaxFieldLength.LIMITED);
indexWrite.deleteDocuments(term);
} catch (Exception e) {
throw new RuntimeException(e);
}finally{
try {
indexWrite.close();
} catch (Exception e) {
throw new RuntimeException();
}
}
}
/**
* 更新就是先删除再添加
*/
@Override
public void update(ArticleEntity article) {
IndexWriter indexWrite = null ;
try {
Term term = new Term("id",article.toString());
Document doc = ArticleDocumentUtils.Article2Document(article);
indexWrite = new IndexWriter(Configuration.getDirectory(), Configuration.getAnalyzer(), MaxFieldLength.LIMITED);
indexWrite.updateDocument(term, doc);
//indexWrite.deleteDocuments(term);
//indexWrite.addDocument(doc);
} catch (Exception e) {
throw new RuntimeException(e);
}finally{
try {
indexWrite.close();
} catch (Exception e) {
throw new RuntimeException();
}
}
}
@Override
public QueryResult<ArticleEntity> search(String query, int firstResult,int number) {
IndexSearcher searchQuery = null ;
QueryParser queryParser = null;
Query queryStr;
try {
//queryParser = new QueryParser(Version.LUCENE_30, "title", Configuration.getAnalyzer());这是默认在title里搜索
queryParser = new MultiFieldQueryParser(Version.LUCENE_30,new String[]{"title","content"}, Configuration.getAnalyzer());//多字段中搜索
queryStr = queryParser.parse(query);
searchQuery = new IndexSearcher(Configuration.getDirectory());
TopDocs topDocs = searchQuery.search(queryStr, 1000);
int totalNum = topDocs.totalHits ;//符合条件的总记录数
ScoreDoc[] scoredoc = topDocs.scoreDocs ;//符合条件的前n条信息
//处理结果
List<ArticleEntity> list = new ArrayList();
int endLenght = Math.max(firstResult+number, scoredoc.length);
for(int i = firstResult ; i < endLenght ; i++){
Document doc = searchQuery.doc(scoredoc[i].doc) ; //得到Document对象
ArticleEntity e =ArticleDocumentUtils.Document2Article(doc); //得到ArticleEntity对象
list.add(e);
}
return new QueryResult(totalNum,list);
} catch (Exception e) {
throw new RuntimeException(e);
}finally{
try {
searchQuery.close();
} catch (Exception e) {
throw new RuntimeException(e);
}
}
}
}
二、对简单的增删改查做完了,单个的测试是没有问题,但是同时有多个IndexWriter在运行的时候就会出现org.apache.lucene.store.LockObtainFailedException: Lock obtain timed out: NativeFSLock@E:\indexDir\write.lock的一场,所以对于一个索引库,只能有一个打开IndexWtriter操作他,如果打开了多个,就会有上面的异常。
分享到:
相关推荐
内容概要:本文介绍了一款基于MATLAB GUI的学生成绩管理系统,旨在提升学校教学管理的效率和准确性。系统主要由三个模块组成:考试收录数据模块、考试数据分析模块和统计分析数据模块。它不仅支持成绩的录入、显示、排序、查找,还包括特征值分析、直方图绘制和教师评语录入等功能。通过对成绩数据的综合分析,系统能为学校教学管理提供客观科学的数据支持。 适合人群:教育工作者(如教师、管理人员)和技术爱好者(特别是对MATLAB GUI感兴趣的开发者)。 使用场景及目标:适用于各类学校和教育机构,用于管理和分析学生成绩,帮助教师和管理者更好地了解学生的学习状况,改进教学质量。 阅读建议:对于希望深入了解如何利用MATLAB GUI进行学生成绩管理的读者来说,本文提供了详细的系统设计思路和功能实现方法,值得仔细研读并尝试实践。
内容概要:本文介绍了基于T-Mats库的涡扇发动机气路故障仿真模型,涵盖了多种类型的故障植入(如部件流量、效率及压比故障),并允许自定义故障程序和组合。该模型通过对软阈值去噪处理后的信号序列进行分析,提取真实的运行扰动信息,确保输出数据符合CMAPASS的排列要求。此外,该模型能够模拟航空发动机的典型气路故障,帮助研发和技术人员更准确地预测和评估发动机性能,从而提前采取预防措施。 适合人群:航空航天领域的研发人员、技术人员以及对航空发动机故障仿真感兴趣的学者。 使用场景及目标:①用于研究和开发涡扇发动机的气路故障诊断系统;②辅助工程师进行故障预测和性能评估;③为后续数据分析和实验验证提供可靠的数据基础。 其他说明:该模型不仅提高了仿真的准确性,还增强了对发动机运行状态的理解,为提升发动机性能和可靠性提供了强有力的技术支持。
scratch少儿编程逻辑思维游戏源码-scratch冒险.zip
少儿编程scratch项目源代码文件案例素材-爬塔.zip
内容概要:本文详细探讨了合金凝固模型中的相场模拟方法及其在各向异性枝晶生长研究中的应用。首先介绍了合金凝固模型的基本概念及其在现代制造业中的重要性,特别是在激光增材制造、选择性激光熔融和定向凝固技术中的应用。接着,重点讨论了相场模拟作为一种数值模拟方法,在预测合金凝固过程中组织结构演变方面的关键作用。文中还提供了MATLAB实现合金各向异性枝晶生长的具体代码及详细注释,以及Comsol用于偏微分方程求解的雪花生长模型。最后,文章总结了当前的研究进展,并展望了未来的发展趋势。 适合人群:从事材料科学、冶金工程、激光增材制造领域的研究人员和技术人员,尤其是对相场模拟和合金凝固感兴趣的学者。 使用场景及目标:适用于希望深入了解合金凝固过程、相场模拟方法及其在现代制造技术中应用的专业人士。目标是提高对合金凝固机制的理解,优化制造工艺,提升产品质量。 其他说明:文章不仅提供了理论分析,还包括具体的代码实现和详细的文献参考资料,有助于读者全面掌握相关技术和最新研究进展。
少儿编程scratch项目源代码文件案例素材-史莱姆出击.zip
少儿编程scratch项目源代码文件案例素材-忍者酷跑.zip
scratch少儿编程逻辑思维游戏源码-点击灌篮.zip
内容概要:本文介绍了将基于RBF神经网络的PID控制器应用于永磁同步电机(PMSM)转速环控制的方法及其性能优势。传统的PID控制器在面对非线性和时变系统时存在参数整定困难的问题,而引入RBF神经网络可以实现实时在线调参,提高系统的灵活性和鲁棒性。文中详细描述了Simulink模型的设计,特别是Matlab s-function模块中RBF神经网络的具体实现,包括高斯函数激活和带惯性的权值更新机制。实验结果显示,在转速突变情况下,改进后的控制器能够迅速稳定系统,超调量控制在2%以内,调节时间较传统方法缩短约40%,并且在负载变化时表现出色,无需重新整定参数。 适合人群:从事电机控制系统研究和开发的技术人员,尤其是对PID控制器优化感兴趣的工程师。 使用场景及目标:适用于需要提升PMSM转速环控制精度和响应速度的应用场合,如工业自动化设备、机器人等领域。目标是通过引入智能算法解决传统PID控制器参数整定难题,提高系统性能。 阅读建议:关注RBF神经网络与PID控制器结合的具体实现细节,特别是在Matlab s-function模块中的编码技巧以及参数调整策略。同时,注意学习率的选择和动量项的作用,这对于实际应用至关重要。
scratch少儿编程逻辑思维游戏源码-Scratch 奔跑.zip
内容概要:本文详细介绍了基于COMSOL有限元软件的变压器辐射传热数值分析方法。首先,解释了变压器内外辐射传热的基本机理,包括热量通过传导、对流和辐射的方式传递,重点在于辐射传热的作用及其数学描述。接着,逐步引导读者从零开始构建有限元仿真模型,涵盖模型参数确定、网格划分、材料属性定义、边界条件设置、传热方程设定、仿真运行及结果分析等多个步骤。最后,探讨了进一步研究的方向,如不同因素(温度、材料属性、几何形状)对辐射传热的影响,以及该模型在电力电子设备和热管理系统的潜在应用。 适合人群:电气工程专业学生、初学者和技术爱好者,尤其是对有限元仿真和变压器辐射传热感兴趣的群体。 使用场景及目标:适用于希望通过实际操作掌握有限元仿真技能的人群,旨在帮助他们理解变压器辐射传热机制并能独立完成相关仿真项目。 其他说明:本文不仅提供了理论知识,还附带了详细的视频教程和仿真模型,使学习过程更加直观易懂。
内容概要:本文详细介绍了交错并联Boost PFC(功率因数校正)仿真电路模型的设计与实现,特别是在临界BCM模式下的双闭环控制特性。文章首先解释了该电路的经典结构及其优势,即能够有效降低开关损耗和电流纹波。接着,重点讨论了双闭环控制的具体实现方法,包括外环电压控制和内环电流控制的MATLAB/Simulink代码示例。文中还特别强调了电流环中零交叉检测的重要性以及交错并联结构中驱动信号相位差的精确设置。此外,作者分享了将模型从Simulink转换到Plecs和Psim时遇到的问题及解决方案,如更换为带反向恢复特性的二极管模型和重新校准控制环路的采样周期。最后,文章展示了优化后的电流波形图,验证了所提方法的有效性。 适合人群:电力电子工程师、电源设计师、从事电力系统仿真的研究人员和技术爱好者。 使用场景及目标:适用于需要进行高效电源设计的研究和开发项目,旨在提高电源系统的性能,减少谐波失真,提升功率因数校正效果。 其他说明:文中提供的具体代码片段和参数设置有助于读者更好地理解和复现实验结果。同时,对于希望深入理解双闭环控制系统和BCM模式的人来说,本文提供了宝贵的实践经验。
scratch少儿编程逻辑思维游戏源码-3000 横版闯过.zip
内容概要:本文介绍了如何利用Matlab/Simulink构建空气涡轮发动机的动态仿真模型。首先,文章详细阐述了各个部件级模型的设计,包括进气道、涡轮、气室、压气机、尾喷管、转子动力学模块和容积模块。接着,重点讨论了PID控制器在维持发动机转速恒定方面的作用,尤其是在面对输出扭矩阶跃扰动时的表现。最后,提供了简单的Simulink模型代码片段,展示了如何设置和运行仿真模型,以便实时监控和调整发动机性能。 适合人群:航空航天工程领域的研究人员和技术人员,尤其是那些对空气涡轮发动机仿真感兴趣的读者。 使用场景及目标:适用于希望通过Matlab/Simulink进行空气涡轮发动机仿真研究的专业人士。主要目标是掌握空气涡轮发动机各部件的工作原理及其相互关系,同时学会使用PID控制器优化发动机性能。 其他说明:本文不仅提供了理论知识,还附有实际操作步骤和代码示例,帮助读者更好地理解和应用所学内容。
少儿编程scratch项目源代码文件案例素材-收集能量.zip
scratch少儿编程逻辑思维游戏源码-弹回的球.zip
少儿编程scratch项目源代码文件案例素材-铅笔画.zip
Sage Decrypter.zip
scratch少儿编程逻辑思维游戏源码-躲避火箭.zip
KEPServerEX6-6.17.269.0,最新版