mcs/class/System.Data/System.Data.Odbc/OdbcConnection.cs

   1 //
   2 // System.Data.Odbc.OdbcConnection
   3 //
   4 // Authors:
   5 //  Brian Ritchie (brianlritchie@hotmail.com)
   6 //
   7 // Copyright (C) Brian Ritchie, 2002
   8 //
   9
  10 //
  11 // Copyright (C) 2004 Novell, Inc (http://www.novell.com)
  12 //
  13 // Permission is hereby granted, free of charge, to any person obtaining
  14 // a copy of this software and associated documentation files (the
  15 // "Software"), to deal in the Software without restriction, including
  16 // without limitation the rights to use, copy, modify, merge, publish,
  17 // distribute, sublicense, and/or sell copies of the Software, and to
  18 // permit persons to whom the Software is furnished to do so, subject to
  19 // the following conditions:
  20 //
  21 // The above copyright notice and this permission notice shall be
  22 // included in all copies or substantial portions of the Software.
  23 //
  24 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  25 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  26 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  27 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  28 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  29 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  30 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  31 //
  32
  33 using System.ComponentModel;
  34 using System.Data;
  35 using System.Data.Common;
  36 using System.EnterpriseServices;
  37
  38 namespace System.Data.Odbc
  39 {
  40         [DefaultEvent("InfoMessage")]
  41         public sealed class OdbcConnection : Component, ICloneable, IDbConnection
  42         {
  43                 #region Fields
  44
  45                 string connectionString;
  46                 int connectionTimeout;
  47                 internal OdbcTransaction transaction;
  48                 IntPtr henv=IntPtr.Zero, hdbc=IntPtr.Zero;
  49                 bool disposed = false;
  50
  51                 #endregion
  52
  53                 #region Constructors
  54
  55                 public OdbcConnection ()
  56                 {
  57                         connectionTimeout = 15;
  58                         connectionString = null;
  59                 }
  60
  61                 public OdbcConnection (string connectionString) : this ()
  62                 {
  63                         ConnectionString = connectionString;
  64                 }
  65
  66                 #endregion // Constructors
  67
  68                 #region Properties
  69
  70                 internal IntPtr hDbc
  71                 {
  72                         get { return hdbc; }
  73                 }
  74
  75                 [OdbcCategoryAttribute ("DataCategory_Data")]
  76                 [DefaultValue ("")]
  77                 [OdbcDescriptionAttribute ("Information used to connect to a Data Source")]
  78                 [RefreshPropertiesAttribute (RefreshProperties.All)]
  79                 [EditorAttribute ("Microsoft.VSDesigner.Data.Odbc.Design.OdbcConnectionStringEditor, "+ Consts.AssemblyMicrosoft_VSDesigner, "System.Drawing.Design.UITypeEditor, "+ Consts.AssemblySystem_Drawing )]
  80                 [RecommendedAsConfigurableAttribute (true)]
  81                 public string ConnectionString {
  82                         get {
  83                                 return connectionString;
  84                         }
  85                         set {
  86                                 connectionString = value;
  87                         }
  88                 }
  89
  90                 [OdbcDescriptionAttribute ("Current connection timeout value, not settable  in the ConnectionString")]
  91                 [DefaultValue (15)]
  92                 public int ConnectionTimeout {
  93                         get {
  94                                 return connectionTimeout;
  95                         }
  96                         set {
  97                                 if (value < 0) {
  98                                         throw new ArgumentException("Timout should not be less than zero.");
  99                                 }
 100                                 connectionTimeout = value;
 101                         }
 102                 }
 103
 104 //              public string DataSource {
 105 //                      get {
 106 //                              if (State==ConnectionState.Open)
 107 //                                      return _dsn;
 108 //                              else
 109 //                                      return null;
 110 //                      }
 111 //              }
 112
 113                 [DesignerSerializationVisibilityAttribute (DesignerSerializationVisibility.Hidden)]
 114                 [OdbcDescriptionAttribute ("Current data source Catlog value, 'Database=X' in the ConnectionString")]
 115                 public string Database {
 116                         get {
 117                                 return "";
 118                         }
 119                 }
 120
 121                 [DesignerSerializationVisibilityAttribute (DesignerSerializationVisibility.Hidden)]
 122                 [OdbcDescriptionAttribute ("The ConnectionState indicating whether the connection is open or closed")]
 123                 [BrowsableAttribute (false)]
 124                 public ConnectionState State
 125                 {
 126                         get {
 127                                 if (hdbc!=IntPtr.Zero) {
 128                                         return ConnectionState.Open;
 129                                 }
 130                                 else
 131                                         return ConnectionState.Closed;
 132                         }
 133                 }
 134
 135                 [MonoTODO]
 136                 [DesignerSerializationVisibilityAttribute (DesignerSerializationVisibility.Hidden)]
 137                 [OdbcDescriptionAttribute ("Current data source, 'Server=X' in the ConnectionString")]
 138                 public string DataSource {
 139                         get {
 140                                 throw new NotImplementedException ();
 141                         }
 142                 }
 143
 144                 [MonoTODO]
 145                 [DesignerSerializationVisibilityAttribute (DesignerSerializationVisibility.Hidden)]
 146                 [OdbcDescriptionAttribute ("Current ODBC Driver")]
 147                 public string Driver {
 148                         get {
 149                                 throw new NotImplementedException ();
 150                         }
 151                 }
 152
 153                 [MonoTODO]
 154                 [DesignerSerializationVisibilityAttribute (DesignerSerializationVisibility.Hidden)]
 155                 [OdbcDescriptionAttribute ("Version of the product accessed by the ODBC Driver")]
 156                 [BrowsableAttribute (false)]
 157                 public string ServerVersion {
 158                         get {
 159                                 throw new NotImplementedException ();
 160                         }
 161                 }
 162
 163
 164                 #endregion // Properties
 165
 166                 #region Methods
 167
 168                 public OdbcTransaction BeginTransaction ()
 169                 {
 170                         return BeginTransaction(IsolationLevel.Unspecified);
 171         }
 172
 173                 IDbTransaction IDbConnection.BeginTransaction ()
 174                 {
 175                         return (IDbTransaction) BeginTransaction();
 176                 }
 177
 178                 public OdbcTransaction BeginTransaction (IsolationLevel level)
 179                 {
 180                         if (transaction==null)
 181                         {
 182                                 transaction=new OdbcTransaction(this,level);
 183                                 return transaction;
 184                         }
 185                         else
 186                                 throw new InvalidOperationException();
 187                 }
 188
 189                 IDbTransaction IDbConnection.BeginTransaction (IsolationLevel level)
 190                 {
 191                         return (IDbTransaction) BeginTransaction(level);
 192                 }
 193
 194                 public void Close ()
 195                 {
 196                         OdbcReturn ret = OdbcReturn.Error;
 197                         if (State == ConnectionState.Open) {
 198                                 // disconnect
 199                                 ret = libodbc.SQLDisconnect (hdbc);
 200                                 if ( (ret!=OdbcReturn.Success) && (ret!=OdbcReturn.SuccessWithInfo))
 201                                         throw new OdbcException (new OdbcError ("SQLDisconnect", OdbcHandleType.Dbc,hdbc));
 202
 203                                 // free handles
 204                                 if (hdbc != IntPtr.Zero) {
 205                                         ret = libodbc.SQLFreeHandle ( (ushort) OdbcHandleType.Dbc, hdbc);
 206                                         if ( (ret!=OdbcReturn.Success) && (ret!=OdbcReturn.SuccessWithInfo))
 207                                                 throw new OdbcException (new OdbcError ("SQLFreeHandle", OdbcHandleType.Dbc,hdbc));
 208                                 }
 209                                 hdbc = IntPtr.Zero;
 210
 211                                 if (henv != IntPtr.Zero) {
 212                                         ret = libodbc.SQLFreeHandle ( (ushort) OdbcHandleType.Env, henv);
 213                                         if ( (ret!=OdbcReturn.Success) && (ret!=OdbcReturn.SuccessWithInfo))
 214                                                 throw new OdbcException (new OdbcError ("SQLFreeHandle", OdbcHandleType.Env,henv));
 215                                 }
 216                                 henv = IntPtr.Zero;
 217
 218                                 transaction = null;
 219                         }
 220                 }
 221
 222                 public OdbcCommand CreateCommand ()
 223                 {
 224                         return new OdbcCommand("", this, transaction);
 225                 }
 226
 227                 [MonoTODO]
 228                 public void ChangeDatabase(string Database)
 229                 {
 230                         throw new NotImplementedException ();
 231                 }
 232
 233                 protected override void Dispose (bool disposing)
 234                 {
 235                         if (!this.disposed) {
 236                                 try
 237                                 {
 238                                         // release the native unmananged resources
 239                                         this.Close();
 240                                         this.disposed = true;
 241                                 }
 242                                 finally
 243                                 {
 244                                         // call Dispose on the base class
 245                                         base.Dispose(disposing);
 246                                 }
 247                         }
 248                 }
 249
 250                 [MonoTODO]
 251                 object ICloneable.Clone ()
 252                 {
 253                         throw new NotImplementedException();
 254                 }
 255
 256                 IDbCommand IDbConnection.CreateCommand ()
 257                 {
 258                         return (IDbCommand) CreateCommand ();
 259                 }
 260
 261                 public void Open ()
 262                 {
 263                         if (State == ConnectionState.Open)
 264                                 throw new InvalidOperationException ();
 265
 266                         OdbcReturn ret = OdbcReturn.Error;
 267
 268                         // allocate Environment handle
 269                         ret = libodbc.SQLAllocHandle (OdbcHandleType.Env, IntPtr.Zero, ref henv);
 270                         if ( (ret!=OdbcReturn.Success) && (ret!=OdbcReturn.SuccessWithInfo))
 271                                 throw new OdbcException (new OdbcError ("SQLAllocHandle"));
 272
 273                         ret=libodbc.SQLSetEnvAttr (henv, OdbcEnv.OdbcVersion, (IntPtr) libodbc.SQL_OV_ODBC3 , 0);
 274                         if ((ret!=OdbcReturn.Success) && (ret!=OdbcReturn.SuccessWithInfo))
 275                                 throw new OdbcException (new OdbcError ("SQLSetEnvAttr", OdbcHandleType.Env,henv));
 276
 277                         // allocate connection handle
 278                         ret=libodbc.SQLAllocHandle (OdbcHandleType.Dbc, henv, ref hdbc);
 279                         if ( (ret!=OdbcReturn.Success) && (ret!=OdbcReturn.SuccessWithInfo))
 280                                 throw new OdbcException (new OdbcError ("SQLAllocHandle",OdbcHandleType.Env,henv));
 281
 282                         // DSN connection
 283                         if (connectionString.ToLower().IndexOf("dsn=")>=0)
 284                         {
 285                                 string _uid="", _pwd="", _dsn="";
 286                                 string[] items=connectionString.Split(new char[1]{';'});
 287                                 foreach (string item in items)
 288                                 {
 289                                         string[] parts=item.Split(new char[1] {'='});
 290                                         switch (parts[0].Trim().ToLower())
 291                                         {
 292                                                 case "dsn":
 293                                                         _dsn=parts[1].Trim();
 294                                                         break;
 295                                                 case "uid":
 296                                                         _uid=parts[1].Trim();
 297                                                         break;
 298                                                 case "pwd":
 299                                                         _pwd=parts[1].Trim();
 300                                                         break;
 301                                         }
 302                                 }
 303                                 ret=libodbc.SQLConnect(hdbc, _dsn, -3, _uid, -3, _pwd, -3);
 304                                 if ((ret!=OdbcReturn.Success) && (ret!=OdbcReturn.SuccessWithInfo))
 305                                         throw new OdbcException(new OdbcError("SQLConnect",OdbcHandleType.Dbc,hdbc));
 306                         }
 307                         else
 308                         {
 309                                 // DSN-less Connection
 310                                 string OutConnectionString=new String(' ',1024);
 311                                 short OutLen=0;
 312                                 ret=libodbc.SQLDriverConnect(hdbc, IntPtr.Zero, connectionString, -3,
 313                                         OutConnectionString, (short) OutConnectionString.Length, ref OutLen, 0);
 314                                 if ((ret!=OdbcReturn.Success) && (ret!=OdbcReturn.SuccessWithInfo))
 315                                         throw new OdbcException(new OdbcError("SQLDriverConnect",OdbcHandleType.Dbc,hdbc));
 316                         }
 317
 318                 }
 319
 320                 [MonoTODO]
 321                 public static void ReleaseObjectPool ()
 322                 {
 323                         throw new NotImplementedException ();
 324                 }
 325
 326                 [MonoTODO]
 327                 public void EnlistDistributedTransaction ( ITransaction transaction) {
 328                         throw new NotImplementedException ();
 329                 }
 330
 331
 332                 #endregion
 333
 334                 #region Events and Delegates
 335
 336                 [OdbcDescription ("DbConnection_StateChange")]
 337                 [OdbcCategory ("DataCategory_StateChange")]
 338                 public event StateChangeEventHandler StateChange;
 339
 340                 [OdbcDescription ("DbConnection_InfoMessage")]
 341                 [OdbcCategory ("DataCategory_InfoMessage")]
 342                 public event OdbcInfoMessageEventHandler InfoMessage;
 343
 344                 #endregion
 345         }
 346 }