Added Datatable support.

ProxyMapper/Core/DbCallInterceptor.cs

@@ -18,10 +18,13 @@ internal class DbCallInterceptor : IInterceptor
 
         private readonly IValidatorChain<CallInfo> _validatorChain;
 
-        public DbCallInterceptor(string connectionString, IDataProcessor dataProcessor)
+        private readonly IDatatableConverter _datatableConverter;
+
+        public DbCallInterceptor(string connectionString, IDataProcessor dataProcessor,IDatatableConverter datatableConverter)
         {
             this._connectionString = connectionString;
             this._dataProcessor = dataProcessor;
+            this._datatableConverter = datatableConverter;
             this._validatorChain = new DefaultValidatorChain<CallInfo>(new IValidator<CallInfo>[]
             {
                 new CallInfoValidator()
@@ -62,7 +65,14 @@ public void Intercept(IInvocation invocation)
                 int i = 0;
                 foreach (object argument in arguments)
                 {
-                    sqlCommand.Parameters.AddWithValue(parameterInfos[i++].Name, argument);
+                    object argumentTobeAdded = argument;
+                    DtAttribute customAttribute = argument.GetType().GetCustomAttribute<DtAttribute>();
+                    if (customAttribute != null)
+                    {
+                        DataTable dataTable = this._datatableConverter.ToDataTable((IEnumerable) argument);
+                        argumentTobeAdded = dataTable;
+                    }
+                    sqlCommand.Parameters.AddWithValue(parameterInfos[i++].Name, argumentTobeAdded);
                 }
 
                 //Call DB

ProxyMapper/Core/DefaultDatatableConverter.cs

@@ -0,0 +1,34 @@
+using System;
+using System.Collections;
+using System.Data;
+using System.Reflection;
+
+namespace ProxyMapper.Core
+{
+    public class DefaultDatatableConverter : IDatatableConverter
+    {
+        public DataTable ToDataTable(IEnumerable list)
+        {
+            Type type = list.GetType().GetGenericArguments()[0];
+            PropertyInfo[] properties = type.GetProperties();
+            DataTable dataTable = new DataTable();
+            foreach (PropertyInfo info in properties)
+            {
+                dataTable.Columns.Add(new DataColumn(info.Name, Nullable.GetUnderlyingType(info.PropertyType) ?? info.PropertyType));
+            }
+
+            foreach (object entity in list)
+            {
+                object[] values = new object[properties.Length];
+                for (int i = 0; i < properties.Length; i++)
+                {
+                    values[i] = properties[i].GetValue(entity);
+                }
+
+                dataTable.Rows.Add(values);
+            }
+
+            return dataTable;
+        }
+    }
+}

ProxyMapper/Core/IDatatableConverter.cs

@@ -0,0 +1,10 @@
+using System.Collections;
+using System.Data;
+
+namespace ProxyMapper.Core
+{
+    public interface IDatatableConverter
+    {
+        DataTable ToDataTable(IEnumerable list);
+    }
+}

ProxyMapper/Core/ProxyFactory.cs

@@ -16,7 +16,8 @@ public static T CreateRepoProxy<T>(string connectionString, IDataProcessor dataP
                     "Proxies can be generated only for interfaces. Please provide a proper interface.");
             }
             object proxy = ProxyGenerator.CreateInterfaceProxyWithoutTarget(typeof(T),
-                new DbCallInterceptor(connectionString, GetDataProcessor(dataProcessor)));
+                new DbCallInterceptor(connectionString, GetDataProcessor(dataProcessor),
+                    new DefaultDatatableConverter()));
             return (T) proxy;
         }
 

ProxyMapper/Enums/DatatableAttribute.cs → ProxyMapper/Enums/DtAttribute.cs

@@ -2,9 +2,9 @@
 
 namespace ProxyMapper.Enums
 {
-    public class DatatableAttribute : Attribute
+    public class DtAttribute : Attribute
     {
-        public DatatableAttribute(string columns)
+        public DtAttribute(string columns)
         {
             this.Columns = columns;
         }

ProxyMapper/ProxyMapper.csproj

@@ -1,7 +1,7 @@
 <Project Sdk="Microsoft.NET.Sdk">
 
   <PropertyGroup>
-    <TargetFrameworks>net46;netcoreapp1.1</TargetFrameworks>
+    <TargetFrameworks>net46</TargetFrameworks>
     <PackageId>ProxyMapper</PackageId>
     <PackageVersion>0.1.1</PackageVersion>
     <Authors>Rohan Usturge</Authors>