查询 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, INTEGER, BIGINT, SMALLINT, TINYINT | int |
| FLOAT, DOUBLE | float |
| DATETIME, TIMESTAMP, DATE | time |
| BOOL | int |
| TEXT | string |
所有其他 SQLite 数据类型都转换为字符串。
此页面是否对您有帮助？
感谢您的反馈！