西安网站设计报价,微网站建设方案,学生网站建设的基本流程,网站模块如何添加ES elasticsearch-analysis-dynamic-synonym连接数据库动态更新synonym近义词
修改源码实现连接数据库获取近义词汇 下载elasticsearch-analysis-dynamic-synonym打开项目(https://github.com/bells/elasticsearch-analysis-dynamic-synonym/tree/master)
一、修改pom.xml …ES elasticsearch-analysis-dynamic-synonym连接数据库动态更新synonym近义词
修改源码实现连接数据库获取近义词汇 下载elasticsearch-analysis-dynamic-synonym打开项目(https://github.com/bells/elasticsearch-analysis-dynamic-synonym/tree/master)
一、修改pom.xml
引入依赖
dependencygroupIdmysql/groupIdartifactIdmysql-connector-java/artifactIdversion8.0.21/version
/dependency!--或者oracle--
dependencygroupIdcom.oracle.ojdbc/groupIdartifactIdojdbc8/artifactIdversion19.3.0.0/version
/dependency将pom文件中的版本修改成跟你的es版本号一样的,比如我的是7.2.0
使用不同的版本对应的lucene包不同,某些代码略有不同,根据编译器提示修改即可,下面的代码照常添加
version7.2.0/version二、 修改main/assemblies/plugin.xml
在标签下添加 根据不同环境二选一 !--添加mysql-connector依赖--
dependencySetoutputDirectory/useProjectArtifacttrue/useProjectArtifactuseTransitiveFilteringtrue/useTransitiveFilteringincludesincludemysql:mysql-connector-java/include/includes
/dependencySet!--将 oracle 的 jar 包打包进 zip 包--
dependencySetoutputDirectory/useProjectArtifacttrue/useProjectArtifactuseTransitiveFilteringtrue/useTransitiveFilteringincludesincludecom.oracle.ojdbc:ojdbc8/include/includes
/dependencySet在标签下添加(与标签同级)
fileSetsfileSetdirectory${project.basedir}/config/directoryoutputDirectoryconfig/outputDirectory/fileSet
/fileSets三、jdbc配置文件
在项目根目录下创建config/jdbc.properties文件,写入以下内容
# mysql
jdbc.driver=com.mysql.cj.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/test?useUnicode=truecharacterEncoding=utf8autoReconnect=trueuseSSL=falseserverTimezone=Asia/Shanghai
jdbc.username=账号
jdbc.password=密码
#近义词sql查询语句。(注意要以words字段展示)
synonym.word.sql=SELECT `keys` AS words FROM es_synonym WHERE ifdel = '0'
#获取近义词最后更新时间,用来判断是否发生了更新。(注意要以maxModitime词汇显示)
synonym.lastModitime.sql=SELECT MAX(moditime) AS maxModitime FROM es_synonym
interval=10# 配置连接oracle数据库
jdbc.driver=oracle.jdbc.driver.OracleDriver
jdbc.url=jdbc:oracle:thin:@127.0.0.1:1521:ORCL
jdbc.username=root
jdbc.password=123456
#近义词sql查询语句。(注意要以words字段展示)
synonym.word.sql=select SYNONYM_KEY as words from es_synonym where IS_DELETED = '0'
#获取近义词最后更新时间,用来判断是否发生了更新。(注意要以maxModitime词汇显示)
synonym.lastModitime.sql=SELECT MAX(UPD_TIME) AS maxModitime FROM es_synonym
interval=60四、编写加载词汇类
1、创建DynamicSynonymFromDb类
在com.bellszhu.elasticsearch.plugin.synonym.analysis包下,我们可以看到很多加载近义词汇的类,比如RemoteSynonymFile类就是通过接口来加载近义词词汇的。 我们在该包下创建类DynamicSynonymFromDb,同时继承SynonymFile接口,该类是用来读取数据库的近义词汇的,代码如下:
/*** @author yandi* @date 2023/06/15*/
public class DynamicSynonymFromDb implements SynonymFile {/*** 配置文件名*/private final static String DB_PROPERTIES = "jdbc.properties";private static Logger logger = LogManager.getLogger("dynamic-synonym");private String format;private boolean expand;private boolean lenient;private Analyzer analyzer;private Environment env;/*** 动态配置类型*/private String location;/*** 作用类型*/private String group;private long lastModified;private Path conf_dir;private JdbcConfig jdbcConfig;DynamicSynonymFromDb(Environment env, Analyzer analyzer,boolean expand, boolean lenient, String format, String location, String group) {this.analyzer = analyzer;this.expand = expand;this.lenient = lenient;this.format = format;this.env = env;this.location = location;this.group = group;// 读取配置文件setJdbcConfig();// 加载驱动try {Class.forName(jdbcConfig.getDriver());} catch (ClassNotFoundException e) {e.printStackTrace();}// 判断是否需要加载isNeedReloadSynonymMap()