查询 MySQL
要用 Flux 查询 MySQL:
导入
sql包。使用
sql.from()并提供以下参数:- driverName: mysql
- dataSourceName: 查看数据源名称
- query: 要执行的SQL查询
import "sql"
sql.from(
driverName: "mysql",
dataSourceName: "user:password@tcp(localhost:3306)/db",
query: "SELECT * FROM example_table",
)
MySQL 数据源名称
mysql 驱动程序使用以下数据源名称 (DSN) 语法(也称为 连接字符串):
username:password@tcp(localhost:3306)/dbname?param=value
MySQL到Flux数据类型转换
sql.from() 将 MySQL 数据类型转换为 Flux 数据类型。
| MySQL 数据类型 | Flux 数据类型 |
|---|---|
| INT, BIGINT, SMALLINT, TINYINT | int |
| 浮点数, 双精度浮点数 | float |
| 日期时间 | time |
| 字符串 | string |
所有其他MySQL数据类型都被转换为字符串。