写入 MySQL

使用 Flux 将数据写入 MySQL：

1. 导入 sql 包。

2. 将数据通过管道传递到 sql.to() 并提供以下参数：

   • driverName: mysql
   • dataSourceName: 查看数据源名称
   • table: 要写入的表
   • batchSize: 每次调用 Exec 时可以排队的参数或列的数量（默认为 10000）

import "sql"

data
    |> sql.to(
        driverName: "mysql",
        dataSourceName: "user:password@tcp(localhost:3306)/db",
        table: "example_table",
    )

MySQL 数据源名称

mysql 驱动程序使用以下数据源名称 (DSN) 语法（也称为 连接字符串）：

username:password@tcp(localhost:3306)/dbname?param=value

Flux到MySQL数据类型转换

sql.to() 将 Flux 数据类型转换为 MySQL 数据类型。