svn path=/branches/Mainsoft.System.Data/mcs/; revision=43842

1 files changed, 751 insertions, 0 deletions

diff --git a/mcs/class/System.Data/System.Data.ProviderBase/AbstractDBCommand.cs b/mcs/class/System.Data/System.Data.ProviderBase/AbstractDBCommand.cs
new file mode 100644
index 00000000000..51746512183
--- /dev/null
+++ b/mcs/class/System.Data/System.Data.ProviderBase/AbstractDBCommand.cs
@@ -0,0 +1,751 @@
+//namespace System.Data.Common

+//{

+//

+//	using java.sql;

+//	using java.util;

+//

+//	using System;

+//	using System.Collections;

+//	using System.Data;

+//	using System.Data.ProviderBase;

+//

+//	/**

+//	 * @author erand

+//	 */

+//	public abstract class AbstractDBCommand : DbCommandBase

+//	{

+//		protected String _cmdText, _javaCmdText;

+//		protected AbstractDBConnection _connection;

+//		protected IDbTransaction _transaction;

+//		protected int _cmdTimeout = 30;

+//		protected CommandType _cmdType = CommandType.Text;

+//		protected UpdateRowSource _updateRowSource = UpdateRowSource.Both;

+//		protected Statement _statement;

+//		protected IDataParameterCollection _paramCollection;

+//		protected IDataReader _reader;

+//		private bool _isCommandTextChanged;

+//		private CommandBehavior _behvior = CommandBehavior.Default;

+//

+//		private static readonly int _oracleRefCursor;

+//		protected const int oracleTypeRefCursor = 1111; // Types.OTHER

+//        

+//        

+//		static AbstractDBCommand()

+//		{

+//			try {

+//				java.lang.Class OracleTypesClass = java.lang.Class.forName("oracle.jdbc.OracleTypes");

+//				_oracleRefCursor = OracleTypesClass.getField("CURSOR").getInt(null);

+//			}

+//			catch(java.lang.ClassNotFoundException e) {

+//				// oracle driver is not in classpath - just continue

+//			}

+//		}

+//

+//		public AbstractDBCommand(

+//			String cmdText,

+//			AbstractDBConnection connection,

+//			IDbTransaction transaction)

+//		{

+//			_connection = connection;

+//			_cmdText = cmdText;

+//			_transaction = transaction;

+//			_isCommandTextChanged = true;

+//		}

+//    

+//		public java.sql.Statement Statement

+//		{

+//			get

+//			{

+//				return _statement;

+//			}

+//			set

+//			{

+//				_statement = value;

+//			}

+//		}

+//

+//		public virtual String JavaCommandText

+//		{

+//			get

+//			{

+//				return _javaCmdText;

+//			}

+//			set

+//			{

+//				_javaCmdText = value;

+//			}

+//		}

+//

+//		protected bool getCommandTextChanged()

+//		{

+//			return _isCommandTextChanged;

+//		}

+//    

+//		internal void setCommandTextChanged(bool value)

+//		{

+//			_isCommandTextChanged = value;

+//		}

+//    

+//		public Statement getStatement()

+//		{

+//			return _statement;

+//		}

+//		/**

+//		 * @see System.Data.IDbCommand#Cancel()

+//		 */

+//		public override void Cancel()

+//		{

+//			try

+//			{

+//				if (_statement != null)

+//					_statement.cancel();

+//			}

+//			catch (SQLException exp)

+//			{

+//				Console.WriteLine(exp);

+//			}

+//		}

+//

+////		/**

+////		 * @see System.Data.IDbCommand#ExecuteScalar()

+////		 */

+////		public virtual Object ExecuteScalar()

+////		{

+////			Object result = null;

+////			IDataReader reader = ((IDbCommand)this).ExecuteReader();

+////

+////			if (reader != null && reader.Read())

+////			{

+////				result = ((IDataRecord) reader).GetValue(0);

+////			}

+////			reader.Close();

+////

+////			return result;

+////		}

+//

+////		/**

+////		 * @see System.Data.IDbCommand#CommandTimeout

