第 53 章 MariaDB Sink
将数据发送到 MariaDB 数据库。
在 Pipe 文件中,您必须在 spec→integration→dependencies 中明确声明 MariaDB 服务器驱动程序依赖项:
- "mvn:org.mariadb.jdbc:mariadb-java-client:<version>"
此 Kamelet 需要 JSON 格式的正文。使用 key:value 对来映射 JSON 字段和参数。例如,以下是一个查询:
'INSERT INTO accounts (username,city) VALUES (:"username,: failingcity)'
以下是示例查询的输入示例:
'{ "username":"oscerd", "city":"Rome"}'
53.1. 配置选项 复制链接链接已复制到粘贴板!
下表总结了 mariadb-sink
Kamelet 可用的选项:
属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
---|---|---|---|---|---|
databaseName * | 数据库名称 | MariaDB 数据库的名称。 | 字符串 | ||
password * | 密码 | 用于访问安全 MariaDB 数据库的密码。 | 字符串 | ||
query * | 查询 | 对 MariaDB 数据库执行的查询。 | 字符串 | INSERT INTO 帐户(username,city) VALUES (:"username,:#city) | |
serverName * | 服务器名称 | 数据源的服务器名称。 | 字符串 | localhost | |
username * | 用户名 | 用于访问安全 MariaDB 数据库的用户名。 | 字符串 | ||
serverPort | 服务器端口 | 数据源的服务器端口。 | 字符串 | 3306 |
* = 标记为星号的字段 是必需的。