第 42 章 MySQL Sink

发送数据到 MySQL 数据库。

这个 Kamelet 预期 JSON 作为正文。JSON 字段和参数之间的映射由键进行，因此如果您有以下查询：

'print INTO accounts(username,city)VALUES(:#username,:#city)'

Kamelet 需要作为输入内容接收，如下所示：

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

42.1. 配置选项

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

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

注意

带有星号(*)标记的字段为必填。