using System.Linq;
using System.Xml.Linq;
using Neo.Afx.ComponentModel;

namespace Neo.Afx.Services.Integration
{
    /// <summary>
    /// The integration database.
    /// </summary>
    public class IntegrationDatabase : Database<IntegrationContext>
    {
        SqlIntegrationStore _sqlStore;

        /// <summary>
        /// Initializes a new instance of the <see cref="IntegrationDatabase"/> class.
        /// </summary>
        public IntegrationDatabase()
            : base(new IntegrationContext())
        {
        }

        #region Open/Close DataStore

        /// <summary>
        /// Opens the <see cref="IntegrationStore"/>.
        /// </summary>
        public void Open()
        {
            _sqlStore = new SqlIntegrationStore();
            _sqlStore.Open();
        }

        /// <summary>
        /// Closes the <see cref="IntegrationStore"/>.
        /// </summary>
        public void Close()
        {
            if(_sqlStore != null)
            {
                _sqlStore.Dispose();
                _sqlStore = null;
            }
        }

        #endregion

        #region GetData

        /// <summary>
        /// Gets the data from the named data source.
        /// <remarks>
        /// Invoke <see cref="Open"/> before the first call 
        /// and <see cref="Close"/> after the last call.
        /// </remarks>
        /// </summary>
        /// <param name="name">The name of the data source to be used.</param>
        /// <param name="queryString">The query string to be used.</param>
        /// <returns>The data from the named data source</returns>
        public XElement GetData(string name, string queryString)
        {
            return _sqlStore.GetData(name, queryString);
        }

        #endregion

        #region GetDataSource

        /// <summary>
        /// Gets the <see cref="DataSource"/> with the given ID.
        /// </summary>
        /// <param name="dataSourceID">The data source ID to be queried.</param>
        /// <returns>The <see cref="DataSource"/> with the given ID.</returns>
        public DataSource GetDataSource(long dataSourceID)
        {
            return GetByID<DataSource>(dataSourceID);
        }

        #endregion

        #region GetDataSources

        /// <summary>
        /// Gets a list of <see cref="DataSource"/>.
        /// </summary>
        /// <returns>A list of <see cref="DataSource"/>.</returns>
        public IQueryable<DataSource> GetDataSources()
        {
            return from q in Context.DataSources
                   orderby q.DataSourceName
                   where !q.IsCancelled
                   select q;
        }

        #endregion

        #region GetConnectionTypes

        /// <summary>
        /// Gets a list of <see cref="ConnectionType"/>.
        /// </summary>
        /// <returns>A list of <see cref="ConnectionType"/>.</returns>
        public IQueryable<ConnectionType> GetConnectionTypes()
        {
            return from q in Context.ConnectionTypes
                   orderby q.ConnectionTypeID, q.Title
                   select q;
        }

        #endregion

        #region GetCommandTypes

        /// <summary>
        /// Gets a list of <see cref="CommandType"/>.
        /// </summary>
        /// <returns>A list of <see cref="CommandType"/>.</returns>
        public IQueryable<CommandType> GetCommandTypes()
        {
            return from q in Context.CommandTypes
                   orderby q.CommandTypeID, q.Title
                   select q;
        }

        #endregion

        #region GetAuthTypes

        /// <summary>
        /// Gets a list of <see cref="AuthType"/>.
        /// </summary>
        /// <returns>A list of <see cref="AuthType"/>.</returns>
        public IQueryable<AuthType> GetAuthTypes()
        {
            return from q in Context.AuthTypes
                   orderby q.Title
                   select q;
        }

        #endregion

        #region GetConnection

        /// <summary>
        /// Gets the <see cref="Connection"/> with the given ID.
        /// </summary>
        /// <param name="connectionID">The connection ID to be queried.</param>
        /// <returns>The <see cref="Connection"/> with the given ID.</returns>
        public Connection GetConnection(long connectionID)
        {
            return GetByID<Connection>(connectionID);
        }

        #endregion

        #region GetConnections

        /// <summary>
        /// Gets a list of <see cref="Connection"/>.
        /// </summary>
        /// <returns>A list of <see cref="Connection"/>.</returns>
        public IQueryable<Connection> GetConnections()
        {
            return from q in Context.Connections
                   where !q.IsCancelled
                   select q;
        }

        #endregion

    }
}