@@ -121,26 +121,26 @@ public override IEnumerable<string> GetCreateTableQuery(string tableName, IEnume
121
121
yield return query . ToString ( ) ;
122
122
123
123
var identity = fieldList . FirstOrDefault ( f => f . IsIdentity ) ;
124
- if ( identity ! = null )
125
- {
126
- var sequenceName = tableName + "_sequence" ;
127
- var triggerName = tableName + "_on_insert " ;
128
-
129
- yield return string . Concat ( "CREATE SEQUENCE " , sequenceName ) ;
130
-
131
- query . Clear ( ) ;
132
- query . Append ( "CREATE OR REPLACE TRIGGER " ) ;
133
- query . Append ( triggerName ) ;
134
- query . Append ( " BEFORE INSERT ON " ) ;
135
- query . Append ( tableName ) ;
136
- query . Append ( " FOR EACH ROW BEGIN SELECT " ) ;
137
- query . Append ( sequenceName ) ;
138
- query . Append ( ".nextval INTO :new." ) ;
139
- query . Append ( identity . Name ) ;
140
- query . Append ( " FROM dual; END;" ) ;
141
-
142
- yield return query . ToString ( ) ;
143
- }
124
+ if ( identity = = null )
125
+ yield break ;
126
+
127
+ var sequenceName = tableName + "_sequence " ;
128
+ var triggerName = tableName + "_on_insert" ;
129
+
130
+ yield return string . Concat ( "CREATE SEQUENCE " , sequenceName ) ;
131
+
132
+ query . Clear ( ) ;
133
+ query . Append ( "CREATE OR REPLACE TRIGGER " ) ;
134
+ query . Append ( triggerName ) ;
135
+ query . Append ( " BEFORE INSERT ON " ) ;
136
+ query . Append ( tableName ) ;
137
+ query . Append ( " FOR EACH ROW BEGIN SELECT " ) ;
138
+ query . Append ( sequenceName ) ;
139
+ query . Append ( ".nextval INTO :new." ) ;
140
+ query . Append ( identity . Name ) ;
141
+ query . Append ( " FROM dual; END;" ) ;
142
+
143
+ yield return query . ToString ( ) ;
144
144
}
145
145
146
146
public override IEnumerable < string > GetCreateTableIfNotExistsQuery ( string tableName , IEnumerable < FieldDefinition > fields )
@@ -157,26 +157,26 @@ public override IEnumerable<string> GetCreateTableIfNotExistsQuery(string tableN
157
157
yield return CatchException ( query . ToString ( ) , - 955 ) ;
158
158
159
159
var identity = fieldList . FirstOrDefault ( f => f . IsIdentity ) ;
160
- if ( identity ! = null )
161
- {
162
- var sequenceName = tableName + "_sequence" ;
163
- var triggerName = tableName + "_on_insert " ;
164
-
165
- yield return CatchException ( string . Concat ( "CREATE SEQUENCE " , sequenceName ) ) ;
166
-
167
- query . Clear ( ) ;
168
- query . Append ( "CREATE OR REPLACE TRIGGER " ) ;
169
- query . Append ( triggerName ) ;
170
- query . Append ( " BEFORE INSERT ON " ) ;
171
- query . Append ( tableName ) ;
172
- query . Append ( " FOR EACH ROW BEGIN SELECT " ) ;
173
- query . Append ( sequenceName ) ;
174
- query . Append ( ".nextval INTO :new." ) ;
175
- query . Append ( identity . Name ) ;
176
- query . Append ( " FROM dual; END;" ) ;
177
-
178
- yield return CatchException ( query . ToString ( ) ) ;
179
- }
160
+ if ( identity = = null )
161
+ yield break ;
162
+
163
+ var sequenceName = tableName + "_sequence " ;
164
+ var triggerName = tableName + "_on_insert" ;
165
+
166
+ yield return CatchException ( string . Concat ( "CREATE SEQUENCE " , sequenceName ) ) ;
167
+
168
+ query . Clear ( ) ;
169
+ query . Append ( "CREATE OR REPLACE TRIGGER " ) ;
170
+ query . Append ( triggerName ) ;
171
+ query . Append ( " BEFORE INSERT ON " ) ;
172
+ query . Append ( tableName ) ;
173
+ query . Append ( " FOR EACH ROW BEGIN SELECT " ) ;
174
+ query . Append ( sequenceName ) ;
175
+ query . Append ( ".nextval INTO :new." ) ;
176
+ query . Append ( identity . Name ) ;
177
+ query . Append ( " FROM dual; END;" ) ;
178
+
179
+ yield return CatchException ( query . ToString ( ) ) ;
180
180
}
181
181
182
182
public override string GetCreateColumnQuery ( string tableName , FieldDefinition field )
@@ -329,13 +329,13 @@ public override string GetAliasFormat()
329
329
return "\" {0}\" " ;
330
330
}
331
331
332
- private string CatchException ( string sql , int exceptionCode )
332
+ private static string CatchException ( string sql , int exceptionCode )
333
333
{
334
334
return string . Concat ( "BEGIN EXECUTE IMMEDIATE '" , sql , "' ; EXCEPTION WHEN OTHERS THEN IF SQLCODE != " ,
335
335
exceptionCode , " THEN RAISE; END IF; END;" ) ;
336
336
}
337
337
338
- private string CatchException ( string sql )
338
+ private static string CatchException ( string sql )
339
339
{
340
340
return string . Concat ( "BEGIN EXECUTE IMMEDIATE '" , sql , "' ; EXCEPTION WHEN OTHERS THEN NULL; END;" ) ;
341
341
}
0 commit comments