一. 数据库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