+////		 */

+////		public virtual int CommandTimeout

+////		{

+////			get

+////			{

+////				return _cmdTimeout;

+////			}

+////			set

+////			{

+////				_cmdTimeout = value;

+////			}

+////		}

+//

+////		/**

+////		 * @see System.Data.IDbCommand#CommandType

+////		 */

+////		public virtual CommandType CommandType

+////		{

+////			get

+////			{

+////				return _cmdType;

+////			}

+////			set

+////			{

+////				_cmdType = value;

+////			}

+////		}

+//

+////		/**

+////		 * @see System.Data.IDbCommand#Connection

+////		 */

+////		public virtual IDbConnection Connection

+////		{

+////			get

+////			{

+////				return (IDbConnection)_connection;

+////			}

+////			set

+////			{

+////				_connection = (AbstractDBConnection) value;

+////			}

+////		}

+//

+////		/**

+////		 * @see System.Data.IDbCommand#Transaction

+////		 */

+////		public virtual IDbTransaction Transaction

+////		{

+////			get

+////			{

+////				return _transaction;

+////			}

+////			set

+////			{

+////				_transaction = value;

+////			}

+////		}

+//

+////		/**

+////		 * @see System.Data.IDbCommand#UpdatedRowSource

+////		 */

+////		public virtual UpdateRowSource UpdatedRowSource

+////		{

+////			get

+////			{

+////				return _updateRowSource;

+////			}

+////			set

+////			{

+////				_updateRowSource = value;

+////			}

+////		}

+//

+////		/**

+////		 * @see System.Data.IDbCommand#CommandText

+////		 */

+////		public virtual String CommandText

+////		{

+////			get

+////			{

+////				return _cmdText;

+////			}

+////			set

+////			{

+////				if (_cmdText == null || String.Compare(_cmdText, value,  true) != 0)

+////				{

+////					_cmdText = value;

+////					_isCommandTextChanged = true;

+////				}

+////			}

+////		}

+//

+//		protected virtual void setInputForStatement(

+//			PreparedStatement stm,

+//			int javaType,

+//			int place,

+//			Object value)

+//			//throws SQLException

+//		{

+//			// by the type of the the parameter we know wich method of

+//			// the statement to use

+//

+//			if (value is DBNull)

+//				stm.setNull(place, javaType);

+//

+//			else if (javaType == Types.BINARY)

+//				stm.setBytes(place, vmw.common.TypeUtils.ToSByteArray((byte[]) value));

+//

+//			else if (javaType == Types.BLOB)

+//				stm.setObject(place, value);

+//

+//			else if (javaType == Types.CLOB)

+//				stm.setObject(place, value);

+//

+//			else if (javaType == Types.DISTINCT)

+//				stm.setObject(place, value);

+//

+//			else if (javaType == Types.ARRAY)

+//				stm.setObject(place, value);

+//

+//			else if (javaType == Types.JAVA_OBJECT)

+//				stm.setObject(place, value);

+//

+//			else if (javaType == Types.REF)

+//				stm.setObject(place, value);

+//

+//			else if (javaType == Types.STRUCT)

+//				stm.setObject(place, value);

+//

+//			else if (javaType == Types.VARBINARY)

+//				stm.setBytes(place, vmw.common.TypeUtils.ToSByteArray((byte[]) value));

+//

+//			else if (javaType == Types.BIGINT)

+//				stm.setLong(place, ((java.lang.Long) value).longValue());

+//

+//			else if (javaType == Types.BIT)

+//				stm.setBoolean(place, ((java.lang.Boolean) value).booleanValue());

+//

+//			else if (javaType == Types.CHAR)

+//				stm.setString(place, ((java.lang.Character) value).toString());

+//

+//			else if (javaType == Types.DATE)

+//			{

+//				DateTime tmp = (DateTime) value;

+//				Calendar c = vmw.common.DateTimeUtils.DateTimeToCalendar(tmp);

+//				stm.setDate(

+//					place, new java.sql.Date(c.getTime().getTime()));

+//			}

