JdbcCatalog组件
组件说明
通过JDBC协议将Flink连接到关系数据库,目前支持Postgres Catalog和MySQL Catalog。
计算引擎
flink
组件分组
Catalog
端口
Inport：默认端口
outport：默认端口
组件属性
| 名称 | 展示名称 | 默认值 | 允许值 | 是否必填 | 描述 | 例子 |
|---|---|---|---|---|---|---|
| catalogName | CatalogName | “” | 无 | 是 | catalog名称。 | my_catalog |
| databaseType | DatabaseType | “” | Set(“postgresql”, “mysql”) | 是 | Postgres Catalog或 MySQL Catalog。 | mysql |
| username | Username | “” | 无 | 是 | 连接到Oracle数据库服务器时要使用的Oracle用户的名称。 | root |
| password | Password | “” | 无 | 是 | 连接Oracle数据库服务器时使用的密码。 | 123456 |
| ip | ip | “” | 无 | 是 | 数据库ip。 | 127.0.0.1 |
| port | port | “” | 无 | 是 | 数据库端口。 | 3306 |
| defaultDatabase | defaultDatabase | “” | 无 | 是 | 默认要连接的数据库。 | my_database |
JdbcCatalog示例配置
{
"flow": {
"name": "test",
"engineType": "flink",
"uuid": "18f37694f6a0438fa920db1a8cbafc5e",
"paths": [
{
"inport": "",
"from": "JdbcCatalog",
"to": "SQLQuery",
"outport": ""
},
{
"inport": "",
"from": "SQLQuery",
"to": "ShowData",
"outport": ""
}
],
"stops": [
{
"name": "JdbcCatalog",
"bundle": "cn.piflow.bundle.flink.catalog.JdbcCatalog",
"uuid": "22ffe6f153fd4322a83de5462bd92a40",
"properties": {
"defaultDatabase": "test",
"ip": "127.0.0.1",
"username": "root",
"catalogName": "mysql_catalog",
"port": "3306",
"databaseType": "mysql",
"password": "123456"
},
"customizedProperties": {
}
},
{
"name": "SQLQuery",
"bundle": "cn.piflow.bundle.flink.common.SQLQuery",
"uuid": "b42fc07d326440b0a224c55d40b0b17c",
"properties": {
"registerSourceViewName": "",
"registerResultViewName": "",
"sql": "select\n *\nfrom\n mysql_catalog.test.test"
},
"customizedProperties": {
}
},
{
"name": "ShowData",
"bundle": "cn.piflow.bundle.flink.common.ShowData",
"uuid": "ed7c46b4552c4bc0960b91fdd0721d7e",
"properties": {
"showNumber": "100"
},
"customizedProperties": {
}
}
]
}
}
示例说明
通过
JdbcCatalog组件注册mysql catalog;使用
SQLQuery组件执行select * from mysql_catalog.test.test语句，从mysql的test库查询test表数据；将上个节点的数据，使用
ShowData组件打印到控制台。
演示DEMO
PiflowX-JdbcCatalog组件