Add InfluxDB 2.x time-series database support

Doc/InfluxDB支持说明.md

@@ -0,0 +1,276 @@
+# XCode InfluxDB 时序数据库支持
+
+## 概述
+
+XCode 现已支持 InfluxDB 2.x 时序数据库，提供完整的添删改查（CRUD）功能。InfluxDB 是专为时序数据优化的开源数据库，广泛应用于物联网（IoT）、工业监控、实时分析等场景。
+
+## 功能特性
+
+- ✅ 支持 InfluxDB 2.x HTTP API
+- ✅ 使用 Flux 查询语言进行数据查询
+- ✅ 使用 Line Protocol 格式进行数据写入
+- ✅ 支持 Token 认证
+- ✅ 支持 Organization 和 Bucket 管理
+- ✅ 批量数据写入
+- ✅ 自动处理 CSV 格式查询结果
+- ✅ 兼容 .NET Framework 4.5 到 .NET 10
+
+## 快速开始
+
+### 1. 安装
+
+```bash
+dotnet add package NewLife.XCode
+```
+
+### 2. 连接字符串配置
+
+```csharp
+// 方式一：在配置文件中配置
+{
+  "ConnectionStrings": {
+    "InfluxDB": "Server=http://localhost:8086;Token=your-token;Organization=your-org;Bucket=your-bucket"
+  }
+}
+
+// 方式二：代码中配置
+DAL.AddConnStr("InfluxDB", "Server=http://localhost:8086;Token=your-token;Organization=your-org;Bucket=your-bucket", null, "InfluxDB");
+```
+
+#### 连接字符串参数说明
+
+| 参数 | 必填 | 说明 | 示例 |
+|------|------|------|------|
+| Server | 是 | InfluxDB 服务器地址（包含协议） | `http://localhost:8086` 或 `https://influx.example.com` |
+| Token | 是 | API Token（在 InfluxDB UI 中生成） | `your-influxdb-token` |
+| Organization | 是 | 组织名称或ID | `my-org` |
+| Bucket | 是 | Bucket 名称（相当于数据库） | `my-bucket` |
+
+### 3. 基本使用
+
+#### 3.1 写入数据（Line Protocol）
+
+```csharp
+var dal = DAL.Create("InfluxDB");
+
+// 单条数据写入
+// 格式：measurement,tag1=value1,tag2=value2 field1=value1,field2=value2 timestamp
+var lineProtocol = $"temperature,location=room1,sensor=sensor1 value=23.5,humidity=45 {DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() * 1000000}";
+dal.Execute(lineProtocol);
+
+// 批量数据写入
+var lines = new[]
+{
+    "temperature,location=room1 value=21.0",
+    "temperature,location=room2 value=22.5",
+    "temperature,location=room3 value=23.0",
+};
+var batchData = String.Join("\n", lines);
+dal.Execute(batchData);
+```
+
+#### 3.2 查询数据（Flux）
+
+```csharp
+var dal = DAL.Create("InfluxDB");
+
+// Flux 查询
+var flux = @"
+from(bucket: ""my-bucket"")
+  |> range(start: -1h)
+  |> filter(fn: (r) => r._measurement == ""temperature"")
+  |> filter(fn: (r) => r.location == ""room1"")
+  |> limit(n: 100)
+";
+
+var dt = dal.Query(flux);
+foreach (var row in dt)
+{
+    var time = row["_time"];
+    var value = row["_value"];
+    var location = row["location"];
+    Console.WriteLine($"Time: {time}, Value: {value}, Location: {location}");
+}
+```
+
+#### 3.3 获取 Measurements（表）
+
+```csharp
+var dal = DAL.Create("InfluxDB");
+
+// 获取所有 measurement
+var tables = dal.Tables;
+foreach (var table in tables)
+{
+    Console.WriteLine($"Measurement: {table.TableName}");
+}
+```
+
+## Line Protocol 格式说明
+
+Line Protocol 是 InfluxDB 的写入格式，语法如下：
+
+```
+measurement,tag_key1=tag_value1,tag_key2=tag_value2 field_key1=field_value1,field_key2=field_value2 timestamp
+```
+
+### 组成部分
+
+1. **measurement**：测量名称（类似表名），必填
+2. **tags**：标签（索引字段），可选，多个用逗号分隔
+3. **fields**：字段值，必填，多个用逗号分隔
+4. **timestamp**：时间戳（纳秒），可选，不指定则使用当前时间
+
+### 示例
+
+```csharp
+// 基本示例
+"temperature value=23.5"
+
+// 带标签
+"temperature,location=room1,sensor=sensor1 value=23.5"
+
+// 多字段
+"temperature,location=room1 value=23.5,humidity=45"
+
+// 指定时间戳（纳秒）
+var nanos = DateTimeOffset.UtcNow.ToUnixTimeMilliseconds() * 1000000;
+$"temperature,location=room1 value=23.5 {nanos}"
+```
+
+## Flux 查询语言
+
+Flux 是 InfluxDB 的查询语言，功能强大且灵活。
+
+### 基本查询示例
+
+```csharp
+// 1. 查询最近1小时的数据
+var flux = @"
+from(bucket: ""my-bucket"")
+  |> range(start: -1h)
+";
+
+// 2. 按 measurement 过滤
+var flux = @"
+from(bucket: ""my-bucket"")
+  |> range(start: -1h)
+  |> filter(fn: (r) => r._measurement == ""temperature"")
+";
+
+// 3. 按 tag 过滤
+var flux = @"
+from(bucket: ""my-bucket"")
+  |> range(start: -1h)
+  |> filter(fn: (r) => r._measurement == ""temperature"")
+  |> filter(fn: (r) => r.location == ""room1"")
+";
+
+// 4. 聚合查询（平均值）
+var flux = @"
+from(bucket: ""my-bucket"")
+  |> range(start: -1h)
+  |> filter(fn: (r) => r._measurement == ""temperature"")
+  |> aggregateWindow(every: 5m, fn: mean)
+";
+
+// 5. 限制返回数量
+var flux = @"
+from(bucket: ""my-bucket"")
+  |> range(start: -1h)
+  |> limit(n: 100)
+";
+```
+
+## 使用场景
+
+### 1. 物联网数据采集
+
+```csharp
+// 传感器数据写入
+var sensorId = "sensor_001";
+var location = "warehouse_A";
+var temperature = 25.3;
+var humidity = 60.5;
+
+var lineProtocol = $"sensor_data,sensor_id={sensorId},location={location} temperature={temperature},humidity={humidity}";
+dal.Execute(lineProtocol);
+```
+
+### 2. 系统监控指标
+
+```csharp
+// 服务器性能指标
+var hostname = Environment.MachineName;
+var cpuUsage = GetCpuUsage();
+var memoryUsage = GetMemoryUsage();
+
+var lineProtocol = $"system_metrics,host={hostname} cpu_usage={cpuUsage},memory_usage={memoryUsage}";
+dal.Execute(lineProtocol);
+```
+
+### 3. 日志与事件追踪
+
+```csharp
+// 应用程序日志
+var appName = "MyApp";
+var level = "INFO";
+var message = "User logged in";
+
+var lineProtocol = $"app_logs,app={appName},level={level} message=\"{message}\"";
+dal.Execute(lineProtocol);
+```
+
+## 注意事项
+
+1. **时间戳精度**：InfluxDB 使用纳秒级时间戳，需要将毫秒 × 1000000
+2. **字符串字段**：在 Line Protocol 中，字符串字段值需要用双引号包裹
+3. **特殊字符**：measurement、tag key/value、field key 中的空格、逗号、等号需要转义
+4. **Bucket 权限**：确保 Token 有对应 Bucket 的读写权限
+5. **查询性能**：合理使用 tag 进行索引，避免在 field 上频繁过滤
+6. **批量写入**：多条数据用换行符分隔，提高写入效率
+
+## 与 XCode 实体的集成
+
+InfluxDB 主要用于时序数据存储，与 XCode 的关系型实体模型有所不同。建议：
+
+- **时序数据**：使用 InfluxDB 的原生 Line Protocol 和 Flux 查询
+- **元数据**：使用 XCode 的其他数据库（如 MySQL、PostgreSQL）存储设备信息、用户信息等
+- **混合场景**：在一个应用中同时使用多个 DAL 连接，InfluxDB 负责时序数据，关系型数据库负责业务数据
+
+## 常见问题
+
+### Q1: 如何生成 InfluxDB Token？
+
+A: 在 InfluxDB UI 中：
+1. 进入 `Load Data` > `API Tokens`
+2. 点击 `Generate API Token`
+3. 选择权限范围（读/写特定 Bucket）
+4. 复制生成的 Token
+
+### Q2: 支持 InfluxDB 1.x 吗？
+
+A: 当前实现主要针对 InfluxDB 2.x。InfluxDB 1.x 使用不同的认证和查询方式（InfluxQL），暂不支持。
+
+### Q3: 如何优化查询性能？
+
+A: 
+- 合理使用 tag 作为索引
+- 查询时指定明确的时间范围
+- 避免使用 `group()` 等高开销操作
+- 使用 `limit()` 限制返回数量
+
+### Q4: 数据保留策略如何设置？
+
+A: 数据保留策略在 Bucket 级别设置，通过 InfluxDB UI 或 API 管理，XCode 不直接管理保留策略。
+
+## 参考资源
+
+- [InfluxDB 官方文档](https://docs.influxdata.com/influxdb/v2/)
+- [Flux 查询语言](https://docs.influxdata.com/flux/v0/)
+- [Line Protocol 参考](https://docs.influxdata.com/influxdb/v2/reference/syntax/line-protocol/)
+- [XCode 文档](https://newlifex.com/xcode)
+
+## 开源协议
+
+本实现遵循 NewLife 系列组件的开源协议，详见项目根目录 LICENSE 文件。

Readme.MD

@@ -6,7 +6,7 @@
 ![Nuget](https://img.shields.io/nuget/v/newlife.xcode?logo=nuget)
 ![Nuget (with prereleases)](https://img.shields.io/nuget/vpre/newlife.xcode?label=dev%20nuget&logo=nuget)
 
-高性能 .NET 数据中间件，聚焦“添删改查 + 极致性能 + 海量数据”，内置多级缓存、自动建模/迁移、分表分库、强类型查询、跨库迁移，支持 MySQL / SQLite / SqlServer / Oracle / PostgreSQL / TDengine / 达梦 / 金仓 / 瀚高 / DB2 等。单表生产实践达百亿级，查询吞吐可达十亿级 QPS（配合缓存策略）。
+高性能 .NET 数据中间件，聚焦“添删改查 + 极致性能 + 海量数据”，内置多级缓存、自动建模/迁移、分表分库、强类型查询、跨库迁移，支持 MySQL / SQLite / SqlServer / Oracle / PostgreSQL / TDengine / InfluxDB / 达梦 / 金仓 / 瀚高 / DB2 等。单表生产实践达百亿级，查询吞吐可达十亿级 QPS（配合缓存策略）。
 
 文档：https://newlifex.com/xcode   社区交流QQ群：1600800 / 1600838