datax自定义mysqlreader
时间: 2023-08-18 14:15:09 浏览: 158
datax读取InfluxDB组件
DataX的自定义MysqlReader是一种用于从Mysql数据库读取数据的插件。它通过JDBC连接器连接到远程的Mysql数据库,并根据用户配置的信息生成查询SELECT SQL语句,然后将该SQL语句发送到Mysql数据库执行,并将执行结果使用DataX自定义的数据类型拼装为抽象的数据集,最后传递给下游的Writer处理。MysqlReader支持大部分Mysql类型,但也存在部分个别类型没有支持的情况。对于用户配置的Table、Column、Where信息,MysqlReader会将其拼接为SQL语句发送到Mysql数据库;对于用户配置的querySql信息,MysqlReader会直接将其发送到Mysql数据库。在数据类型转换方面,DataX支持六种内部数据类型:Long、Double、String、Date、Bool和Bytes,对应地,MysqlReader也提供了相应的Column实现来进行类型转换。\[3\]
#### 引用[.reference_title]
- *1* *2* [mysqlReader](https://blog.csdn.net/mjlfto/article/details/86686844)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insertT0,239^v3^insert_chatgpt"}} ] [.reference_item]
- *3* [DataX MysqlReader](https://blog.csdn.net/capricorn85/article/details/108517827)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v91^insertT0,239^v3^insert_chatgpt"}} ] [.reference_item]
[ .reference_list ]
阅读全文