Mercurial > pub > bltoolkit

comparison Source/DataAccess/SqlQueryInfo.cs @ 0:f990fcb411a9

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Копия текущей версии из github
author cin
date Thu, 27 Mar 2014 21:46:09 +0400
parents
children
comparison
equal deleted inserted replaced
-1:000000000000 0:f990fcb411a9
1 using System;
2 using System.Collections.Generic;
3 using System.Data;
4
5 using BLToolkit.Data;
6 using BLToolkit.Mapping;
7
8 namespace BLToolkit.DataAccess
9 {
10 public class SqlQueryInfo
11 {
12 //NOTE Added empty constructor
13 public SqlQueryInfo()
14 {
15 }
16
17 public SqlQueryInfo(ObjectMapper objectMapper)
18 {
19 ObjectMapper = objectMapper;
20 }
21
22 public string QueryText { get; set; }
23 public ObjectMapper ObjectMapper { get; private set; }
24
25 public Type ObjectType
26 {
27 get { return ObjectMapper.TypeAccessor.OriginalType; }
28 }
29
30 //NOTE Changed from private to protected
31 protected readonly List<SqlQueryParameterInfo> Parameters = new List<SqlQueryParameterInfo>();
32
33 //NOTE Changed to virtual
34 public virtual SqlQueryParameterInfo AddParameter(string parameterName, string fieldName)
35 {
36 var parameter = new SqlQueryParameterInfo { ParameterName = parameterName, FieldName = fieldName };
37
38 parameter.SetMemberMapper(ObjectMapper);
39
40 Parameters.Add(parameter);
41
42 return parameter;
43 }
44
45 public IDbDataParameter[] GetParameters(DbManager db, object[] key)
46 {
47 if (Parameters.Count != key.Length)
48 throw new DataAccessException("Parameter list does match key list.");
49
50 var parameters = new IDbDataParameter[Parameters.Count];
51
52 for (var i = 0; i < Parameters.Count; i++)
53 {
54 var info = Parameters[i];
55
56 parameters[i] = db.Parameter(info.ParameterName, key[i]);
57 }
58
59 return parameters;
60 }
61
62 public IDbDataParameter[] GetParameters(DbManager db, object obj)
63 {
64 var parameters = new IDbDataParameter[Parameters.Count];
65
66 for (var i = 0; i < Parameters.Count; i++)
67 {
68 var info = Parameters[i];
69
70 //parameters[i] = db.Parameter(info.ParameterName, info.MemberMapper.GetValue(obj));
71
72 var mmi = info.MemberMapper.MapMemberInfo;
73 var val = info.MemberMapper.GetValue(obj);
74
75 if (val == null && mmi.Nullable/* && mmi.NullValue == null*/)
76 {
77 //replace value with DbNull
78 val = DBNull.Value;
79 }
80
81 if (mmi.IsDbTypeSet)
82 {
83 parameters[i] = mmi.IsDbSizeSet
84 ? db.Parameter(info.ParameterName, val, info.MemberMapper.DbType, mmi.DbSize)
85 : db.Parameter(info.ParameterName, val, info.MemberMapper.DbType);
86 }
87 else
88 {
89 parameters[i] = val != DBNull.Value
90 ? db.Parameter(info.ParameterName, val)
91 : db.Parameter(info.ParameterName, val, info.MemberMapper.GetDbType());
92 }
93 }
94
95 return parameters;
96 }
97
98 public MemberMapper[] GetMemberMappers()
99 {
100 var members = new MemberMapper[Parameters.Count];
101
102 for (var i = 0; i < Parameters.Count; i++)
103 members[i] = Parameters[i].MemberMapper;
104
105 return members;
106 }
107 }
108 }