wip

Author: stidsborg

Core/Cleipnir.ResilientFunctions.Tests/TestTemplates/StateStoreTests.cs

@@ -0,0 +1,9 @@
+using System.Threading.Tasks;
+
+namespace Cleipnir.ResilientFunctions.Storage;
+
+public interface IStoreCommandExecutor
+{
+    public Task<IStoreCommandReader> Execute(StoreCommands commands);
+    Task<int> ExecuteNonQuery(StoreCommands commands);
+}

Core/Cleipnir.ResilientFunctions/Storage/IStoreCommandExecutor.cs

@@ -4,6 +4,11 @@
 
 namespace Cleipnir.ResilientFunctions.Storage;
 
+public record StoreCommands(List<StoreCommand> Commands)
+{
+    public static StoreCommands Create(params List<StoreCommand> commands) => new(commands);
+};
+
 public record StoreCommand(string Sql, List<ParameterValueAndName> Parameters)
 {
     public void AddParameter(string name, object value) => Parameters.Add(new ParameterValueAndName(name, value));

Core/Cleipnir.ResilientFunctions/Storage/StoreCommand.cs

@@ -0,0 +1,20 @@
+using System;
+using System.Threading.Tasks;
+
+namespace Cleipnir.ResilientFunctions.Storage;
+
+public interface IStoreCommandReader : IAsyncDisposable
+{
+    int AffectedRows { get; }
+    Task<bool> MoveToNextResults();
+    Task<bool> ReadAsync();
+    
+    Task<bool> IsDbNullAsync(int ordinal); 
+    Guid GetGuid(int ordinal);
+    object GetValue(int ordinal);
+    bool GetBoolean(int ordinal);
+    int GetInt32(int ordinal);
+    long GetInt64(int ordinal);
+    string GetString(int ordinal);
+    bool IsDbNull(int ordinal);
+}

Core/Cleipnir.ResilientFunctions/Storage/StoreCommandReader.cs

@@ -0,0 +1,8 @@
+using System.Collections.Generic;
+
+namespace Cleipnir.ResilientFunctions.Storage;
+
+public interface IStoreReader<T>
+{
+    public List<T> Read();
+}