refactor sample

Author: panoukos41

samples/ConsoleApp/Benchy.cs

@@ -0,0 +1,57 @@
+using BenchmarkDotNet.Attributes;
+using NoSQLite;
+
+namespace ConsoleApp;
+
+[MemoryDiagnoser(true)]
+public class Benchy
+{
+    public NoSQLiteConnection Connection { get; set; } = null!;
+    public NoSQLiteTable WriteTable { get; set; } = null!;
+    public NoSQLiteTable ReadTable { get; set; } = null!;
+
+    public Person Person { get; set; } = null!;
+    public string[] PeopleIds { get; set; } = null!;
+    public Dictionary<string, Person> People { get; set; } = null!;
+
+    [GlobalSetup]
+    public void Setup()
+    {
+        Connection = new(Path.Combine(Environment.CurrentDirectory, "benchmark.sqlite3"));
+        WriteTable = Connection.GetTable("Write");
+        ReadTable = Connection.GetTable("Read");
+
+        Person = new Person
+        {
+            Name = "singe_write",
+            Description = "A"
+        };
+
+        PeopleIds = (0..100).Select(static num => num.ToString()).ToArray();
+
+        People = PeopleIds.Select(num => new Person
+        {
+            Name = num.ToString(),
+            Description = "Yay",
+            Surname = "no"
+        })
+        .ToDictionary(static x => x.Name);
+
+        ReadTable.InsertMany(People);
+    }
+
+    [GlobalCleanup]
+    public void Cleanup() => Connection.Dispose();
+
+    [Benchmark]
+    public Person Read_Singe() => ReadTable.Find<Person>("0")!;
+
+    [Benchmark]
+    public List<Person> Read_Many() => ReadTable.FindMany<Person>(PeopleIds).ToList();
+
+    [Benchmark]
+    public void Write_Singe() => WriteTable.Insert(Person.Name, Person);
+
+    [Benchmark]
+    public void Write_Many() => WriteTable.InsertMany(People);
+}

samples/ConsoleApp/CRUD.cs

@@ -4,8 +4,9 @@ namespace ConsoleApp;
 
 public static class CRUD
 {
-    public static void Objects(NoSQLiteConnection db)
+    public static void Objects(NoSQLiteConnection connection)
     {
+        var db = connection.GetTable();
         // objects
         var panos = new Person
         {
@@ -23,7 +24,7 @@ public static void Objects(NoSQLiteConnection db)
         db.Insert("0", panos);
         db.Insert("1", john);
 
-        db.Insert(new Dictionary<string, Person>
+        db.InsertMany(new Dictionary<string, Person>
         {
             ["0"] = panos,
             ["1"] = john
@@ -34,17 +35,19 @@ public static void Objects(NoSQLiteConnection db)
         var panos2 = db.Find<Person>("0");
         var john2 = db.Find<Person>("1");
 
-        var people = db.Find<Person>(new[] { "0", "1" }).ToArray();
+        var people = db.FindMany<Person>(new[] { "0", "1" }).ToArray();
 
         db.Remove("0");
-        db.Remove(new[] { "0", "1" });
+        db.RemoveMany(new[] { "0", "1" });
 
         db.Insert("0", panos);
         db.Insert("1", john);
     }
 
-    public static void Lists(NoSQLiteConnection db)
+    public static void Lists(NoSQLiteConnection connection)
     {
+        var db = connection.GetTable();
+
         var people = new[]
         {
             new Person{ Name = "person1", },

samples/ConsoleApp/ConsoleApp.csproj

@@ -4,8 +4,14 @@
     <OutputType>Exe</OutputType>
     <TargetFramework>net6.0</TargetFramework>
     <NoWarn>CS1591;NU1603;</NoWarn>
+    <IsPackable>false</IsPackable>
+    <GenerateAssemblyInfo>false</GenerateAssemblyInfo>
   </PropertyGroup>
 
+  <ItemGroup>
+    <PackageReference Include="BenchmarkDotNet" Version="0.13.2" />
+  </ItemGroup>
+
   <ItemGroup>
     <ProjectReference Include="..\..\src\NoSQLite\NoSQLite.csproj" />
   </ItemGroup>

samples/ConsoleApp/Extensions/RangeExtensions.cs

@@ -0,0 +1,36 @@
+namespace System;
+
+public static class RangeExtensions
+{
+    public static RangeEnumerator GetEnumerator(this Range range) => new(range);
+
+    public static IEnumerable<TResult> Select<TResult>(this Range range, Func<int, TResult> selector)
+    {
+        foreach (var num in range)
+        {
+            yield return selector(num);
+        }
+    }
+}
+
+public struct RangeEnumerator
+{
+    private int _current;
+    private readonly int _end;
+
+    public RangeEnumerator(Range range)
+    {
+        if (range.End.IsFromEnd) throw new NotSupportedException("From end ranges not supported");
+
+        _current = range.Start.Value - 1;
+        _end = range.End.Value;
+    }
+
+    public int Current => _current;
+
+    public bool MoveNext()
+    {
+        _current += 1;
+        return _current <= _end;
+    }
+}

samples/ConsoleApp/INDEX.cs

@@ -4,8 +4,10 @@ namespace ConsoleApp;
 
 public static class INDEX
 {
-    public static void Execute(NoSQLiteConnection db)
+    public static void Execute(NoSQLiteConnection connection)
     {
+        var db = connection.GetTable();
+
         var indexName = "name_index";
 
         var exists = db.IndexExists(indexName);

samples/ConsoleApp/Program.cs

@@ -1,13 +1,20 @@
 global using ConsoleApp.Data;
+using BenchmarkDotNet.Configs;
+using BenchmarkDotNet.Running;
 using ConsoleApp;
 using NoSQLite;
 using System.Diagnostics;
 using System.Text.Json;
 using System.Text.Json.Serialization;
 
+
+//BenchmarkRunner.Run<Benchy>();
+
+//return;
+
 var stopwatch = Stopwatch.StartNew();
 
-var db = new NoSQLiteConnection(
+var connection = new NoSQLiteConnection(
     Path.Combine(Environment.CurrentDirectory, "console.sqlite3"),
     new JsonSerializerOptions
     {
@@ -19,22 +26,21 @@
 Console.WriteLine($"Open elapsed time: {stopwatch.ElapsedMilliseconds}");
 
 Console.WriteLine($"""
-       Path: {db.Path}
-      Table: {db.Table}
-    Version: {db.Version}
+       Path: {connection.Path}
+    Version: {connection.Version}
     """);
 
 stopwatch.Restart();
 
-CRUD.Objects(db);
-CRUD.Lists(db);
-INDEX.Execute(db);
+CRUD.Objects(connection);
+CRUD.Lists(connection);
+INDEX.Execute(connection);
 
 stopwatch.Stop();
 Console.WriteLine($"Operation time: {stopwatch.ElapsedMilliseconds}");
 
 stopwatch.Restart();
-db.Dispose();
+connection.Dispose();
 
 stopwatch.Stop();
 Console.WriteLine($"Close elapsed time: {stopwatch.ElapsedMilliseconds}");