虚谷数据库、采集数据库中数据、输出到mysql、使用java(Mysql,虚谷等)
一. 数据库jdbc.
下面是项目目录:
这个系统可以连接mysql适配虚谷的数据库,可从数据库中根据配置文件进行数据的采集。
1. 如果要添加新的数据库只需要继承DbClient 写一个新的需要加入的客户端,重写的方法主要为了连接数据库,获取表的信息。
connect() 方法中new 的 Driver 驱动如果新写的类引入的驱动跟你要添加的一不一样,不然连接不上。
getMetaData() 方法中的获取元数据信息,如果该数据库直接支持取。比如获取表的元数据时Mysql 可以直接desc 表名, 但是虚谷必须的从驱动获得的连接里面获取,比较麻烦,否则直接进入父类的方法里面就可以拿到。但是虚谷得自己写。如果有问题可以上官网加他们的技术群,有问必答的。
2. Dbconfig 主要是数据库的一些参数信息,连接的时候需要用到。
添加完之后需要再ClientType 加入新的数据库枚举的类型
3. util 下面的 SimpleJdbcClientFactory 用到简单工厂模式,直接根据传入的Dbconfig ,创建所对应的就可以了
4. 这个项目是maven 的,第三方jar 包,直接根据mvn 指令打进仓库里面就可以直接再pom.xml 里面引用了。
二 . 具体执行端
添加新的数据库这里面需要继承manager 中的抽象类。比如MysqlParseManagerImpl 和Xugu 那个。
这个实现类中主要是对具体实行的的sql 进行一个拼接,应对的查询不一样,三个方法,一个是拼接select 一个是拼接where 条件,还有一个拼个limit,开始和结束。
这个主要根据配置文件来做定时采集的,通过配置的cron 表达式,来根据开始和结束时间select 数据库中的数据。
配置文件对应的实体类就是JdbcInputEntity.
源码我打成jar. 如有需要自行下载查阅。
————————————————
版权声明:本文为CSDN博主「Marain123」的原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接及本声明。
原文链接:https://blog.csdn.net/Marain123/article/details/116027482
相关文章