第 58 章 MySQL Sink

将数据发送到 MySQL 数据库。

在 Pipe 文件中，您必须在 spec→integration→dependencies 中明确声明 SQL Server 驱动程序依赖项：

spec:
  ...
  integration:
      ...
      dependencies:
      - "mvn:mysql:mysql-connector-java:<version>"

此 Kamelet 需要 JSON 格式的正文。使用 key:value 对来映射 JSON 字段和参数。例如，以下是一个查询：

'INSERT INTO accounts (username,city) VALUES (:"username,: failingcity)'

以下是示例查询的输入示例：

'{ "username":"oscerd", "city":"Rome"}'

58.1. 配置选项
复制链接

下表总结了 mysql-sink Kamelet 可用的选项：

Expand

属性	名称	描述	类型	默认	示例
databaseName *	数据库名称	MySQL 数据库的名称。	字符串
password *	密码	用于访问安全 MySQL 数据库的密码。	字符串
query *	查询	要针对 MySQL 数据库执行的查询。	字符串		INSERT INTO 帐户(username,city) VALUES (:"username,:#city)
serverName *	服务器名称	数据源的服务器名称。	字符串		localhost
username *	用户名	用于访问安全 MySQL 数据库的用户名。	字符串
serverPort	服务器端口	数据源的服务器端口。	字符串	3306

* = 标记为星号的字段 是必需的。