Click here to Skip to main content
15,886,518 members
Articles / Desktop Programming / WPF

DBTool for Oracle - Part 1

Rate me:
Please Sign up or sign in to vote.
4.92/5 (45 votes)
13 Apr 2014CPOL18 min read 136.2K   5.1K   88  
Enhance productivity and reliability, write your own tools.
using System;
using System.Collections.Generic;
using System.Data;
using System.Text;

using Oracle.DataAccess.Client;
using Oracle.DataAccess.Types;

using System.Reflection;
using System.ComponentModel;
using Harlinn.Common;
using Harlinn.DBTool.Common;
using Harlinn.DBTool.DataSources.Oracle.DB;




namespace Harlinn.DBTool.DataSources.Oracle
{
    public class DBOracleFields : DBOracleElement, IDBColumns
    {
        private static readonly log4net.ILog sfLog = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        private static void LogException(Exception exc, System.Reflection.MethodBase method)
        {
            Logger.LogException(sfLog, exc, method);
        }

        string qualifiedName;
        bool refreshed;

        public DBOracleFields()
        {
            
        }
        public DBOracleFields(NodeBase parent, string qualifiedName)
            : base(parent, "Fields")
        {
            this.qualifiedName = qualifiedName;
        }

        [Browsable(false)]
        public DBOracleTable Table
        {
            get
            {
                DBOracleTable result = Parent as DBOracleTable;
                return result;
            }
        }

        [Browsable(false)]
        public DBOracleView View
        {
            get
            {
                DBOracleView result = Parent as DBOracleView;
                return result;
            }
        }

        [Browsable(false)]
        public DBOracleField this[string name]
        {
            get
            {
                if (!refreshed)
                {
                    Refresh();
                }
                DBOracleField result = GetChildByName<DBOracleField>(name);
                return result;
            }
        }

        [Browsable(false)]
        public DBOracleField this[int index]
        {
            get
            {
                if (!refreshed)
                {
                    Refresh();
                }
                DBOracleField result = (DBOracleField)Children[index];
                return result;
            }
        }


        public override DBOracleElementType ElementType
        {
            get 
            {
                return DBOracleElementType.Fields;
            }
        }

        public override void Refresh()
        {
            try
            {
                base.Refresh();

                OracleConnection connection = ConnectionManager.Connection;
                OracleCommand command = connection.CreateCommand();
                using (command)
                {
                    command.CommandText = "SELECT * FROM " + qualifiedName;
                    OracleDataReader reader = command.ExecuteReader(CommandBehavior.SchemaOnly | CommandBehavior.KeyInfo);
                    using (reader)
                    {
                        DataTable schemaInfo = reader.GetSchemaTable();
                        foreach (DataRow fieldDefinition in schemaInfo.Rows)
                        {
                            DBOracleField field = new DBOracleField(this, fieldDefinition);
                            Children.Add(field);
                        }
                    }
                }
                refreshed = true;
            }
            catch (Exception exc)
            {
                LogException(exc, MethodBase.GetCurrentMethod());
                //throw;
            }
        }


        public IDBColumn GetColumnByName(string name)
        {
            if (!refreshed)
            {
                Refresh();
            }
            DBOracleField result = GetChildByName<DBOracleField>(name);
            return result;
        }

        public int IndexOf(IDBColumn item)
        {
            if (!refreshed)
            {
                Refresh();
            }
            return Children.IndexOf((DBOracleField)item);
        }

        public void Insert(int index, IDBColumn item)
        {
            if (!refreshed)
            {
                Refresh();
            }
            Children.Insert(index, (DBOracleField)item);
        }

        public void RemoveAt(int index)
        {
            if (!refreshed)
            {
                Refresh();
            }
            Children.RemoveAt(index);
        }

        IDBColumn IList<IDBColumn>.this[int index]
        {
            get
            {
                if (!refreshed)
                {
                    Refresh();
                }
                return (DBOracleField)Children[index];
            }
            set
            {
                if (!refreshed)
                {
                    Refresh();
                }
                Children[index] = (DBOracleField)value;
            }
        }

