Mercurial > pub > bltoolkit

comparison Extensions/JointureAddOn/DataAccess/FullSqlQueryBase.cs @ 0:f990fcb411a9

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Копия текущей версии из github
author cin
date Thu, 27 Mar 2014 21:46:09 +0400
parents
children
comparison
equal deleted inserted replaced
-1:000000000000 0:f990fcb411a9
1 using System;
2 using System.Collections;
3 using System.Linq;
4 using System.Reflection;
5 using System.Text;
6 using BLToolkit.Aspects;
7 using BLToolkit.Data;
8 using BLToolkit.Data.DataProvider;
9 using BLToolkit.Mapping;
10 using BLToolkit.TypeBuilder;
11
12 namespace BLToolkit.DataAccess
13 {
14 public abstract class FullSqlQueryBase : SqlQueryBase
15 {
16 private readonly bool _ignoreLazyLoad;
17
18 #region Constructors
19
20 protected FullSqlQueryBase(DbManager dbManager, bool ignoreLazyLoad = false, MappingOrder mappingOrder = MappingOrder.ByColumnIndex)
21 : base(dbManager)
22 {
23 dbManager.MappingSchema = new FullMappingSchema(dbManager, mappingOrder: mappingOrder);
24
25 _ignoreLazyLoad = ignoreLazyLoad;
26 }
27
28 #endregion
29
30 #region Overrides
31
32 [NoInterception]
33 protected override SqlQueryInfo CreateSqlText(DbManager db, Type type, string actionName)
34 {
35 switch (actionName)
36 {
37 case "SelectByKey":
38 return CreateSelectFullByKeySqlText(db, type);
39 case "SelectAll":
40 return CreateSelectAllFullSqlText(db, type);
41 default:
42 return base.CreateSqlText(db, type, actionName);
43 }
44 }
45
46 protected override void AppendTableName(StringBuilder sb, DbManager db, Type type)
47 {
48 var database = GetDatabaseName(type);
49 var owner = GetOwnerName(type);
50 var name = base.GetTableName(type);
51
52 db.DataProvider.CreateSqlProvider().BuildTableName(sb,
53 database == null ? null : db.DataProvider.Convert(database, ConvertType.NameToDatabase).ToString(),
54 owner == null ? null : db.DataProvider.Convert(owner, ConvertType.NameToOwner).ToString(),
55 name == null ? null : db.DataProvider.Convert(name, ConvertType.NameToQueryTable).ToString());
56
57 //TODO Override OracleSqlProvider in order to avoid this mess...
58 string alias = GetTableName(type);
59 sb.Append(" " + alias);
60 sb.AppendLine();
61 }
62
63 protected override string GetTableName(Type type)
64 {
65 //bool isSet;
66 //return MappingSchema.MetadataProvider.GetTableName(type, Extensions, out isSet);
67
68 return type.Name;
69 }
70
71 #endregion
72
73 private SqlQueryInfo CreateSelectAllFullSqlText(DbManager db, Type type)
74 {
75 var sb = new StringBuilder();
76 var query = new FullSqlQueryInfo();
77
78 sb.Append("SELECT\n");
79
80 var mainMapper = (FullObjectMapper)db.MappingSchema.GetObjectMapper(type); ;
81 BuildSelectSQL(mainMapper, sb, db);
82
83 sb.Remove(sb.Length - 2, 1);
84
85 sb.Append("FROM\n\t");
86
87 AppendTableName(sb, db, type);
88
89 AppendJoinTableName(sb, db, type);
90
91 query.QueryText = sb.ToString();
92
93 return query;
94 }
95
96 private SqlQueryInfo CreateSelectFullByKeySqlText(DbManager db, Type type)
97 {
98 var sb = new StringBuilder();
99 var query = new FullSqlQueryInfo();
100
101 sb.Append("SELECT\n");
102
103 var mainMapper = (FullObjectMapper)db.MappingSchema.GetObjectMapper(type);
104
105 BuildSelectSQL(mainMapper, sb, db);
106
107 sb.Remove(sb.Length - 2, 1);
108
109 sb.Append("FROM\n\t");
110
111 AppendTableName(sb, db, type);
112
113 AppendJoinTableName(sb, db, type);
114
115 AddWherePK(db, query, sb, -1, mainMapper);
116
117 query.QueryText = sb.ToString();
118
119 return query;
120 }
121
122 private void BuildSelectSQL(IPropertiesMapping mapper, StringBuilder sb, DbManager db)
123 {
124 foreach (IMapper mapField in mapper.PropertiesMapping)
125 {
126 if (mapField is ValueMapper)
127 sb.AppendFormat("\t{0}.{1},\n", ((IObjectMapper)mapper).PropertyType.Name,
128 db.DataProvider.Convert(((ValueMapper)mapField).ColumnName, ConvertType.NameToQueryField));
129 else if (mapField is IPropertiesMapping)
130 {
131 var propertiesMapping = (IPropertiesMapping)mapField;
132 var cel = propertiesMapping.ParentMapping;
133 while (cel != null)
134 {
135 // To avoid recursion dont take in account types already loaded.
136 if (((IMapper)cel).PropertyType == mapField.PropertyType)
137 continue;
138 cel = cel.ParentMapping;
139 }
140 var objectMapper = (IObjectMapper)mapField;
141 if (!objectMapper.IsLazy)
142 BuildSelectSQL(propertiesMapping, sb, db);
143 }
144 else
145 throw new NotImplementedException(mapField.GetType() + " is not yet implemented.");
146 }
147 }
148
149 private void AppendJoinTableName(StringBuilder sb, DbManager db, Type type)
150 {
151 string parentName = GetTableName(type);
152
153 foreach (PropertyInfo prop in type.GetProperties())
154 {
155 bool isCollection = prop.PropertyType.GetInterfaces().ToList().Contains(typeof(IList));
156 Type listElementType = null;
157 if (isCollection)
158 {
159 listElementType = FullMappingSchema.GetGenericType(prop.PropertyType);
160 }
161
162 if (!_ignoreLazyLoad)
163 {
164 object[] lazy = prop.GetCustomAttributes(typeof(LazyInstanceAttribute), true);
165 if (lazy.Length > 0)
166 {
167 if (((LazyInstanceAttribute)lazy[0]).IsLazy)
168 {
169 continue;
170 }
171 }
172 }
173
174 object[] attribs = prop.GetCustomAttributes(typeof(AssociationAttribute), true);
175 if (attribs.Length > 0)
176 {
177 var assocAttrib = (AssociationAttribute)attribs[0];
178
179 PropertyInfo parentField = type.GetProperty(assocAttrib.ThisKey);
180 PropertyInfo childField = prop.PropertyType.GetProperty(assocAttrib.OtherKey);
181 if (isCollection)
182 {
183 childField = listElementType.GetProperty(assocAttrib.OtherKey);
184 //FullMappingSchema.GetColumnFromProperty(listElementType, associationAttribute.OtherKey);
185 }
186
187 object[] parentFieldAttributes = parentField.GetCustomAttributes(typeof(MapFieldAttribute), true);
188 string parentDbField = parentFieldAttributes.Length > 0
189 ? ((MapFieldAttribute)parentFieldAttributes[0]).MapName
190 : assocAttrib.ThisKey;
191
192 object[] childFieldAttributes = childField.GetCustomAttributes(typeof(MapFieldAttribute), true);
193 string childDbField = childFieldAttributes.Length > 0
194 ? ((MapFieldAttribute)childFieldAttributes[0]).MapName
195 : assocAttrib.OtherKey;
196
197
198 string childDatabase = isCollection
199 ? GetDatabaseName(listElementType)
200 : GetDatabaseName(prop.PropertyType);
201
202 string childOwner = isCollection ? base.GetOwnerName(listElementType) : base.GetOwnerName(prop.PropertyType);
203 string childName = isCollection ? base.GetTableName(listElementType) : base.GetTableName(prop.PropertyType);
204 string childAlias = isCollection ? GetTableName(listElementType) : GetTableName(prop.PropertyType);
205
206 StringBuilder childFullName = db.DataProvider.CreateSqlProvider().BuildTableName(
207 new StringBuilder(),
208 childDatabase == null
209 ? null
210 : db.DataProvider.Convert(childDatabase, ConvertType.NameToDatabase).ToString(),
211 childOwner == null
212 ? null
213 : db.DataProvider.Convert(childOwner, ConvertType.NameToOwner).ToString(),
214 childName == null
215 ? null
216 : db.DataProvider.Convert(childName, ConvertType.NameToQueryTable).ToString());
217
218 sb.AppendFormat("\tINNER JOIN {0} {1} ON {2}.{3}={4}.{5}\n",
219 childFullName,
220 childAlias,
221 parentName,
222 parentDbField,
223 childAlias,
224 childDbField
225 );
226
227 AppendJoinTableName(sb, db, isCollection ? listElementType : prop.PropertyType);
228 }
229 }
230
231 sb.AppendLine();
232
233 //SELECT
234 // ARTIST2.ID_ARTIST,
235 // ARTIST2.ARTIST,
236 // TRACK.ID_TRACK,
237 // TRACK.TRACK,
238 // TRACK.ID_ARTIST,
239 // ARTIST.ID_ARTIST,
240 // ARTIST.ARTIST
241 //FROM
242 // PITAFR01.ARTIST ARTIST2
243 // INNER JOIN PITAFR01.TRACK TRACK ON ARTIST2.ID_ARTIST=TRACK.ID_ARTIST
244 // INNER JOIN PITAFR01.ARTIST ARTIST ON TRACK.ID_ARTIST=ARTIST.ID_ARTIST
245 //WHERE
246 // ARTIST2.ID_ARTIST = 2566
247 }
248
249 private void AddWherePK(DbManager db, SqlQueryInfo query, StringBuilder sb, int nParameter,
250 FullObjectMapper mapper)
251 {
252 sb.Append("WHERE\n");
253
254 foreach (IMapper mm in mapper.PropertiesMapping)
255 {
256 if (mm is ValueMapper && mm.DataReaderIndex == mapper.DataReaderIndex)
257 {
258 var valueMapper = (ValueMapper)mm;
259
260 string tableAlias = mapper.PropertyType.Name;
261
262 //mm.Name = ID_TRACK
263 SqlQueryParameterInfo p = query.AddParameter(
264 db.DataProvider.Convert(valueMapper.ColumnName + "_W", ConvertType.NameToQueryParameter).
265 ToString(),
266 valueMapper.ColumnName);
267
268 sb.AppendFormat("\t{0}.{1} = ", tableAlias, db.DataProvider.Convert(p.FieldName, ConvertType.NameToQueryField));
269
270 if (nParameter < 0)
271 sb.AppendFormat("{0} AND\n", p.ParameterName);
272 else
273 sb.AppendFormat("{{{0}}} AND\n", nParameter++);
274 }
275 }
276
277 sb.Remove(sb.Length - 5, 5);
278 }
279 }
280 }