mono/mcs/class/System.Data.OracleClient/System.Data.OracleClient.Oci/OciDefineHandle.cs

// 
// OciDefineHandle.cs 
//  
// Part of managed C#/.NET library System.Data.OracleClient.dll
//
// Part of the Mono class libraries at
// mcs/class/System.Data.OracleClient/System.Data.OracleClient.Oci
//
// Assembly: System.Data.OracleClient.dll
// Namespace: System.Data.OracleClient.Oci
// 
// Author: 
//     Tim Coleman <[email protected]>
//         
// Copyright (C) Tim Coleman, 2003
// 

using System;
using System.Runtime.InteropServices;
using System.Text;

namespace System.Data.OracleClient.Oci {
	internal sealed class OciDefineHandle : IOciHandle, IDisposable
	{
		#region Fields

		IntPtr handle;
		IntPtr value;
		short indicator;
		OracleType type;
		OciDataType ociType;
		OciDataType definedType;
		int definedSize;
		int rlenp;
		sbyte scale;
	
		#endregion // Fields

		#region Constructors

		public OciDefineHandle (OciStatementHandle statement, int position)
		{
			int ociTypeInt;
			int status = 0;

			IntPtr parameterHandle = statement.CreateParameterHandle (position);

			status = OciGlue.OCIAttrGetInt32 (parameterHandle,
							(uint) OciDescriptorType.Parameter,
							out definedSize,
							IntPtr.Zero,
							OciAttributeType.DataSize,
							statement.ErrorHandle.Handle);
			if (status != 0) {
				OciErrorInfo info = statement.ErrorHandle.HandleError ();
				throw new OracleException (info.ErrorCode, info.ErrorMessage);
			}

			status = OciGlue.OCIAttrGetSByte (parameterHandle,
							(uint) OciDescriptorType.Parameter,
							out scale,
							IntPtr.Zero,
							OciAttributeType.DataSize,
							statement.ErrorHandle.Handle);
			if (status != 0) {
				OciErrorInfo info = statement.ErrorHandle.HandleError ();
				throw new OracleException (info.ErrorCode, info.ErrorMessage);
			}

			status = OciGlue.OCIAttrGetInt32 (parameterHandle,
							(uint) OciDescriptorType.Parameter,
							out ociTypeInt,
							IntPtr.Zero,
							OciAttributeType.DataType,
							statement.ErrorHandle.Handle);
			if (status != 0) {
				OciErrorInfo info = statement.ErrorHandle.HandleError ();
				throw new OracleException (info.ErrorCode, info.ErrorMessage);
			}
			definedType = (OciDataType) ociTypeInt;

			switch (definedType) {
			case OciDataType.Number:
				ociType = OciDataType.Char;
				break;
			case OciDataType.Date:
				ociType = OciDataType.Char;
				definedSize = 20;
				break;
			default:
				ociType = definedType;
				break;
			}

			value = Marshal.AllocHGlobal (definedSize);

			status = OCIDefineByPos (statement.Handle,
							out handle,
							statement.ErrorHandle.Handle,
							position,
							value,
							definedSize,
							ociType,
							ref indicator,
							ref rlenp,
							IntPtr.Zero,
							0);

			if (status != 0) {
				OciErrorInfo info = statement.ErrorHandle.HandleError ();
				throw new OracleException (info.ErrorCode, info.ErrorMessage);
			}

			statement.FreeParameterHandle (parameterHandle);
		}

		#endregion // Constructors

		#region Properties

		public OciDataType DataType {
			get { return definedType; }
		}

		public int DefinedSize {
			get { return definedSize; }
		}

		public IntPtr Handle {
			get { return handle; }
			set { handle = value; }
		}

		public OciHandleType HandleType {
			get { return OciHandleType.Define; }
		}

		public bool IsNull {
			get { return (indicator == -1); }
		}

		public sbyte Scale {
			get { return scale; }
		}

		public int Size {
			get { return rlenp; }
		}

		public IntPtr Value {
			get { return value; }
		}

		#endregion

		#region Methods

		[DllImport ("oci")]
		public static extern int OCIDefineByPos (IntPtr stmtp,
							out IntPtr defnpp,
							IntPtr errhp,
							[MarshalAs (UnmanagedType.U4)] int position,
							IntPtr valuep,
							int value_sz,
							[MarshalAs (UnmanagedType.U2)] OciDataType dty,
							ref short indp,
							ref int rlenp,
							IntPtr rcodep,
							uint mode);

		public void Dispose ()
		{
			Marshal.FreeHGlobal (value);
		}

		public object GetValue ()
		{
			object tmp;

			switch (DataType) {
			case OciDataType.VarChar2:
			case OciDataType.String:
			case OciDataType.VarChar:
			case OciDataType.Char:
			case OciDataType.CharZ:
			case OciDataType.OciString:
				tmp = Marshal.PtrToStringAnsi (Value, Size);
				if (tmp != null)
					return String.Copy ((string) tmp);
				break;
			case OciDataType.Integer:
				tmp = Marshal.PtrToStringAnsi (Value, Size);
				if (tmp != null)
					return Int32.Parse (String.Copy ((string) tmp));
				break;
			case OciDataType.Number:
				tmp = Marshal.PtrToStringAnsi (Value, Size);
				if (tmp != null) {
					if (Scale == 0)
						return Int32.Parse (String.Copy ((string) tmp));
					else
						return Decimal.Parse (String.Copy ((string) tmp));
				}
				break;
			case OciDataType.Float:
				tmp = Marshal.PtrToStringAnsi (Value, Size);
				if (tmp != null)
					return Double.Parse (String.Copy ((string) tmp));
				break;
			case OciDataType.Date:
				tmp = Marshal.PtrToStringAnsi (Value, Size);
				if (tmp != null)
					return DateTime.Parse ((string) tmp);
				break;
			}

			return DBNull.Value;
		}

		#endregion // Methods
	}
}