+//			else if (javaType == Types.DECIMAL || javaType == Types.NUMERIC)

+//				stm.setBigDecimal(place, vmw.common.PrimitiveTypeUtils.DecimalToBigDecimal((Decimal) value));

+//

+//			else if (javaType == Types.DOUBLE)

+//				stm.setDouble(place, ((java.lang.Double) value).doubleValue());

+//

+//			else if (javaType == Types.FLOAT)

+//				stm.setFloat(place, ((java.lang.Float) value).floatValue());

+//

+//			else if (javaType == Types.INTEGER)

+//				stm.setInt(place, ((java.lang.Integer) value).intValue());

+//

+//			else if (javaType == Types.LONGVARCHAR)

+//				stm.setString(place, (String) value);

+//

+//			else if (javaType == Types.LONGVARBINARY)

+//				stm.setBytes(place, vmw.common.TypeUtils.ToSByteArray((byte[]) value));

+//

+//			else if (javaType == Types.REAL)

+//				stm.setFloat(place, ((java.lang.Float) value).floatValue());

+//

+//			else if (javaType == Types.SMALLINT)

+//				stm.setShort(place, ((java.lang.Short) value).shortValue());

+//

+//			else if (javaType == Types.TIME)

+//			{

+//				Calendar c = vmw.common.DateTimeUtils.DateTimeToCalendar(value);

+//				stm.setTime(

+//					place,

+//					new java.sql.Time(c.getTime().getTime()));

+//			}

+//			else if (javaType == Types.TIMESTAMP)

+//			{

+//				DateTime tmp = (DateTime) value;

+//				Calendar c = vmw.common.DateTimeUtils.DateTimeToCalendar(value);

+//				stm.setTimestamp(

+//					place,

+//					new java.sql.Timestamp(c.getTime().getTime()));

+//			}

+//

+//			else if (javaType == Types.TINYINT)

+//				stm.setByte(place, ((java.lang.Byte) value).byteValue());

+//

+//			else if (javaType == Types.VARCHAR)

+//				stm.setString(place, (String) value);

+//

+//			else

+//				stm.setObject(place, value, javaType);

+//

+//		}

+//

+//		// create the _javaCmdText from the _cmdText (the .NET text)

+//		protected String createCommandForStoreProcedure(String text)

+//		{

+//			IDbDataParameter param;

+//			bool isFirst = true;

+//			IList paramCollection = (IList) ((IDbCommand)this).Parameters;

+//        

+//			//in .Net the name of sore procedure can be wraped by '[' and ']'

+//			// so we remove them.

+//			int indx1 = text.IndexOf('[');

+//			if (indx1 != -1)

+//			{

+//				int indx2 = text.IndexOf(']', indx1);

+//				if (indx2 != -1)

+//					text = text.Substring(indx1 + 1, indx2 - (indx1 + 1));

+//			}

+//

+//			java.lang.StringBuffer sb = new java.lang.StringBuffer(text);

+//			sb.insert(0, "{call ");

+//

+//			for (int i = 0; i < paramCollection.Count; i++)

+//			{

+//				param = (IDbDataParameter) paramCollection[i];

+//

+//				if (param.Direction == ParameterDirection.ReturnValue)

+//					sb = sb.insert(1, "? =");

+//				else if (isFirst)

+//				{

+//					sb = sb.append("(?");

+//					isFirst = false;

+//				}

+//				else

+//					sb = sb.append(",?");

+//			}

+//

+//			String retVal = sb.toString();

+//

+//			if (retVal.IndexOf("(") != -1)

+//				retVal = retVal + ")";

+//

+//			retVal += "}";

+//

+//			_javaCmdText = retVal;

+//

+//			return retVal;

+//

+//		}

+//

+//		// prepare the input and output parameters for the jdbc prepared statement

+//		// from the SqlParameters of this instance

+//		internal virtual void prepareStatementForStoreProcedure()// throws SQLException

+//		{

+//			CallableStatement stm = (CallableStatement) _statement;

+//			AbstractDBParameter param;

