feat: 新增 BenchmarkDotNet 性能测试项目

Co-authored-by: nnhy <506367+nnhy@users.noreply.github.com>

Author: Copilot

.gitignore

@@ -24,3 +24,4 @@ bld/
 /BinTest
 /BinUnitTest
 /MapApi/Locations/Config
+/BenchmarkDotNet.Artifacts

Benchmark/AntiViralConfig.cs

@@ -0,0 +1,19 @@
+using BenchmarkDotNet.Columns;
+using BenchmarkDotNet.Configs;
+using BenchmarkDotNet.Jobs;
+using BenchmarkDotNet.Toolchains.InProcess.NoEmit;
+
+namespace Benchmark;
+
+/// <summary>自定义配置，使用 InProcess 工具链避免 Deterministic 构建冲突</summary>
+public class AntiViralConfig : ManualConfig
+{
+    public AntiViralConfig()
+    {
+        AddJob(Job.Default
+            .WithToolchain(InProcessNoEmitToolchain.Instance)
+            .WithWarmupCount(3)
+            .WithIterationCount(5));
+        AddColumn(StatisticColumn.OperationsPerSecond);
+    }
+}

Benchmark/Benchmark.csproj

@@ -0,0 +1,21 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+  <PropertyGroup>
+    <OutputType>Exe</OutputType>
+    <TargetFramework>net8.0</TargetFramework>
+    <OutputPath>..\Bin\Benchmark</OutputPath>
+    <AppendTargetFrameworkToOutputPath>false</AppendTargetFrameworkToOutputPath>
+    <ImplicitUsings>enable</ImplicitUsings>
+    <Nullable>enable</Nullable>
+    <LangVersion>latest</LangVersion>
+  </PropertyGroup>
+
+  <ItemGroup>
+    <PackageReference Include="BenchmarkDotNet" Version="0.15.8" />
+  </ItemGroup>
+
+  <ItemGroup>
+    <ProjectReference Include="..\NewLife.NovaDb\NewLife.NovaDb.csproj" />
+  </ItemGroup>
+
+</Project>

Benchmark/EmbeddedSqlBenchmark.cs

@@ -0,0 +1,78 @@
+using BenchmarkDotNet.Attributes;
+using NewLife.NovaDb.Core;
+using NewLife.NovaDb.Sql;
+
+namespace Benchmark;
+
+/// <summary>嵌入模式 SQL 引擎基准测试</summary>
+[MemoryDiagnoser]
+[Config(typeof(AntiViralConfig))]
+public class EmbeddedSqlBenchmark
+{
+    private String _dbPath = null!;
+    private SqlEngine _engine = null!;
+    private Int32 _counter;
+
+    [Params(WalMode.None, WalMode.Normal)]
+    public WalMode WalMode { get; set; }
+
+    [GlobalSetup]
+    public void Setup()
+    {
+        _dbPath = Path.Combine(Path.GetTempPath(), $"NovaBench_Sql_{WalMode}_{Guid.NewGuid():N}");
+        _engine = new SqlEngine(_dbPath, new DbOptions { Path = _dbPath, WalMode = WalMode });
+        _engine.Execute("CREATE TABLE bench (id INT PRIMARY KEY, name VARCHAR, age INT, score DOUBLE)");
+
+        // 预置查询数据
+        for (var i = 1; i <= 1000; i++)
+            _engine.Execute($"INSERT INTO bench VALUES ({i}, 'user{i}', {20 + i % 50}, {60.0 + i % 40})");
+
+        _counter = 2000;
+    }
+
+    [GlobalCleanup]
+    public void Cleanup()
+    {
+        _engine.Dispose();
+        try { Directory.Delete(_dbPath, true); } catch { }
+    }
+
+    [Benchmark(Description = "Insert 单行插入")]
+    public void Insert()
+    {
+        var id = Interlocked.Increment(ref _counter);
+        _engine.Execute($"INSERT INTO bench VALUES ({id}, 'bench{id}', 25, 88.5)");
+    }
+
+    [Benchmark(Description = "Select 主键查询")]
+    public void SelectByPK()
+    {
+        _engine.Execute("SELECT * FROM bench WHERE id = 500");
+    }
+
+    [Benchmark(Description = "Select 范围查询")]
+    public void SelectRange()
+    {
+        _engine.Execute("SELECT * FROM bench WHERE age > 30 AND age < 50");
+    }
+
+    [Benchmark(Description = "Update 单行更新")]
+    public void Update()
+    {
+        _engine.Execute("UPDATE bench SET score = 99.9 WHERE id = 100");
+    }
+
+    [Benchmark(Description = "Delete 单行删除 + 重插")]
+    public void DeleteAndReinsert()
+    {
+        var id = Interlocked.Increment(ref _counter);
+        _engine.Execute($"INSERT INTO bench VALUES ({id}, 'tmp', 20, 70.0)");
+        _engine.Execute($"DELETE FROM bench WHERE id = {id}");
+    }
+
+    [Benchmark(Description = "聚合查询 COUNT/AVG")]
+    public void Aggregate()
+    {
+        _engine.Execute("SELECT COUNT(*), AVG(score) FROM bench WHERE age >= 25");
+    }
+}

