- basic mapping implemented

Author: eben-roux

Shuttle.Core.Data.Tests/QueryMapper/BasicMapping.cs

@@ -0,0 +1,11 @@
+using System;
+
+namespace Shuttle.Core.Data.Tests
+{
+    public class BasicMapping
+    {
+        public Guid Id { get; set; }
+        public string Name { get; set; }
+        public int Age { get; set; } 
+    }
+}

Shuttle.Core.Data.Tests/QueryMapper/QueryMapperFixture.cs

@@ -0,0 +1,46 @@
+using System.Linq;
+using NUnit.Framework;
+
+namespace Shuttle.Core.Data.Tests
+{
+    [TestFixture]
+    public class QueryMapperFixture : Fixture
+    {
+        [Test]
+        public void Should_be_able_to_do_basic_mapping()
+        {
+            var mapper = new QueryMapper(new DatabaseGateway());
+
+            var queryRow = RawQuery.Create(@"
+select top 1
+    Id,
+    Name,
+    Age
+from
+    BasicMapping
+");
+
+            var queryRows = RawQuery.Create(@"
+select
+    Id,
+    Name,
+    Age
+from
+    BasicMapping
+");
+
+            using (GetDatabaseContext())
+            {
+                var item = mapper.MapObject<BasicMapping>(queryRow);
+                var items = mapper.MapObjects<BasicMapping>(queryRows);
+
+                Assert.AreEqual(2, items.Count());
+
+                var mappedRow = mapper.MapRow<BasicMapping>(queryRow);
+                var mappedRows = mapper.MapRows<BasicMapping>(queryRows);
+
+                Assert.AreEqual(2, mappedRows.Count());
+            }
+        }
+    }
+}

Shuttle.Core.Data.Tests/Shuttle.Core.Data.Tests.csproj

@@ -72,6 +72,8 @@
     <Compile Include="MappedDataTests.cs" />
     <Compile Include="ProcedureQueryTests.cs" />
     <Compile Include="Properties\AssemblyInfo.cs" />
+    <Compile Include="QueryMapper\BasicMapping.cs" />
+    <Compile Include="QueryMapper\QueryMapperFixture.cs" />
     <Compile Include="RawQueryTests.cs" />
     <Compile Include="Fakes\Order.cs" />
     <Compile Include="Fakes\OrderAssembler.cs" />

Shuttle.Core.Data/IQueryMapper.cs

@@ -0,0 +1,12 @@
+using System.Collections.Generic;
+
+namespace Shuttle.Core.Data
+{
+    public interface IQueryMapper
+    {
+        MappedRow<T> MapRow<T>(IQuery query) where T : new();
+        IEnumerable<MappedRow<T>> MapRows<T>(IQuery query) where T : new();
+        T MapObject<T>(IQuery query) where T : new();
+        IEnumerable<T> MapObjects<T>(IQuery query) where T : new();
+    }
+}

Shuttle.Core.Data/QueryMapper.cs

@@ -0,0 +1,68 @@
+using System.Collections.Generic;
+using System.Data;
+using System.Linq;
+using System.Reflection;
+using Shuttle.Core.Infrastructure;
+
+namespace Shuttle.Core.Data
+{
+    public class QueryMapper : IQueryMapper
+    {
+        private readonly IDatabaseGateway _databaseGateway;
+
+        public QueryMapper(IDatabaseGateway databaseGateway)
+        {
+            Guard.AgainstNull(databaseGateway, "databaseGateway");
+
+            _databaseGateway = databaseGateway;
+        }
+
+        public MappedRow<T> MapRow<T>(IQuery query) where T : new()
+        {
+            var row = _databaseGateway.GetSingleRowUsing(query);
+
+            return new MappedRow<T>(row, Map<T>(row));
+        }
+
+        private T Map<T>(DataRow row) where T : new()
+        {
+            var result = new T();
+            var type = typeof (T);
+
+            foreach (PropertyInfo pi in type.GetProperties())
+            {
+                var value = row[pi.Name];
+
+                if (value == null)
+                {
+                    continue;
+                }
+
+                try
+                {
+                    pi.SetValue(result, value, null);
+                }
+                catch
+                {
+                }
+            }
+
+            return result;
+        }
+
+        public IEnumerable<MappedRow<T>> MapRows<T>(IQuery query) where T : new()
+        {
+            return _databaseGateway.GetRowsUsing(query).Select(row => new MappedRow<T>(row, Map<T>(row)));
+        }
+
+        public T MapObject<T>(IQuery query) where T : new()
+        {
+            return Map<T>(_databaseGateway.GetSingleRowUsing(query));
+        }
+
+        public IEnumerable<T> MapObjects<T>(IQuery query) where T : new()
+        {
+            return _databaseGateway.GetRowsUsing(query).Select(row => Map<T>(row));
+        }
+    }
+}

Shuttle.Core.Data/Shuttle.Core.Data.csproj

@@ -75,6 +75,8 @@
   </ItemGroup>
   <ItemGroup>
     <Compile Include="ConnectionStringService.cs" />
+    <Compile Include="QueryMapper.cs" />
+    <Compile Include="IQueryMapper.cs" />
     <Compile Include="IQueryParameter.cs" />
     <Compile Include="DatabaseContext.cs" />
     <Compile Include="ThreadStaticDatabaseContextCache.cs" />