Apache Seatunnel-Sink plugin : Mysql [Spark]

作者: Apache Seatunnel
Apache Seatunnel

支持Update的方式输出数据到Mysql

Options

name type required default value
[url] url-string
[user] user-string
[password] password-string
[save_mode] save_mode-string
[dbtable] dbtable-string
[customUpdateStmt] customUpdateStmt-string
[duplicateIncs] duplicateIncs-string
url [string]

JDBC连接的URL。参考一个案例: jdbc:mysql://localhost/dbName

user [string]

用户名

Password [string]

用户密码

save_mode [string]

存储模式，添加模式update，在插入数据键冲突的时候进行可指定方式的数据覆盖

基本模式overwrite，append，ignore以及error。每个模式具体含义见save-modes

dbtable [string]

源数据表名

customUpdateStmt [string]

在save_mode指定为update时配置，用于指定键冲突的更新语句模板

参考mysql的INSERT INTO table (...) values (...) ON DUPLICATE KEY UPDATE...的使用方式，values中使用占位符或固定值

duplicateIncs [string]

在save_mode指定为update时配置，指定键冲突时值更新为现有值加上原有值

Examples

Mysql {
    save_mode = "update",
    truncate = true,
    url = "jdbc:mysql://192.168.1.1:3306/database",
    user= "userName",
    password = "***********",
    dbtable = "tableName",
    customUpdateStmt = "INSERT INTO table (column1, column2, created, modified, yn) values(?, ?, now(), now(), 1) ON DUPLICATE KEY UPDATE column1 = IFNULL(VALUES (column1), column1), column2 = IFNULL(VALUES (column2), column2)"
}

文章列表

更多推荐

更多
这里什么都没有

Apache Seatunnel

42
文章数
1066
获赞数
1024
粉丝数
Apache Seatunnel

近期文章

更多
文章目录

    热门标签

    更多

    推荐作者

    更多