mcs/class/System.Data.OracleClient/System.Data.OracleClient/OracleConnection.cs

   1 //
   2 // OracleConnection.cs
   3 //
   4 // Part of the Mono class libraries at
   5 // mcs/class/System.Data.OracleClient/System.Data.OracleClient
   6 //
   7 // Assembly: System.Data.OracleClient.dll
   8 // Namespace: System.Data.OracleClient
   9 //
  10 // Authors:
  11 //    Daniel Morgan <danmorg@sc.rr.com>
  12 //    Tim Coleman <tim@timcoleman.com>
  13 //
  14 // Copyright (C) Daniel Morgan, 2002
  15 // Copyright (C) Tim Coleman, 2003
  16 //
  17 // Original source code for setting ConnectionString
  18 // by Tim Coleman <tim@timcoleman.com>
  19 //
  20 // Copyright (C) Tim Coleman, 2002
  21 //
  22 // Licensed under the MIT/X11 License.
  23 //
  24
  25 using System;
  26 using System.Collections;
  27 using System.Collections.Specialized;
  28 using System.ComponentModel;
  29 using System.Data;
  30 using System.Data.OracleClient.Oci;
  31 using System.Drawing.Design;
  32 using System.EnterpriseServices;
  33 using System.Text;
  34
  35 namespace System.Data.OracleClient
  36 {
  37         internal struct OracleConnectionInfo
  38         {
  39                 public string Username;
  40                 public string Password;
  41                 public string Database;
  42         }
  43
  44         [DefaultEvent ("InfoMessage")]
  45         public sealed class OracleConnection : Component, ICloneable, IDbConnection
  46         {
  47                 #region Fields
  48
  49                 OciGlue oci;
  50                 ConnectionState state;
  51                 OracleConnectionInfo conInfo;
  52                 OracleTransaction transaction = null;
  53                 string connectionString = "";
  54                 OracleDataReader dataReader = null;
  55
  56                 #endregion // Fields
  57
  58                 #region Constructors
  59
  60                 public OracleConnection ()
  61                 {
  62                         state = ConnectionState.Closed;
  63                         oci = new OciGlue ();
  64                 }
  65
  66                 public OracleConnection (string connectionString)
  67                         : this()
  68                 {
  69                         SetConnectionString (connectionString);
  70                 }
  71
  72                 #endregion // Constructors
  73
  74                 #region Properties
  75
  76                 int IDbConnection.ConnectionTimeout {
  77                         [MonoTODO]
  78                         get { return -1; }
  79                 }
  80
  81                 string IDbConnection.Database {
  82                         [MonoTODO]
  83                         get { return String.Empty; }
  84                 }
  85
  86                 internal OracleDataReader DataReader {
  87                         get { return dataReader; }
  88                         set { dataReader = value; }
  89                 }
  90
  91                 internal OciEnvironmentHandle Environment {
  92                         get { return oci.Environment; }
  93                 }
  94
  95                 internal OciErrorHandle ErrorHandle {
  96                         get { return oci.ErrorHandle; }
  97                 }
  98
  99                 internal OciServiceHandle ServiceContext {
 100                         get { return oci.ServiceContext; }
 101                 }
 102
 103                 [MonoTODO]
 104                 [DesignerSerializationVisibility (DesignerSerializationVisibility.Hidden)]
 105                 public string DataSource {
 106                         get {
 107                                 throw new NotImplementedException ();
 108                         }
 109                 }
 110
 111                 [Browsable (false)]
 112                 [DesignerSerializationVisibility (DesignerSerializationVisibility.Hidden)]
 113                 public ConnectionState State {
 114                         get { return state; }
 115                 }
 116
 117                 [DefaultValue ("")]
 118                 [RecommendedAsConfigurable (true)]
 119                 [RefreshProperties (RefreshProperties.All)]
 120                 [Editor ("Microsoft.VSDesigner.Data.Oracle.Design.OracleConnectionStringEditor, " + Consts.AssemblyMicrosoft_VSDesigner, typeof(UITypeEditor))]
 121                 public string ConnectionString {
 122                         get { return connectionString; }
 123                         set { SetConnectionString (value); }
 124                 }
 125
 126                 [MonoTODO]
 127                 [Browsable (false)]
 128                 [DesignerSerializationVisibility (DesignerSerializationVisibility.Hidden)]
 129                 public string ServerVersion {
 130                         get {
 131                                 throw new NotImplementedException ();
 132                         }
 133                 }
 134
 135                 internal OciGlue Oci {
 136                         get { return oci; }
 137                 }
 138
 139                 internal OracleTransaction Transaction {
 140                         get { return transaction; }
 141                         set { transaction = value; }
 142                 }
 143
 144                 #endregion // Properties
 145
 146                 #region Methods
 147
 148                 public OracleTransaction BeginTransaction ()
 149                 {
 150                         return BeginTransaction (IsolationLevel.ReadCommitted);
 151                 }
 152
 153                 public OracleTransaction BeginTransaction (IsolationLevel il)
 154                 {
 155                         if (state == ConnectionState.Closed)
 156                                 throw new InvalidOperationException ("The connection is not open.");
 157                         if (transaction != null)
 158                                 throw new InvalidOperationException ("OracleConnection does not support parallel transactions.");
 159
 160                         OciTransactionHandle transactionHandle = oci.CreateTransaction ();
 161                         if (transactionHandle == null)
 162                                 throw new Exception("Error: Unable to start transaction");
 163                         else {
 164                                 transactionHandle.Begin ();
 165                                 transaction = new OracleTransaction (this, il, transactionHandle);
 166                         }
 167
 168                         return transaction;
 169                 }
 170
 171                 [MonoTODO]
 172                 void IDbConnection.ChangeDatabase (string databaseName)
 173                 {
 174                         throw new NotImplementedException ();
 175                 }
 176
 177                 public OracleCommand CreateCommand ()
 178                 {
 179                         OracleCommand command = new OracleCommand ();
 180                         command.Connection = this;
 181                         return command;
 182                 }
 183
 184                 [MonoTODO]
 185                 object ICloneable.Clone ()
 186                 {
 187                         throw new NotImplementedException ();
 188                 }
 189
 190                 IDbTransaction IDbConnection.BeginTransaction ()
 191                 {
 192                         return BeginTransaction ();
 193                 }
 194
 195                 IDbTransaction IDbConnection.BeginTransaction (IsolationLevel iso)
 196                 {
 197                         return BeginTransaction (iso);
 198                 }
 199
 200                 IDbCommand IDbConnection.CreateCommand ()
 201                 {
 202                         return CreateCommand ();
 203                 }
 204
 205                 void IDisposable.Dispose ()
 206                 {
 207                         Dispose (true);
 208                         GC.SuppressFinalize (this);
 209                 }
 210
 211                 [MonoTODO]
 212                 protected override void Dispose (bool disposing)
 213                 {
 214                         base.Dispose (disposing);
 215                 }
 216
 217                 [MonoTODO]
 218                 public void EnlistDistributedTransaction (ITransaction distributedTransaction)
 219                 {
 220                         throw new NotImplementedException ();
 221                 }
 222
 223                 public void Open ()
 224                 {
 225                         oci.CreateConnection (conInfo);
 226                         state = ConnectionState.Open;
 227                 }
 228
 229                 public void Close ()
 230                 {
 231                         if (transaction != null)
 232                                 transaction.Rollback ();
 233
 234                         oci.Disconnect ();
 235                         state = ConnectionState.Closed;
 236                 }
 237
 238
 239                 void SetConnectionString (string connectionString)
 240                 {
 241                         this.connectionString = connectionString;
 242                         conInfo.Username = "";
 243                         conInfo.Database = "";
 244                         conInfo.Password = "";
 245
 246                         if (connectionString == String.Empty)
 247                                 return;
 248
 249                         connectionString += ";";
 250                         NameValueCollection parameters = new NameValueCollection ();
 251
 252                         bool inQuote = false;
 253                         bool inDQuote = false;
 254
 255                         string name = String.Empty;
 256                         string value = String.Empty;
 257                         StringBuilder sb = new StringBuilder ();
 258
 259                         foreach (char c in connectionString) {
 260                                 switch (c) {
 261                                 case '\'':
 262                                         inQuote = !inQuote;
 263                                         break;
 264                                 case '"' :
 265                                         inDQuote = !inDQuote;
 266                                         break;
 267                                 case ';' :
 268                                         if (!inDQuote && !inQuote) {
 269                                                 if (name != String.Empty && name != null) {
 270                                                         value = sb.ToString ();
 271                                                         parameters [name.ToUpper ().Trim ()] = value.Trim ();
 272                                                 }
 273                                                 name = String.Empty;
 274                                                 value = String.Empty;
 275                                                 sb = new StringBuilder ();
 276                                         }
 277                                         else
 278                                                 sb.Append (c);
 279                                         break;
 280                                 case '=' :
 281                                         if (!inDQuote && !inQuote) {
 282                                                 name = sb.ToString ();
 283                                                 sb = new StringBuilder ();
 284                                         }
 285                                         else
 286                                                 sb.Append (c);
 287                                         break;
 288                                 default:
 289                                         sb.Append (c);
 290                                         break;
 291                                 }
 292                         }
 293
 294                         SetProperties (parameters);
 295                 }
 296
 297                 private void SetProperties (NameValueCollection parameters)
 298                 {
 299                         string value;
 300                         foreach (string name in parameters) {
 301                                 value = parameters[name];
 302
 303                                 switch (name) {
 304                                 case "DATA SOURCE" :
 305                                 case "DATABASE" :
 306                                         // set Database property
 307                                         conInfo.Database = value;
 308                                         break;
 309                                 case "PASSWORD" :
 310                                 case "PWD" :
 311                                         conInfo.Password = value;
 312                                         break;
 313                                 case "UID" :
 314                                 case "USER ID" :
 315                                         conInfo.Username = value;
 316                                         break;
 317                                 default:
 318                                         throw new Exception("Connection parameter not supported." + name);
 319                                 }
 320                         }
 321                 }
 322
 323                 #endregion // Methods
 324
 325                 public event OracleInfoMessageEventHandler InfoMessage;
 326                 public event StateChangeEventHandler StateChange;
 327         }
 328 }