1
1
using System ;
2
-
3
2
using NHibernate . Engine ;
4
3
using NHibernate . Type ;
5
4
using NHibernate . Util ;
@@ -14,10 +13,18 @@ public class ANSIJoinFragment : JoinFragment
14
13
private SqlStringBuilder buffer = new SqlStringBuilder ( ) ;
15
14
private SqlStringBuilder conditions = new SqlStringBuilder ( ) ;
16
15
17
- public override void AddJoin ( string tableName , string alias , string [ ] fkColumns , string [ ] pkColumns , JoinType joinType )
16
+ /// <summary>
17
+ ///
18
+ /// </summary>
19
+ /// <param name="tableName"></param>
20
+ /// <param name="alias"></param>
21
+ /// <param name="fkColumns"></param>
22
+ /// <param name="pkColumns"></param>
23
+ /// <param name="joinType"></param>
24
+ public override void AddJoin ( string tableName , string alias , string [ ] fkColumns , string [ ] pkColumns , JoinType joinType )
18
25
{
19
26
string joinString = null ;
20
- switch ( joinType )
27
+ switch ( joinType )
21
28
{
22
29
case JoinType . InnerJoin :
23
30
joinString = " inner join " ;
@@ -32,81 +39,127 @@ public override void AddJoin(string tableName, string alias, string[] fkColumns,
32
39
joinString = " full outer join " ;
33
40
break ;
34
41
default :
35
- throw new AssertionFailure ( "undefind join type" ) ;
42
+ throw new AssertionFailure ( "undefind join type" ) ;
36
43
}
37
44
38
45
buffer . Add ( joinString + tableName + ' ' + alias + " on " ) ;
39
46
40
- for ( int j = 0 ; j < fkColumns . Length ; j ++ )
47
+ for ( int j = 0 ; j < fkColumns . Length ; j ++ )
41
48
{
42
- if ( fkColumns [ j ] . IndexOf ( '.' ) < 1 ) throw new AssertionFailure ( "missing alias" ) ;
43
- buffer . Add ( fkColumns [ j ] + "=" + alias + StringHelper . Dot + pkColumns [ j ] ) ;
44
- if ( j < fkColumns . Length - 1 ) buffer . Add ( " and " ) ;
49
+ if ( fkColumns [ j ] . IndexOf ( '.' ) < 1 )
50
+ {
51
+ throw new AssertionFailure ( "missing alias" ) ;
52
+ }
53
+ buffer . Add ( fkColumns [ j ] + "=" + alias + StringHelper . Dot + pkColumns [ j ] ) ;
54
+ if ( j < fkColumns . Length - 1 )
55
+ {
56
+ buffer . Add ( " and " ) ;
57
+ }
45
58
}
46
59
}
47
60
48
- public override SqlString ToFromFragmentString
61
+ /// <summary></summary>
62
+ public override SqlString ToFromFragmentString
49
63
{
50
64
get { return buffer . ToSqlString ( ) ; }
51
65
}
52
66
53
- public override SqlString ToWhereFragmentString
67
+ /// <summary></summary>
68
+ public override SqlString ToWhereFragmentString
54
69
{
55
70
get { return conditions . ToSqlString ( ) ; }
56
71
}
57
72
58
- public override void AddJoins ( SqlString fromFragment , SqlString whereFragment )
73
+ /// <summary>
74
+ ///
75
+ /// </summary>
76
+ /// <param name="fromFragment"></param>
77
+ /// <param name="whereFragment"></param>
78
+ public override void AddJoins ( SqlString fromFragment , SqlString whereFragment )
59
79
{
60
- buffer . Add ( fromFragment ) ;
80
+ buffer . Add ( fromFragment ) ;
61
81
//where fragment must be empty!
62
82
}
63
83
64
- public override JoinFragment Copy ( )
84
+ /// <summary></summary>
85
+ public override JoinFragment Copy ( )
65
86
{
66
87
ANSIJoinFragment copy = new ANSIJoinFragment ( ) ;
67
88
copy . buffer = new SqlStringBuilder ( buffer . ToSqlString ( ) ) ;
68
89
return copy ;
69
90
}
70
91
71
- public override void AddCondition ( string alias , string [ ] columns , string condition )
92
+ /// <summary>
93
+ ///
94
+ /// </summary>
95
+ /// <param name="alias"></param>
96
+ /// <param name="columns"></param>
97
+ /// <param name="condition"></param>
98
+ public override void AddCondition ( string alias , string [ ] columns , string condition )
72
99
{
73
- for ( int i = 0 ; i < columns . Length ; i ++ )
100
+ for ( int i = 0 ; i < columns . Length ; i ++ )
74
101
{
75
- conditions . Add ( " and " + alias + StringHelper . Dot + columns [ i ] + condition ) ;
102
+ conditions . Add ( " and " + alias + StringHelper . Dot + columns [ i ] + condition ) ;
76
103
}
77
104
}
78
105
79
- public override void AddCondition ( string alias , string [ ] columns , string condition , IType conditionType , ISessionFactoryImplementor factory )
106
+ /// <summary>
107
+ ///
108
+ /// </summary>
109
+ /// <param name="alias"></param>
110
+ /// <param name="columns"></param>
111
+ /// <param name="condition"></param>
112
+ /// <param name="conditionType"></param>
113
+ /// <param name="factory"></param>
114
+ public override void AddCondition ( string alias , string [ ] columns , string condition , IType conditionType , ISessionFactoryImplementor factory )
80
115
{
81
- Parameter [ ] parameters = Parameter . GenerateParameters ( factory , alias , columns , conditionType ) ;
82
- for ( int i = 0 ; i < columns . Length ; i ++ )
116
+ Parameter [ ] parameters = Parameter . GenerateParameters ( factory , alias , columns , conditionType ) ;
117
+ for ( int i = 0 ; i < columns . Length ; i ++ )
83
118
{
84
- conditions . Add ( " and " + alias + StringHelper . Dot + columns [ i ] + condition ) ;
85
- conditions . Add ( parameters [ i ] ) ;
119
+ conditions . Add ( " and " + alias + StringHelper . Dot + columns [ i ] + condition ) ;
120
+ conditions . Add ( parameters [ i ] ) ;
86
121
}
87
122
}
88
123
89
-
90
- public override void AddCrossJoin ( string tableName , string alias )
124
+ /// <summary>
125
+ ///
126
+ /// </summary>
127
+ /// <param name="tableName"></param>
128
+ /// <param name="alias"></param>
129
+ public override void AddCrossJoin ( string tableName , string alias )
91
130
{
92
- buffer . Add ( StringHelper . CommaSpace + tableName + " " + alias ) ;
131
+ buffer . Add ( StringHelper . CommaSpace + tableName + " " + alias ) ;
93
132
}
94
133
95
- public override void AddCondition ( string alias , string [ ] fkColumns , string [ ] pkColumns )
134
+ /// <summary>
135
+ ///
136
+ /// </summary>
137
+ /// <param name="alias"></param>
138
+ /// <param name="fkColumns"></param>
139
+ /// <param name="pkColumns"></param>
140
+ public override void AddCondition ( string alias , string [ ] fkColumns , string [ ] pkColumns )
96
141
{
97
142
throw new NotSupportedException ( ) ;
98
143
}
99
144
100
- public override void AddCondition ( string condition )
145
+ /// <summary>
146
+ ///
147
+ /// </summary>
148
+ /// <param name="condition"></param>
149
+ public override void AddCondition ( string condition )
101
150
{
102
151
throw new NotSupportedException ( ) ;
103
152
}
104
153
105
- public override void AddCondition ( SqlString condition )
154
+ /// <summary>
155
+ ///
156
+ /// </summary>
157
+ /// <param name="condition"></param>
158
+ public override void AddCondition ( SqlString condition )
106
159
{
107
160
throw new NotSupportedException ( ) ;
108
161
}
109
162
110
163
111
164
}
112
- }
165
+ }
0 commit comments