Benchmark/FluxEngineBenchmark.cs

@@ -0,0 +1,77 @@
+using BenchmarkDotNet.Attributes;
+using NewLife.NovaDb.Core;
+using NewLife.NovaDb.Engine.Flux;
+
+namespace Benchmark;
+
+/// <summary>时序引擎基准测试</summary>
+[MemoryDiagnoser]
+[Config(typeof(AntiViralConfig))]
+public class FluxEngineBenchmark
+{
+    private String _basePath = null!;
+    private FluxEngine _engine = null!;
+    private Int64 _baseTicks;
+
+    [GlobalSetup]
+    public void Setup()
+    {
+        _basePath = Path.Combine(Path.GetTempPath(), $"NovaBench_Flux_{Guid.NewGuid():N}");
+        _engine = new FluxEngine(_basePath, new DbOptions());
+        _baseTicks = DateTime.UtcNow.Ticks;
+
+        // 预置查询数据
+        for (var i = 0; i < 1000; i++)
+        {
+            _engine.Append(new FluxEntry
+            {
+                Timestamp = _baseTicks + i * TimeSpan.TicksPerSecond,
+                Fields = new Dictionary<String, Object?> { ["temperature"] = 20.0 + i % 30, ["humidity"] = 40.0 + i % 50 },
+                Tags = new Dictionary<String, String> { ["device"] = $"sensor_{i % 10}" }
+            });
+        }
+    }
+
+    [GlobalCleanup]
+    public void Cleanup()
+    {
+        _engine.Dispose();
+        try { Directory.Delete(_basePath, true); } catch { }
+    }
+
+    [Benchmark(Description = "Append 单条写入")]
+    public void AppendSingle()
+    {
+        _engine.Append(new FluxEntry
+        {
+            Timestamp = _baseTicks + Random.Shared.Next(0, 3600) * TimeSpan.TicksPerSecond,
+            Fields = new Dictionary<String, Object?> { ["temperature"] = 25.5, ["humidity"] = 60.0 },
+            Tags = new Dictionary<String, String> { ["device"] = "sensor_0" }
+        });
+    }
+
+    [Benchmark(Description = "AppendBatch 批量写入(100条)")]
+    public void AppendBatch()
+    {
+        var entries = new List<FluxEntry>(100);
+        var ts = _baseTicks;
+        for (var i = 0; i < 100; i++)
+        {
+            entries.Add(new FluxEntry
+            {
+                Timestamp = ts + i * TimeSpan.TicksPerMillisecond,
+                Fields = new Dictionary<String, Object?> { ["temperature"] = 20.0 + i, ["humidity"] = 50.0 },
+                Tags = new Dictionary<String, String> { ["device"] = "batch_sensor" }
+            });
+        }
+        _engine.AppendBatch(entries);
+    }
+
+    [Benchmark(Description = "QueryRange 时间范围查询")]
+    public List<FluxEntry> QueryRange()
+    {
+        var start = _baseTicks;
+        var end = _baseTicks + 100 * TimeSpan.TicksPerSecond;
+        return _engine.QueryRange(start, end);
+    }
+}

Benchmark/KvStoreBenchmark.cs

@@ -0,0 +1,71 @@
+using BenchmarkDotNet.Attributes;
+using NewLife.NovaDb.Core;
+using NewLife.NovaDb.Engine.KV;
+
+namespace Benchmark;
+
+/// <summary>KV 引擎基准测试</summary>
+[MemoryDiagnoser]
+[Config(typeof(AntiViralConfig))]
+public class KvStoreBenchmark
+{
+    private String _storePath = null!;
+    private KvStore _store = null!;
+    private Int32 _counter;
+    private Byte[] _value = null!;
+
+    [Params(64, 1024)]
+    public Int32 ValueSize { get; set; }
+
+    [GlobalSetup]
+    public void Setup()
+    {
+        _storePath = Path.Combine(Path.GetTempPath(), $"NovaBench_Kv_{ValueSize}_{Guid.NewGuid():N}");
+        Directory.CreateDirectory(_storePath);
+        _store = new KvStore(new DbOptions { DefaultKvTtl = TimeSpan.Zero }, _storePath);
+        _value = new Byte[ValueSize];
+        Random.Shared.NextBytes(_value);
+
+        // 预置数据
+        for (var i = 0; i < 1000; i++)
+            _store.Set($"key:{i}", _value);
+
+        _counter = 2000;
+    }
+
+    [GlobalCleanup]
+    public void Cleanup()
+    {
+        try { Directory.Delete(_storePath, true); } catch { }
+    }
+
+    [Benchmark(Description = "Set 写入")]
+    public void Set()
+    {
+        var id = Interlocked.Increment(ref _counter);
+        _store.Set($"key:{id}", _value);
+    }
+
+    [Benchmark(Description = "Get 读取")]
+    public Byte[]? Get()
+    {
+        return _store.Get("key:500");
+    }
+
+    [Benchmark(Description = "Set+Get 读写混合")]
+    public Byte[]? SetThenGet()
+    {
+        var id = Interlocked.Increment(ref _counter);
+        var key = $"key:{id}";
+        _store.Set(key, _value);
+        return _store.Get(key);
+    }
+
+    [Benchmark(Description = "Delete 删除")]
+    public void Delete()
+    {
+        var id = Interlocked.Increment(ref _counter);
+        _store.Set($"del:{id}", _value);
+        _store.Delete($"del:{id}");
+    }
+}

