mono/mcs/class/System.Data/System.Data.OleDb.jvm/OleDbConnection.cs

//
// System.Data.OleDb.OleDbConnection
//
// Author:
//   Boris Kirzner ([email protected])
//


using System.Data;
using System.Data.Common;
using System.Collections;

using java.sql;

namespace System.Data.OleDb
{
	public sealed class OleDbConnection : AbstractDBConnection, System.ICloneable
	{
		#region Fields 

		protected static Hashtable _skippedUserParameters = new Hashtable(new CaseInsensitiveHashCodeProvider(),new CaseInsensitiveComparer());

		private static DbStringManager _stringManager = new DbStringManager("System.Data.System.Data.ProviderBase.jvm.OleDbStrings");

		private static readonly string[] _resourceIgnoredKeys = new string[] {"CON_PROVIDER","CON_DATA_SOURCE","CON_DATABASE",
																			  "CON_PASSWORD","CON_USER_ID","CON_TIMEOUT",
																			  "CON_SERVER_NAME","CON_PORT","CON_SERVICE_NAME",
																			  "CON_JNDI_NAME","CON_JNDI_PROVIDER","CON_JNDI_FACTORY",
																			  "JDBC_DRIVER","JDBC_URL","DB2_CON_LOCATION" };

		#endregion //Fields

		#region Events

		public event OleDbInfoMessageEventHandler InfoMessage;
		public event StateChangeEventHandler StateChange;

		#endregion // Events
		
		#region Constructors

		public OleDbConnection() : this(null)
		{
		}

		public OleDbConnection(String connectionString) : base(connectionString)
		{			
		}

		#endregion // Constructors

		#region Properties

		protected override string[] ResourceIgnoredKeys
		{
			get { return _resourceIgnoredKeys; }
		}

		public String Provider
		{
			get { return ConnectionStringHelper.FindValue(UserParameters,StringManager.GetStringArray("CON_PROVIDER")); }
		}

		protected override Hashtable SkippedUserParameters
		{
			get { return _skippedUserParameters; }
		}

		protected override string ServerName
		{
			get { 
				if (ProviderType == PROVIDER_TYPE.IBMDADB2 || ProviderType == PROVIDER_TYPE.MSDAORA) {
					string host = ConnectionStringHelper.FindValue(UserParameters,StringManager.GetStringArray("CON_SERVER_NAME"));

					if (!String.Empty.Equals(host)) {
						return host;
					}

					if (ProviderType == PROVIDER_TYPE.IBMDADB2) {
						string location = ConnectionStringHelper.FindValue(UserParameters,StringManager.GetStringArray("DB2_CON_LOCATION"));

						if (!String.Empty.Equals(location)) {
							int semicolumnIndex = location.IndexOf(':');
							if (semicolumnIndex != -1) {
								return location.Substring(0,semicolumnIndex);
							}
							else {
								return location;
							}
						}
					}

				}
				return base.ServerName; 
			}
		}

		protected override string CatalogName
		{
			get { 
				switch (ProviderType) {
					case PROVIDER_TYPE.IBMDADB2:
					case PROVIDER_TYPE.MSDAORA:
						return DataSource;
				}
				return base.CatalogName;
			}
		}

		protected override string Port
		{
			get {
				string port = ConnectionStringHelper.FindValue(UserParameters, StringManager.GetStringArray("CON_PORT"));
				switch (ProviderType) {
					case PROVIDER_TYPE.MSDAORA :
						if (String.Empty.Equals(port)) {
							return StringManager.GetString("ORA_CON_PORT");
						}
						return port;
					case PROVIDER_TYPE.IBMDADB2 :
						if (String.Empty.Equals(port)) {
							string location = ConnectionStringHelper.FindValue(UserParameters,StringManager.GetStringArray("DB2_CON_LOCATION"));

							if (!String.Empty.Equals(location)) {
								int semicolumnIndex = location.IndexOf(':');
								if (semicolumnIndex != -1) {
									return location.Substring(semicolumnIndex + 1);
								}
							}
							return StringManager.GetString("DB2_CON_PORT");
						}
						return port;
				}
				return base.Port;
			}
		}

		protected override string JdbcDriverName
		{
			get {
				JDBC_MODE jdbcMode = JdbcMode;
				switch (jdbcMode) {
					case JDBC_MODE.DATA_SOURCE_MODE :
						return base.JdbcDriverName;
					case JDBC_MODE.JDBC_DRIVER_MODE :
						return ConnectionStringHelper.FindValue(UserParameters,StringManager.GetStringArray("JDBC_DRIVER"));
					case JDBC_MODE.PROVIDER_MODE:
						switch (ProviderType) {
							case PROVIDER_TYPE.SQLOLEDB :
								return StringManager.GetString("SQL_JDBC_DRIVER");
							case PROVIDER_TYPE.MSDAORA :
								return StringManager.GetString("ORA_JDBC_DRIVER");
							case PROVIDER_TYPE.IBMDADB2 :
								return StringManager.GetString("DB2_JDBC_DRIVER");
						}
						break;
				};
				return base.JdbcDriverName;
			}
		}

		protected override DbStringManager StringManager
		{
			get { return _stringManager; }
		}

		#endregion // Properties

		#region Methods

		public new OleDbTransaction BeginTransaction(IsolationLevel level)
		{
			return new OleDbTransaction(level, this);
		}

