--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/Source/Mapping/DataReaderMapper.cs	Thu Mar 27 21:46:09 2014 +0400
@@ -0,0 +1,151 @@
+using System;
+using System.Data;
+using System.Data.SqlTypes;
+
+namespace BLToolkit.Mapping
+{
+	using Data;
+
+	public class DataReaderMapper : IMapDataSource
+	{
+		public DataReaderMapper(MappingSchema mappingSchema, IDataReader dataReader)
+		{
+			_mappingSchema = mappingSchema;
+			_dataReader    = dataReader;
+			_dataReaderEx  = dataReader as IDataReaderEx;
+		}
+
+		readonly IDataReaderEx _dataReaderEx;
+
+		readonly IDataReader _dataReader;
+		public   IDataReader  DataReader
+		{
+			get { return _dataReader; }
+		}
+
+		readonly MappingSchema _mappingSchema;
+		public   MappingSchema  MappingSchema
+		{
+			get { return _mappingSchema; }
+		}
+
+		#region IMapDataSource Members
+
+		public virtual int Count
+		{
+			get { return _dataReader.FieldCount; }
+		}
+
+		public virtual Type GetFieldType(int index)
+		{
+			return _dataReader.GetFieldType(index);
+		}
+
+		public virtual string GetName(int index)
+		{
+			return _dataReader.GetName(index);
+		}
+
+		public virtual int GetOrdinal(string name)
+		{
+			return _dataReader.GetOrdinal(name);
+		}
+
+		public virtual object GetValue(object o, int index)
+		{
+			var value = _dataReader.GetValue(index);
+			return value is DBNull? null: value;
+		}
+
+		public virtual object GetValue(object o, string name)
+		{
+			var value = _dataReader[name];
+			return value is DBNull? null: value;
+		}
+
+		public virtual bool     IsNull     (object o, int index) { return _dataReader.IsDBNull(index); }
+		public virtual bool     SupportsTypedValues(int index)   { return true; }
+
+		// Simple type getters.
+		//
+		[CLSCompliant(false)]
+		public virtual SByte    GetSByte   (object o, int index) { return _mappingSchema.ConvertToSByte(GetValue(o, index)); }
+		public virtual Int16    GetInt16   (object o, int index) { return _dataReader.GetInt16   (index); }
+		public virtual Int32    GetInt32   (object o, int index) { return _dataReader.GetInt32   (index); }
+		public virtual Int64    GetInt64   (object o, int index) { return _dataReader.GetInt64   (index); }
+
+		public virtual Byte     GetByte    (object o, int index) { return _dataReader.GetByte    (index); }
+		[CLSCompliant(false)]
+		public virtual UInt16   GetUInt16  (object o, int index) { return _mappingSchema.ConvertToUInt16(GetValue(o, index)); }
+		[CLSCompliant(false)]
+		public virtual UInt32   GetUInt32  (object o, int index) { return _mappingSchema.ConvertToUInt32(GetValue(o, index)); }
+		[CLSCompliant(false)]
+		public virtual UInt64   GetUInt64  (object o, int index) { return _mappingSchema.ConvertToUInt64(GetValue(o, index)); }
+
+		public virtual Boolean  GetBoolean (object o, int index) { return _dataReader.GetBoolean (index); }
+		public virtual Char     GetChar    (object o, int index) { return _dataReader.GetChar    (index); }
+		public virtual Single   GetSingle  (object o, int index) { return _dataReader.GetFloat   (index); }
+		public virtual Double   GetDouble  (object o, int index) { return _dataReader.GetDouble  (index); }
+		public virtual Decimal  GetDecimal (object o, int index) { return _dataReader.GetDecimal (index); }
+		public virtual Guid     GetGuid    (object o, int index) { return _dataReader.GetGuid    (index); }
+		public virtual DateTime GetDateTime(object o, int index) { return _dataReader.GetDateTime(index); }
+
+		public virtual DateTimeOffset GetDateTimeOffset(object o, int index)
+		{
+			return _dataReaderEx != null?
+				_dataReaderEx.GetDateTimeOffset(index):
+				_mappingSchema.ConvertToDateTimeOffset(_dataReader.GetValue(index));
+		}
+
+		// Nullable type getters.
+		//
+		[CLSCompliant(false)]
+		public virtual SByte?    GetNullableSByte   (object o, int index) { return _dataReader.IsDBNull(index)? null: _mappingSchema.ConvertToNullableSByte(GetValue(o, index)); }
+		public virtual Int16?    GetNullableInt16   (object o, int index) { return _dataReader.IsDBNull(index)? null: (Int16?)_dataReader.GetInt16   (index); }
+		public virtual Int32?    GetNullableInt32   (object o, int index) { return _dataReader.IsDBNull(index)? null: (Int32?)_dataReader.GetInt32   (index); }
+		public virtual Int64?    GetNullableInt64   (object o, int index) { return _dataReader.IsDBNull(index)? null: (Int64?)_dataReader.GetInt64   (index); }
+
+		public virtual Byte?     GetNullableByte    (object o, int index) { return _dataReader.IsDBNull(index)? null: (Byte?) _dataReader.GetByte    (index); }
+		[CLSCompliant(false)]
+		public virtual UInt16?   GetNullableUInt16  (object o, int index) { return _dataReader.IsDBNull(index)? null: _mappingSchema.ConvertToNullableUInt16(GetValue(o, index)); }
+		[CLSCompliant(false)]
+		public virtual UInt32?   GetNullableUInt32  (object o, int index) { return _dataReader.IsDBNull(index)? null: _mappingSchema.ConvertToNullableUInt32(GetValue(o, index)); }
+		[CLSCompliant(false)]
+		public virtual UInt64?   GetNullableUInt64  (object o, int index) { return _dataReader.IsDBNull(index)? null: _mappingSchema.ConvertToNullableUInt64(GetValue(o, index)); }
+
+		public virtual Boolean?  GetNullableBoolean (object o, int index) { return _dataReader.IsDBNull(index)? null: (Boolean?) _dataReader.GetBoolean (index); }
+		public virtual Char?     GetNullableChar    (object o, int index) { return _dataReader.IsDBNull(index)? null: (Char?)    _dataReader.GetChar    (index); }
+		public virtual Single?   GetNullableSingle  (object o, int index) { return _dataReader.IsDBNull(index)? null: (Single?)  _dataReader.GetFloat   (index); }
+		public virtual Double?   GetNullableDouble  (object o, int index) { return _dataReader.IsDBNull(index)? null: (Double?)  _dataReader.GetDouble  (index); }
+		public virtual Decimal?  GetNullableDecimal (object o, int index) { return _dataReader.IsDBNull(index)? null: (Decimal?) _dataReader.GetDecimal (index); }
+		public virtual Guid?     GetNullableGuid    (object o, int index) { return _dataReader.IsDBNull(index)? null: (Guid?)    _dataReader.GetGuid    (index); }
+		public virtual DateTime? GetNullableDateTime(object o, int index) { return _dataReader.IsDBNull(index)? null: (DateTime?)_dataReader.GetDateTime(index); }
+		public virtual DateTimeOffset? GetNullableDateTimeOffset(object o, int index)
+		{
+			return _dataReader.IsDBNull(index)? null:
+				_dataReaderEx != null? _dataReaderEx.GetDateTimeOffset(index):
+				_mappingSchema.ConvertToNullableDateTimeOffset(_dataReader.GetValue(index));
+		}
+
+#if !SILVERLIGHT
+
+		// SQL type getters.
+		//
+		public virtual SqlByte     GetSqlByte    (object o, int index) { return _dataReader.IsDBNull(index)? SqlByte.    Null: _dataReader.GetByte    (index); }
+		public virtual SqlInt16    GetSqlInt16   (object o, int index) { return _dataReader.IsDBNull(index)? SqlInt16.   Null: _dataReader.GetInt16   (index); }
+		public virtual SqlInt32    GetSqlInt32   (object o, int index) { return _dataReader.IsDBNull(index)? SqlInt32.   Null: _dataReader.GetInt32   (index); }
+		public virtual SqlInt64    GetSqlInt64   (object o, int index) { return _dataReader.IsDBNull(index)? SqlInt64.   Null: _dataReader.GetInt64   (index); }
+		public virtual SqlSingle   GetSqlSingle  (object o, int index) { return _dataReader.IsDBNull(index)? SqlSingle.  Null: _dataReader.GetFloat   (index); }
+		public virtual SqlBoolean  GetSqlBoolean (object o, int index) { return _dataReader.IsDBNull(index)? SqlBoolean. Null: _dataReader.GetBoolean (index); }
+		public virtual SqlDouble   GetSqlDouble  (object o, int index) { return _dataReader.IsDBNull(index)? SqlDouble.  Null: _dataReader.GetDouble  (index); }
+		public virtual SqlDateTime GetSqlDateTime(object o, int index) { return _dataReader.IsDBNull(index)? SqlDateTime.Null: _dataReader.GetDateTime(index); }
+		public virtual SqlDecimal  GetSqlDecimal (object o, int index) { return _dataReader.IsDBNull(index)? SqlDecimal. Null: _dataReader.GetDecimal (index); }
+		public virtual SqlMoney    GetSqlMoney   (object o, int index) { return _dataReader.IsDBNull(index)? SqlMoney.   Null: _dataReader.GetDecimal (index); }
+		public virtual SqlGuid     GetSqlGuid    (object o, int index) { return _dataReader.IsDBNull(index)? SqlGuid.    Null: _dataReader.GetGuid    (index); }
+		public virtual SqlString   GetSqlString  (object o, int index) { return _dataReader.IsDBNull(index)? SqlString.  Null: _dataReader.GetString  (index); }
+
+#endif
+
+		#endregion
+	}
+}