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

   1 //
   2 // ociglue.cs - provides glue between
   3 //              managed C#/.NET System.Data.OracleClient.dll and
   4 //              unmanaged native c library oci.dll
   5 //              to be used in Mono System.Data.OracleClient as
   6 //              the Oracle 8i data provider.
   7 //
   8 // Part of managed C#/.NET library System.Data.OracleClient.dll
   9 //
  10 // Part of the Mono class libraries at
  11 // mcs/class/System.Data.OracleClient/System.Data.OracleClient.OCI
  12 //
  13 // Assembly: System.Data.OracleClient.dll
  14 // Namespace: System.Data.OracleClient.Oci
  15 //
  16 // Authors:
  17 //     Daniel Morgan <danmorg@sc.rr.com>
  18 //     Tim Coleman <tim@timcoleman.com>
  19 //
  20 // Copyright (C) Daniel Morgan, 2002
  21 // Copyright (C) Tim Coleman, 2002
  22 //
  23
  24 using System;
  25 using System.Runtime.InteropServices;
  26 using System.Text;
  27
  28 namespace System.Data.OracleClient.Oci {
  29         internal sealed class OciGlue
  30         {
  31                 #region Fields
  32
  33                 bool connected;
  34                 OciEnvironmentHandle environment;
  35                 OciErrorHandle error;
  36                 OciServerHandle server;
  37                 OciServiceHandle service;
  38                 OciSessionHandle session;
  39
  40                 // other codes
  41                 public const int OCI_DEFAULT = 0;
  42                 public const int OCI_SUCCESS = 0;
  43                 public const int OCI_SUCCESS_WITH_INFO = 1;
  44                 public const int OCI_RESERVED_FOR_INT_USE = 200;
  45                 public const int OCI_NO_DATA = 100;
  46                 public const int OCI_ERROR = -1;
  47                 public const int OCI_INVALID_HANDLE = -2;
  48                 public const int OCI_NEED_DATA = 99;
  49                 public const int OCI_STILL_EXECUTING = -3123;
  50                 public const int OCI_CONTINUE = -24200;
  51
  52                 #endregion // Fields
  53
  54                 #region Properties
  55
  56                 public bool Connected {
  57                         get { return connected; }
  58                 }
  59
  60                 public OciEnvironmentHandle Environment {
  61                         get { return environment; }
  62                 }
  63
  64                 public OciErrorHandle ErrorHandle {
  65                         get { return error; }
  66                 }
  67
  68                 public OciServiceHandle ServiceContext {
  69                         get { return service; }
  70                 }
  71
  72                 #endregion // Properties
  73
  74                 #region Methods
  75
  76                 public void CreateConnection (OracleConnectionInfo conInfo)
  77                 {
  78                         environment = new OciEnvironmentHandle (OciEnvironmentMode.Threaded | OciEnvironmentMode.NoUserCallback);
  79
  80                         if (environment.Handle == IntPtr.Zero)
  81                                 throw new OracleException (0, "Could not allocate the Oracle environment.");
  82
  83                         service = (OciServiceHandle) environment.Allocate (OciHandleType.Service);
  84                         if (service == null) {
  85                                 OciErrorInfo info = environment.HandleError ();
  86                                 Disconnect ();
  87                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
  88                         }
  89
  90                         error = (OciErrorHandle) environment.Allocate (OciHandleType.Error);
  91                         if (error == null) {
  92                                 OciErrorInfo info = environment.HandleError ();
  93                                 Disconnect ();
  94                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
  95                         }
  96                         service.ErrorHandle = error;
  97
  98                         server = (OciServerHandle) environment.Allocate (OciHandleType.Server);
  99                         if (server == null) {
 100                                 OciErrorInfo info = environment.HandleError ();
 101                                 Disconnect ();
 102                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
 103                         }
 104
 105                         session = (OciSessionHandle) environment.Allocate (OciHandleType.Session);
 106                         if (session == null) {
 107                                 OciErrorInfo info = environment.HandleError ();
 108                                 Disconnect ();
 109                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
 110                         }
 111                         session.Username = conInfo.Username;
 112                         session.Password = conInfo.Password;
 113                         session.Service = service;
 114
 115                         if (!server.Attach (conInfo.Database, ErrorHandle)) {
 116                                 OciErrorInfo info = error.HandleError ();
 117                                 Disconnect ();
 118                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
 119                         }
 120
 121                         if (!service.SetServer (server)) {
 122                                 OciErrorInfo info = error.HandleError ();
 123                                 Disconnect ();
 124                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
 125                         }
 126
 127                         if (!session.BeginSession (OciCredentialType.RDBMS, OciSessionMode.Default, ErrorHandle)) {
 128                                 OciErrorInfo info = error.HandleError ();
 129                                 Disconnect ();
 130                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
 131                         }
 132
 133
 134                         if (!service.SetSession (session)) {
 135                                 OciErrorInfo info = error.HandleError ();
 136                                 Disconnect ();
 137                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
 138                         }
 139
 140                         connected = true;
 141                 }
 142
 143                 public OciStatementHandle CreateStatement ()
 144                 {
 145                         OciStatementHandle statement = (OciStatementHandle) environment.Allocate (OciHandleType.Statement);
 146                         if (statement == null) {
 147                                 OciErrorInfo info = environment.HandleError ();
 148                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
 149                         }
 150                         statement.ErrorHandle = error;
 151                         statement.Service = service;
 152
 153                         return statement;
 154                 }
 155
 156                 public OciTransactionHandle CreateTransaction ()
 157                 {
 158                         OciTransactionHandle transaction = (OciTransactionHandle) environment.Allocate (OciHandleType.Transaction);
 159                         if (transaction == null) {
 160                                 OciErrorInfo info = environment.HandleError ();
 161                                 throw new OracleException (info.ErrorCode, info.ErrorMessage);
 162                         }
 163                         transaction.ErrorHandle = error;
 164                         transaction.Service = service;
 165
 166                         return transaction;
 167                 }
 168
 169                 public void Disconnect()
 170                 {
 171                         if (session != null)
 172                                 session.Dispose ();
 173                         if (server != null)
 174                                 server.Dispose ();
 175                         if (error != null)
 176                                 error.Dispose ();
 177                         if (service != null)
 178                                 service.Dispose ();
 179                         if (environment != null)
 180                                 environment.Dispose ();
 181                 }
 182
 183                 #endregion // Methods
 184         }
 185 }