查询 SQLite
使用 Flux 查询 SQLite:
导入
sql包。使用
sql.from()并提供以下参数:- driverName: sqlite3
- dataSourceName: 查看数据源名称
- query: 要执行的SQL查询
import "sql"
sql.from(
driverName: "sqlite3",
dataSourceName: "file:/path/to/example.db?cache=shared&mode=ro",
query: "SELECT * FROM example_table",
)
需要文件系统访问
要查询SQLite,Flux必须能够访问文件系统。 如果Flux无法访问文件系统,查询将返回类似以下的错误:
错误:无法打开数据库文件读取文件失败:文件系统服务未初始化发生内部错误
如果使用InfluxDB Cloud或InfluxDB OSS,Flux 进程不可以访问文件系统。
SQLite 数据源名称
sqlite3 驱动程序使用以下 DSN 语法(也称为 连接字符串):
file:/path/to/example.db?param=value
SQLite到Flux数据类型转换
sql.from() 将 SQLite 数据类型转换为 Flux 数据类型。
| SQLite 数据类型 | Flux 数据类型 |
|---|---|
| 整数, 整数, 大整数, 小整数, 微小整数 | int |
| 浮点数, 双精度浮点数 | float |
| 日期时间, 时间戳, 日期 | time |
| 布尔值 | 整型 |
| 文本 | string |
所有其他SQLite数据类型都被转换为字符串。