+//			IList paramCollection = (IList) ((IDbCommand)this).Parameters;

+//			ParameterDirection direction;

+//			//int place;

+//

+//			// NOTE - we add 1 to the index because in .NET it is zero base

+//			// and in jdbc it is one base

+//			for (int i = 0; i < paramCollection.Count; i++)

+//			{

+//				param = (AbstractDBParameter) paramCollection[i];

+//				direction = param.Direction;

+//

+//				if (direction == ParameterDirection.Input)

+//					setInput(stm, i + 1, param);

+//				else if (direction == ParameterDirection.Output)

+//				{

+//					setOutput(stm, i + 1, param);

+//					param.setParameterPlace(i + 1);

+//				}

+//				else if (direction == ParameterDirection.InputOutput)

+//				{

+//					setInput(stm, i + 1, param);

+//					setOutput(stm, i + 1, param);

+//					param.setParameterPlace(i + 1);

+//				}

+//				else if (direction == ParameterDirection.ReturnValue)

+//				{

+//					setOutput(stm, 1, param);

+//					param.setParameterPlace(1);

+//				}

+//			}

+//

+//		}

+//

+//		// set input parameter for the statement

+//		protected void setInput(

+//			PreparedStatement stm,

+//			int place,

+//			AbstractDbParameter param)

+//			//throws SQLException

+//		{

+//			int javaType = param.JdbcType;

+//			Object value = param.Value;

+//

+//			value = getJavaWrapperFromCSharp(value);

+//

+//			setInputForStatement(stm, javaType, place, value);

+//		}

+//        

+//		public static Object getJavaWrapperFromCSharp(Object obj)

+//		{

+//			if (obj is bool)

+//				return new java.lang.Boolean((bool)obj);

+//			else if (obj is byte)

+//				return new java.lang.Byte((sbyte)obj);

+//			else if (obj is char)

+//				return new java.lang.Character((char) obj);

+//			else if (obj is short)

+//				return new java.lang.Short((short)obj);

+//			else if (obj is int)

+//				return new java.lang.Integer((int)obj);

+//			else if (obj is long)

+//				return new java.lang.Long((long)obj);

+//			else if (obj is float)

+//				return new java.lang.Float((float)obj);

+//			else if (obj is double)

+//				return new java.lang.Double((double)obj);

+//

+//			return obj;

+//

+//		}

+//

+//		// set an output parameter to the statement.

+//		protected void setOutput(

+//			CallableStatement stm,

+//			int place,

+//			AbstractDbParameter param)

+//			//throws SQLException

+//		{

+//			int javaType = param.JdbcType;

+//

+//			// the scale has a meening only in DECIMAL parameters

+//			if (javaType == Types.DECIMAL || javaType == Types.NUMERIC)

+//			{

+//				if(param.DbType == DbType.Currency)

+//					stm.registerOutParameter(place, javaType, 4);

+//				else

+//					stm.registerOutParameter(place, javaType, param.Scale);

+//			}

+//			else if (javaType == oracleTypeRefCursor) {

+//				stm.registerOutParameter(place, _oracleRefCursor);

+//			}

+//			else {

+//				stm.registerOutParameter(place, javaType);

+//			}

+//

+//		}

+//

+//		// get the the output parameter for a specific statement at a specific place

+//		// returns the value of the output parameter

+//		protected Object getOutputValue(

+//			AbstractDbParameter param,

+//			CallableStatement stm)

+//			//throws SQLException

+//		{

+//			Object retVal = null;

+//

+//			int place = param.getParameterPlace();

+//

+//			// by the type of the parameter we know wich method to use

+//			// on the statement

+//			int type = param.JdbcType;

+//

+//			if (type == Types.ARRAY)

+//				retVal = stm.getObject(place);

+//			else if (type == Types.BIGINT)

+//				retVal = stm.getLong(place);

+//			else if (type == Types.BINARY)

+//				retVal = stm.getBytes(place);

+//			else if (type == Types.BIT)

+//				retVal = stm.getBoolean(place);

+//			else if (type == Types.BLOB)

