Datei: Provider/SqlServerProvider/NDO.SqlServer/Provider.cs

Last Commit (e9b343b)
1 using NDOInterfaces;
2 using System;
3 using System.Collections.Generic;
4 using System.Data;
5 using System.Data.Common;
6 using Microsoft.Data.SqlClient;
7 using System.Text;
8 using System.Text.RegularExpressions;
9
10 namespace SqlServerProvider
11 {
12 ····/// <summary>
13 ····/// This is an Implementation of the IProvider interface for SqlServer.
14 ····/// For more information see <see cref="IProvider"> IProvider interface </see>.
15 ····/// </summary>
16 ····public class Provider : NDOAbstractProvider
17 ····{
18
19 ········#region Implementation of IProvider
20
21
22 ········/// <summary>
23 ········/// See <see cref="IProvider"> IProvider interface </see>
24 ········/// </summary>
25 ········public override bool UseNamedParams
26 ········{
27 ············get { return true; }
28 ········}
29
30 ········/// <summary>
31 ········/// See <see cref="IProvider"> IProvider interface </see>
32 ········/// </summary>
33 ········public override string GetNamedParameter( string plainParameterName )
34 ········{
35 ············return "@" + plainParameterName;
36 ········}
37
38
39 ········/// <summary>
40 ········/// See <see cref="IProvider"> IProvider interface </see>
41 ········/// </summary>
42 ········public override string NamedParamPrefix
43 ········{
44 ············get { return "@"; }
45 ········}
46
47 ········/// <summary>
48 ········/// See <see cref="IProvider"> IProvider interface </see>
49 ········/// </summary>
50 ········private string GetDateExpression( DateTime dt )
51 ········{
52 ············string dtstr = dt.ToString();
53 ············dtstr = dtstr.Replace( ".", "/" );
54 ············dtstr = dtstr.Replace( "-", "/" );
55 ············return "'" + dtstr + "'";
56 ········}
57
58 ········/// <summary>
59 ········/// See <see cref="IProvider"> IProvider interface </see>
60 ········/// </summary>
61 ········public override string GetSqlLiteral( object o )
62 ········{
63 ············if (o is DateTime)
64 ················return this.GetDateExpression( (DateTime)o );
65 ············return base.GetSqlLiteral( o );
66 ········}
67
68
69 ········/// <summary>
70 ········/// See <see cref="IProvider"> IProvider interface </see>
71 ········/// </summary>
72 ········public override System.Data.IDbConnection NewConnection( string connectionString )
73 ········{
74 ············return new SqlConnection( connectionString );
75 ········}
76
77 ········/// <summary>
78 ········/// See <see cref="IProvider"> IProvider interface </see>
79 ········/// </summary>
80 ········public override System.Data.IDbCommand NewSqlCommand( System.Data.IDbConnection connection )
81 ········{
82 ············SqlCommand command = new SqlCommand();
83 ············command.Connection = (SqlConnection)connection;
84 ············return command;
85 ········}
86
87 ········/// <summary>
88 ········/// See <see cref="IProvider"> IProvider interface </see>
89 ········/// </summary>
90 ········public override DbDataAdapter NewDataAdapter( System.Data.IDbCommand select, System.Data.IDbCommand update, System.Data.IDbCommand insert, System.Data.IDbCommand delete )
91 ········{
92 ············SqlDataAdapter da = new SqlDataAdapter();
93 ············da.SelectCommand = (SqlCommand)select;
94 ············da.UpdateCommand = (SqlCommand)update;
95 ············da.InsertCommand = (SqlCommand)insert;
96 ············da.DeleteCommand = (SqlCommand)delete;
97 ············return da;
98 ········}
99
100
101 ········/// <summary>
102 ········/// See <see cref="IProvider"> IProvider interface </see>
103 ········/// </summary>
104 ········public override object NewCommandBuilder( DbDataAdapter dataAdapter )
105 ········{
106 ············return new SqlCommandBuilder( (SqlDataAdapter)dataAdapter );
107 ········}
108
109 ········/// <summary>
110 ········/// See <see cref="IProvider"> IProvider interface </see>
111 ········/// </summary>
112 ········public override IDataParameter AddParameter( System.Data.IDbCommand command, string parameterName, object dbType, int size, string columnName )
113 ········{
114 ············return ((SqlCommand)command).Parameters.Add( new SqlParameter( parameterName, (SqlDbType)dbType, size > -1 ? size : 0, columnName ) );
115 ········}
116
117 ········/// <summary>
118 ········/// See <see cref="IProvider"> IProvider interface </see>
119 ········/// </summary>
120 ········public override IDataParameter AddParameter( IDbCommand command, string parameterName, object dbType, int size, ParameterDirection dir, bool isNullable, byte precision, byte scale, string srcColumn, DataRowVersion srcVersion, object value )
121 ········{
122 ············return ((SqlCommand)command).Parameters.Add( new SqlParameter( parameterName, (SqlDbType)dbType, size > -1 ? size : 0, dir, isNullable, precision, scale, srcColumn, srcVersion, value ) );
123 ········}
124
125 ········/// <summary>
126 ········/// See <see cref="IProvider"> IProvider interface </see>
127 ········/// </summary>
128 ········public override object GetDbType( Type t )
129 ········{
130 ············t = base.ConvertNullableType( t );
131 ············if (t == typeof( bool ))
132 ················return SqlDbType.Bit;
133 ············else if (t == typeof( byte ))
134 ················return SqlDbType.TinyInt;
135 ············else if (t == typeof( sbyte ))
136 ················return SqlDbType.TinyInt;
137 ············else if (t == typeof( char ))
138 ················return SqlDbType.Char;
139 ············else if (t == typeof( short ))
140 ················return SqlDbType.SmallInt;
141 ············else if (t == typeof( ushort ))
142 ················return SqlDbType.SmallInt;
143 ············else if (t == typeof( int ))
144 ················return SqlDbType.Int;
145 ············else if (t == typeof( uint ))
146 ················return SqlDbType.Int;
147 ············else if (t == typeof( long ))
148 ················return SqlDbType.BigInt;
149 ············else if (t == typeof( System.Guid ))
150 ················return SqlDbType.UniqueIdentifier;
151 ············else if (t == typeof( ulong ))
152 ················return SqlDbType.BigInt;
153 ············else if (t == typeof( float ))
154 ················return SqlDbType.Real;
155 ············else if (t == typeof( double ))
156 ················return SqlDbType.Float;
157 ············else if (t == typeof( string ))
158 ················return SqlDbType.NVarChar;
159 ············else if (t == typeof( byte[] ))
160 ················return SqlDbType.Image;
161 ············else if (t == typeof( decimal ))
162 ················return SqlDbType.Decimal;
163 ············else if (t == typeof( System.DateTime ))
164 ················return SqlDbType.DateTime;
165 ············else if (t.IsSubclassOf( typeof( System.Enum ) ))
166 ················return SqlDbType.Int;
167 ············else if (t == typeof( System.Data.SqlTypes.SqlXml ))
168 ················return SqlDbType.Xml;
169 ············else
170 ················throw new Exception( $"NDOSqlProvider.GetDbType: Type {t.Name} can't be converted into a SqlDbType." );
171 ········}
172
173 ········public override string GetDbTypeString( IDbDataParameter parameter )
174 ········{
175 ············return (((SqlParameter)parameter).SqlDbType).ToString();
176 ········}
177
178 ········public override int GetDefaultLength( Type t )
179 ········{
180 ············if (t == typeof( byte[] ))
181 ················return 65535;
182 ············return base.GetDefaultLength( t );
183 ········}
184
185 ········/// <summary>
186 ········/// See <see cref="IProvider"> IProvider interface </see>
187 ········/// </summary>
188 ········public override object GetDbType( string typeName )
189 ········{
190 ············string typeNameLower = typeName.ToLower();
191 ············if (typeNameLower.StartsWith( "nvarchar" )) return SqlDbType.NVarChar;
192 ············if (String.Compare( typeName, "VarChar", true ) == 0) return SqlDbType.VarChar;
193 ············if (String.Compare( typeName, "NChar", true ) == 0) return SqlDbType.NChar;
194 ············if (String.Compare( typeName, "Int", true ) == 0) return SqlDbType.Int;
195 ············if (String.Compare( typeName, "Char", true ) == 0) return SqlDbType.Char;
196 ············if (String.Compare( typeName, "UniqueIdentifier", true ) == 0) return SqlDbType.UniqueIdentifier;
197 ············if (String.Compare( typeName, "DateTime", true ) == 0) return SqlDbType.DateTime;
198 ············if (String.Compare( typeName, "Decimal", true ) == 0) return SqlDbType.Decimal;
199 ············if (String.Compare( typeName, "Binary", true ) == 0) return SqlDbType.Binary;
200 ············if (String.Compare( typeName, "Bit", true ) == 0) return SqlDbType.Bit;
201 ············if (String.Compare( typeName, "Real", true ) == 0) return SqlDbType.Real;
202 ············if (String.Compare( typeName, "Float", true ) == 0) return SqlDbType.Float;
203 ············if (String.Compare( typeName, "Image", true ) == 0) return SqlDbType.Image;
204 ············if (String.Compare( typeName, "Money", true ) == 0) return SqlDbType.Money;
205 ············if (String.Compare( typeName, "NText", true ) == 0) return SqlDbType.NText;
206 ············if (String.Compare( typeName, "SmallDateTime", true ) == 0) return SqlDbType.SmallDateTime;
207 ············if (String.Compare( typeName, "SmallInt", true ) == 0) return SqlDbType.SmallInt;
208 ············if (String.Compare( typeName, "SmallMoney", true ) == 0) return SqlDbType.SmallMoney;
209 ············if (String.Compare( typeName, "Text", true ) == 0) return SqlDbType.Text;
210 ············if (String.Compare( typeName, "Timestamp", true ) == 0) return SqlDbType.Timestamp;
211 ············if (String.Compare( typeName, "TinyInt", true ) == 0) return SqlDbType.TinyInt;
212 ············if (String.Compare( typeName, "VarBinary", true ) == 0) return SqlDbType.VarBinary;
213 ············if (String.Compare( typeName, "Variant", true ) == 0) return SqlDbType.Variant;
214 ············if (String.Compare( typeName, "BigInt", true ) == 0) return SqlDbType.BigInt;
215 ············if (typeNameLower.StartsWith( "xml" )) return SqlDbType.Xml;
216 ············if (String.Compare( typeName, "RowVersion", true ) == 0) return SqlDbType.Timestamp;
217 ············SqlDbType result;
218 ············if (Enum.TryParse( typeName, out result ))
219 ················return result;
220 ············throw new Exception( $"NDOSqlProvider.GetDbType: Type name {typeName} can't be converted into a SqlDbType." );
221 ········}
222
223 ········/// <summary>
224 ········/// See <see cref="IProvider"> IProvider interface </see>
225 ········/// </summary>
226 ········public override string GetQuotedName( string plainName )
227 ········{
228 ············if (plainName[0] == '[')
229 ················return plainName;
230 ············return "[" + plainName + "]";
231 ········}
232
233 ········/// <summary>
234 ········/// Indicates whether the last automatically generated ID can be retrieved.
235 ········/// Returns true if a database provides automatically incremented IDs and its syntax has an expression
236 ········/// which retrieves the last generated ID; otherwise false.
237 ········/// </summary>
238 ········public override bool SupportsLastInsertedId
239 ········{
240 ············get { return true; }
241 ········}
242
243 ········/// <summary>
244 ········/// Gets an expression in the SQL dialect of the database, which retrieves the ID of the last
245 ········/// inserted row, if the ID is automatically generated by the database.
246 ········/// </summary>
247 ········/// <param name="tableName">The table name, the insert happens into.</param>
248 ········/// <param name="columnName">The column name of the autoincremented primary key column.</param>
249 ········/// <returns></returns>········
250 ········public override string GetLastInsertedId( string tableName, string columnName )
251 ········{
252 ············return "SCOPE_IDENTITY()";
253 ········}
254
255 ········/// <summary>
256 ········/// Determines whether a database supports bulk command strings.
257 ········/// </summary>
258 ········public override bool SupportsBulkCommands
259 ········{
260 ············get { return true; }
261 ········}
262
263
264 ········/// <summary>
265 ········/// Generate one big command string out of several partial commands to save roundtrips
266 ········/// to the server.
267 ········/// </summary>
268 ········/// <param name="commands"></param>
269 ········/// <returns></returns>
270 ········public override string GenerateBulkCommand( string[] commands )
271 ········{
272 ············StringBuilder sb = new StringBuilder( commands.Length * 100 );
273 ············foreach (string s in commands)
274 ············{
275 ················sb.Append( s );
276 ················sb.Append( ';' );
277 ············}
278 ············return sb.ToString();
279 ········}
280
281 ········/// <summary>
282 ········/// See <see cref="NDOInterfaces.IProvider">IProvider interface</see>.
283 ········/// </summary>
284 ········public override int MaxBulkCommandLength
285 ········{
286 ············// Der Wert ist willkürlich gesetzt. Die Query in der Größe dauert ungefähr 15s.
287 ············get { return 1280000; }
288 ········}
289
290
291
292 ········/// <summary>
293 ········/// See <see cref="IProvider"> IProvider interface </see>
294 ········/// </summary>
295 ········public override string[] GetTableNames( IDbConnection conn, string owner )
296 ········{
297 ············List<string> result = new List<string>();
298 ············string sql = "SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE'";
299 ············SqlCommand cmd = new SqlCommand( sql, (SqlConnection)conn );
300 ············bool wasOpen = true;
301
302 ············if (conn.State == ConnectionState.Closed)
303 ············{
304 ················wasOpen = false;
305 ················conn.Open();
306 ············}
307
308 ············SqlDataReader dr = cmd.ExecuteReader();
309 ············while (dr.Read())
310 ············{
311 ················string tbl = dr.GetString( 2 );
312 ················if (tbl != "dtproperties")
313 ····················result.Add( tbl );
314 ············}
315
316 ············dr.Close();
317
318 ············if (!wasOpen)
319 ················conn.Close();
320
321 ············return result.ToArray();
322 ········}
323
324 ········/// <summary>
325 ········/// See <see cref="IProvider"> IProvider interface </see>
326 ········/// </summary>
327 ········public override string[] TypeNames
328 ········{
329 ············get
330 ············{
331 ················return Enum.GetNames( typeof( SqlDbType ) );
332 ············}
333 ········}
334
335 ········/// <summary>
336 ········/// See <see cref="IProvider"> IProvider interface </see>
337 ········/// </summary>
338 ········public override string Name { get { return "SqlServer"; } }
339
340 ········/// <summary>
341 ········/// See <see cref="IProvider"> IProvider interface </see>
342 ········/// </summary>
343 ········public override bool SupportsNativeGuidType { get { return true; } }
344
345 ········public override bool SupportsInsertBatch
346 ········{
347 ············get
348 ············{
349 ················return true;
350 ············}
351 ········}
352
353 ········public override string CreateDatabase( string databaseName, string connectionString, object additionalData )
354 ········{
355 ············base.CreateDatabase( databaseName, connectionString, additionalData );
356 ············Regex regex = new Regex( @"Initial\sCatalog=([^\;]*)" );
357 ············Match match = regex.Match( connectionString );
358 ············if (match.Success)
359 ············{
360 ················return connectionString.Substring( 0, match.Groups[1].Index ) + GetQuotedName( databaseName ) + connectionString.Substring( match.Index + match.Length );
361 ············}
362
363 ············if (connectionString.EndsWith( ";" ))
364 ················return connectionString + "Initial Catalog=" + databaseName;
365 ············else
366 ················return connectionString + ";Initial Catalog=" + databaseName;
367 ········}
368
369 ········#endregion
370
371 ····}
372 }
373
New Commit (273289e)
1 using NDOInterfaces;
2 using System;
3 using System.Collections.Generic;
4 using System.Data;
5 using System.Data.Common;
6 using Microsoft.Data.SqlClient;
7 using System.Text;
8 using System.Text.RegularExpressions;
9
10 namespace SqlServerProvider
11 {
12 ····/// <summary>
13 ····/// This is an Implementation of the IProvider interface for SqlServer.
14 ····/// For more information see <see cref="IProvider"> IProvider interface </see>.
15 ····/// </summary>
16 ····public class Provider : NDOAbstractProvider
17 ····{
18
19 ········#region Implementation of IProvider
20
21
22 ········/// <summary>
23 ········/// See <see cref="IProvider"> IProvider interface </see>
24 ········/// </summary>
25 ········public override bool UseNamedParams
26 ········{
27 ············get { return true; }
28 ········}
29
30 ········/// <summary>
31 ········/// See <see cref="IProvider"> IProvider interface </see>
32 ········/// </summary>
33 ········public override string GetNamedParameter( string plainParameterName )
34 ········{
35 ············return "@" + plainParameterName;
36 ········}
37
38
39 ········/// <summary>
40 ········/// See <see cref="IProvider"> IProvider interface </see>
41 ········/// </summary>
42 ········public override string NamedParamPrefix
43 ········{
44 ············get { return "@"; }
45 ········}
46
47 ········/// <summary>
48 ········/// See <see cref="IProvider"> IProvider interface </see>
49 ········/// </summary>
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
50 ········public override System.Data.IDbConnection NewConnection( string connectionString )
51 ········{
52 ············return new SqlConnection( connectionString );
53 ········}
54
55 ········/// <summary>
56 ········/// See <see cref="IProvider"> IProvider interface </see>
57 ········/// </summary>
58 ········public override System.Data.IDbCommand NewSqlCommand( System.Data.IDbConnection connection )
59 ········{
60 ············SqlCommand command = new SqlCommand();
61 ············command.Connection = (SqlConnection)connection;
62 ············return command;
63 ········}
64
65 ········/// <summary>
66 ········/// See <see cref="IProvider"> IProvider interface </see>
67 ········/// </summary>
68 ········public override DbDataAdapter NewDataAdapter( System.Data.IDbCommand select, System.Data.IDbCommand update, System.Data.IDbCommand insert, System.Data.IDbCommand delete )
69 ········{
70 ············SqlDataAdapter da = new SqlDataAdapter();
71 ············da.SelectCommand = (SqlCommand)select;
72 ············da.UpdateCommand = (SqlCommand)update;
73 ············da.InsertCommand = (SqlCommand)insert;
74 ············da.DeleteCommand = (SqlCommand)delete;
75 ············return da;
76 ········}
77
78
79 ········/// <summary>
80 ········/// See <see cref="IProvider"> IProvider interface </see>
81 ········/// </summary>
82 ········public override object NewCommandBuilder( DbDataAdapter dataAdapter )
83 ········{
84 ············return new SqlCommandBuilder( (SqlDataAdapter)dataAdapter );
85 ········}
86
87 ········/// <summary>
88 ········/// See <see cref="IProvider"> IProvider interface </see>
89 ········/// </summary>
90 ········public override IDataParameter AddParameter( System.Data.IDbCommand command, string parameterName, object dbType, int size, string columnName )
91 ········{
92 ············return ((SqlCommand)command).Parameters.Add( new SqlParameter( parameterName, (SqlDbType)dbType, size > -1 ? size : 0, columnName ) );
93 ········}
94
95 ········/// <summary>
96 ········/// See <see cref="IProvider"> IProvider interface </see>
97 ········/// </summary>
98 ········public override IDataParameter AddParameter( IDbCommand command, string parameterName, object dbType, int size, ParameterDirection dir, bool isNullable, byte precision, byte scale, string srcColumn, DataRowVersion srcVersion, object value )
99 ········{
100 ············return ((SqlCommand)command).Parameters.Add( new SqlParameter( parameterName, (SqlDbType)dbType, size > -1 ? size : 0, dir, isNullable, precision, scale, srcColumn, srcVersion, value ) );
101 ········}
102
103 ········/// <summary>
104 ········/// See <see cref="IProvider"> IProvider interface </see>
105 ········/// </summary>
106 ········public override object GetDbType( Type t )
107 ········{
108 ············t = base.ConvertNullableType( t );
109 ············if (t == typeof( bool ))
110 ················return SqlDbType.Bit;
111 ············else if (t == typeof( byte ))
112 ················return SqlDbType.TinyInt;
113 ············else if (t == typeof( sbyte ))
114 ················return SqlDbType.TinyInt;
115 ············else if (t == typeof( char ))
116 ················return SqlDbType.Char;
117 ············else if (t == typeof( short ))
118 ················return SqlDbType.SmallInt;
119 ············else if (t == typeof( ushort ))
120 ················return SqlDbType.SmallInt;
121 ············else if (t == typeof( int ))
122 ················return SqlDbType.Int;
123 ············else if (t == typeof( uint ))
124 ················return SqlDbType.Int;
125 ············else if (t == typeof( long ))
126 ················return SqlDbType.BigInt;
127 ············else if (t == typeof( System.Guid ))
128 ················return SqlDbType.UniqueIdentifier;
129 ············else if (t == typeof( ulong ))
130 ················return SqlDbType.BigInt;
131 ············else if (t == typeof( float ))
132 ················return SqlDbType.Real;
133 ············else if (t == typeof( double ))
134 ················return SqlDbType.Float;
135 ············else if (t == typeof( string ))
136 ················return SqlDbType.NVarChar;
137 ············else if (t == typeof( byte[] ))
138 ················return SqlDbType.Image;
139 ············else if (t == typeof( decimal ))
140 ················return SqlDbType.Decimal;
141 ············else if (t == typeof( System.DateTime ))
142 ················return SqlDbType.DateTime;
143 ············else if (t.IsSubclassOf( typeof( System.Enum ) ))
144 ················return SqlDbType.Int;
145 ············else if (t == typeof( System.Data.SqlTypes.SqlXml ))
146 ················return SqlDbType.Xml;
147 ············else
148 ················throw new Exception( $"NDOSqlProvider.GetDbType: Type {t.Name} can't be converted into a SqlDbType." );
149 ········}
150
151 ········public override string GetDbTypeString( IDbDataParameter parameter )
152 ········{
153 ············return (((SqlParameter)parameter).SqlDbType).ToString();
154 ········}
155
156 ········public override int GetDefaultLength( Type t )
157 ········{
158 ············if (t == typeof( byte[] ))
159 ················return 65535;
160 ············return base.GetDefaultLength( t );
161 ········}
162
163 ········/// <summary>
164 ········/// See <see cref="IProvider"> IProvider interface </see>
165 ········/// </summary>
166 ········public override object GetDbType( string typeName )
167 ········{
168 ············string typeNameLower = typeName.ToLower();
169 ············if (typeNameLower.StartsWith( "nvarchar" )) return SqlDbType.NVarChar;
170 ············if (String.Compare( typeName, "VarChar", true ) == 0) return SqlDbType.VarChar;
171 ············if (String.Compare( typeName, "NChar", true ) == 0) return SqlDbType.NChar;
172 ············if (String.Compare( typeName, "Int", true ) == 0) return SqlDbType.Int;
173 ············if (String.Compare( typeName, "Char", true ) == 0) return SqlDbType.Char;
174 ············if (String.Compare( typeName, "UniqueIdentifier", true ) == 0) return SqlDbType.UniqueIdentifier;
175 ············if (String.Compare( typeName, "DateTime", true ) == 0) return SqlDbType.DateTime;
176 ············if (String.Compare( typeName, "Decimal", true ) == 0) return SqlDbType.Decimal;
177 ············if (String.Compare( typeName, "Binary", true ) == 0) return SqlDbType.Binary;
178 ············if (String.Compare( typeName, "Bit", true ) == 0) return SqlDbType.Bit;
179 ············if (String.Compare( typeName, "Real", true ) == 0) return SqlDbType.Real;
180 ············if (String.Compare( typeName, "Float", true ) == 0) return SqlDbType.Float;
181 ············if (String.Compare( typeName, "Image", true ) == 0) return SqlDbType.Image;
182 ············if (String.Compare( typeName, "Money", true ) == 0) return SqlDbType.Money;
183 ············if (String.Compare( typeName, "NText", true ) == 0) return SqlDbType.NText;
184 ············if (String.Compare( typeName, "SmallDateTime", true ) == 0) return SqlDbType.SmallDateTime;
185 ············if (String.Compare( typeName, "SmallInt", true ) == 0) return SqlDbType.SmallInt;
186 ············if (String.Compare( typeName, "SmallMoney", true ) == 0) return SqlDbType.SmallMoney;
187 ············if (String.Compare( typeName, "Text", true ) == 0) return SqlDbType.Text;
188 ············if (String.Compare( typeName, "Timestamp", true ) == 0) return SqlDbType.Timestamp;
189 ············if (String.Compare( typeName, "TinyInt", true ) == 0) return SqlDbType.TinyInt;
190 ············if (String.Compare( typeName, "VarBinary", true ) == 0) return SqlDbType.VarBinary;
191 ············if (String.Compare( typeName, "Variant", true ) == 0) return SqlDbType.Variant;
192 ············if (String.Compare( typeName, "BigInt", true ) == 0) return SqlDbType.BigInt;
193 ············if (typeNameLower.StartsWith( "xml" )) return SqlDbType.Xml;
194 ············if (String.Compare( typeName, "RowVersion", true ) == 0) return SqlDbType.Timestamp;
195 ············SqlDbType result;
196 ············if (Enum.TryParse( typeName, out result ))
197 ················return result;
198 ············throw new Exception( $"NDOSqlProvider.GetDbType: Type name {typeName} can't be converted into a SqlDbType." );
199 ········}
200
201 ········/// <summary>
202 ········/// See <see cref="IProvider"> IProvider interface </see>
203 ········/// </summary>
204 ········public override string GetQuotedName( string plainName )
205 ········{
206 ············if (plainName[0] == '[')
207 ················return plainName;
208 ············return "[" + plainName + "]";
209 ········}
210
211 ········/// <summary>
212 ········/// Indicates whether the last automatically generated ID can be retrieved.
213 ········/// Returns true if a database provides automatically incremented IDs and its syntax has an expression
214 ········/// which retrieves the last generated ID; otherwise false.
215 ········/// </summary>
216 ········public override bool SupportsLastInsertedId
217 ········{
218 ············get { return true; }
219 ········}
220
221 ········/// <summary>
222 ········/// Gets an expression in the SQL dialect of the database, which retrieves the ID of the last
223 ········/// inserted row, if the ID is automatically generated by the database.
224 ········/// </summary>
225 ········/// <param name="tableName">The table name, the insert happens into.</param>
226 ········/// <param name="columnName">The column name of the autoincremented primary key column.</param>
227 ········/// <returns></returns>········
228 ········public override string GetLastInsertedId( string tableName, string columnName )
229 ········{
230 ············return "SCOPE_IDENTITY()";
231 ········}
232
233 ········/// <summary>
234 ········/// Determines whether a database supports bulk command strings.
235 ········/// </summary>
236 ········public override bool SupportsBulkCommands
237 ········{
238 ············get { return true; }
239 ········}
240
241
242 ········/// <summary>
243 ········/// Generate one big command string out of several partial commands to save roundtrips
244 ········/// to the server.
245 ········/// </summary>
246 ········/// <param name="commands"></param>
247 ········/// <returns></returns>
248 ········public override string GenerateBulkCommand( string[] commands )
249 ········{
250 ············StringBuilder sb = new StringBuilder( commands.Length * 100 );
251 ············foreach (string s in commands)
252 ············{
253 ················sb.Append( s );
254 ················sb.Append( ';' );
255 ············}
256 ············return sb.ToString();
257 ········}
258
259 ········/// <summary>
260 ········/// See <see cref="NDOInterfaces.IProvider">IProvider interface</see>.
261 ········/// </summary>
262 ········public override int MaxBulkCommandLength
263 ········{
264 ············// Der Wert ist willkürlich gesetzt. Die Query in der Größe dauert ungefähr 15s.
265 ············get { return 1280000; }
266 ········}
267
268
269
270 ········/// <summary>
271 ········/// See <see cref="IProvider"> IProvider interface </see>
272 ········/// </summary>
273 ········public override string[] GetTableNames( IDbConnection conn, string owner )
274 ········{
275 ············List<string> result = new List<string>();
276 ············string sql = "SELECT * FROM INFORMATION_SCHEMA.TABLES WHERE TABLE_TYPE = 'BASE TABLE'";
277 ············SqlCommand cmd = new SqlCommand( sql, (SqlConnection)conn );
278 ············bool wasOpen = true;
279
280 ············if (conn.State == ConnectionState.Closed)
281 ············{
282 ················wasOpen = false;
283 ················conn.Open();
284 ············}
285
286 ············SqlDataReader dr = cmd.ExecuteReader();
287 ············while (dr.Read())
288 ············{
289 ················string tbl = dr.GetString( 2 );
290 ················if (tbl != "dtproperties")
291 ····················result.Add( tbl );
292 ············}
293
294 ············dr.Close();
295
296 ············if (!wasOpen)
297 ················conn.Close();
298
299 ············return result.ToArray();
300 ········}
301
302 ········/// <summary>
303 ········/// See <see cref="IProvider"> IProvider interface </see>
304 ········/// </summary>
305 ········public override string[] TypeNames
306 ········{
307 ············get
308 ············{
309 ················return Enum.GetNames( typeof( SqlDbType ) );
310 ············}
311 ········}
312
313 ········/// <summary>
314 ········/// See <see cref="IProvider"> IProvider interface </see>
315 ········/// </summary>
316 ········public override string Name { get { return "SqlServer"; } }
317
318 ········/// <summary>
319 ········/// See <see cref="IProvider"> IProvider interface </see>
320 ········/// </summary>
321 ········public override bool SupportsNativeGuidType { get { return true; } }
322
323 ········public override bool SupportsInsertBatch
324 ········{
325 ············get
326 ············{
327 ················return true;
328 ············}
329 ········}
330
331 ········public override string CreateDatabase( string databaseName, string connectionString, object additionalData )
332 ········{
333 ············base.CreateDatabase( databaseName, connectionString, additionalData );
334 ············Regex regex = new Regex( @"Initial\sCatalog=([^\;]*)" );
335 ············Match match = regex.Match( connectionString );
336 ············if (match.Success)
337 ············{
338 ················return connectionString.Substring( 0, match.Groups[1].Index ) + GetQuotedName( databaseName ) + connectionString.Substring( match.Index + match.Length );
339 ············}
340
341 ············if (connectionString.EndsWith( ";" ))
342 ················return connectionString + "Initial Catalog=" + databaseName;
343 ············else
344 ················return connectionString + ";Initial Catalog=" + databaseName;
345 ········}
346
347 ········#endregion
348
349 ····}
350 }
351