annotate Source/Data/Linq/Builder/TableBuilder.cs @ 7:99cd4f3947d8

Закомментированы строки мешающие добавлению авиа дежурств.
author nickolay
date Fri, 27 Oct 2017 18:26:29 +0300
parents 8f65451dc28f
children
Ignore whitespace changes - Everywhere: Within whitespace: At end of lines:
rev   line source
0
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1 using System;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
2 using System.Collections;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
3 using System.Collections.Generic;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
4 using System.Data;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
5 using System.Linq;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
6 using System.Linq.Expressions;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
7 using System.Reflection;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
8
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
9 namespace BLToolkit.Data.Linq.Builder
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
10 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
11 using BLToolkit.Linq;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
12 using Data.Sql;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
13 using Mapping;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
14 using Reflection;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
15 using Reflection.Extension;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
16
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
17 class TableBuilder : ISequenceBuilder
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
18 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
19 #region TableBuilder
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
20
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
21 int ISequenceBuilder.BuildCounter { get; set; }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
22
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
23 static T Find<T>(ExpressionBuilder builder, BuildInfo buildInfo, Func<int,IBuildContext,T> action)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
24 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
25 var expression = buildInfo.Expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
26
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
27 switch (expression.NodeType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
28 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
29 case ExpressionType.Constant:
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
30 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
31 var c = (ConstantExpression)expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
32 if (c.Value is IQueryable)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
33 return action(1, null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
34
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
35 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
36 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
37
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
38 case ExpressionType.Call:
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
39 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
40 var mc = (MethodCallExpression)expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
41
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
42 if (mc.Method.Name == "GetTable")
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
43 if (expression.Type.IsGenericType && expression.Type.GetGenericTypeDefinition() == typeof(Table<>))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
44 return action(2, null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
45
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
46 var attr = builder.GetTableFunctionAttribute(mc.Method);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
47
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
48 if (attr != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
49 return action(5, null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
50
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
51 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
52 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
53
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
54 case ExpressionType.MemberAccess:
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
55
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
56 if (expression.Type.IsGenericType && expression.Type.GetGenericTypeDefinition() == typeof(Table<>))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
57 return action(3, null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
58
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
59 // Looking for association.
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
60 //
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
61 if (buildInfo.IsSubQuery && buildInfo.SqlQuery.From.Tables.Count == 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
62 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
63 var ctx = builder.GetContext(buildInfo.Parent, expression);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
64 if (ctx != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
65 return action(4, ctx);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
66 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
67
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
68 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
69
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
70 case ExpressionType.Parameter:
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
71 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
72 if (buildInfo.IsSubQuery && buildInfo.SqlQuery.From.Tables.Count == 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
73 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
74 var ctx = builder.GetContext(buildInfo.Parent, expression);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
75 if (ctx != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
76 return action(4, ctx);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
77 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
78
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
79 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
80 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
81 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
82
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
83 return action(0, null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
84 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
85
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
86 public bool CanBuild(ExpressionBuilder builder, BuildInfo buildInfo)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
87 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
88 return Find(builder, buildInfo, (n,_) => n > 0);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
89 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
90
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
91 public IBuildContext BuildSequence(ExpressionBuilder builder, BuildInfo buildInfo)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
92 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
93 return Find(builder, buildInfo, (n,ctx) =>
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
94 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
95 switch (n)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
96 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
97 case 0 : return null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
98 case 1 : return new TableContext(builder, buildInfo, ((IQueryable)((ConstantExpression)buildInfo.Expression).Value).ElementType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
99 case 2 :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
100 case 3 : return new TableContext(builder, buildInfo, buildInfo.Expression.Type.GetGenericArguments()[0]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
101 case 4 : return ctx.GetContext(buildInfo.Expression, 0, buildInfo);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
102 case 5 : return new TableContext(builder, buildInfo);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
103 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
104
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
105 throw new InvalidOperationException();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
106 });
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
107 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
108
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
109 public SequenceConvertInfo Convert(ExpressionBuilder builder, BuildInfo buildInfo, ParameterExpression param)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
110 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
111 return null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
112 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
113
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
114 public bool IsSequence(ExpressionBuilder builder, BuildInfo buildInfo)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
115 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
116 return true;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
117 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
118
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
119 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
120
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
121 #region TableContext
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
122
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
123 public class TableContext : IBuildContext
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
124 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
125 #region Properties
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
126
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
127 #if DEBUG
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
128 public string _sqlQueryText { get { return SqlQuery == null ? "" : SqlQuery.SqlText; } }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
129 #endif
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
130
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
131 public ExpressionBuilder Builder { get; private set; }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
132 public Expression Expression { get; private set; }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
133 public SqlQuery SqlQuery { get; set; }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
134
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
135 public virtual IBuildContext Parent { get; set; }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
136
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
137 public Type OriginalType;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
138 public Type ObjectType;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
139 public ObjectMapper ObjectMapper;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
140 public SqlTable SqlTable;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
141
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
142 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
143
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
144 #region Init
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
145
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
146 public TableContext(ExpressionBuilder builder, BuildInfo buildInfo, Type originalType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
147 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
148 Builder = builder;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
149 Parent = buildInfo.Parent;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
150 Expression = buildInfo.Expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
151 SqlQuery = buildInfo.SqlQuery;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
152
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
153 OriginalType = originalType;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
154 ObjectType = GetObjectType();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
155 SqlTable = new SqlTable(builder.MappingSchema, ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
156 ObjectMapper = Builder.MappingSchema.GetObjectMapper(ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
157
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
158 SqlQuery.From.Table(SqlTable);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
159
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
160 Init();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
161 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
162
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
163 protected TableContext(ExpressionBuilder builder, SqlQuery sqlQuery)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
164 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
165 Builder = builder;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
166 SqlQuery = sqlQuery;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
167 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
168
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
169 public TableContext(ExpressionBuilder builder, BuildInfo buildInfo)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
170 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
171 Builder = builder;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
172 Parent = buildInfo.Parent;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
173 Expression = buildInfo.Expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
174 SqlQuery = buildInfo.SqlQuery;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
175
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
176 var mc = (MethodCallExpression)Expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
177 var attr = builder.GetTableFunctionAttribute(mc.Method);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
178
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
179 if (!mc.Method.ReturnType.IsGenericType || mc.Method.ReturnType.GetGenericTypeDefinition() != typeof(Table<>))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
180 throw new LinqException("Table function has to return Table<T>.");
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
181
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
182 OriginalType = mc.Method.ReturnType.GetGenericArguments()[0];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
183 ObjectType = GetObjectType();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
184 SqlTable = new SqlTable(builder.MappingSchema, ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
185 ObjectMapper = Builder.MappingSchema.GetObjectMapper(ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
186
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
187 SqlQuery.From.Table(SqlTable);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
188
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
189 var args = mc.Arguments.Select(a => builder.ConvertToSql(this, a, false));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
190
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
191 attr.SetTable(SqlTable, mc.Method, mc.Arguments, args);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
192
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
193 Init();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
194 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
195
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
196 protected Type GetObjectType()
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
197 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
198 for (var type = OriginalType.BaseType; type != null && type != typeof(object); type = type.BaseType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
199 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
200 var extension = TypeExtension.GetTypeExtension(type, Builder.MappingSchema.Extensions);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
201 var mapping = Builder.MappingSchema.MetadataProvider.GetInheritanceMapping(type, extension);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
202
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
203 if (mapping.Length > 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
204 return type;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
205 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
206
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
207 return OriginalType;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
208 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
209
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
210 public List<InheritanceMappingAttribute> InheritanceMapping;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
211 public List<string> InheritanceDiscriminators;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
212
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
213 protected void Init()
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
214 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
215 Builder.Contexts.Add(this);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
216
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
217 InheritanceMapping = ObjectMapper.InheritanceMapping;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
218
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
219 if (InheritanceMapping.Count > 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
220 InheritanceDiscriminators = GetInheritanceDiscriminators(Builder, SqlTable, ObjectType, InheritanceMapping);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
221
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
222 // Original table is a parent.
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
223 //
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
224 if (ObjectType != OriginalType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
225 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
226 var predicate = Builder.MakeIsPredicate(this, OriginalType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
227
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
228 if (predicate.GetType() != typeof(SqlQuery.Predicate.Expr))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
229 SqlQuery.Where.SearchCondition.Conditions.Add(new SqlQuery.Condition(false, predicate));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
230 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
231 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
232
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
233 internal static List<string> GetInheritanceDiscriminators(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
234 ExpressionBuilder builder,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
235 SqlTable sqlTable,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
236 Type objectType,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
237 List<InheritanceMappingAttribute> inheritanceMapping)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
238 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
239 var inheritanceDiscriminators = new List<string>(inheritanceMapping.Count);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
240
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
241 foreach (var mapping in inheritanceMapping)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
242 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
243 string discriminator = null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
244
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
245 foreach (MemberMapper mm in builder.MappingSchema.GetObjectMapper(mapping.Type))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
246 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
247 if (mm.MapMemberInfo.SqlIgnore == false && !sqlTable.Fields.Any(f => f.Value.Name == mm.MemberName))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
248 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
249 var field = new SqlField(mm.Type, mm.MemberName, mm.Name, mm.MapMemberInfo.Nullable, int.MinValue, null, mm);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
250 sqlTable.Fields.Add(field);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
251 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
252
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
253 if (mm.MapMemberInfo.IsInheritanceDiscriminator)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
254 discriminator = mm.MapMemberInfo.MemberName;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
255 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
256
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
257 inheritanceDiscriminators.Add(discriminator);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
258 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
259
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
260 var dname = inheritanceDiscriminators.FirstOrDefault(s => s != null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
261
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
262 if (dname == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
263 throw new LinqException("Inheritance Discriminator is not defined for the '{0}' hierarchy.", objectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
264
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
265 for (var i = 0; i < inheritanceDiscriminators.Count; i++)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
266 if (inheritanceDiscriminators[i] == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
267 inheritanceDiscriminators[i] = dname;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
268
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
269 return inheritanceDiscriminators;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
270 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
271
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
272 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
273
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
274 #region BuildQuery
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
275
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
276 class MappingData
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
277 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
278 public MappingSchema MappingSchema;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
279 public ObjectMapper ObjectMapper;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
280 public int[] Index;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
281 public IValueMapper[] ValueMappers;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
282 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
283
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
284 static object MapDataReaderToObject1(IDataReader dataReader, MappingData data)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
285 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
286 var source = data.MappingSchema.CreateDataReaderMapper(dataReader);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
287 var destObject = data.ObjectMapper.CreateInstance();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
288
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
289 if (data.ValueMappers == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
290 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
291 var mappers = new IValueMapper[data.Index.Length];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
292
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
293 for (var i = 0; i < data.Index.Length; i++)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
294 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
295 var n = data.Index[i];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
296
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
297 if (n < 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
298 continue;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
299
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
300 if (!data.ObjectMapper.SupportsTypedValues(i))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
301 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
302 mappers[i] = data.MappingSchema.DefaultValueMapper;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
303 continue;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
304 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
305
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
306 var sourceType = source. GetFieldType(n) ?? typeof(object);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
307 var destType = data.ObjectMapper.GetFieldType(i) ?? typeof(object);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
308
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
309 IValueMapper t;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
310
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
311 if (sourceType == destType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
312 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
313 lock (data.MappingSchema.SameTypeMappers)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
314 if (!data.MappingSchema.SameTypeMappers.TryGetValue(sourceType, out t))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
315 data.MappingSchema.SameTypeMappers.Add(sourceType, t = data.MappingSchema.GetValueMapper(sourceType, destType));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
316 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
317 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
318 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
319 var key = new KeyValuePair<Type,Type>(sourceType, destType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
320
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
321 lock (data.MappingSchema.DifferentTypeMappers)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
322 if (!data.MappingSchema.DifferentTypeMappers.TryGetValue(key, out t))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
323 data.MappingSchema.DifferentTypeMappers.Add(key, t = data.MappingSchema.GetValueMapper(sourceType, destType));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
324 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
325
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
326 mappers[i] = t;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
327 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
328
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
329 data.ValueMappers = mappers;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
330 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
331
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
332 var dest = data.ObjectMapper;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
333 var idx = data.Index;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
334 var ms = data.ValueMappers;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
335
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
336 for (var i = 0; i < idx.Length; i++)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
337 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
338 var n = idx[i];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
339
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
340 if (n >= 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
341 ms[i].Map(source, dataReader, n, dest, destObject, i);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
342 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
343
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
344 return destObject;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
345 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
346
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
347 static object MapDataReaderToObject2(IDataReader dataReader, MappingData data)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
348 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
349 var source = data.MappingSchema.CreateDataReaderMapper(dataReader);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
350
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
351 var initContext = new InitContext
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
352 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
353 MappingSchema = data.MappingSchema,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
354 DataSource = source,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
355 SourceObject = dataReader,
1
8f65451dc28f Исправлена проблема с фабрикой и выборкой нескольких объектов в linq выражении
cin
parents: 0
diff changeset
356 ObjectMapper = data.ObjectMapper,
8f65451dc28f Исправлена проблема с фабрикой и выборкой нескольких объектов в linq выражении
cin
parents: 0
diff changeset
357 MappingIndex = data.Index
0
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
358 };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
359
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
360 var destObject = data.ObjectMapper.CreateInstance(initContext);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
361
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
362 if (initContext.StopMapping)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
363 return destObject;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
364
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
365 var smDest = destObject as ISupportMapping;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
366
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
367 if (smDest != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
368 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
369 smDest.BeginMapping(initContext);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
370
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
371 if (initContext.StopMapping)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
372 return destObject;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
373 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
374
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
375 if (data.ValueMappers == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
376 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
377 var mappers = new IValueMapper[data.Index.Length];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
378
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
379 for (var i = 0; i < data.Index.Length; i++)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
380 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
381 var n = data.Index[i];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
382
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
383 if (n < 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
384 continue;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
385
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
386 if (!data.ObjectMapper.SupportsTypedValues(i))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
387 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
388 mappers[i] = data.MappingSchema.DefaultValueMapper;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
389 continue;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
390 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
391
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
392 var sourceType = source. GetFieldType(n) ?? typeof(object);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
393 var destType = data.ObjectMapper.GetFieldType(i) ?? typeof(object);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
394
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
395 IValueMapper t;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
396
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
397 if (sourceType == destType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
398 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
399 lock (data.MappingSchema.SameTypeMappers)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
400 if (!data.MappingSchema.SameTypeMappers.TryGetValue(sourceType, out t))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
401 data.MappingSchema.SameTypeMappers.Add(sourceType, t = data.MappingSchema.GetValueMapper(sourceType, destType));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
402 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
403 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
404 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
405 var key = new KeyValuePair<Type,Type>(sourceType, destType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
406
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
407 lock (data.MappingSchema.DifferentTypeMappers)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
408 if (!data.MappingSchema.DifferentTypeMappers.TryGetValue(key, out t))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
409 data.MappingSchema.DifferentTypeMappers.Add(key, t = data.MappingSchema.GetValueMapper(sourceType, destType));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
410 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
411
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
412 mappers[i] = t;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
413 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
414
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
415 data.ValueMappers = mappers;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
416 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
417
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
418 var dest = data.ObjectMapper;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
419 var idx = data.Index;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
420 var ms = data.ValueMappers;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
421
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
422 for (var i = 0; i < idx.Length; i++)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
423 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
424 var n = idx[i];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
425
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
426 if (n >= 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
427 ms[i].Map(source, dataReader, n, dest, destObject, i);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
428 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
429
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
430 if (smDest != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
431 smDest.EndMapping(initContext);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
432
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
433 return destObject;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
434 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
435
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
436 static object DefaultInheritanceMappingException(object value, Type type)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
437 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
438 throw new LinqException("Inheritance mapping is not defined for discriminator value '{0}' in the '{1}' hierarchy.", value, type);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
439 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
440
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
441 static readonly MethodInfo _mapperMethod1 = ReflectionHelper.Expressor<object>.MethodExpressor(_ => MapDataReaderToObject1(null, null));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
442 static readonly MethodInfo _mapperMethod2 = ReflectionHelper.Expressor<object>.MethodExpressor(_ => MapDataReaderToObject2(null, null));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
443
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
444 #if FW4 || SILVERLIGHT
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
445 ParameterExpression _variable;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
446 static int _varIndex;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
447 #endif
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
448
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
449 Expression BuildTableExpression(bool buildBlock, Type objectType, int[] index)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
450 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
451 #if FW4 || SILVERLIGHT
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
452 if (buildBlock && _variable != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
453 return _variable;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
454 #endif
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
455
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
456 var data = new MappingData
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
457 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
458 MappingSchema = Builder.MappingSchema,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
459 ObjectMapper = Builder.MappingSchema.GetObjectMapper(objectType),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
460 Index = index
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
461 };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
462
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
463 Expression expr;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
464
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
465 if (Builder.DataContextInfo.DataContext == null ||
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
466 TypeHelper.IsSameOrParent(typeof(ISupportMapping), objectType) ||
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
467 TypeHelper.GetFirstAttribute(objectType, typeof(ObjectFactoryAttribute)) != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
468 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
469 expr = Expression.Convert(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
470 Expression.Call(null, _mapperMethod2,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
471 ExpressionBuilder.DataReaderParam,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
472 Expression.Constant(data)),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
473 objectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
474 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
475 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
476 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
477 expr = Expression.Convert(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
478 Expression.Call(null, _mapperMethod1,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
479 ExpressionBuilder.DataReaderParam,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
480 Expression.Constant(data)),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
481 objectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
482 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
483
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
484 expr = ProcessExpression(expr);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
485
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
486 #if FW4 || SILVERLIGHT
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
487
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
488 if (!buildBlock)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
489 return expr;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
490
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
491 Builder.BlockVariables. Add(_variable = Expression.Variable(expr.Type, expr.Type.Name + _varIndex++));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
492 Builder.BlockExpressions.Add(Expression.Assign(_variable, expr));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
493
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
494 return _variable;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
495
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
496 #else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
497 return expr;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
498 #endif
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
499 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
500
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
501 protected virtual Expression ProcessExpression(Expression expression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
502 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
503 return expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
504 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
505
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
506 int[] BuildIndex(int[] index, Type objectType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
507 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
508 var names = new Dictionary<string,int>();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
509 var n = 0;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
510
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
511 foreach (MemberMapper mm in Builder.MappingSchema.GetObjectMapper(objectType))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
512 if (mm.MapMemberInfo.SqlIgnore == false)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
513 names.Add(mm.MemberName, n++);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
514
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
515 var q =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
516 from r in SqlTable.Fields.Values.Select((f,i) => new { f, i })
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
517 where names.ContainsKey(r.f.Name)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
518 orderby names[r.f.Name]
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
519 select index[r.i];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
520
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
521 return q.ToArray();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
522 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
523
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
524 Expression BuildQuery(Type tableType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
525 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
526 SqlInfo[] info;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
527
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
528 if (ObjectType == tableType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
529 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
530 info = ConvertToIndex(null, 0, ConvertFlags.All);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
531 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
532 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
533 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
534 info = ConvertToSql(null, 0, ConvertFlags.All);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
535
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
536 var table = new SqlTable(Builder.MappingSchema, tableType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
537 var q =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
538 from fld1 in table.Fields.Values.Select((f,i) => new { f, i })
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
539 join fld2 in info on fld1.f.Name equals ((SqlField)fld2.Sql).Name
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
540 orderby fld1.i
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
541 select GetIndex(fld2);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
542
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
543 info = q.ToArray();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
544 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
545
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
546 var index = info.Select(idx => ConvertToParentIndex(idx.Index, null)).ToArray();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
547
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
548 if (ObjectType != tableType || InheritanceMapping.Count == 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
549 return BuildTableExpression(!Builder.IsBlockDisable, tableType, index);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
550
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
551 Expression expr;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
552
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
553 var defaultMapping = InheritanceMapping.SingleOrDefault(m => m.IsDefault);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
554
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
555 if (defaultMapping != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
556 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
557 expr = Expression.Convert(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
558 BuildTableExpression(false, defaultMapping.Type, BuildIndex(index, defaultMapping.Type)),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
559 ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
560 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
561 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
562 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
563 var exceptionMethod = ReflectionHelper.Expressor<object>.MethodExpressor(_ => DefaultInheritanceMappingException(null, null));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
564 var dindex =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
565 (
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
566 from f in SqlTable.Fields.Values
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
567 where f.Name == InheritanceDiscriminators[0]
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
568 select ConvertToParentIndex(_indexes[f].Index, null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
569 ).First();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
570
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
571 expr = Expression.Convert(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
572 Expression.Call(null, exceptionMethod,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
573 Expression.Call(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
574 ExpressionBuilder.DataReaderParam,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
575 ReflectionHelper.DataReader.GetValue,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
576 Expression.Constant(dindex)),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
577 Expression.Constant(ObjectType)),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
578 ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
579 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
580
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
581 foreach (var mapping in InheritanceMapping.Select((m,i) => new { m, i }).Where(m => m.m != defaultMapping))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
582 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
583 var dindex =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
584 (
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
585 from f in SqlTable.Fields.Values
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
586 where f.Name == InheritanceDiscriminators[mapping.i]
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
587 select ConvertToParentIndex(_indexes[f].Index, null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
588 ).First();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
589
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
590 Expression testExpr;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
591
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
592 if (mapping.m.Code == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
593 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
594 testExpr = Expression.Call(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
595 ExpressionBuilder.DataReaderParam,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
596 ReflectionHelper.DataReader.IsDBNull,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
597 Expression.Constant(dindex));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
598 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
599 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
600 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
601 var codeType = mapping.m.Code.GetType();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
602
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
603 testExpr = Expression.Equal(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
604 Expression.Constant(mapping.m.Code),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
605 Builder.BuildSql(codeType, dindex));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
606 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
607
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
608 expr = Expression.Condition(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
609 testExpr,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
610 Expression.Convert(BuildTableExpression(false, mapping.m.Type, BuildIndex(index, mapping.m.Type)), ObjectType),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
611 expr);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
612 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
613
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
614 return expr;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
615 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
616
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
617 public void BuildQuery<T>(Query<T> query, ParameterExpression queryParameter)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
618 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
619 var expr = BuildQuery(typeof(T));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
620 var mapper = Builder.BuildMapper<T>(expr);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
621
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
622 query.SetQuery(mapper.Compile());
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
623 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
624
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
625 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
626
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
627 #region BuildExpression
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
628
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
629 public Expression BuildExpression(Expression expression, int level)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
630 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
631 // Build table.
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
632 //
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
633 var table = FindTable(expression, level, false);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
634
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
635 if (table == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
636 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
637 if (expression is MemberExpression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
638 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
639 var memberExpression = (MemberExpression)expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
640
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
641 if (ObjectMapper != null &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
642 ObjectMapper.TypeAccessor.OriginalType == memberExpression.Member.DeclaringType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
643 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
644 throw new LinqException("Member '{0}.{1}' is not a table column.",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
645 memberExpression.Member.Name, memberExpression.Member.Name);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
646 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
647 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
648
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
649 throw new InvalidOperationException();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
650 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
651
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
652 if (table.Field == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
653 return table.Table.BuildQuery(table.Table.OriginalType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
654
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
655 // Build field.
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
656 //
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
657 var info = ConvertToIndex(expression, level, ConvertFlags.Field).Single();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
658 var idx = ConvertToParentIndex(info.Index, null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
659
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
660 if (expression is MemberExpression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
661 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
662 var me = (MemberExpression)expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
663 var memberAccessor = TypeAccessor.GetAccessor(me.Member.DeclaringType)[me.Member.Name];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
664 return Builder.BuildSql(memberAccessor, idx);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
665 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
666 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
667 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
668 return Builder.BuildSql(expression.Type, idx);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
669 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
670 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
671
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
672 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
673
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
674 #region ConvertToSql
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
675
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
676 public SqlInfo[] ConvertToSql(Expression expression, int level, ConvertFlags flags)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
677 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
678 switch (flags)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
679 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
680 case ConvertFlags.All :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
681 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
682 var table = FindTable(expression, level, false);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
683
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
684 if (table.Field == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
685 return table.Table.SqlTable.Fields.Values
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
686 .Select(_ => new SqlInfo(_.MemberMapper.MemberAccessor.MemberInfo) { Sql = _ })
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
687 .ToArray();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
688
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
689 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
690 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
691
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
692 case ConvertFlags.Key :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
693 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
694 var table = FindTable(expression, level, false);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
695
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
696 if (table.Field == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
697 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
698 var q =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
699 from f in table.Table.SqlTable.Fields.Values
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
700 where f.IsPrimaryKey
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
701 orderby f.PrimaryKeyOrder
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
702 select new SqlInfo(f.MemberMapper.MemberAccessor.MemberInfo) { Sql = f };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
703
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
704 var key = q.ToArray();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
705
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
706 return key.Length != 0 ? key : ConvertToSql(expression, level, ConvertFlags.All);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
707 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
708
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
709 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
710 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
711
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
712 case ConvertFlags.Field :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
713 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
714 var table = FindTable(expression, level, true);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
715
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
716 if (table.Field != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
717 return new[]
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
718 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
719 new SqlInfo(table.Field.MemberMapper.MemberAccessor.MemberInfo) { Sql = table.Field }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
720 };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
721
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
722 break;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
723 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
724 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
725
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
726 throw new InvalidOperationException();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
727 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
728
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
729 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
730
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
731 #region ConvertToIndex
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
732
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
733 readonly Dictionary<ISqlExpression,SqlInfo> _indexes = new Dictionary<ISqlExpression,SqlInfo>();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
734
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
735 protected SqlInfo GetIndex(SqlInfo expr)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
736 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
737 SqlInfo n;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
738
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
739 if (_indexes.TryGetValue(expr.Sql, out n))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
740 return n;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
741
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
742 if (expr.Sql is SqlField)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
743 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
744 var field = (SqlField)expr.Sql;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
745 expr.Index = SqlQuery.Select.Add(field, field.Alias);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
746 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
747 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
748 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
749 expr.Index = SqlQuery.Select.Add(expr.Sql);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
750 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
751
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
752 expr.Query = SqlQuery;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
753
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
754 _indexes.Add(expr.Sql, expr);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
755
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
756 return expr;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
757 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
758
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
759 public SqlInfo[] ConvertToIndex(Expression expression, int level, ConvertFlags flags)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
760 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
761 switch (flags)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
762 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
763 case ConvertFlags.Field :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
764 case ConvertFlags.Key :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
765 case ConvertFlags.All :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
766
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
767 var info = ConvertToSql(expression, level, flags);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
768
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
769 for (var i = 0; i < info.Length; i++)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
770 info[i] = GetIndex(info[i]);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
771
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
772 return info;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
773 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
774
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
775 throw new InvalidOperationException();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
776 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
777
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
778 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
779
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
780 #region IsExpression
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
781
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
782 public IsExpressionResult IsExpression(Expression expression, int level, RequestFor requestFor)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
783 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
784 switch (requestFor)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
785 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
786 case RequestFor.Field :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
787 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
788 var table = FindTable(expression, level, false);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
789 return new IsExpressionResult(table != null && table.Field != null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
790 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
791
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
792 case RequestFor.Table :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
793 case RequestFor.Object :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
794 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
795 var table = FindTable(expression, level, false);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
796 var isTable =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
797 table != null &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
798 table.Field == null &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
799 (expression == null || expression.GetLevelExpression(table.Level) == expression);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
800
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
801 return new IsExpressionResult(isTable, isTable ? table.Table : null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
802 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
803
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
804 case RequestFor.Expression :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
805 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
806 if (expression == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
807 return IsExpressionResult.False;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
808
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
809 var levelExpression = expression.GetLevelExpression(level);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
810
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
811 switch (levelExpression.NodeType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
812 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
813 case ExpressionType.MemberAccess :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
814 case ExpressionType.Parameter :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
815 case ExpressionType.Call :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
816
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
817 var table = FindTable(expression, level, false);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
818 return new IsExpressionResult(table == null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
819 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
820
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
821 return IsExpressionResult.True;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
822 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
823
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
824 case RequestFor.Association :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
825 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
826 if (ObjectMapper.Associations.Count > 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
827 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
828 var table = FindTable(expression, level, false);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
829 var isat =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
830 table != null &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
831 table.Table is AssociatedTableContext &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
832 table.Field == null &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
833 (expression == null || expression.GetLevelExpression(table.Level) == expression);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
834
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
835 return new IsExpressionResult(isat, isat ? table.Table : null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
836 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
837
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
838 return IsExpressionResult.False;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
839 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
840 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
841
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
842 return IsExpressionResult.False;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
843 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
844
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
845 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
846
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
847 #region GetContext
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
848
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
849 interface IAssociationHelper
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
850 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
851 Expression GetExpression(Expression parent, AssociatedTableContext association);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
852 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
853
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
854 class AssociationHelper<T> : IAssociationHelper
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
855 where T : class
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
856 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
857 public Expression GetExpression(Expression parent, AssociatedTableContext association)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
858 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
859 Expression expr = null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
860 var param = Expression.Parameter(typeof(T), "c");
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
861
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
862 foreach (var cond in (association).ParentAssociationJoin.Condition.Conditions)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
863 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
864 var p = (SqlQuery.Predicate.ExprExpr)cond.Predicate;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
865 var e1 = Expression.MakeMemberAccess(parent, ((SqlField)p.Expr1).MemberMapper.MemberAccessor.MemberInfo);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
866 var e2 = Expression.MakeMemberAccess(param, ((SqlField)p.Expr2).MemberMapper.MemberAccessor.MemberInfo) as Expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
867
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
868 while (e1.Type != e2.Type)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
869 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
870 if (TypeHelper.IsNullableType(e1.Type))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
871 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
872 e1 = Expression.PropertyOrField(e1, "Value");
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
873 continue;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
874 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
875
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
876 if (TypeHelper.IsNullableType(e2.Type))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
877 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
878 e2 = Expression.PropertyOrField(e2, "Value");
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
879 continue;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
880 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
881
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
882 e2 = Expression.Convert(e2, e1.Type);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
883 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
884
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
885 var ex = Expression.Equal(e1, e2);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
886
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
887 expr = expr == null ? ex : Expression.AndAlso(expr, ex);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
888 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
889
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
890 var predicate = Expression.Lambda<Func<T,bool>>(expr, param);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
891
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
892 return association.Builder.DataContextInfo.DataContext.GetTable<T>().Where(predicate).Expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
893 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
894 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
895
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
896 public IBuildContext GetContext(Expression expression, int level, BuildInfo buildInfo)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
897 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
898 if (expression == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
899 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
900 if (buildInfo != null && buildInfo.IsSubQuery)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
901 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
902 var table = new TableContext(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
903 Builder,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
904 new BuildInfo(Parent is SelectManyBuilder.SelectManyContext ? this : Parent, Expression, buildInfo.SqlQuery),
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
905 SqlTable.ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
906
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
907 return table;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
908 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
909
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
910 return this;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
911 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
912
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
913 if (ObjectMapper.Associations.Count > 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
914 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
915 var levelExpression = expression.GetLevelExpression(level);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
916
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
917 if (buildInfo != null && buildInfo.IsSubQuery)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
918 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
919 if (levelExpression == expression && expression.NodeType == ExpressionType.MemberAccess)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
920 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
921 var tableLevel = GetAssociation(expression, level);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
922 var association = (AssociatedTableContext)tableLevel.Table;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
923
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
924 if (association.IsList)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
925 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
926 var ma = (MemberExpression)buildInfo.Expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
927 var atype = typeof(AssociationHelper<>).MakeGenericType(association.ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
928 var helper = (IAssociationHelper)Activator.CreateInstance(atype);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
929 var expr = helper.GetExpression(ma.Expression, association);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
930
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
931 buildInfo.IsAssociationBuilt = true;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
932
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
933 if (tableLevel.IsNew || buildInfo.CopyTable)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
934 association.ParentAssociationJoin.IsWeak = true;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
935
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
936 return Builder.BuildSequence(new BuildInfo(buildInfo, expr));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
937 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
938 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
939 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
940 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
941 var association = GetAssociation(levelExpression, level);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
942 var paj = ((AssociatedTableContext)association.Table).ParentAssociationJoin;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
943
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
944 paj.IsWeak = paj.IsWeak && buildInfo.CopyTable;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
945
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
946 return association.Table.GetContext(expression, level + 1, buildInfo);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
947 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
948 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
949 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
950
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
951 throw new InvalidOperationException();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
952 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
953
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
954 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
955
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
956 #region ConvertToParentIndex
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
957
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
958 public int ConvertToParentIndex(int index, IBuildContext context)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
959 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
960 return Parent == null ? index : Parent.ConvertToParentIndex(index, this);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
961 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
962
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
963 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
964
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
965 #region SetAlias
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
966
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
967 public void SetAlias(string alias)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
968 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
969 if (alias.Contains('<'))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
970 return;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
971
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
972 if (SqlTable.Alias == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
973 SqlTable.Alias = alias;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
974 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
975
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
976 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
977
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
978 #region GetSubQuery
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
979
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
980 public ISqlExpression GetSubQuery(IBuildContext context)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
981 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
982 return null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
983 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
984
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
985 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
986
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
987 #region Helpers
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
988
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
989 SqlField GetField(Expression expression, int level, bool throwException)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
990 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
991 if (expression.NodeType == ExpressionType.MemberAccess)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
992 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
993 var memberExpression = (MemberExpression)expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
994 var levelExpression = expression.GetLevelExpression(level);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
995
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
996 if (levelExpression.NodeType == ExpressionType.MemberAccess)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
997 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
998 if (levelExpression != expression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
999 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1000 var levelMember = (MemberExpression)levelExpression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1001
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1002 if (TypeHelper.IsNullableValueMember(memberExpression.Member) && memberExpression.Expression == levelExpression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1003 memberExpression = levelMember;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1004 else
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1005 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1006 var sameType =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1007 levelMember.Member.ReflectedType == SqlTable.ObjectType ||
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1008 levelMember.Member.DeclaringType == SqlTable.ObjectType;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1009
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1010 if (!sameType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1011 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1012 var mi = SqlTable.ObjectType.GetMember(levelMember.Member.Name, BindingFlags.Public | BindingFlags.NonPublic | BindingFlags.Instance);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1013 sameType = mi.Any(_ => _.DeclaringType == levelMember.Member.DeclaringType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1014 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1015
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1016 if (sameType || InheritanceMapping.Count > 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1017 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1018 foreach (var field in SqlTable.Fields.Values)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1019 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1020 if (field.MemberMapper is MemberMapper.ComplexMapper)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1021 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1022 var name = levelMember.Member.Name;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1023
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1024 for (var ex = (MemberExpression)expression; ex != levelMember; ex = (MemberExpression)ex.Expression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1025 name += "." + ex.Member.Name;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1026
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1027 if (field.MemberMapper.MemberName == name)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1028 return field;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1029 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1030 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1031 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1032 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1033 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1034
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1035 if (levelExpression == memberExpression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1036 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1037 foreach (var field in SqlTable.Fields.Values)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1038 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1039 if (TypeHelper.Equals(field.MemberMapper.MapMemberInfo.MemberAccessor.MemberInfo, memberExpression.Member, SqlTable.ObjectType))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1040 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1041 if (field.MemberMapper is MemberMapper.ComplexMapper &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1042 field.MemberMapper.MemberName.IndexOf('.') > 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1043 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1044 var name = memberExpression.Member.Name;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1045 var me = memberExpression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1046
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1047 if (!(me.Expression is MemberExpression))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1048 return null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1049
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1050 while (me.Expression is MemberExpression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1051 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1052 me = (MemberExpression)me.Expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1053 name = me.Member.Name + '.' + name;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1054 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1055
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1056 return SqlTable.Fields.Values.FirstOrDefault(f => f.MemberMapper.MemberName == name);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1057 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1058
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1059 return field;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1060 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1061
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1062 if (InheritanceMapping.Count > 0 && field.Name == memberExpression.Member.Name)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1063 foreach (var mapping in InheritanceMapping)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1064 foreach (MemberMapper mm in Builder.MappingSchema.GetObjectMapper(mapping.Type))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1065 if (TypeHelper.Equals(mm.MapMemberInfo.MemberAccessor.MemberInfo, memberExpression.Member))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1066 return field;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1067 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1068
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1069 if (throwException &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1070 ObjectMapper != null &&
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1071 ObjectMapper.TypeAccessor.OriginalType == memberExpression.Member.DeclaringType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1072 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1073 throw new LinqException("Member '{0}.{1}' is not a table column.",
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1074 memberExpression.Member.DeclaringType.Name, memberExpression.Member.Name);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1075 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1076 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1077 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1078 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1079
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1080 return null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1081 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1082
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1083 [JetBrains.Annotations.NotNull]
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1084 readonly Dictionary<MemberInfo,AssociatedTableContext> _associations =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1085 new Dictionary<MemberInfo,AssociatedTableContext>(new MemberInfoComparer());
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1086
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1087 class TableLevel
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1088 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1089 public TableContext Table;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1090 public SqlField Field;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1091 public int Level;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1092 public bool IsNew;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1093 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1094
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1095 TableLevel FindTable(Expression expression, int level, bool throwException)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1096 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1097 if (expression == null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1098 return new TableLevel { Table = this };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1099
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1100 var levelExpression = expression.GetLevelExpression(level);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1101
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1102 switch (levelExpression.NodeType)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1103 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1104 case ExpressionType.MemberAccess :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1105 case ExpressionType.Parameter :
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1106 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1107 var field = GetField(expression, level, throwException);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1108
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1109 if (field != null || (level == 0 && levelExpression == expression))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1110 return new TableLevel { Table = this, Field = field, Level = level };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1111
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1112 return GetAssociation(expression, level);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1113 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1114 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1115
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1116 return null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1117 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1118
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1119 TableLevel GetAssociation(Expression expression, int level)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1120 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1121 var objectMapper = ObjectMapper;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1122 var levelExpression = expression.GetLevelExpression(level);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1123 var inheritance =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1124 (
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1125 from m in InheritanceMapping
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1126 let om = Builder.MappingSchema.GetObjectMapper(m.Type)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1127 where om.Associations.Count > 0
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1128 select om
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1129 ).ToList();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1130
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1131 if (objectMapper.Associations.Count > 0 || inheritance.Count > 0)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1132 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1133 if (levelExpression.NodeType == ExpressionType.MemberAccess)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1134 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1135 var memberExpression = (MemberExpression)levelExpression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1136 var isNew = false;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1137
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1138 AssociatedTableContext tableAssociation;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1139
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1140 if (!_associations.TryGetValue(memberExpression.Member, out tableAssociation))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1141 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1142 var q =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1143 from a in objectMapper.Associations.Concat(inheritance.SelectMany(om => om.Associations))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1144 where TypeHelper.Equals(a.MemberAccessor.MemberInfo, memberExpression.Member)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1145 select new AssociatedTableContext(Builder, this, a) { Parent = Parent };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1146
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1147 tableAssociation = q.FirstOrDefault();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1148
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1149 isNew = true;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1150
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1151 _associations.Add(memberExpression.Member, tableAssociation);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1152 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1153
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1154 if (tableAssociation != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1155 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1156 if (levelExpression == expression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1157 return new TableLevel { Table = tableAssociation, Level = level, IsNew = isNew };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1158
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1159 var al = tableAssociation.GetAssociation(expression, level + 1);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1160
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1161 if (al != null)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1162 return al;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1163
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1164 var field = tableAssociation.GetField(expression, level + 1, false);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1165
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1166 return new TableLevel { Table = tableAssociation, Field = field, Level = field == null ? level : level + 1, IsNew = isNew };
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1167 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1168 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1169 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1170
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1171 return null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1172 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1173
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1174 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1175 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1176
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1177 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1178
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1179 #region AssociatedTableContext
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1180
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1181 public class AssociatedTableContext : TableContext
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1182 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1183 public readonly TableContext ParentAssociation;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1184 public readonly SqlQuery.JoinedTable ParentAssociationJoin;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1185 public readonly Association Association;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1186 public readonly bool IsList;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1187
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1188 public override IBuildContext Parent
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1189 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1190 get { return ParentAssociation.Parent; }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1191 set { }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1192 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1193
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1194 public AssociatedTableContext(ExpressionBuilder builder, TableContext parent, Association association)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1195 : base(builder, parent.SqlQuery)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1196 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1197 var type = TypeHelper.GetMemberType(association.MemberAccessor.MemberInfo);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1198 var left = association.CanBeNull;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1199
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1200 if (TypeHelper.IsSameOrParent(typeof(IEnumerable), type))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1201 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1202 var etypes = TypeHelper.GetGenericArguments(type, typeof(IEnumerable));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1203 type = etypes != null && etypes.Length > 0 ? etypes[0] : TypeHelper.GetListItemType(type);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1204 IsList = true;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1205 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1206
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1207 OriginalType = type;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1208 ObjectType = GetObjectType();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1209 ObjectMapper = Builder.MappingSchema.GetObjectMapper(ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1210 SqlTable = new SqlTable(builder.MappingSchema, ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1211
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1212 var psrc = parent.SqlQuery.From[parent.SqlTable];
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1213 var join = left ? SqlTable.WeakLeftJoin() : IsList ? SqlTable.InnerJoin() : SqlTable.WeakInnerJoin();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1214
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1215 Association = association;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1216 ParentAssociation = parent;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1217 ParentAssociationJoin = join.JoinedTable;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1218
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1219 psrc.Joins.Add(join.JoinedTable);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1220
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1221 for (var i = 0; i < association.ThisKey.Length; i++)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1222 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1223 SqlField field1;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1224 SqlField field2;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1225
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1226 if (!parent.SqlTable.Fields.TryGetValue(association.ThisKey[i], out field1))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1227 throw new LinqException("Association key '{0}' not found for type '{1}.", association.ThisKey[i], parent.ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1228
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1229 if (!SqlTable.Fields.TryGetValue(association.OtherKey[i], out field2))
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1230 throw new LinqException("Association key '{0}' not found for type '{1}.", association.OtherKey[i], ObjectType);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1231
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1232 join.Field(field1).Equal.Field(field2);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1233 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1234
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1235 Init();
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1236 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1237
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1238 protected override Expression ProcessExpression(Expression expression)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1239 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1240 var isLeft = false;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1241
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1242 for (
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1243 var association = this;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1244 isLeft == false && association != null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1245 association = association.ParentAssociation as AssociatedTableContext)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1246 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1247 isLeft =
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1248 association.ParentAssociationJoin.JoinType == SqlQuery.JoinType.Left ||
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1249 association.ParentAssociationJoin.JoinType == SqlQuery.JoinType.OuterApply;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1250 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1251
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1252 if (isLeft)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1253 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1254 Expression cond = null;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1255
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1256 var keys = ConvertToIndex(null, 0, ConvertFlags.Key);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1257
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1258 foreach (var key in keys)
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1259 {
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1260 var index2 = ConvertToParentIndex(key.Index, null);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1261
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1262 Expression e = Expression.Call(
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1263 ExpressionBuilder.DataReaderParam,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1264 ReflectionHelper.DataReader.IsDBNull,
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1265 Expression.Constant(index2));
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1266
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1267 cond = cond == null ? e : Expression.AndAlso(cond, e);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1268 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1269
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1270 expression = Expression.Condition(cond, Expression.Constant(null, expression.Type), expression);
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1271 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1272
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1273 return expression;
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1274 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1275 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1276
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1277 #endregion
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1278 }
f990fcb411a9 Копия текущей версии из github
cin
parents:
diff changeset
1279 }