create slo linq2db

.github/workflows/slo.yml

@@ -20,6 +20,7 @@ jobs:
           - AdoNet
           - Dapper
           - EF
+          - Linq2db.Slo
         include:
           - workload: AdoNet
             read_rps: 1000
@@ -30,7 +31,10 @@ jobs:
           - workload: EF
             read_rps: 1000
             write_rps: 100
-
+          - workload: Linq2db.Slo
+            read_rps: 1000
+            write_rps: 100
+
     concurrency:
       group: slo-${{ github.ref }}-${{ matrix.workload }}
       cancel-in-progress: true

slo/src/Linq2db.Slo/Linq2db.Slo.csproj

@@ -0,0 +1,19 @@
+<Project Sdk="Microsoft.NET.Sdk">
+
+    <PropertyGroup>
+        <OutputType>Exe</OutputType>
+        <TargetFramework>net8.0</TargetFramework>
+        <ImplicitUsings>enable</ImplicitUsings>
+        <Nullable>enable</Nullable>
+        <RootNamespace>Linq2db</RootNamespace>
+    </PropertyGroup>
+	    <ItemGroup>
+			<PackageReference Include="Community.Ydb.Linq2db" Version="0.0.1" />
+		</ItemGroup>
+	    <ItemGroup>	
+			<ProjectReference Include="..\Internal\Internal.csproj" />
+		</ItemGroup>
+		<ItemGroup>
+			<PackageReference Include="linq2db" Version="6.0.0-rc.3" />
+		</ItemGroup>	
+</Project>

slo/src/Linq2db.Slo/Program.cs

@@ -0,0 +1,4 @@
+using Internal;
+using Linq2db;
+
+await Cli.Run(new SloTableContext(), args);

slo/src/Linq2db.Slo/SloTableContext.cs

@@ -0,0 +1,105 @@
+using Internal;
+using Linq2db.Ydb;
+using Linq2db.Ydb.Internal;
+using LinqToDB;
+using LinqToDB.Async;
+using LinqToDB.Data;
+using LinqToDB.Mapping;
+
+namespace Linq2db;
+
+public sealed class SloTableContext : SloTableContext<SloTableContext.Linq2dbClient>
+{
+    protected override string Job => "Linq2db";
+
+    static SloTableContext()
+    {
+        YdbSdkRetryPolicyRegistration.UseGloballyWithIdempotence();
+        DataConnection.AddProviderDetector(YdbTools.ProviderDetector);
+    }
+
+    public sealed class Linq2dbClient(string connectionString)
+    {
+        public DataConnection Open()
+            => new(new DataOptions().UseConnectionString("YDB", connectionString));
+    }
+
+    protected override Linq2dbClient CreateClient(Config config) => new(config.ConnectionString);
+
+    protected override async Task Create(Linq2dbClient client, int operationTimeout)
+    {
+        await using var db = client.Open();
+        db.CommandTimeout = operationTimeout;
+
+        await db.ExecuteAsync($@"
+            CREATE TABLE `{SloTable.Name}` (
+                Guid             Uuid,
+                Id               Int32,
+                PayloadStr       Text,
+                PayloadDouble    Double,
+                PayloadTimestamp Timestamp,
+                PRIMARY KEY (Guid, Id)
+            )");
+
+        await db.ExecuteAsync(SloTable.Options);
+    }
+
+    protected override async Task<int> Save(Linq2dbClient client, SloTable sloTable, int writeTimeout)
+    {
+        await using var db = client.Open();
+        db.CommandTimeout = writeTimeout;
+
+        var sql = $@"
+UPSERT INTO `{SloTable.Name}` (Guid, Id, PayloadStr, PayloadDouble, PayloadTimestamp)
+VALUES (@Guid, @Id, @PayloadStr, @PayloadDouble, @PayloadTimestamp);";
+
+        var affected = await db.ExecuteAsync(
+            sql,
+            new DataParameter("Guid", sloTable.Guid, DataType.Guid),
+            new DataParameter("Id", sloTable.Id, DataType.Int32),
+            new DataParameter("PayloadStr", sloTable.PayloadStr, DataType.NVarChar),
+            new DataParameter("PayloadDouble", sloTable.PayloadDouble, DataType.Double),
+            new DataParameter("PayloadTimestamp", sloTable.PayloadTimestamp, DataType.DateTime2)
+        );
+
+        return affected > 0 ? affected : 1;
+    }
+
+    protected override async Task<object?> Select(Linq2dbClient client, (Guid Guid, int Id) select, int readTimeout)
+    {
+        await using var db = client.Open();
+        db.CommandTimeout = readTimeout;
+
+        var t = db.GetTable<SloRow>();
+
+        var row = await t
+            .Where(r => r.Guid == select.Guid && r.Id == select.Id)
+            .Select(r => new
+            {
+                r.Guid,
+                r.Id,
+                r.PayloadStr,
+                r.PayloadDouble,
+                r.PayloadTimestamp
+            })
+            .FirstOrDefaultAsync();
+
+        return row;
+    }
+
+    protected override async Task<int> SelectCount(Linq2dbClient client)
+    {
+        await using var db = client.Open();
+        return await db.GetTable<SloRow>().CountAsync();
+    }
+
+    [Table(SloTable.Name)]
+    private sealed class SloRow(Guid guid, int id, string? payloadStr, double payloadDouble, DateTime payloadTimestamp)
+    {
+        [Column] public Guid Guid { get; } = guid;
+        [Column] public int Id { get; } = id;
+        [Column] public string? PayloadStr { get; } = payloadStr;
+        [Column] public double PayloadDouble { get; } = payloadDouble;
+        [Column] public DateTime PayloadTimestamp { get; } = payloadTimestamp;
+    }
+}

slo/src/src.sln

@@ -13,6 +13,8 @@ Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "EF", "EF\EF.csproj", "{291A
 EndProject
 Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "AdoNet.Dapper", "Dapper\AdoNet.Dapper.csproj", "{A6B9B4F1-4C7C-42C1-A212-B71A9B0D67F7}"
 EndProject
+Project("{FAE04EC0-301F-11D3-BF4B-00C04F79EFBC}") = "Linq2db.Slo", "Linq2db.Slo\Linq2db.Slo.csproj", "{59758BC9-E53B-46C8-84AC-62670DD559D4}"
+EndProject
 Global
 	GlobalSection(SolutionConfigurationPlatforms) = preSolution
 		Debug|Any CPU = Debug|Any CPU
@@ -39,6 +41,10 @@ Global
 		{A6B9B4F1-4C7C-42C1-A212-B71A9B0D67F7}.Debug|Any CPU.Build.0 = Debug|Any CPU
 		{A6B9B4F1-4C7C-42C1-A212-B71A9B0D67F7}.Release|Any CPU.ActiveCfg = Release|Any CPU
 		{A6B9B4F1-4C7C-42C1-A212-B71A9B0D67F7}.Release|Any CPU.Build.0 = Release|Any CPU
+		{59758BC9-E53B-46C8-84AC-62670DD559D4}.Debug|Any CPU.ActiveCfg = Debug|Any CPU
+		{59758BC9-E53B-46C8-84AC-62670DD559D4}.Debug|Any CPU.Build.0 = Debug|Any CPU
+		{59758BC9-E53B-46C8-84AC-62670DD559D4}.Release|Any CPU.ActiveCfg = Release|Any CPU
+		{59758BC9-E53B-46C8-84AC-62670DD559D4}.Release|Any CPU.Build.0 = Release|Any CPU
 	EndGlobalSection
 	GlobalSection(SolutionProperties) = preSolution
 		HideSolutionNode = FALSE