|
0
|
1 using System;
|
|
|
2 using System.Data;
|
|
|
3 using System.Data.SqlTypes;
|
|
|
4
|
|
|
5 namespace BLToolkit.Mapping
|
|
|
6 {
|
|
|
7 using Data;
|
|
|
8
|
|
|
9 public class DataReaderMapper : IMapDataSource
|
|
|
10 {
|
|
|
11 public DataReaderMapper(MappingSchema mappingSchema, IDataReader dataReader)
|
|
|
12 {
|
|
|
13 _mappingSchema = mappingSchema;
|
|
|
14 _dataReader = dataReader;
|
|
|
15 _dataReaderEx = dataReader as IDataReaderEx;
|
|
|
16 }
|
|
|
17
|
|
|
18 readonly IDataReaderEx _dataReaderEx;
|
|
|
19
|
|
|
20 readonly IDataReader _dataReader;
|
|
|
21 public IDataReader DataReader
|
|
|
22 {
|
|
|
23 get { return _dataReader; }
|
|
|
24 }
|
|
|
25
|
|
|
26 readonly MappingSchema _mappingSchema;
|
|
|
27 public MappingSchema MappingSchema
|
|
|
28 {
|
|
|
29 get { return _mappingSchema; }
|
|
|
30 }
|
|
|
31
|
|
|
32 #region IMapDataSource Members
|
|
|
33
|
|
|
34 public virtual int Count
|
|
|
35 {
|
|
|
36 get { return _dataReader.FieldCount; }
|
|
|
37 }
|
|
|
38
|
|
|
39 public virtual Type GetFieldType(int index)
|
|
|
40 {
|
|
|
41 return _dataReader.GetFieldType(index);
|
|
|
42 }
|
|
|
43
|
|
|
44 public virtual string GetName(int index)
|
|
|
45 {
|
|
|
46 return _dataReader.GetName(index);
|
|
|
47 }
|
|
|
48
|
|
|
49 public virtual int GetOrdinal(string name)
|
|
|
50 {
|
|
|
51 return _dataReader.GetOrdinal(name);
|
|
|
52 }
|
|
|
53
|
|
|
54 public virtual object GetValue(object o, int index)
|
|
|
55 {
|
|
|
56 var value = _dataReader.GetValue(index);
|
|
|
57 return value is DBNull? null: value;
|
|
|
58 }
|
|
|
59
|
|
|
60 public virtual object GetValue(object o, string name)
|
|
|
61 {
|
|
|
62 var value = _dataReader[name];
|
|
|
63 return value is DBNull? null: value;
|
|
|
64 }
|
|
|
65
|
|
|
66 public virtual bool IsNull (object o, int index) { return _dataReader.IsDBNull(index); }
|
|
|
67 public virtual bool SupportsTypedValues(int index) { return true; }
|
|
|
68
|
|
|
69 // Simple type getters.
|
|
|
70 //
|
|
|
71 [CLSCompliant(false)]
|
|
|
72 public virtual SByte GetSByte (object o, int index) { return _mappingSchema.ConvertToSByte(GetValue(o, index)); }
|
|
|
73 public virtual Int16 GetInt16 (object o, int index) { return _dataReader.GetInt16 (index); }
|
|
|
74 public virtual Int32 GetInt32 (object o, int index) { return _dataReader.GetInt32 (index); }
|
|
|
75 public virtual Int64 GetInt64 (object o, int index) { return _dataReader.GetInt64 (index); }
|
|
|
76
|
|
|
77 public virtual Byte GetByte (object o, int index) { return _dataReader.GetByte (index); }
|
|
|
78 [CLSCompliant(false)]
|
|
|
79 public virtual UInt16 GetUInt16 (object o, int index) { return _mappingSchema.ConvertToUInt16(GetValue(o, index)); }
|
|
|
80 [CLSCompliant(false)]
|
|
|
81 public virtual UInt32 GetUInt32 (object o, int index) { return _mappingSchema.ConvertToUInt32(GetValue(o, index)); }
|
|
|
82 [CLSCompliant(false)]
|
|
|
83 public virtual UInt64 GetUInt64 (object o, int index) { return _mappingSchema.ConvertToUInt64(GetValue(o, index)); }
|
|
|
84
|
|
|
85 public virtual Boolean GetBoolean (object o, int index) { return _dataReader.GetBoolean (index); }
|
|
|
86 public virtual Char GetChar (object o, int index) { return _dataReader.GetChar (index); }
|
|
|
87 public virtual Single GetSingle (object o, int index) { return _dataReader.GetFloat (index); }
|
|
|
88 public virtual Double GetDouble (object o, int index) { return _dataReader.GetDouble (index); }
|
|
|
89 public virtual Decimal GetDecimal (object o, int index) { return _dataReader.GetDecimal (index); }
|
|
|
90 public virtual Guid GetGuid (object o, int index) { return _dataReader.GetGuid (index); }
|
|
|
91 public virtual DateTime GetDateTime(object o, int index) { return _dataReader.GetDateTime(index); }
|
|
|
92
|
|
|
93 public virtual DateTimeOffset GetDateTimeOffset(object o, int index)
|
|
|
94 {
|
|
|
95 return _dataReaderEx != null?
|
|
|
96 _dataReaderEx.GetDateTimeOffset(index):
|
|
|
97 _mappingSchema.ConvertToDateTimeOffset(_dataReader.GetValue(index));
|
|
|
98 }
|
|
|
99
|
|
|
100 // Nullable type getters.
|
|
|
101 //
|
|
|
102 [CLSCompliant(false)]
|
|
|
103 public virtual SByte? GetNullableSByte (object o, int index) { return _dataReader.IsDBNull(index)? null: _mappingSchema.ConvertToNullableSByte(GetValue(o, index)); }
|
|
|
104 public virtual Int16? GetNullableInt16 (object o, int index) { return _dataReader.IsDBNull(index)? null: (Int16?)_dataReader.GetInt16 (index); }
|
|
|
105 public virtual Int32? GetNullableInt32 (object o, int index) { return _dataReader.IsDBNull(index)? null: (Int32?)_dataReader.GetInt32 (index); }
|
|
|
106 public virtual Int64? GetNullableInt64 (object o, int index) { return _dataReader.IsDBNull(index)? null: (Int64?)_dataReader.GetInt64 (index); }
|
|
|
107
|
|
|
108 public virtual Byte? GetNullableByte (object o, int index) { return _dataReader.IsDBNull(index)? null: (Byte?) _dataReader.GetByte (index); }
|
|
|
109 [CLSCompliant(false)]
|
|
|
110 public virtual UInt16? GetNullableUInt16 (object o, int index) { return _dataReader.IsDBNull(index)? null: _mappingSchema.ConvertToNullableUInt16(GetValue(o, index)); }
|
|
|
111 [CLSCompliant(false)]
|
|
|
112 public virtual UInt32? GetNullableUInt32 (object o, int index) { return _dataReader.IsDBNull(index)? null: _mappingSchema.ConvertToNullableUInt32(GetValue(o, index)); }
|
|
|
113 [CLSCompliant(false)]
|
|
|
114 public virtual UInt64? GetNullableUInt64 (object o, int index) { return _dataReader.IsDBNull(index)? null: _mappingSchema.ConvertToNullableUInt64(GetValue(o, index)); }
|
|
|
115
|
|
|
116 public virtual Boolean? GetNullableBoolean (object o, int index) { return _dataReader.IsDBNull(index)? null: (Boolean?) _dataReader.GetBoolean (index); }
|
|
|
117 public virtual Char? GetNullableChar (object o, int index) { return _dataReader.IsDBNull(index)? null: (Char?) _dataReader.GetChar (index); }
|
|
|
118 public virtual Single? GetNullableSingle (object o, int index) { return _dataReader.IsDBNull(index)? null: (Single?) _dataReader.GetFloat (index); }
|
|
|
119 public virtual Double? GetNullableDouble (object o, int index) { return _dataReader.IsDBNull(index)? null: (Double?) _dataReader.GetDouble (index); }
|
|
|
120 public virtual Decimal? GetNullableDecimal (object o, int index) { return _dataReader.IsDBNull(index)? null: (Decimal?) _dataReader.GetDecimal (index); }
|
|
|
121 public virtual Guid? GetNullableGuid (object o, int index) { return _dataReader.IsDBNull(index)? null: (Guid?) _dataReader.GetGuid (index); }
|
|
|
122 public virtual DateTime? GetNullableDateTime(object o, int index) { return _dataReader.IsDBNull(index)? null: (DateTime?)_dataReader.GetDateTime(index); }
|
|
|
123 public virtual DateTimeOffset? GetNullableDateTimeOffset(object o, int index)
|
|
|
124 {
|
|
|
125 return _dataReader.IsDBNull(index)? null:
|
|
|
126 _dataReaderEx != null? _dataReaderEx.GetDateTimeOffset(index):
|
|
|
127 _mappingSchema.ConvertToNullableDateTimeOffset(_dataReader.GetValue(index));
|
|
|
128 }
|
|
|
129
|
|
|
130 #if !SILVERLIGHT
|
|
|
131
|
|
|
132 // SQL type getters.
|
|
|
133 //
|
|
|
134 public virtual SqlByte GetSqlByte (object o, int index) { return _dataReader.IsDBNull(index)? SqlByte. Null: _dataReader.GetByte (index); }
|
|
|
135 public virtual SqlInt16 GetSqlInt16 (object o, int index) { return _dataReader.IsDBNull(index)? SqlInt16. Null: _dataReader.GetInt16 (index); }
|
|
|
136 public virtual SqlInt32 GetSqlInt32 (object o, int index) { return _dataReader.IsDBNull(index)? SqlInt32. Null: _dataReader.GetInt32 (index); }
|
|
|
137 public virtual SqlInt64 GetSqlInt64 (object o, int index) { return _dataReader.IsDBNull(index)? SqlInt64. Null: _dataReader.GetInt64 (index); }
|
|
|
138 public virtual SqlSingle GetSqlSingle (object o, int index) { return _dataReader.IsDBNull(index)? SqlSingle. Null: _dataReader.GetFloat (index); }
|
|
|
139 public virtual SqlBoolean GetSqlBoolean (object o, int index) { return _dataReader.IsDBNull(index)? SqlBoolean. Null: _dataReader.GetBoolean (index); }
|
|
|
140 public virtual SqlDouble GetSqlDouble (object o, int index) { return _dataReader.IsDBNull(index)? SqlDouble. Null: _dataReader.GetDouble (index); }
|
|
|
141 public virtual SqlDateTime GetSqlDateTime(object o, int index) { return _dataReader.IsDBNull(index)? SqlDateTime.Null: _dataReader.GetDateTime(index); }
|
|
|
142 public virtual SqlDecimal GetSqlDecimal (object o, int index) { return _dataReader.IsDBNull(index)? SqlDecimal. Null: _dataReader.GetDecimal (index); }
|
|
|
143 public virtual SqlMoney GetSqlMoney (object o, int index) { return _dataReader.IsDBNull(index)? SqlMoney. Null: _dataReader.GetDecimal (index); }
|
|
|
144 public virtual SqlGuid GetSqlGuid (object o, int index) { return _dataReader.IsDBNull(index)? SqlGuid. Null: _dataReader.GetGuid (index); }
|
|
|
145 public virtual SqlString GetSqlString (object o, int index) { return _dataReader.IsDBNull(index)? SqlString. Null: _dataReader.GetString (index); }
|
|
|
146
|
|
|
147 #endif
|
|
|
148
|
|
|
149 #endregion
|
|
|
150 }
|
|
|
151 }
|