Benchmark/Program.cs

@@ -0,0 +1,8 @@
+using BenchmarkDotNet.Running;
+
+namespace Benchmark;
+
+class Program
+{
+    static void Main(String[] args) => BenchmarkSwitcher.FromAssembly(typeof(Program).Assembly).Run(args);
+}

Benchmark/ServerModeBenchmark.cs

@@ -0,0 +1,101 @@
+using BenchmarkDotNet.Attributes;
+using NewLife.NovaDb.Client;
+using NewLife.NovaDb.Core;
+using NovaServer = NewLife.NovaDb.Server.NovaServer;
+
+namespace Benchmark;
+
+/// <summary>独立服务模式基准测试（通过 TCP 协议访问 NovaServer）</summary>
+[MemoryDiagnoser]
+[Config(typeof(AntiViralConfig))]
+public class ServerModeBenchmark
+{
+    private NovaServer _server = null!;
+    private NovaConnection _conn = null!;
+    private String _dbPath = null!;
+    private Int32 _counter;
+
+    [GlobalSetup]
+    public void Setup()
+    {
+        _dbPath = Path.Combine(Path.GetTempPath(), $"NovaBench_Server_{Guid.NewGuid():N}");
+
+        // 使用随机端口避免冲突
+        var port = Random.Shared.Next(20000, 60000);
+        _server = new NovaServer(port)
+        {
+            DbPath = _dbPath,
+            Options = new ServerDbOptions { WalMode = WalMode.None }
+        };
+        _server.Start();
+
+        // 通过 ADO.NET 连接
+        _conn = new NovaConnection($"Server=127.0.0.1;Port={port}");
+        _conn.Open();
+
+        using var cmd = _conn.CreateCommand();
+        cmd.CommandText = "CREATE TABLE bench (id INT PRIMARY KEY, name VARCHAR, age INT, score DOUBLE)";
+        cmd.ExecuteNonQuery();
+
+        // 预置数据
+        for (var i = 1; i <= 1000; i++)
+        {
+            cmd.CommandText = $"INSERT INTO bench VALUES ({i}, 'user{i}', {20 + i % 50}, {60.0 + i % 40})";
+            cmd.ExecuteNonQuery();
+        }
+
+        _counter = 2000;
+    }
+
+    [GlobalCleanup]
+    public void Cleanup()
+    {
+        _conn.Dispose();
+        _server.Dispose();
+        try { Directory.Delete(_dbPath, true); } catch { }
+    }
+
+    [Benchmark(Description = "Server Insert 插入")]
+    public void Insert()
+    {
+        var id = Interlocked.Increment(ref _counter);
+        using var cmd = _conn.CreateCommand();
+        cmd.CommandText = $"INSERT INTO bench VALUES ({id}, 'bench{id}', 25, 88.5)";
+        cmd.ExecuteNonQuery();
+    }
+
+    [Benchmark(Description = "Server Select 主键查询")]
+    public void SelectByPK()
+    {
+        using var cmd = _conn.CreateCommand();
+        cmd.CommandText = "SELECT * FROM bench WHERE id = 500";
+        using var reader = cmd.ExecuteReader();
+        while (reader.Read()) { }
+    }
+
+    [Benchmark(Description = "Server Select 范围查询")]
+    public void SelectRange()
+    {
+        using var cmd = _conn.CreateCommand();
+        cmd.CommandText = "SELECT * FROM bench WHERE age > 30 AND age < 50";
+        using var reader = cmd.ExecuteReader();
+        while (reader.Read()) { }
+    }
+
+    [Benchmark(Description = "Server Update 更新")]
+    public void Update()
+    {
+        using var cmd = _conn.CreateCommand();
+        cmd.CommandText = "UPDATE bench SET score = 99.9 WHERE id = 100";
+        cmd.ExecuteNonQuery();
+    }
+
+    [Benchmark(Description = "Server 聚合查询")]
+    public void Aggregate()
+    {
+        using var cmd = _conn.CreateCommand();
+        cmd.CommandText = "SELECT COUNT(*), AVG(score) FROM bench WHERE age >= 25";
+        using var reader = cmd.ExecuteReader();
+        while (reader.Read()) { }
+    }
+}