+//				retVal = stm.getObject(place);

+//			else if (type == Types.CHAR)

+//				retVal = stm.getString(place);

+//			else if (type == Types.CLOB)

+//				retVal = stm.getObject(place);

+//			else if (type == Types.DATE)

+//			{

+//				java.sql.Date date = stm.getDate(place);

+//				if(date != null)

+//				{

+//					// convertirn sql.Date to DateTime

+//					Calendar c = Calendar.getInstance();

+//					c.setTime(date);

+//

+//					retVal = vmw.common.DateTimeUtils.CalendarToDateTime(c);

+//				}

+//				

+//			}

+//			else if (type == Types.DECIMAL)

+//			{

+//				java.math.BigDecimal bd = stm.getBigDecimal(place);

+//				if(bd != null)

+//					retVal = vmw.common.PrimitiveTypeUtils.BigDecimalToDecimal(bd);

+//			}

+//			else if (type == Types.DISTINCT)

+//				retVal = stm.getObject(place);

+//			else if (type == Types.DOUBLE)

+//				retVal = stm.getDouble(place);

+//			else if (type == Types.FLOAT)

+//				retVal = stm.getFloat(place);

+//			else if (type == Types.INTEGER)

+//				retVal = stm.getInt(place);

+//			else if (type == Types.JAVA_OBJECT)

+//				retVal = stm.getObject(place);

+//			else if (type == Types.LONGVARBINARY)

+//				retVal = stm.getBytes(place);

+//			else if (type == Types.LONGVARCHAR)

+//				retVal = stm.getString(place);

+//			else if (type == Types.NULL)

+//				retVal = DBNull.Value;

+//			else if (type == Types.NUMERIC)

+//				retVal = stm.getBigDecimal(place);

+//			else if (type == Types.OTHER)

+//				retVal = stm.getObject(place);

+//			else if (type == Types.REAL)

+//				retVal = stm.getFloat(place);

+//			else if (type == Types.REF)

+//				retVal = stm.getObject(place);

+//			else if (type == Types.SMALLINT)

+//				retVal = stm.getShort(place);

+//			else if (type == Types.STRUCT)

+//				retVal = stm.getObject(place);

+//			else if (type == Types.TIME)

+//			{

+//				Time t = stm.getTime(place);

+//				if(t != null)

+//				{

+//					java.util.Date d = new java.util.Date(t.getTime());

+//					// convertirn sql.Date to DateTime

+//					Calendar c = Calendar.getInstance();

+//					c.setTime(d);

+//

+//					retVal = vmw.common.DateTimeUtils.CalendarToDateTime(c);

+//				}

+//				

+//			}

+//			else if (type == Types.TIMESTAMP)

+//			{

+//				Timestamp ts = stm.getTimestamp(place);

+//				if(ts != null)

+//				{

+//					java.util.Calendar cal = java.util.Calendar.getInstance();

+//					cal.setTime(new java.util.Date(ts.getTime() + ts.getNanos()/1000000));

+//					retVal = (DateTime)vmw.common.DateTimeUtils.CalendarToDateTime(cal);

+//				}

+//			}

+//			else if (type == Types.TINYINT)

+//				retVal = stm.getByte(place);

+//			else if (type == Types.VARBINARY)

+//				retVal = stm.getBytes(place);

+//			else if (type == Types.VARCHAR)

+//				retVal = stm.getString(place);

+//        

+//			if(stm.wasNull())

+//				retVal = DBNull.Value;

+//            

+//			return retVal;

+//		}

+//

+//    

+////		IDbDataParameter IDbCommand.CreateParameter()

+////		{

+////			return null;

+////		}

+//    

+////		IDataReader IDbCommand.ExecuteReader(CommandBehavior behavior)

+////		{

+////			return null;

+////		}

+////

+////		IDataReader IDbCommand.ExecuteReader()

+////		{

+////			return null;

+////		}

+////

+////		int IDbCommand.ExecuteNonQuery()

+////		{

+////			return -1;

+////		}

+////

+////		void IDbCommand.Prepare()

+////		{

