mcs/class/System.Data/Test/ProviderTests/System.Data.SqlClient/SqlConnectionTest.cs

   1 //
   2 // SqlConnectionTest.cs - NUnit Test Cases for testing the
   3 //                          SqlConnection class
   4 // Author:
   5 //      Senganal T (tsenganal@novell.com)
   6 //
   7 // Copyright (c) 2004 Novell Inc., and the individuals listed
   8 // on the ChangeLog entries.
   9 //
  10 // Permission is hereby granted, free of charge, to any person obtaining
  11 // a copy of this software and associated documentation files (the
  12 // "Software"), to deal in the Software without restriction, including
  13 // without limitation the rights to use, copy, modify, merge, publish,
  14 // distribute, sublicense, and/or sell copies of the Software, and to
  15 // permit persons to whom the Software is furnished to do so, subject to
  16 // the following conditions:
  17 //
  18 // The above copyright notice and this permission notice shall be
  19 // included in all copies or substantial portions of the Software.
  20 //
  21 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  22 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  23 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  24 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  25 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  26 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  27 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  28 //
  29
  30 using System;
  31 using System.Collections;
  32 using System.Data;
  33 using System.Data.SqlClient;
  34 using System.Net;
  35 using System.Threading;
  36
  37 using NUnit.Framework;
  38
  39 namespace MonoTests.System.Data.Connected.SqlClient
  40 {
  41         [TestFixture]
  42         [Category ("sqlserver")]
  43         public class SqlConnectionTest
  44         {
  45                 SqlConnection conn;
  46                 String connectionString;
  47                 ArrayList events;
  48                 EngineConfig engine;
  49
  50                 [SetUp]
  51                 public void SetUp ()
  52                 {
  53                         events = new ArrayList ();
  54                         connectionString = ConnectionManager.Instance.Sql.ConnectionString;
  55                         engine = ConnectionManager.Instance.Sql.EngineConfig;
  56                 }
  57
  58                 [TearDown]
  59                 public void TearDown ()
  60                 {
  61                         if (conn != null)
  62                                 conn.Dispose ();
  63                         if (connectionString != null)
  64                                 SqlConnection.ClearAllPools ();
  65                 }
  66
  67                 [Test]
  68                 public void OverloadedConstructorTest ()
  69                 {
  70                         //check synonyms.
  71                         //do i need to check for all the synonyms..
  72                         conn = new SqlConnection ("Timeout=10;Connect Timeout=20;Connection Timeout=30");
  73                         Assert.AreEqual (30, conn.ConnectionTimeout, "#A1");
  74                         conn = new SqlConnection ("Connect Timeout=100;Connection Timeout=200;Timeout=300");
  75                         Assert.AreEqual (300, conn.ConnectionTimeout, "#A2");
  76                         conn = new SqlConnection ("Connection Timeout=1000;Timeout=2000;Connect Timeout=3000");
  77                         Assert.AreEqual (3000, conn.ConnectionTimeout, "#A3");
  78
  79                         //'==' doesent work correctly in both msdotnet and mono
  80                         /*
  81                         conn = new SqlConnection ("server=local==host;database=tmp;");
  82                         Assert.AreEqual ("local==host", conn.DataSource,
  83                                 "# Datasource name is set incorrectly");
  84                         */
  85                         string connStr = "Server='loca\"lhost';Database='''Db'; packet Size=\"512\";"
  86                                 + "connect Timeout=20;Workstation Id=\"'\"\"desktop\";";
  87                         conn = new SqlConnection (connStr);
  88                         Assert.AreEqual (connStr , conn.ConnectionString , "#B1");
  89                         Assert.AreEqual ("loca\"lhost" , conn.DataSource , "#B2");
  90                         Assert.AreEqual ("'Db" , conn.Database , "#B3");
  91                         Assert.AreEqual (512 , conn.PacketSize , "#B4");
  92                         Assert.AreEqual (20 , conn.ConnectionTimeout , "#B5");
  93                         Assert.AreEqual ("'\"desktop" , conn.WorkstationId , "#B6");
  94                 }
  95
  96                 [Test]
  97                 public void Open ()
  98                 {
  99                         conn = new SqlConnection (connectionString);
 100                         conn.StateChange += new StateChangeEventHandler (Connection_StateChange);
 101                         conn.Open ();
 102
 103                         Assert.AreEqual (ConnectionState.Open, conn.State, "#1");
 104                         Assert.AreEqual (1, events.Count, "#2");
 105                         StateChangeEventArgs args = events [0] as StateChangeEventArgs;
 106                         Assert.IsNotNull (args, "#3");
 107                         Assert.AreEqual (ConnectionState.Closed, args.OriginalState, "#4");
 108                         Assert.AreEqual (ConnectionState.Open, args.CurrentState, "#5");
 109
 110                         conn.Close ();
 111                 }
 112
 113                 [Test]
 114                 public void Open_Connection_Open ()
 115                 {
 116                         conn = new SqlConnection (connectionString);
 117                         conn.Open ();
 118
 119                         try {
 120                                 conn.Open ();
 121                                 Assert.Fail ("#1");
 122                         } catch (InvalidOperationException ex) {
 123                                 // The connection was not closed. The connection's
 124                                 // current state is open
 125                                 Assert.AreEqual (typeof (InvalidOperationException), ex.GetType (), "#2");
 126                                 Assert.IsNull (ex.InnerException, "#3");
 127                                 Assert.IsNotNull (ex.Message, "#4");
 128                         } finally {
 129                                 conn.Close ();
 130                         }
 131                 }
 132
 133                 [Test]
 134                 public void Open_ConnectionString_LoginInvalid ()
 135                 {
 136                         // login invalid
 137                         conn = new SqlConnection (connectionString + "user id=invalidLogin");
 138                         try {
 139                                 conn.Open ();
 140                                 Assert.Fail ("#1");
 141                         } catch (SqlException ex) {
 142                                 // Login failed for user 'invalidLogin'
 143                                 Assert.AreEqual (typeof (SqlException), ex.GetType (), "#2");
 144                                 Assert.AreEqual ((byte) 14, ex.Class, "#3");
 145                                 Assert.IsNull (ex.InnerException, "#4");
 146                                 Assert.IsNotNull (ex.Message, "#5");
 147                                 Assert.AreEqual (18456, ex.Number, "#7");
 148                                 Assert.AreEqual ((byte) 1, ex.State, "#8");
 149                         } finally {
 150                                 conn.Close ();
 151                         }
 152                 }
 153
 154                 [Test]
 155                 public void Open_ConnectionString_DatabaseInvalid ()
 156                 {
 157                         conn = new SqlConnection (connectionString + "database=invalidDB");
 158                         try {
 159                                 conn.Open ();
 160                                 Assert.Fail ("#1");
 161                         } catch (SqlException ex) {
 162                                 // Cannot open database "invalidDB" requested
 163                                 // by the login. The login failed
 164                                 Assert.AreEqual (typeof (SqlException), ex.GetType (), "#2");
 165                                 Assert.AreEqual ((byte) 11, ex.Class, "#3");
 166                                 Assert.IsNull (ex.InnerException, "#4");
 167                                 Assert.IsNotNull (ex.Message, "#5");
 168                                 Assert.AreEqual (4060, ex.Number, "#7");
 169                                 Assert.AreEqual ((byte) 1, ex.State, "#8");
 170                         } finally {
 171                                 conn.Close ();
 172                         }
 173
 174                 }
 175
 176                 [Test]
 177                 public void Open_ConnectionString_PasswordInvalid ()
 178                 {
 179                         // password invalid
 180                         conn = new SqlConnection (connectionString + ";password=invalidPassword");
 181                         try {
 182                                 conn.Open ();
 183                                 Assert.Fail ("#1");
 184                         } catch (SqlException ex) {
 185                                 // Login failed for user '...'
 186                                 Assert.AreEqual (typeof (SqlException), ex.GetType (), "#2");
 187                                 Assert.AreEqual ((byte) 14, ex.Class, "#3");
 188                                 Assert.IsNull (ex.InnerException, "#4");
 189                                 Assert.IsNotNull (ex.Message, "#5");
 190                                 Assert.AreEqual (18456, ex.Number, "#6");
 191                                 Assert.AreEqual ((byte) 1, ex.State, "#7");
 192                         } finally {
 193                                 conn.Close ();
 194                         }
 195                 }
 196
 197                 [Test]
 198                 public void Open_ConnectionString_ServerInvalid ()
 199                 {
 200                         Assert.Ignore ("Long running");
 201
 202                         // server invalid
 203                         conn = new SqlConnection (connectionString + ";server=invalidServerName");
 204                         try {
 205                                 conn.Open ();
 206                                 Assert.Fail ("#1");
 207                         } catch (SqlException ex) {
 208                                 // An error has occurred while establishing a
 209                                 // connection to the server...
 210                                 Assert.AreEqual (typeof (SqlException), ex.GetType (), "#2");
 211                                 Assert.AreEqual ((byte) 20, ex.Class, "#3");
 212                                 Assert.IsNull (ex.InnerException, "#4");
 213                                 Assert.IsNotNull (ex.Message, "#5");
 214                                 Assert.AreEqual (53, ex.Number, "#6");
 215                                 Assert.AreEqual ((byte) 0, ex.State, "#7");
 216                         } finally {
 217                                 conn.Close ();
 218                         }
 219                         }
 220
 221                 [Test] // bug #383061
 222                 [Category("NotWorking")]
 223                 public void Open_MaxPoolSize_Reached ()
 224                 {
 225                         connectionString += ";Pooling=true;Connection Lifetime=6;Connect Timeout=3;Max Pool Size=2";
 226
 227                         SqlConnection conn1 = new SqlConnection (connectionString);
 228                         conn1.Open ();
 229
 230                         SqlConnection conn2 = new SqlConnection (connectionString);
 231                         conn2.Open ();
 232
 233                         DateTime start = DateTime.Now;
 234
 235                         try {
 236                                 using (SqlConnection sqlConnection = new SqlConnection (connectionString)) {
 237                                         sqlConnection.Open ();
 238                                 }
 239                                 Assert.Fail ("#A1");
 240                         } catch (InvalidOperationException ex) {
 241                                 // System.InvalidOperationException: Timeout expired.
 242                                 // The timeout period elapsed prior to obtaining a
 243                                 // connection from the pool. This may have occurred
 244                                 // because all pooled connections were in use and max
 245                                 // pool size was reached.
 246                                 Assert.AreEqual (typeof (InvalidOperationException), ex.GetType (), "#A2");
 247                                 Assert.IsNull (ex.InnerException, "#A3");
 248                                 Assert.IsNotNull (ex.Message, "#A4");
 249                         }
 250
 251                         TimeSpan elapsed = DateTime.Now - start;
 252
 253                         Assert.IsTrue (elapsed.TotalSeconds >= 3, "#B1:" + elapsed.TotalSeconds);
 254                         Assert.IsTrue (elapsed.TotalSeconds < 4, "#B2:" + elapsed.TotalSeconds);
 255
 256                         conn2.Close ();
 257
 258                         // as the second connection is closed, we should now be
 259                         // able to open a new connection (which essentially
 260                         // uses the pooled connection from conn2)
 261                         SqlConnection conn3 = new SqlConnection (connectionString);
 262                         conn3.Open ();
 263                         conn3.Close ();
 264
 265                         conn1.Close ();
 266                 }
 267
 268                 [Test] // bug #412574
 269                 public void Close ()
 270                 {
 271                         conn = new SqlConnection (connectionString);
 272                         conn.Open ();
 273                         conn.StateChange += new StateChangeEventHandler (Connection_StateChange);
 274                         conn.Close ();
 275
 276                         Assert.AreEqual (ConnectionState.Closed, conn.State, "#1");
 277                         Assert.AreEqual (1, events.Count, "#2");
 278                         StateChangeEventArgs args = events [0] as StateChangeEventArgs;
 279                         Assert.IsNotNull (args, "#3");
 280                         Assert.AreEqual (ConnectionState.Open, args.OriginalState, "#4");
 281                         Assert.AreEqual (ConnectionState.Closed, args.CurrentState, "5");
 282
 283                         conn.Close ();
 284
 285                         Assert.AreEqual (1, events.Count, "#6");
 286                 }
 287
 288                 [Test]
 289                 public void ChangeDatabase ()
 290                 {
 291                         conn = new SqlConnection(connectionString);
 292                         conn.Open();
 293
 294                         if (ConnectionManager.Instance.Sql.IsAzure)
 295                         {
 296                                 var exc = Assert.Throws<SqlException>(() => conn.ChangeDatabase("master"));
 297                                 Assert.Equals(40508, exc.Number); //USE statement is not supported to switch between databases (Azure).
 298                         }
 299                         else
 300                         {
 301                                 conn.ChangeDatabase("master");
 302                                 Assert.AreEqual("master", conn.Database);
 303                         }
 304                 }
 305
 306                 [Test]
 307                 public void ChangeDatabase_DatabaseName_DoesNotExist ()
 308                 {
 309                         if (ConnectionManager.Instance.Sql.IsAzure)
 310                                 Assert.Ignore("SQL Azure doesn't support 'ChangeDatabase'");
 311
 312                         conn = new SqlConnection (connectionString);
 313                         conn.Open ();
 314
 315                         String database = conn.Database;
 316
 317                         try {
 318                                 conn.ChangeDatabase ("doesnotexist");
 319                                 Assert.Fail ("#1");
 320                         } catch (SqlException ex) {
 321                                 // Could not locate entry in sysdatabases for
 322                                 // database 'doesnotexist'. No entry found with
 323                                 // that name. Make sure that the name is entered
 324                                 // correctly.
 325                                 Assert.AreEqual (typeof (SqlException), ex.GetType (), "#2");
 326                                 Assert.AreEqual ((byte) 16, ex.Class, "#3");
 327                                 Assert.IsNull (ex.InnerException, "#4");
 328                                 Assert.IsNotNull (ex.Message, "#5");
 329                                 Assert.IsTrue (ex.Message.IndexOf ("'doesnotexist'") != -1, "#6");
 330                                 Assert.AreEqual (911, ex.Number, "#7");
 331                                 Assert.AreEqual ((byte) 1, ex.State, "#8");
 332
 333                                 Assert.AreEqual (database, conn.Database, "#9");
 334                         } finally {
 335                                 conn.Close ();
 336                         }
 337                 }
 338
 339                 [Test]
 340                 public void ChangeDatabase_DatabaseName_Empty ()
 341                 {
 342                         conn = new SqlConnection (connectionString);
 343                         conn.Open ();
 344                         try {
 345                                 conn.ChangeDatabase (string.Empty);
 346                                 Assert.Fail ("#1");
 347                         } catch (ArgumentException ex) {
 348                                 // Database cannot be null, the empty string,
 349                                 // or string of only whitespace
 350                                 Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
 351                                 Assert.IsNull (ex.InnerException, "#3");
 352                                 Assert.IsNotNull (ex.Message, "#4");
 353                                 Assert.IsNull (ex.ParamName);
 354                         }
 355                 }
 356
 357                 [Test]
 358                 public void ChangeDatabase_DatabaseName_Null ()
 359                 {
 360                         conn = new SqlConnection (connectionString);
 361                         conn.Open ();
 362                         try {
 363                                 conn.ChangeDatabase ((string) null);
 364                                 Assert.Fail ("#1");
 365                         } catch (ArgumentException ex) {
 366                                 // Database cannot be null, the empty string,
 367                                 // or string of only whitespace
 368                                 Assert.AreEqual (typeof (ArgumentException), ex.GetType (), "#2");
 369                                 Assert.IsNull (ex.InnerException, "#3");
 370                                 Assert.IsNotNull (ex.Message, "#4");
 371                                 Assert.IsNull (ex.ParamName);
 372                         }
 373                 }
 374
 375                 [Test] // bug #412581
 376                 public void ChangeDatabase_DatabaseName_Whitespace ()
 377                 {
 378                         Assert.Ignore ("bug #412581");
 379
 380                         conn = new SqlConnection (connectionString);
 381                         conn.Open ();
 382                         try {
 383                                 conn.ChangeDatabase ("   ");
 384                                 Assert.Fail ("#1");
 385                         } catch (SqlException ex) {
 386                                 // Could not locate entry in sysdatabases for
 387                                 // database '   '. No entry found with that name.
 388                                 // Make sure that the name is entered correctly
 389                                 Assert.AreEqual (typeof (SqlException), ex.GetType (), "#2");
 390                                 Assert.AreEqual ((byte) 16, ex.Class, "#3");
 391                                 Assert.IsNull (ex.InnerException, "#4");
 392                                 Assert.IsNotNull (ex.Message, "#5");
 393                                 Assert.IsTrue (ex.Message.IndexOf ("'   '") != -1, "#6");
 394                                 Assert.AreEqual (911, ex.Number, "#7");
 395                                 Assert.AreEqual ((byte) 1, ex.State, "#8");
 396                         }
 397                 }
 398
 399                 [Test]
 400                 [Category("NotWorking")]
 401                 public void ClearAllPools ()
 402                 {
 403                         SqlConnection conn1 = new SqlConnection (connectionString + ";Pooling=false");
 404                         conn1.Open ();
 405
 406                         int initial_connection_count = GetConnectionCount (conn1);
 407
 408                         SqlConnection conn2 = new SqlConnection (connectionString + ";App=A");
 409                         conn2.Open ();
 410                         conn2.Close ();
 411
 412                         SqlConnection conn3 = new SqlConnection (connectionString + ";App=B");
 413                         conn3.Open ();
 414                         conn3.Close ();
 415
 416                         Assert.AreEqual (initial_connection_count + 2, GetConnectionCount (conn1), "#1");
 417
 418                         SqlConnection.ClearAllPools ();
 419
 420                         Assert.AreEqual (initial_connection_count, GetConnectionCount (conn1), "#2");
 421                         conn1.Close ();
 422                 }
 423
 424                 [Test] // bug #443131
 425                 [Category("NotWorking")]
 426                 public void ClearPool ()
 427                 {
 428                         SqlConnection conn1 = new SqlConnection (connectionString);
 429                         conn1.Open ();
 430
 431                         int initial_connection_count = GetConnectionCount (conn1);
 432
 433                         SqlConnection conn2 = new SqlConnection (connectionString);
 434                         conn2.Open ();
 435
 436                         SqlConnection conn3 = new SqlConnection (connectionString);
 437                         conn3.Open ();
 438                         conn3.Close ();
 439
 440                         Assert.AreEqual (initial_connection_count + 2, GetConnectionCount (conn1), "#1");
 441
 442                         SqlConnection.ClearPool (conn1);
 443
 444                         // check if pooled connections that were not in use are
 445                         // actually closed
 446                         Assert.AreEqual (initial_connection_count + 1, GetConnectionCount (conn1), "#2");
 447
 448                         conn2.Close ();
 449
 450                         // check if connections that were in use when the pool
 451                         // was cleared will not be returned to the pool when
 452                         // closed (and are closed instead)
 453                         Assert.AreEqual (initial_connection_count, GetConnectionCount (conn1), "#3");
 454
 455                         SqlConnection conn4 = new SqlConnection (connectionString);
 456                         conn4.Open ();
 457
 458                         SqlConnection conn5 = new SqlConnection (connectionString);
 459                         conn5.Open ();
 460
 461                         SqlConnection conn6 = new SqlConnection (connectionString);
 462                         conn6.Open ();
 463
 464                         Assert.AreEqual (initial_connection_count + 3, GetConnectionCount (conn1), "#4");
 465
 466                         conn5.Close ();
 467                         conn6.Close ();
 468
 469                         // check if new connections are stored in the pool again
 470                         Assert.AreEqual (initial_connection_count + 3, GetConnectionCount (conn1), "#5");
 471
 472                         conn1.Close ();
 473
 474                         Assert.AreEqual (initial_connection_count + 2, GetConnectionCount (conn4), "#6");
 475
 476                         SqlConnection.ClearPool (conn3);
 477
 478                         // the connection passed to ClearPool does not have to
 479                         // be open
 480                         Assert.AreEqual (initial_connection_count, GetConnectionCount (conn4), "#7");
 481
 482                         SqlConnection conn7 = new SqlConnection (connectionString);
 483                         conn7.Open ();
 484                         conn7.Close ();
 485
 486                         Assert.AreEqual (initial_connection_count + 1, GetConnectionCount (conn4), "#8");
 487
 488                         conn3.ConnectionString += ";App=B";
 489                         SqlConnection.ClearPool (conn3);
 490
 491                         // check if a pool is identified by its connection string
 492                         Assert.AreEqual (initial_connection_count + 1, GetConnectionCount (conn4), "#9");
 493
 494                         SqlConnection conn8 = new SqlConnection (connectionString);
 495                         SqlConnection.ClearPool (conn8);
 496
 497                         // connection should not have been opened before to
 498                         // clear the corresponding pool
 499                         Assert.AreEqual (initial_connection_count, GetConnectionCount (conn4), "#10");
 500
 501                         SqlConnection conn9 = new SqlConnection (connectionString);
 502                         conn9.Open ();
 503                         conn9.Close ();
 504
 505                         Assert.AreEqual (initial_connection_count + 1, GetConnectionCount (conn4), "#11");
 506
 507                         conn3.ConnectionString = connectionString;
 508                         SqlConnection.ClearPool (conn3);
 509
 510                         Assert.AreEqual (initial_connection_count, GetConnectionCount (conn4), "#12");
 511
 512                         SqlConnection conn10 = new SqlConnection (connectionString);
 513                         conn10.Open ();
 514
 515                         SqlConnection conn11 = new SqlConnection (connectionString + ";App=B");
 516                         conn11.Open ();
 517
 518                         SqlConnection conn12 = new SqlConnection (connectionString + ";App=B");
 519                         conn12.Open ();
 520
 521                         SqlConnection conn13 = new SqlConnection (connectionString + ";App=B");
 522                         conn13.Open ();
 523
 524                         conn10.Close ();
 525                         conn11.Close ();
 526                         conn12.Close ();
 527                         conn13.Close ();
 528
 529                         Assert.AreEqual (initial_connection_count + 4, GetConnectionCount (conn4), "#13");
 530
 531                         // check that other connection pools are not affected
 532                         SqlConnection.ClearPool (conn13);
 533
 534                         Assert.AreEqual (initial_connection_count + 1, GetConnectionCount (conn4), "#14");
 535
 536                         SqlConnection conn14 = new SqlConnection (connectionString);
 537                         conn14.Open ();
 538                         conn14.Dispose ();
 539
 540                         // a disposed connection cannot be used to clear a pool
 541                         SqlConnection.ClearPool (conn14);
 542
 543                         Assert.AreEqual (initial_connection_count + 1, GetConnectionCount (conn4), "#15");
 544
 545                         SqlConnection.ClearPool (conn4);
 546
 547                         Assert.AreEqual (initial_connection_count, GetConnectionCount (conn4), "#16");
 548
 549                         conn4.Close ();
 550                 }
 551
 552                 [Test]
 553                 public void InterfaceTransactionTest ()
 554                 {
 555                         conn = new SqlConnection (connectionString);
 556                         conn.Open ();
 557                         IDbCommand idbCommand = new SqlCommand ("use [mono-test]", conn);
 558                         idbCommand.Connection = null;
 559                         Assert.AreEqual (null, idbCommand.Connection, "Connection should be null");
 560                         idbCommand.Transaction = null;
 561                         Assert.AreEqual (null, idbCommand.Transaction, "Transaction should be null");
 562
 563                         conn.Close ();
 564                 }
 565
 566                 [Test]
 567                 public void BeginTransaction ()
 568                 {
 569                         conn = new SqlConnection (connectionString);
 570                         conn.Open ();
 571
 572                         SqlTransaction trans = conn.BeginTransaction ();
 573                         Assert.AreSame (conn, trans.Connection, "#A1");
 574                         Assert.AreEqual (IsolationLevel.ReadCommitted, trans.IsolationLevel, "#A2");
 575                         trans.Rollback ();
 576
 577                         trans = conn.BeginTransaction ();
 578
 579                         try {
 580                                 conn.BeginTransaction ();
 581                                 Assert.Fail ("#B1");
 582                         } catch (InvalidOperationException ex) {
 583                                 // SqlConnection does not support parallel transactions
 584                                 Assert.AreEqual (typeof(InvalidOperationException), ex.GetType(), "#B2");
 585                                 Assert.IsNull (ex.InnerException, "#B3");
 586                                 Assert.IsNotNull (ex.Message, "#B4");
 587                         } finally {
 588                                 trans.Rollback();
 589                         }
 590
 591                         try {
 592                                 trans = conn.BeginTransaction ();
 593                                 trans.Rollback ();
 594                                 trans = conn.BeginTransaction ();
 595                                 trans.Commit ();
 596                                 trans = conn.BeginTransaction ();
 597                         } finally {
 598                                 trans.Rollback ();
 599                         }
 600                 }
 601
 602                 [Test]
 603                 public void ConnectionString ()
 604                 {
 605                         conn = new SqlConnection (connectionString);
 606                         // Test Repeated Keyoword should take the latest value
 607                         conn.ConnectionString = conn.ConnectionString + ";server=RepeatedServer;";
 608                         Assert.AreEqual ("RepeatedServer", ((SqlConnection)conn).DataSource, "#A1");
 609                         conn.ConnectionString += ";database=gen;Initial Catalog=gen1";
 610                         Assert.AreEqual ("gen1", conn.Database, "#A2");
 611
 612                         // Test if properties are set correctly
 613                         string str = "server=localhost1;database=db;user id=user;";
 614                         str += "password=pwd;Workstation ID=workstation;Packet Size=512;";
 615                         str += "Connect Timeout=10";
 616                         conn.ConnectionString = str;
 617
 618                         Assert.AreEqual ("localhost1", conn.DataSource, "#B1");
 619                         Assert.AreEqual ("db", conn.Database, "#B2");
 620                         Assert.AreEqual (ConnectionState.Closed, conn.State, "#B3");
 621                         Assert.AreEqual ("workstation", conn.WorkstationId, "#B4");
 622                         Assert.AreEqual (512, conn.PacketSize, "#B5");
 623                         Assert.AreEqual (10, conn.ConnectionTimeout, "#B6");
 624
 625                         // Test if any leftover values exist from previous invocation
 626                         conn.ConnectionString = connectionString;
 627                         conn.ConnectionString = string.Empty;
 628                         Assert.AreEqual (string.Empty, conn.DataSource, "#C1");
 629                         Assert.AreEqual ("", conn.Database, "#C2");
 630                         Assert.AreEqual (8000, conn.PacketSize, "#C3");
 631                         Assert.AreEqual (15, conn.ConnectionTimeout, "#C4");
 632                 }
 633
 634                 [Test]
 635                 public void ConnectionString_Connection_Open ()
 636                 {
 637                         conn = new SqlConnection (connectionString);
 638                         conn.ConnectionString = connectionString;
 639                         conn.Open ();
 640                         try {
 641                                 conn.ConnectionString = "server=localhost;database=tmp;";
 642                                 Assert.Fail ("#1");
 643                         } catch (InvalidOperationException ex) {
 644                                 // Not allowed to change the 'ConnectionString'
 645                                 // property. The connection's current state is open
 646                                 Assert.AreEqual (typeof (InvalidOperationException), ex.GetType (), "#2");
 647                                 Assert.IsNull (ex.InnerException, "#3");
 648                                 Assert.IsNotNull (ex.Message, "#4");
 649                         } finally {
 650                                 conn.Close ();
 651                         }
 652                 }
 653
 654                 [Test]
 655                 public void ServerVersionTest ()
 656                 {
 657                         conn = new SqlConnection (connectionString);
 658
 659                         // Test InvalidOperation Exception is thrown if Connection is CLOSED
 660                         try {
 661                                 string s = conn.ServerVersion;
 662                                 Assert.Fail ("#A1:" + s);
 663                         } catch (InvalidOperationException ex) {
 664                                 Assert.AreEqual (typeof (InvalidOperationException), ex.GetType (), "#A2");
 665                                 Assert.IsNull (ex.InnerException, "#A3");
 666                                 Assert.IsNotNull (ex.Message, "#A4");
 667                         }
 668
 669                         // Test if Release Version is as per specification.
 670                         conn.Open ();
 671                         String [] version = conn.ServerVersion.Split ('.');
 672                         Assert.AreEqual (2, version[0].Length,
 673                                 "#B1 The Major release shud be exactly 2 characters");
 674                         Assert.AreEqual (2, version[1].Length,
 675                                 "#B2 The Minor release shud be exactly 2 characters");
 676                         Assert.AreEqual (4, version[2].Length,
 677                                 "#B3 The Release version should be exactly 4 digits");
 678                 }
 679
 680                 [Test]
 681                 public void Database ()
 682                 {
 683                         if (ConnectionManager.Instance.Sql.IsAzure)
 684                                 Assert.Ignore("SQL Azure doesn't support 'use [db]'");
 685
 686                         conn = new SqlConnection (connectionString);
 687                         string database = conn.Database;
 688
 689                         SqlCommand cmd;
 690
 691                         // Test if database property is updated when a query changes database
 692                         conn.Open ();
 693                         cmd = new SqlCommand ("use [master]" , conn);
 694                         cmd.ExecuteNonQuery ();
 695                         Assert.AreEqual ("master", conn.Database, "#1");
 696
 697                         // ensure we're really in the expected database
 698                         if (ClientVersion == 7)
 699                                 cmd.CommandText = "SELECT name FROM sysdatabases WHERE name = 'master'";
 700                         else
 701                                 cmd.CommandText = "SELECT name FROM sys.databases WHERE name = 'master'";
 702                         using (SqlDataReader dr = cmd.ExecuteReader ()) {
 703                                 Assert.IsTrue (dr.Read (), "#2");
 704                         }
 705
 706                         conn.Close ();
 707                         Assert.AreEqual (database, conn.Database, "#3");
 708
 709                         // Test if the database property is reset on re-opening the connection
 710                         conn.ConnectionString = connectionString;
 711                         conn.Open ();
 712                         Assert.AreEqual (database, conn.Database, "#4");
 713
 714                         // ensure we're really in the expected database
 715                         cmd.CommandText = "SELECT fname FROM employee WHERE id = 2";
 716                         using (SqlDataReader dr = cmd.ExecuteReader ()) {
 717                                 Assert.IsTrue (dr.Read (), "#5");
 718                                 Assert.AreEqual ("ramesh", dr.GetValue (0), "#6");
 719                         }
 720
 721                         conn.Close ();
 722                 }
 723
 724                 [Test]
 725                 [Category("NotWorking")] //https://github.com/dotnet/corefx/issues/22871
 726                 public void WorkstationId()
 727                 {
 728                         var connection1 = new SqlConnection (connectionString + ";Workstation Id=Desktop");
 729                         var connection2 = new SqlConnection (connectionString);
 730                         connection1.Dispose();
 731                         Assert.AreEqual (Environment.MachineName, connection1.WorkstationId);
 732                         Assert.AreEqual (Environment.MachineName, connection2.WorkstationId);
 733                 }
 734
 735                 [Test] // bug #412571
 736                 public void Dispose ()
 737                 {
 738                         StateChangeEventArgs stateChangeArgs;
 739                         EventArgs disposedArgs;
 740
 741                         conn = new SqlConnection (connectionString + ";Connection Timeout=30;Packet Size=512;Workstation Id=Desktop");
 742                         conn.Disposed += new EventHandler (Connection_Disposed);
 743                         conn.Open ();
 744                         conn.StateChange += new StateChangeEventHandler (Connection_StateChange);
 745                         Assert.AreEqual (0, events.Count, "#A1");
 746                         conn.Dispose ();
 747                         Assert.AreEqual (string.Empty, conn.ConnectionString, "#A2");
 748                         Assert.AreEqual (15, conn.ConnectionTimeout, "#A3");
 749                         Assert.AreEqual (string.Empty, conn.Database, "#A4");
 750                         Assert.AreEqual (string.Empty, conn.DataSource, "#A5");
 751                         Assert.AreEqual (8000, conn.PacketSize, "#A6");
 752                         Assert.AreEqual (ConnectionState.Closed, conn.State, "#A7");
 753                         Assert.AreEqual (2, events.Count, "#A9");
 754
 755                         stateChangeArgs = events [0] as StateChangeEventArgs;
 756                         Assert.IsNotNull (stateChangeArgs, "#B1");
 757                         Assert.AreEqual (typeof (StateChangeEventArgs), stateChangeArgs.GetType (), "#B2");
 758                         Assert.AreEqual (ConnectionState.Open, stateChangeArgs.OriginalState, "#B3");
 759                         Assert.AreEqual (ConnectionState.Closed, stateChangeArgs.CurrentState, "B4");
 760
 761                         disposedArgs = events [1] as EventArgs;
 762                         Assert.IsNotNull (disposedArgs, "#C1");
 763                         Assert.AreEqual (typeof (EventArgs), disposedArgs.GetType (), "#C2");
 764
 765                         conn.Dispose ();
 766
 767                         Assert.AreEqual (ConnectionState.Closed, conn.State, "#D1");
 768                         Assert.AreEqual (3, events.Count, "#D2");
 769
 770                         disposedArgs = events [2] as EventArgs;
 771                         Assert.IsNotNull (disposedArgs, "#E1");
 772                         Assert.AreEqual (typeof (EventArgs), disposedArgs.GetType (), "#E2");
 773                 }
 774
 775                 void Connection_StateChange (object sender , StateChangeEventArgs e)
 776                 {
 777                         events.Add (e);
 778                 }
 779
 780                 void Connection_Disposed (object sender , EventArgs e)
 781                 {
 782                         events.Add (e);
 783                 }
 784
 785                 [Test]
 786                 public void FireInfoMessageEventOnUserErrorsTest ()
 787                 {
 788                         conn = new SqlConnection ();
 789                         Assert.AreEqual(false, conn.FireInfoMessageEventOnUserErrors, "#1 The default value should be false");
 790                         conn.FireInfoMessageEventOnUserErrors = true;
 791                         Assert.AreEqual(true, conn.FireInfoMessageEventOnUserErrors, "#1 The value should be true after setting the property to true");
 792                 }
 793
 794                 [Test]
 795                 public void StatisticsEnabledTest ()
 796                 {
 797                         conn = new SqlConnection ();
 798                         Assert.AreEqual(false, conn.StatisticsEnabled, "#1 The default value should be false");
 799                         conn.StatisticsEnabled = true;
 800                         Assert.AreEqual(true, conn.StatisticsEnabled, "#1 The value should be true after setting the property to true");
 801                 }
 802
 803                 [Test]
 804                 [Category("NotWorking")]
 805                 public void ChangePasswordTest ()
 806                 {
 807                         string tmpPassword = "modifiedbymonosqlclient";
 808                         SqlConnection.ChangePassword (connectionString, tmpPassword);
 809                         SqlConnectionStringBuilder connBuilder = new SqlConnectionStringBuilder (connectionString);
 810                         string oldPassword = connBuilder.Password;
 811                         connBuilder.Password = tmpPassword;
 812                         SqlConnection.ChangePassword (connBuilder.ConnectionString, oldPassword); // Modify to the original password
 813                 }
 814
 815                 static int GetConnectionCount (SqlConnection conn)
 816                 {
 817                         Thread.Sleep (200);
 818
 819                         SqlCommand cmd = conn.CreateCommand ();
 820                         cmd.CommandText = "select count(*) from master..sysprocesses where db_name(dbid) = @dbname";
 821                         cmd.Parameters.Add (new SqlParameter ("@dbname", conn.Database));
 822                         int connection_count = (int) cmd.ExecuteScalar ();
 823                         cmd.Dispose ();
 824
 825                         return connection_count;
 826                 }
 827
 828                 int ClientVersion {
 829                         get {
 830                                 return (engine.ClientVersion);
 831                         }
 832                 }
 833         }
 834
 835         [TestFixture]
 836         [Category ("sqlserver")]
 837         public class GetSchemaTest
 838         {
 839                 SqlConnection conn = null;
 840                 String connectionString = ConnectionManager.Instance.Sql.ConnectionString;
 841
 842                 [SetUp]
 843                 public void SetUp()
 844                 {
 845                         conn = new SqlConnection(connectionString);
 846                         conn.Open();
 847                 }
 848
 849                 [TearDown]
 850                 public void TearDown()
 851                 {
 852                         conn?.Close();
 853                 }
 854
 855                 [Test]
 856                 public void GetSchemaTest1()
 857                 {
 858                         if (ConnectionManager.Instance.Sql.IsAzure)
 859                                 Assert.Ignore("SQL Azure - Not supported'");
 860
 861                         bool flag = false;
 862                         DataTable tab1 = conn.GetSchema("databases");
 863                         foreach (DataRow row in tab1.Rows)
 864                         {
 865                                 foreach (DataColumn col in tab1.Columns)
 866                                 {
 867                                         if (col.ColumnName.ToString() == "database_name" && row[col].ToString() == ConnectionManager.Instance.DatabaseName)
 868                                         {
 869                                                 flag = true;
 870                                                 break;
 871                                         }
 872                                 }
 873                                 if (flag)
 874                                         break;
 875                         }
 876                         Assert.AreEqual(true, flag, "#GS1 failed");
 877                 }
 878
 879                 [Test]
 880                 [ExpectedException(typeof(ArgumentException))]
 881                 public void GetSchemaTest2()
 882                 {
 883                         conn.GetSchema(null);
 884                 }
 885
 886                 [Test]
 887                 public void GetSchemaTest3 ()
 888                 {
 889                         Assert.Ignore ("We currently have no foreign keys defined in the test database");
 890
 891                         bool flag = false;
 892                         DataTable tab1 = conn.GetSchema("ForeignKeys");
 893                         foreach (DataRow row in tab1.Rows)
 894                         {
 895                                 foreach (DataColumn col in tab1.Columns)
 896                                 {
 897                                         /*
 898                                          * We need to consider multiple values
 899                                          */
 900                                         if (col.ColumnName.ToString() == "TABLE_NAME" && row[col].ToString() == "tmptable1")
 901                                         {
 902                                                 flag = true;
 903                                                 break;
 904                                         }
 905                                 }
 906                                 if (flag)
 907                                         break;
 908                         }
 909                         Assert.AreEqual(true, flag, "#GS3 failed");
 910                 }
 911
 912                 [Test]
 913                 public void GetSchemaTest4()
 914                 {
 915                         bool flag = false;
 916                         DataTable tab1 = conn.GetSchema("Indexes");
 917                         foreach (DataRow row in tab1.Rows)
 918                         {
 919                                 foreach (DataColumn col in tab1.Columns)
 920                                 {
 921                                         /*
 922                                          * We need to consider multiple values
 923                                          */
 924                                         if (col.ColumnName.ToString() == "table_name" && row[col].ToString() == "binary_family")
 925                                         {
 926                                                 flag = true;
 927                                                 break;
 928                                         }
 929                                 }
 930                                 if (flag)
 931                                         break;
 932                         }
 933                         Assert.AreEqual(true, flag, "#GS4 failed");
 934                 }
 935
 936                 [Test]
 937                 public void GetSchemaTest5()
 938                 {
 939                         bool flag = false;
 940                         DataTable tab1 = conn.GetSchema("IndexColumns");
 941                         foreach (DataRow row in tab1.Rows)
 942                         {
 943                                 foreach (DataColumn col in tab1.Columns)
 944                                 {
 945                                         /*
 946                                          * We need to consider multiple values
 947                                          */
 948                                         if (col.ColumnName.ToString() == "table_name" && row[col].ToString() == "binary_family")
 949                                         {
 950                                                 flag = true;
 951                                                 break;
 952                                         }
 953                                 }
 954                                 if (flag)
 955                                         break;
 956                         }
 957                         Assert.AreEqual(true, flag, "#GS5 failed");
 958                 }
 959
 960                 [Test]
 961                 public void GetSchemaTest6()
 962                 {
 963                         bool flag = false;
 964                         DataTable tab1 = conn.GetSchema("Procedures");
 965                         foreach (DataRow row in tab1.Rows)
 966                         {
 967                                 foreach (DataColumn col in tab1.Columns)
 968                                 {
 969                                         /*
 970                                          * We need to consider multiple values
 971                                          */
 972                                         if (col.ColumnName.ToString() == "SPECIFIC_NAME" && row[col].ToString() == "sp_get_age")
 973                                         {
 974                                                 flag = true;
 975                                                 break;
 976                                         }
 977                                 }
 978                                 if (flag)
 979                                         break;
 980                         }
 981                         Assert.AreEqual(true, flag, "#GS6 failed");
 982                 }
 983
 984                 [Test]
 985                 public void GetSchemaTest7()
 986                 {
 987                         bool flag = false;
 988                         DataTable tab1 = conn.GetSchema("ProcedureParameters");
 989                         foreach (DataRow row in tab1.Rows)
 990                         {
 991                                 foreach (DataColumn col in tab1.Columns)
 992                                 {
 993                                         /*
 994                                          * We need to consider multiple values
 995                                          */
 996                                         if (col.ColumnName.ToString() == "SPECIFIC_NAME" && row[col].ToString() == "sp_get_age")
 997                                         {
 998                                                 flag = true;
 999                                                 break;
1000                                         }
1001                                 }
1002                                 if (flag)
1003                                         break;
1004                         }
1005                         Assert.AreEqual(true, flag, "#GS7 failed");
1006                 }
1007
1008                 [Test]
1009                 public void GetSchemaTest8()
1010                 {
1011                         bool flag = false;
1012                         DataTable tab1 = conn.GetSchema("Tables");
1013                         foreach (DataRow row in tab1.Rows)
1014                         {
1015                                 foreach (DataColumn col in tab1.Columns)
1016                                 {
1017                                         /*
1018                                          * We need to consider multiple values
1019                                          */
1020                                         if (col.ColumnName.ToString() == "TABLE_NAME" && row[col].ToString() == "binary_family")
1021                                         {
1022                                                 flag = true;
1023                                                 break;
1024                                         }
1025                                 }
1026                                 if (flag)
1027                                         break;
1028                         }
1029                         Assert.AreEqual(true, flag, "#GS8 failed");
1030                 }
1031
1032                 [Test]
1033                 public void GetSchemaTest9()
1034                 {
1035                         if (ConnectionManager.Instance.Sql.IsAzure)
1036                                 Assert.Ignore("SQL Azure - Not supported'");
1037
1038                         bool flag = false;
1039                         DataTable tab1 = conn.GetSchema("Columns");
1040                         foreach (DataRow row in tab1.Rows)
1041                         {
1042                                 foreach (DataColumn col in tab1.Columns)
1043                                 {
1044                                         /*
1045                                          * We need to consider multiple values
1046                                          */
1047                                         if (col.ColumnName.ToString() == "TABLE_NAME" && row[col].ToString() == "binary_family")
1048                                         {
1049                                                 flag = true;
1050                                                 break;
1051                                         }
1052                                 }
1053                                 if (flag)
1054                                         break;
1055                         }
1056                         Assert.AreEqual(true, flag, "#GS9 failed");
1057                 }
1058
1059                 [Test]
1060                 public void GetSchemaTest10()
1061                 {
1062                         bool flag = false;
1063                         DataTable tab1 = conn.GetSchema("Users");
1064                         foreach (DataRow row in tab1.Rows)
1065                         {
1066                                 foreach (DataColumn col in tab1.Columns)
1067                                 {
1068                                         /*
1069                                          * We need to consider multiple values
1070                                          */
1071                                         if (col.ColumnName.ToString() == "user_name" && row[col].ToString() == "public")
1072                                         {
1073                                                 flag = true;
1074                                                 break;
1075                                         }
1076                                 }
1077                                 if (flag)
1078                                         break;
1079                         }
1080                         Assert.AreEqual(true, flag, "#GS10 failed");
1081                 }
1082
1083                 [Test]
1084                 public void GetSchemaTest11 ()
1085                 {
1086                         Assert.Ignore ("Incorrect syntax near 'TABLE_SCHEMA'");
1087
1088                         bool flag = false;
1089                         DataTable tab1 = conn.GetSchema("Views");
1090                         flag = true; // FIXME: Currently MS-SQL 2005 returns empty table. Remove this flag ASAP.
1091                         foreach (DataRow row in tab1.Rows)
1092                         {
1093                                 foreach (DataColumn col in tab1.Columns)
1094                                 {
1095                                         /*
1096                                          * We need to consider multiple values.
1097                                          */
1098                                         if (col.ColumnName.ToString() == "user_name" && row[col].ToString() == "public")
1099                                         {
1100                                                 flag = true;
1101                                                 break;
1102                                         }
1103                                 }
1104                                 if (flag)
1105                                         break;
1106                         }
1107                         Assert.AreEqual(true, flag, "#GS11 failed");
1108                 }
1109
1110                 [Test]
1111                 public void GetSchemaTest12 ()
1112                 {
1113                         Assert.Ignore ("Incorrect syntax near '('");
1114
1115                         bool flag = false;
1116                         DataTable tab1 = conn.GetSchema("ViewColumns");
1117                         flag = true; // FIXME: Currently MS-SQL 2005 returns empty table. Remove this flag ASAP.
1118                         foreach (DataRow row in tab1.Rows)
1119                         {
1120                                 foreach (DataColumn col in tab1.Columns)
1121                                 {
1122                                         /*
1123                                          * We need to consider multiple values.
1124                                          */
1125                                         if (col.ColumnName.ToString() == "user_name" && row[col].ToString() == "public")
1126                                         {
1127                                                 flag = true;
1128                                                 break;
1129                                         }
1130                                 }
1131                                 if (flag)
1132                                         break;
1133                         }
1134                         Assert.AreEqual(true, flag, "#GS12 failed");
1135                 }
1136
1137                 [Test]
1138                 public void GetSchemaTest13 ()
1139                 {
1140                         Assert.Ignore ("The multi-part identifier \"assportemblies.name\" could not be bound");
1141
1142                         bool flag = false;
1143                         DataTable tab1 = conn.GetSchema("UserDefinedTypes");
1144                         flag = true; // FIXME: Currently MS-SQL 2005 returns empty table. Remove this flag ASAP.
1145                         foreach (DataRow row in tab1.Rows)
1146                         {
1147                                 foreach (DataColumn col in tab1.Columns)
1148                                 {
1149                                         /*
1150                                          * We need to consider multiple values.
1151                                          */
1152                                         if (col.ColumnName.ToString() == "user_name" && row[col].ToString() == "public")
1153                                         {
1154                                                 flag = true;
1155                                                 break;
1156                                         }
1157                                 }
1158                                 if (flag)
1159                                         break;
1160                         }
1161                         Assert.AreEqual(true, flag, "#GS13 failed");
1162                 }
1163
1164                 [Test]
1165                 [Ignore("TODO: fix restrictions")]
1166                 public void GetSchemaTest14()
1167                 {
1168                         bool flag = false;
1169                         string [] restrictions = new string[4];
1170
1171                         restrictions[0] = ConnectionManager.Instance.DatabaseName;
1172                         restrictions[1] = "dbo";
1173                         restrictions[2] = null;
1174                         restrictions[3] = "BASE TABLE";
1175                         DataTable tab1 = conn.GetSchema("Tables", restrictions);
1176                         foreach (DataRow row in tab1.Rows)
1177                         {
1178                                 foreach (DataColumn col in tab1.Columns)
1179                                 {
1180                                         /*
1181                                          * We need to consider multiple values
1182                                          */
1183                                         if (col.ColumnName.ToString() == "TABLE_NAME" && row[col].ToString() == "binary_family")
1184                                         {
1185                                                 flag = true;
1186                                                 break;
1187                                         }
1188                                 }
1189                                 if (flag)
1190                                         break;
1191                         }
1192                         Assert.AreEqual(true, flag, "#GS14 failed");
1193                 }
1194
1195                 [Test]
1196                 [Ignore("TODO: fix restrictions")]
1197                 public void GetSchemaTest15()
1198                 {
1199                         bool flag = false;
1200                         string [] restrictions = new string[4];
1201
1202                         restrictions[0] = ConnectionManager.Instance.DatabaseName;
1203                         restrictions[1] = null;
1204                         restrictions[2] = "binary_family";
1205                         restrictions[3] = null;
1206                         DataTable tab1 = conn.GetSchema("IndexColumns", restrictions);
1207                         foreach (DataRow row in tab1.Rows)
1208                         {
1209                                 foreach (DataColumn col in tab1.Columns)
1210                                 {
1211                                         /*
1212                                          * We need to consider multiple values
1213                                          */
1214                                         if (col.ColumnName.ToString() == "table_name" && row[col].ToString() == "binary_family")
1215                                         {
1216                                                 flag = true;
1217                                                 break;
1218                                         }
1219                                 }
1220                                 if (flag)
1221                                         break;
1222                         }
1223                         Assert.AreEqual(true, flag, "#GS15 failed");
1224                 }
1225
1226                 [Test]
1227                 [Ignore("TODO: fix restrictions")]
1228                 public void GetSchemaTest16()
1229                 {
1230                         bool flag = false;
1231                         string [] restrictions = new string[4];
1232
1233                         restrictions[0] = ConnectionManager.Instance.DatabaseName;
1234                         restrictions[1] = null;
1235                         restrictions[2] = "sp_get_age";
1236                         restrictions[3] = null;
1237                         DataTable tab1 = conn.GetSchema("Procedures", restrictions);
1238                         foreach (DataRow row in tab1.Rows)
1239                         {
1240                                 foreach (DataColumn col in tab1.Columns)
1241                                 {
1242                                         /*
1243                                          * We need to consider multiple values
1244                                          */
1245                                         if (col.ColumnName.ToString() == "ROUTINE_NAME" && row[col].ToString() == "sp_get_age")
1246                                         {
1247                                                 flag = true;
1248                                                 break;
1249                                         }
1250                                 }
1251                                 if (flag)
1252                                         break;
1253                         }
1254                         Assert.AreEqual(true, flag, "#GS16 failed");
1255                 }
1256
1257                 [Test]
1258                 public void GetSchemaTest17()
1259                 {
1260                         bool flag = false;
1261                         DataTable tab1 = conn.GetSchema();
1262                         foreach (DataRow row in tab1.Rows)
1263                         {
1264                                 foreach (DataColumn col in tab1.Columns)
1265                                 {
1266                                         /*
1267                                          * We need to consider multiple values
1268                                          */
1269                                         if (col.ColumnName.ToString() == "CollectionName" && row[col].ToString() == "UserDefinedTypes")
1270                                         {
1271                                                 flag = true;
1272                                                 break;
1273                                         }
1274                                 }
1275                                 if (flag)
1276                                         break;
1277                         }
1278                         Assert.AreEqual(true, flag, "#GS17 failed");
1279                 }
1280
1281                 [Test]
1282                 public void GetSchemaTest18()
1283                 {
1284                         bool flag = false;
1285                         DataTable tab1 = conn.GetSchema("RESTRICTIONS");
1286                         foreach (DataRow row in tab1.Rows)
1287                         {
1288                                 foreach (DataColumn col in tab1.Columns)
1289                                 {
1290                                         /*
1291                                          * We need to consider multiple values
1292                                          */
1293                                         if (col.ColumnName.ToString() == "RestrictionDefault" && row[col].ToString() == "CONSTRAINT_NAME")
1294                                         {
1295                                                 flag = true;
1296                                                 break;
1297                                         }
1298                                 }
1299                                 if (flag)
1300                                         break;
1301                         }
1302                         Assert.AreEqual(true, flag, "#GS18 failed");
1303                 }
1304
1305                 [Test]
1306                 [ExpectedException (typeof (ArgumentException))]
1307                 public void GetSchemaTest19 ()
1308                 {
1309                         String [] restrictions = new String[1];
1310                         conn.GetSchema("RESTRICTIONS", restrictions);
1311                 }
1312
1313                 [Test]
1314                 public void GetSchemaTest20 ()
1315                 {
1316                         bool flag = false;
1317                         DataTable tab1 = conn.GetSchema("DataTypes");
1318                         foreach (DataRow row in tab1.Rows)
1319                         {
1320                                 foreach (DataColumn col in tab1.Columns)
1321                                 {
1322                                         /*
1323                                          * We need to consider multiple values
1324                                          */
1325                                         if (col.ColumnName.ToString() == "TypeName" && row[col].ToString() == "uniqueidentifier")
1326                                         {
1327                                                 flag = true;
1328                                                 break;
1329                                         }
1330                                 }
1331                                 if (flag)
1332                                         break;
1333                         }
1334                         Assert.AreEqual(true, flag, "#GS20 failed");
1335                 }
1336
1337                 [Test]
1338                 public void GetSchemaTest21()
1339                 {
1340                         bool flag = false;
1341                         DataTable tab1 = conn.GetSchema();
1342                         foreach (DataRow row in tab1.Rows)
1343                         {
1344                                 foreach (DataColumn col in tab1.Columns)
1345                                 {
1346                                         /*
1347                                          * We need to consider multiple values
1348                                          */
1349                                         if (col.ColumnName.ToString() == "CollectionName" && row[col].ToString() == "UserDefinedTypes")
1350                                         {
1351                                                 flag = true;
1352                                                 break;
1353                                         }
1354                                 }
1355                                 if (flag)
1356                                         break;
1357                         }
1358                         Assert.AreEqual(true, flag, "#GS21 failed");
1359                 }
1360                 [Test]
1361                 public void GetSchemaTest22()
1362                 {
1363                         bool flag = false;
1364                         DataTable tab1 = conn.GetSchema("ReservedWords");
1365                         foreach (DataRow row in tab1.Rows)
1366                         {
1367                                 foreach (DataColumn col in tab1.Columns)
1368                                 {
1369                                         /*
1370                                          * We need to consider multiple values
1371                                          */
1372                                         if (col.ColumnName.ToString() == "ReservedWord" && row[col].ToString() == "UPPER")
1373                                         {
1374                                                 flag = true;
1375                                                 break;
1376                                         }
1377                                 }
1378                                 if (flag)
1379                                         break;
1380                         }
1381                         Assert.AreEqual(true, flag, "#GS22 failed");
1382                 }
1383
1384                 [Test]
1385                 public void GetSchemaTest23()
1386                 {
1387                         bool flag = false;
1388                         DataTable tab1 = conn.GetSchema("ReservedWords");
1389                         foreach (DataRow row in tab1.Rows)
1390                         {
1391                                 foreach (DataColumn col in tab1.Columns)
1392                                 {
1393                                         /*
1394                                          * We need to consider multiple values
1395                                          */
1396                                         if (col.ColumnName.ToString() == "ReservedWord" && row[col].ToString() == "upper")
1397                                         {
1398                                                 flag = true;
1399                                                 break;
1400                                         }
1401                                 }
1402                                 if (flag)
1403                                         break;
1404                         }
1405                         Assert.AreEqual(false, flag, "#GS23 failed");
1406                 }
1407
1408                 [Test]
1409                 public void GetSchemaTest24()
1410                 {
1411                         bool flag = false;
1412                         string [] restrictions = new string[4];
1413
1414                         restrictions[0] = ConnectionManager.Instance.DatabaseName;
1415                         restrictions[1] = null;
1416                         restrictions[2] = "sp_get_age";
1417                         restrictions[3] = null;
1418                         DataTable tab1 = conn.GetSchema("Procedures", restrictions);
1419                         foreach (DataRow row in tab1.Rows)
1420                         {
1421                                 foreach (DataColumn col in tab1.Columns)
1422                                 {
1423                                         /*
1424                                          * We need to consider multiple values
1425                                          */
1426                                         if (col.ColumnName.ToString() == "ROUTINE_NAME" && row[col].ToString() == "mono")
1427                                         {
1428                                                 flag = true;
1429                                                 break;
1430                                         }
1431                                 }
1432                                 if (flag)
1433                                         break;
1434                         }
1435                         Assert.AreEqual(false, flag, "#GS24 failed");
1436                 }
1437
1438                 [Test]
1439                 [ExpectedException (typeof (ArgumentException))]
1440                 public void GetSchemaTest25 ()
1441                 {
1442                         String [] restrictions = new String [1];
1443                         conn.GetSchema ("Mono", restrictions);
1444                 }
1445         }
1446 }