mcs/class/System.Data.OracleClient/System.Data.OracleClient.jvm/OracleDataReader.cs

   1 //\r
   2 // System.Data.OracleClient.OracleDataReader\r
   3 //\r
   4 // Authors:
   5 //      Konstantin Triger <kostat@mainsoft.com>
   6 //      Boris Kirzner <borisk@mainsoft.com>\r
   7 //\r
   8 // (C) 2005 Mainsoft Corporation (http://www.mainsoft.com)
   9 //
  10
  11 //
  12 // Permission is hereby granted, free of charge, to any person obtaining
  13 // a copy of this software and associated documentation files (the
  14 // "Software"), to deal in the Software without restriction, including
  15 // without limitation the rights to use, copy, modify, merge, publish,
  16 // distribute, sublicense, and/or sell copies of the Software, and to
  17 // permit persons to whom the Software is furnished to do so, subject to
  18 // the following conditions:
  19 //
  20 // The above copyright notice and this permission notice shall be
  21 // included in all copies or substantial portions of the Software.
  22 //
  23 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  24 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  25 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  26 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  27 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  28 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  29 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  30 //\r
  31 \r
  32 using System.Data.Common;\r
  33 using System.Data.ProviderBase;\r
  34 \r
  35 using java.sql;\r
  36 \r
  37 namespace System.Data.OracleClient {\r
  38         public sealed class OracleDataReader : AbstractDataReader {\r
  39                 #region Fields\r
  40 \r
  41                 #endregion // Fields\r
  42 \r
  43                 #region Constructors\r
  44 \r
  45                 internal OracleDataReader(OracleCommand command) : base(command) {\r
  46                 }\r
  47 \r
  48                 #endregion // Constructors\r
  49 \r
  50                 #region Methods\r
  51 \r
  52                 protected sealed override SystemException CreateException(string message, SQLException e) {\r
  53                         return new OracleException(message,e, (OracleConnection)_command.Connection);           \r
  54                 }\r
  55 \r
  56                 protected sealed override SystemException CreateException(java.io.IOException e) {\r
  57                         return new OracleException(e, (OracleConnection)_command.Connection);           \r
  58                 }\r
  59 \r
  60                 public override String GetDataTypeName(int columnIndex) {\r
  61                         try {\r
  62                                 string jdbcTypeName = Results.getMetaData().getColumnTypeName(columnIndex + 1);\r
  63                                 \r
  64                                 return OracleConvert.JdbcTypeNameToDbTypeName(jdbcTypeName);\r
  65                         }\r
  66                         catch (SQLException e) {\r
  67                                 throw CreateException(e);\r
  68                         }\r
  69                 }\r
  70 \r
  71                 protected override int GetProviderType(int jdbcType) {
  72                         return (int)OracleConvert.JdbcTypeToOracleType(jdbcType);
  73                 }\r
  74 \r
  75                 protected override IReaderCacheContainer CreateReaderCacheContainer(int jdbcType, int columnIndex) {\r
  76                         switch ((JavaSqlTypes)jdbcType) {\r
  77                                 case JavaSqlTypes.BINARY_FLOAT:\r
  78                                         jdbcType = (int)JavaSqlTypes.REAL;\r
  79                                         break;\r
  80                                 case JavaSqlTypes.BINARY_DOUBLE:\r
  81                                         jdbcType = (int)JavaSqlTypes.DOUBLE;\r
  82                                         break;\r
  83                                 case JavaSqlTypes.ROWID:\r
  84                                         jdbcType = (int)JavaSqlTypes.VARCHAR;\r
  85                                         break;\r
  86 //                              case JavaSqlTypes.CURSOR:\r
  87 //                                      jdbcType = JavaSqlTypes.OTHER;\r
  88 //                                      break;\r
  89                                 case JavaSqlTypes.TIMESTAMPNS:\r
  90                                         jdbcType = (int)JavaSqlTypes.TIMESTAMP;\r
  91                                         break;\r
  92                                 case JavaSqlTypes.TIMESTAMPTZ:\r
  93                                         jdbcType = (int)JavaSqlTypes.TIMESTAMP;\r
  94                                         break;\r
  95                                 case JavaSqlTypes.TIMESTAMPLTZ: \r
  96                                         jdbcType = (int)JavaSqlTypes.TIMESTAMP;\r
  97                                         break;\r
  98                                 case JavaSqlTypes.INTERVALYM:\r
  99                                         jdbcType = (int)JavaSqlTypes.INTEGER;\r
 100                                         break;\r
 101                                 case JavaSqlTypes.INTERVALDS:\r
 102                                         jdbcType = (int)JavaSqlTypes.TIMESTAMP;\r
 103                                         break;\r
 104                         }\r
 105                         return base.CreateReaderCacheContainer (jdbcType, columnIndex);\r
 106                 }\r
 107 \r
 108 \r
 109                 protected override void SetSchemaType(DataRow schemaRow, ResultSetMetaData metaData, int columnIndex) {\r
 110                         JavaSqlTypes columnType = (JavaSqlTypes)metaData.getColumnType(columnIndex);\r
 111                         switch (columnType) {\r
 112                                 case JavaSqlTypes.BINARY_FLOAT:\r
 113                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 114                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfFloat;\r
 115                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 116                                         break;\r
 117                                 case JavaSqlTypes.BINARY_DOUBLE:\r
 118                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 119                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfDouble;\r
 120                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 121                                         break;\r
 122                                 case JavaSqlTypes.ROWID:\r
 123                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 124                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfString;\r
 125                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 126                                         break;\r
 127                                 case JavaSqlTypes.CURSOR:\r
 128                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 129                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfDouble;\r
 130                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 131                                         break;\r
 132                                 case JavaSqlTypes.TIMESTAMPNS:\r
 133                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 134                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfTimespan;\r
 135                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 136                                         break;\r
 137                                 case JavaSqlTypes.TIMESTAMPTZ:\r
 138                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 139                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfTimespan;\r
 140                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 141                                         break;\r
 142                                 case JavaSqlTypes.TIMESTAMPLTZ: \r
 143                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 144                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfTimespan;\r
 145                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 146                                         break;\r
 147                                 case JavaSqlTypes.INTERVALYM:\r
 148                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 149                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfUInt32;\r
 150                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 151                                         break;\r
 152                                 case JavaSqlTypes.INTERVALDS:\r
 153                                         schemaRow [(int)SCHEMA_TABLE.ProviderType] = GetProviderType((int)columnType);\r
 154                                         schemaRow [(int)SCHEMA_TABLE.DataType] = OracleConvert.TypeOfTimespan;\r
 155                                         schemaRow [(int)SCHEMA_TABLE.IsLong] = false;\r
 156                                         break;\r
 157                                 default:\r
 158                                         base.SetSchemaType(schemaRow, metaData, columnIndex);\r
 159                                         break;\r
 160                         }\r
 161                 }\r
 162 \r
 163                 public override decimal GetDecimal(int i) {\r
 164                         if (IsNumeric(i))\r
 165                                 return GetDecimalSafe(i);\r
 166 \r
 167                         return base.GetDecimal(i);\r
 168                 }\r
 169 \r
 170                 public override double GetDouble(int i) {\r
 171                         if (IsNumeric(i))\r
 172                                 return GetDoubleSafe(i);\r
 173 \r
 174                         return base.GetDouble(i);\r
 175                 }\r
 176 \r
 177                 public override float GetFloat(int i) {\r
 178                         if (IsNumeric(i))\r
 179                                 return GetFloatSafe(i);\r
 180 \r
 181                         return base.GetFloat(i);\r
 182                 }\r
 183 //\r
 184 //              OracleClient does not "excuse" for Int16\r
 185 //\r
 186 //              public override short GetInt16(int i) {\r
 187 //                      if (IsNumeric(i))\r
 188 //                              return GetInt16Safe(i);\r
 189 //\r
 190 //                      return base.GetInt16(i);\r
 191 //              }\r
 192 \r
 193 \r
 194                 public override int GetInt32(int i) {\r
 195                         if (IsNumeric(i))\r
 196                                 return GetInt32Safe(i);\r
 197 \r
 198                         return base.GetInt32(i);\r
 199                 }\r
 200 \r
 201                 public override long GetInt64(int i) {\r
 202                         if (IsNumeric(i))\r
 203                                 return GetInt64Safe(i);\r
 204 \r
 205                         return base.GetInt64(i);\r
 206                 }\r
 207 \r
 208 #if SUPPORT_ORACLE_TYPES\r
 209                 #region GetOracleXXX\r
 210 \r
 211                 public OracleBFile GetOracleBFile(\r
 212                         int i\r
 213                         ) {\r
 214                         throw new NotImplementedException();\r
 215                 }\r
 216 \r
 217                 public OracleBinary GetOracleBinary(\r
 218                         int i\r
 219                         ) {\r
 220                         throw new NotImplementedException();\r
 221                 }\r
 222 \r
 223                 public OracleDateTime GetOracleDateTime(\r
 224                         int i\r
 225                         ) {\r
 226                         throw new NotImplementedException();\r
 227                 }\r
 228 \r
 229                 public OracleLob GetOracleLob(\r
 230                         int i\r
 231                         ) {\r
 232                         throw new NotImplementedException();\r
 233                 }\r
 234 \r
 235                 public OracleMonthSpan GetOracleMonthSpan(\r
 236                         int i\r
 237                         ) {\r
 238                         throw new NotImplementedException();\r
 239                 }\r
 240 \r
 241                 public OracleNumber GetOracleNumber(\r
 242                         int i\r
 243                         ) {\r
 244                         throw new NotImplementedException();\r
 245                 }\r
 246 \r
 247                 public OracleString GetOracleString(\r
 248                         int i\r
 249                         ) {\r
 250                         throw new NotImplementedException();\r
 251                 }\r
 252 \r
 253                 public OracleTimeSpan GetOracleTimeSpan(\r
 254                         int i\r
 255                         ) {\r
 256                         throw new NotImplementedException();\r
 257                 }\r
 258 \r
 259                 public object GetOracleValue(\r
 260                         int i\r
 261                         ) {\r
 262                         throw new NotImplementedException();\r
 263                 }\r
 264 \r
 265                 public int GetOracleValues(\r
 266                         object[] values\r
 267                         ) {\r
 268                         throw new NotImplementedException();\r
 269                 }\r
 270 \r
 271                 #endregion\r
 272 #endif\r
 273 \r
 274                 #endregion // Methods\r
 275         }\r
 276 }