+////		}

+//

+//        

+////		public IDataParameterCollection Parameters

+////		{

+////			get

+////			{

+////				return _paramCollection;

+////			}

+////		}

+//

+//		~AbstractDBCommand()

+//		{

+//			Dispose();

+//		}

+//

+//		public new void Dispose()
+//		{
+//			if (_paramCollection != null)
+//				_paramCollection.Clear();
+//
+//			_connection = null;
+//			_transaction = null;
+//
+//			if (_statement != null)
+//			{
+//				_statement.close();
+//				_statement = null;
+//			}
+//			base.Dispose();
+//		}

+//

+//		protected void CheckTrasactionContext()

+//		{

+//			if (_connection.Transaction != null && 

+//				(Transaction == null || Transaction != _connection.Transaction)) {

+//				throw new InvalidOperationException("Execute requires the command to have a transaction object" + 

+//							" when the connection assigned to the command is in a pending local transaction." +

+//							" The Transaction property of the command has not been initialized.");

+//			}

+//		}

+//

+//		protected String buildJavaCommand(String command)

+//		{

+//			IDataParameterCollection parameters = Parameters;

+//			

+//			if (parameters != null && parameters.Count > 0) {

+//				string tokens = command;

+//				System.Text.StringBuilder sb = new System.Text.StringBuilder(tokens.Length);

+//

+//				int currParameter = 0;

+//				int currStart = 0;

+//				int curr = 0;

+//				char curSeparator = (char)0;

+//				bool foundSeparator = false;

+//

+//				for(;curr<tokens.Length;curr++) {

+//					switch(tokens[curr]) {

+//						case '"':

+//						case '\'':

+//							if (foundSeparator) {

+//								if (curSeparator == tokens[curr]) {

+//									foundSeparator = false;

+//								}

+//							}

+//							else {

+//								// start inner string

+//								foundSeparator = true;

+//								curSeparator = tokens[curr];

+//							}

+//							break;

+//						case '?':

+//							if (!foundSeparator) {

+//								if (curr > currStart) { 

+//									// copy collected 

+//									sb.Append(tokens,currStart,curr - currStart);

+//								}

+//								// append parameter value

+//								AbstractDBParameter param = (AbstractDBParameter)parameters[currParameter++];

+//								sb.Append(param.formatParameter());

+//								currStart = curr+1;

+//							}

+//							break;

+//					}

+//				}

+//

+//				if (curr > currStart) { // end of the stirng

+//					sb.Append(tokens,currStart,curr - currStart);

+//				}

+//

+//				command = sb.ToString();

+//			}

+//			return command;

+//		}

+//

+//		internal void fillParameters()
+//		{
+//			if(CommandType == CommandType.StoredProcedure)
+//			{
+//				AbstractDBParameter param;
+//				CallableStatement stm = (CallableStatement)_statement;
+//				// get the output parameters from the statement
+//				// and put their values into the SqlParameter
+//				for (int i = 0; i < _paramCollection.Count; i++)
+//				{
+//					param = (AbstractDBParameter)_paramCollection[i];
+//
+//					if (param.IsOracleRefCursor)
+//						continue;
+//
+//					ParameterDirection direction = param.Direction;
+//					if (direction == ParameterDirection.InputOutput
+//						|| direction == ParameterDirection.Output
+//						|| direction == ParameterDirection.ReturnValue)
+//						param.Value = getOutputValue(param, stm);
+//				}
+//			}
+//		}

+//

+//		protected void setCommandBehabior(CommandBehavior cmdBehavior)

+//		{

+//			_behvior = cmdBehavior;

+//		}

+//

+//		internal CommandBehavior getCommandBehavior()

+//		{

+//			return _behvior;

+//		}

+//

+//		protected static String GetProcedureName(string cmdText)

+//		{

+//			if(cmdText[0] == '[' && cmdText[cmdText.Length - 1] == ']')

+//				return cmdText.Substring(1, cmdText.Length - 2);

+//			return cmdText;

+//		}

+//        

+//	}

+//}
\ No newline at end of file