46. MariaDB Sink
将数据发送到 MariaDB 数据库。此 Kamelet 需要 JSON 格式的正文。使用 key:value 对来映射 JSON 字段和参数。
46.1. MariaDB Sink Kamelet Description 复制链接链接已复制到粘贴板!
46.1.1. 数据库连接 复制链接链接已复制到粘贴板!
这个 Kamelet 使用 JDBC 连接到 MariaDB 数据库。MariaDB 是一个流行的开源关系数据库管理系统,它是兼容 MySQL 的替换。
46.1.2. 数据处理 复制链接链接已复制到粘贴板!
Kamelet 需要 JSON 输入数据,数据在执行 SQL 查询前是 unmarshalled。可以使用命名参数在 SQL 查询中引用输入数据字段。
46.1.3. 查询配置 复制链接链接已复制到粘贴板!
SQL 查询应该使用命名参数(如 :" username,:"city),对应于传入 JSON 数据中的字段。这允许安全参数化查询来防止 SQL 注入攻击。
46.1.4. 连接池 复制链接链接已复制到粘贴板!
Kamelet 使用 Apache Commons DBCP2 连接池,提供高效的数据库连接管理和资源优化。
46.1.5. 身份验证 复制链接链接已复制到粘贴板!
需要用户名和密码身份验证才能安全数据库访问。这些凭证应正确管理和保护。
46.2. 配置选项 复制链接链接已复制到粘贴板!
下表总结了 mariadb-sink Kamelet 可用的选项:
| 属性 | 名称 | 描述 | 类型 | 默认 | 示例 |
|---|---|---|---|---|---|
| databaseName * | 数据库名称 | MariaDB 数据库的名称。 | 字符串 | ||
| password * | 密码 | 用于访问安全 MariaDB 数据库的密码。 | 字符串 | ||
| query * | 查询 | 对 MariaDB 数据库执行的查询。 | 字符串 | INSERT INTO 帐户(username,city) VALUES (:"username,:#city) | |
| serverName * | 服务器名称 | 数据源的服务器名称。 | 字符串 | localhost | |
| username * | 用户名 | 用于访问安全 MariaDB 数据库的用户名。 | 字符串 | ||
| serverPort | 服务器端口 | 数据源的服务器端口。 | 字符串 | 3306 |
* = 标记为星号的字段 是必需的。
46.3. 依赖项 复制链接链接已复制到粘贴板!
在运行时,mariadb-sink Kamelet 依赖于以下依赖项:
<dependencies>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifact>camel-quarkus-jackson</artifact>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifact>camel-quarkus-kamelet</artifact>
</dependency>
<dependency>
<groupId>org.apache.camel.quarkus</groupId>
<artifact>camel-quarkus-sql</artifact>
</dependency>
<dependency>
<groupId>org.apache.camel.kamelets</groupId>
<artifact>camel-kamelets-utils</artifact>
<version>{kamelets-utils-version}</version>
</dependency>
<dependency>
<groupId>org.apache.commons</groupId>
<artifact>commons-dbcp2</artifact>
<version>2.13.0</version>
</dependency>
</dependencies>
46.4. kamelets 源文件 复制链接链接已复制到粘贴板!
https://github.com/apache/camel-kamelets/blob/4.14.x/kamelets/mariadb-sink.kamelet.yaml