Geography parameter handling (#25)

* Added custom handling for geography parameters

* Bumped version

* Tweaking setting of udt type

* Added geography integration tests

DataDude.Tests/Core/Scripts/Migrations/1.0.0/01.Schema.sql

@@ -82,6 +82,12 @@ CREATE TABLE Test_Nullable_Text_Data_Type(
 )
 GO
 
+CREATE TABLE Test_Geography_Data(
+	Id INT IDENTITY PRIMARY KEY,
+	Position GEOGRAPHY NULL,
+)
+GO
+
 CREATE TRIGGER People.EmployeeUpdatedAt ON People.Employee AFTER UPDATE AS BEGIN
 	UPDATE People.Employee 
 		SET People.Employee.UpdatedAt = GETDATE()

DataDude.Tests/DataDude.Tests.csproj

@@ -11,6 +11,7 @@
     <PackageReference Include="ADatabaseFixture.SqlServer" Version="0.4.0" />
     <PackageReference Include="FakeItEasy" Version="7.3.1" />
     <PackageReference Include="Microsoft.NET.Test.Sdk" Version="17.4.1" />
+    <PackageReference Include="Microsoft.SqlServer.Types" Version="160.1000.6" />
     <PackageReference Include="Respawn" Version="6.0.0" />
     <PackageReference Include="Shouldly" Version="4.1.0" />
     <PackageReference Include="xunit" Version="2.4.2" />

DataDude.Tests/Inserts/InstructionTests.cs

@@ -4,6 +4,7 @@
 using DataDude.Instructions.Insert;
 using DataDude.Instructions.Insert.Insertion;
 using DataDude.Tests.Core;
+using Microsoft.SqlServer.Types;
 using Shouldly;
 using Xunit;
 
@@ -345,5 +346,30 @@ public async Task Split_Inserts_Keeps_Track_Of_Previously_Inserted_Data()
             var officeOccupancies = await connection.QueryAsync<dynamic>("SELECT * FROM People.OfficeOccupancy");
             officeOccupancies.ShouldContain(x => true, 2, "Should contain two occupancies");
         }
+
+        [Fact]
+        public async Task Can_Insert_Geography_Data()
+        {
+            using var connection = Fixture.CreateNewConnection();
+            var position = SqlGeography.Point(50, 11, 4326);
+
+            var dude = new Dude();
+            await dude
+                .Insert("Test_Geography_Data", 
+                    new { Position = position },
+                    new { Position = (SqlGeography)null })
+                .Go(connection);
+
+            var geography_data = (await connection.QueryAsync<(decimal? Lat, decimal? Long)>("SELECT Position.Lat, Position.Long FROM Test_Geography_Data ORDER BY Id")).ToList();
+            geography_data.ShouldSatisfyAllConditions(
+                positions => positions[0].ShouldSatisfyAllConditions(
+                    position => position.Lat.ShouldBe(50),
+                    position => position.Long.ShouldBe(11)),
+                positions => positions[1].ShouldSatisfyAllConditions(
+                    position => position.Lat.ShouldBeNull(),
+                    position => position.Long.ShouldBeNull()));
+
+
+        }
     }
 }

DataDude/DataDude.csproj

@@ -4,7 +4,7 @@
     <TargetFramework>netstandard2.1</TargetFramework>
     <LangVersion>9.0</LangVersion>
     <Nullable>enable</Nullable>
-    <Version>0.8.0-preview.1</Version>
+    <Version>0.8.0-preview.2</Version>
     <GenerateDocumentationFile>true</GenerateDocumentationFile>
     <IncludeSymbols>true</IncludeSymbols>
     <SymbolPackageFormat>snupkg</SymbolPackageFormat>

DataDude/Database/DataDudeDbParameter.cs

@@ -1,31 +1,37 @@
 using System;
 using System.Data;
 using System.Data.Common;
+using System.Reflection;
+using DataDude.Instructions.Insert;
+using DataDude.Schema;
 
 namespace DataDude.Core
 {
     public struct DataDudeDbParameter
     {
-        public DataDudeDbParameter(string name, object? value, DbType? dbType)
+        public DataDudeDbParameter(ColumnInformation column, ColumnValue? value)
         {
-            Name = name;
-            Value = value;
-            DbType = dbType;
+            Column = column;
+            ColumnValue = value;
         }
 
-        public string Name { get; }
-        public object? Value { get; }
-        public DbType? DbType { get; }
+        public ColumnInformation Column { get; }
+        public ColumnValue? ColumnValue { get; }
 
         public void AddParameterTo(DbCommand cmd)
         {
             var param = cmd.CreateParameter();
-            param.ParameterName = $"@{Name}";
-            param.Value = Value ?? DBNull.Value;
+            param.ParameterName = $"@{Column.Name}";
+            param.Value = ColumnValue?.Value ?? DBNull.Value;
             param.Direction = ParameterDirection.Input;
-            if (DbType is { })
+
+            if (ColumnValue?.DbType is { } dbType)
             {
-                param.DbType = DbType.Value;
+                param.DbType = dbType;
+            }
+            else if (Column is { DataType: "geography" } && param.GetType().GetProperty("UdtTypeName") is PropertyInfo udtProperty)
+            {
+                udtProperty.SetValue(param, "geography");
             }
 
             cmd.Parameters.Add(param);

DataDude/Instructions/IInstructionDecorator.cs

@@ -3,7 +3,7 @@
 namespace DataDude.Instructions
 {
     /// <summary>
-    /// 
+    /// Intercept context before and after instructions have been executed
     /// </summary>
     public interface IInstructionDecorator
     {

DataDude/Instructions/Insert/Insertion/RowInsertHandler.cs

@@ -23,7 +23,7 @@ protected internal (string columns, string values, IReadOnlyList<DataDudeDbParam
             {
                 if (!(value.Value is RawSql))
                 {
-                    parameters.Add(new (column.Name, value.Value, value.DbType));
+                    parameters.Add(new (column, value));
                 }
             }