        public void Add(IDBColumn item)
        {
            if (!refreshed)
            {
                Refresh();
            }
            Children.Add((DBOracleField)item);
        }

        public bool Contains(IDBColumn item)
        {
            if (!refreshed)
            {
                Refresh();
            }
            return Children.Contains((DBOracleField)item);
        }

        public void CopyTo(IDBColumn[] array, int arrayIndex)
        {
            if (!refreshed)
            {
                Refresh();
            }
            for (int i = 0; i < Children.Count; i++)
            {
                if (array.Length > i + arrayIndex)
                {
                    array[i + arrayIndex] = (DBOracleField)Children[i];
                }
                else
                {
                    break;
                }
            }
        }

        public int Count
        {
            get 
            {
                if (!refreshed)
                {
                    Refresh();
                }
                return Children.Count;
            }
        }

        public bool IsReadOnly
        {
            get 
            {
                if (!refreshed)
                {
                    Refresh();
                }
                return ((IList<NodeBase>)Children).IsReadOnly;
            }
        }

        public bool Remove(IDBColumn item)
        {
            if (!refreshed)
            {
                Refresh();
            }
            return Children.Remove((DBOracleField)item);
        }

        private class InterfaceEnumerator : IEnumerator<IDBColumn>
        {
            IEnumerator<NodeBase> enumerator;

            public InterfaceEnumerator(IEnumerator<NodeBase> enumerator)
            {
                if (enumerator == null)
                {
                    throw new ArgumentNullException("enumerator");
                }
                this.enumerator = enumerator;
            }

            public IDBColumn Current
            {
                get
                {
                    return (IDBColumn)enumerator.Current;
                }
            }

            public void Dispose()
            {
                enumerator.Dispose();
            }

            object System.Collections.IEnumerator.Current
            {
                get
                {
                    return (object)enumerator.Current;
                }
            }

            public bool MoveNext()
            {
                return enumerator.MoveNext();
            }

            public void Reset()
            {
                enumerator.Reset();
            }
        }


        public IEnumerator<IDBColumn> GetEnumerator()
        {
            if (!refreshed)
            {
                Refresh();
            }
            return new InterfaceEnumerator(Children.GetEnumerator());
        }

        System.Collections.IEnumerator System.Collections.IEnumerable.GetEnumerator()
        {
            if (!refreshed)
            {
                Refresh();
            }
            return ((System.Collections.IEnumerable)Children).GetEnumerator();
        }
    }
}

By viewing downloads associated with this article you agree to the Terms of Service and the article's licence.

If a file you wish to view isn't highlighted, and is a text file (not binary), please let us know and we'll add colourisation support for it.

License

This article, along with any associated source code and files, is licensed under The Code Project Open License (CPOL)


Written By
Architect Sea Surveillance AS
Norway Norway
Chief Architect - Sea Surveillance AS.

Specializing in integrated operations and high performance computing solutions.

I’ve been fooling around with computers since the early eighties, I’ve even done work on CP/M and MP/M.

Wrote my first “real” program on a BBC micro model B based on a series in a magazine at that time. It was fun and I got hooked on this thing called programming ...

A few Highlights:

  • High performance application server development
  • Model Driven Architecture and Code generators
  • Real-Time Distributed Solutions
  • C, C++, C#, Java, TSQL, PL/SQL, Delphi, ActionScript, Perl, Rexx
  • Microsoft SQL Server, Oracle RDBMS, IBM DB2, PostGreSQL
  • AMQP, Apache qpid, RabbitMQ, Microsoft Message Queuing, IBM WebSphereMQ, Oracle TuxidoMQ
  • Oracle WebLogic, IBM WebSphere
  • Corba, COM, DCE, WCF
  • AspenTech InfoPlus.21(IP21), OsiSoft PI


More information about what I do for a living can be found at: harlinn.com or LinkedIn

You can contact me at espen@harlinn.no

Comments and Discussions