		public new OleDbTransaction BeginTransaction()
		{
			return BeginTransaction(IsolationLevel.ReadCommitted);
		}

		public new OleDbCommand CreateCommand()
		{
			return new OleDbCommand(this);
		}

		protected override DbTransaction BeginDbTransaction(IsolationLevel isolationLevel) {
			return BeginTransaction();
		}

		protected override DbCommand CreateDbCommand() {
			return CreateCommand();
		}


		protected internal override void CopyTo(AbstractDBConnection target)
		{
			base.CopyTo(target);
		}

		public object Clone()
		{
			OleDbConnection clone = new OleDbConnection();
			CopyTo(clone);
			return clone;
		}

		protected override SystemException CreateException(SQLException e)
		{
			return new OleDbException(e,this);		
		}

		public DataTable GetOleDbSchemaTable (Guid schema, object[] restrictions)
		{
			DataTable schemaTable = new DataTable("Tables");
			schemaTable.Columns.Add("TABLE_CATALOG");
			schemaTable.Columns.Add("TABLE_SCHEMA");
			schemaTable.Columns.Add("TABLE_NAME");
			schemaTable.Columns.Add("TABLE_TYPE");
			schemaTable.Columns.Add("TABLE_GUID");
			schemaTable.Columns.Add("DESCRIPTION");
			schemaTable.Columns.Add("TABLE_PROPID");
			schemaTable.Columns.Add("DATE_CREATED");
			schemaTable.Columns.Add("DATE_MODIFIED");
            
            
			Connection con = JdbcConnection;
			String catalog = con.getCatalog();
            
			DatabaseMetaData meta = con.getMetaData();
			ResultSet schemaRes = meta.getSchemas();
			System.Collections.ArrayList schemas = new System.Collections.ArrayList();
			while(schemaRes.next()) {
				schemas.Add(schemaRes.getString(1));
			}
			schemaRes.close();

			for(int i = 0; i < schemas.Count; i++) {
				ResultSet tableRes = meta.getTables(catalog, schemas[i].ToString(), null, null);
				while(tableRes.next()) {
					DataRow row = schemaTable.NewRow();
					row["TABLE_CATALOG"] = catalog;
					row["TABLE_SCHEMA"] = schemas[i];
					row["TABLE_NAME"] = tableRes.getString("TABLE_NAME");
					row["TABLE_TYPE"] = tableRes.getString("TABLE_TYPE");
					row["DESCRIPTION"] = tableRes.getString("REMARKS");
                    
					schemaTable.Rows.Add(row);
				}
				tableRes.close();
			}
			return schemaTable;
		}

		protected internal override void ValidateConnectionString(string connectionString)
		{
			base.ValidateConnectionString(connectionString);

			JDBC_MODE currentJdbcMode = JdbcMode;
			
			if (currentJdbcMode == JDBC_MODE.NONE) {
				string provider = StringManager.GetString("CON_PROVIDER");

				if (String.Empty.Equals(provider)) {
					throw ExceptionHelper.OleDbNoProviderSpecified();
				}
			}
		}

		protected override string BuildJdbcUrl()
		{
			switch (JdbcMode) {
				case JDBC_MODE.PROVIDER_MODE :
				switch (ProviderType) {
					case PROVIDER_TYPE.IBMDADB2:
						return BuildDb2Url();
					case PROVIDER_TYPE.MSDAORA:
						return BuildOracleUrl();
					case PROVIDER_TYPE.SQLOLEDB:
						return BuildMsSqlUrl();
				}
				break;
			}
			return base.BuildJdbcUrl();
		}

		public static void ReleaseObjectPool()
		{
			// since we're using connection pool from app servet, this is by design
			//throw new NotImplementedException();
		}

		internal override void OnSqlWarning(SQLWarning warning)
		{
			OleDbErrorCollection col = new OleDbErrorCollection(warning, this);
			OnOleDbInfoMessage(new OleDbInfoMessageEventArgs(col));
		}

		internal override Connection GetConnectionFromProvider()
		{
			if ((ProviderType == PROVIDER_TYPE.MSDAORA) && 
				("true").Equals(StringManager.GetString("ORA_CONNECTION_POOLING_ENABLED","false"))) {
				ActivateJdbcDriver(JdbcDriverName);
				return OleDbConnectionFactory.GetConnection(ProviderType,JdbcUrl,User,Password,ConnectionTimeout);
			}
			else {
				return base.GetConnectionFromProvider();
			}
		}

		private String BuildDb2Url()
		{
			return StringManager.GetString("DB2_JDBC_URL") //jdbc:db2://
				+ ServerName + ":" + Port + "/" + CatalogName;
		}

		private String BuildOracleUrl()
		{
			return StringManager.GetString("ORA_JDBC_URL") //"jdbc:oracle:thin:@"
				+ ServerName + ":" + Port + ":" + CatalogName;
		}
        
		internal override void OnStateChanged(ConnectionState orig, ConnectionState current)
		{
			if(StateChange != null) {
				StateChange(this, new StateChangeEventArgs(orig, current));
			}
		}

		public override void Close()
		{
			ConnectionState orig = State;
			base.Close();
			ConnectionState current = State;
			if(current != orig) {
				OnStateChanged(orig, current);
			}
		}

		private void OnOleDbInfoMessage (OleDbInfoMessageEventArgs value)
		{
			if (InfoMessage != null) {
				InfoMessage (this, value);
			}
		}

		#endregion // Methods

	}
}