Add async version of CustomSqlTests

Author: mythz

tests/ServiceStack.OrmLiteV45.Tests/CustomSqlTestsAsync.cs

@@ -0,0 +1,101 @@
+using System.Data;
+using System.Threading.Tasks;
+using NUnit.Framework;
+using ServiceStack.DataAnnotations;
+
+namespace ServiceStack.OrmLite.Tests
+{
+    public class LetterFrequency
+    {
+        [AutoIncrement]
+        public int Id { get; set; }
+
+        public string Letter { get; set; }
+    }
+
+    [TestFixture]
+    public class CustomSqlTestsAsync : OrmLiteTestBase
+    {
+        private const string DropProcedureSql = @"
+            IF OBJECT_ID('spSearchLetters') IS NOT NULL
+                    DROP PROCEDURE spSearchLetters";
+
+        private const string CreateProcedureSql = @"
+            CREATE PROCEDURE spSearchLetters 
+            (
+                @pLetter varchar(10),
+                @pTotal int OUT
+            )
+            AS
+            BEGIN
+                SELECT @pTotal = COUNT(*) FROM LetterFrequency WHERE Letter = @pLetter
+                SELECT * FROM LetterFrequency WHERE Letter = @pLetter
+            END";
+
+        [Test]
+        public async Task Can_execute_stored_procedure_using_SqlList_with_out_params()
+        {
+            using (var db = OpenDbConnection())
+            {
+                db.DropAndCreateTable<LetterFrequency>();
+
+                var rows = "A,B,B,C,C,C,D,D,E".Split(',').Map(x => new LetterFrequency { Letter = x });
+                await db.InsertAllAsync(rows);
+
+                await db.ExecuteSqlAsync(DropProcedureSql);
+                await db.ExecuteSqlAsync(CreateProcedureSql);
+
+                IDbDataParameter pTotal = null;
+                var results = await db.SqlListAsync<LetterFrequency>("spSearchLetters",
+                    cmd => {
+                        cmd.CommandType = CommandType.StoredProcedure;
+                        cmd.AddParam("pLetter", "C");
+                        pTotal = cmd.AddParam("pTotal", direction: ParameterDirection.Output);
+                    });
+
+                Assert.That(results.Count, Is.EqualTo(3));
+                Assert.That(pTotal.Value, Is.EqualTo("3"));
+            }
+        }
+
+        [Test]
+        public async Task Can_execute_stored_procedure_using_SqlProc_with_out_params()
+        {
+            using (var db = OpenDbConnection())
+            {
+                db.DropAndCreateTable<LetterFrequency>();
+
+                var rows = "A,B,B,C,C,C,D,D,E".Split(',').Map(x => new LetterFrequency { Letter = x });
+                await db.InsertAllAsync(rows);
+
+                await db.ExecuteSqlAsync(DropProcedureSql);
+                await db.ExecuteSqlAsync(CreateProcedureSql);
+
+                var cmd = db.SqlProc("spSearchLetters", new { pLetter = "C" });
+
+                Assert.That(((OrmLiteCommand)cmd).IsDisposed, Is.False);
+
+                var pTotal = cmd.AddParam("pTotal", direction: ParameterDirection.Output);
+                var results = await cmd.ConvertToListAsync<LetterFrequency>();
+
+                Assert.That(results.Count, Is.EqualTo(3));
+                Assert.That(pTotal.Value, Is.EqualTo("3"));
+            }
+        }
+
+        [Test]
+        public async Task Can_execute_stored_proceduce_returning_scalars()
+        {
+            using (var db = OpenDbConnection())
+            {
+                using (var cmd = db.SqlProc(
+                    "GetUserIdsFromEmailAddresses", new { EmailAddresses = "as@if.com" }))
+                {
+                    var userIds = await cmd.ConvertToListAsync<int>();
+
+                    Assert.That(userIds.Count, Is.GreaterThan(0));
+                }
+            }
+        }
+    }
+}

tests/ServiceStack.OrmLiteV45.Tests/ServiceStack.OrmLiteV45.Tests.csproj

@@ -68,6 +68,7 @@
     <Compile Include="ApiSqlServerTestsAsync.cs" />
     <Compile Include="AsyncTests.cs" />
     <Compile Include="ApiMySqlTestsAsync.cs" />
+    <Compile Include="CustomSqlTestsAsync.cs" />
     <Compile Include="LoadReferencesTests.cs" />
     <Compile Include="OrmLiteContextTests.cs" />
     <Compile Include="OrmLiteTestBase.cs" />