Event-Driven Architecture in the Clouds with Windows Azure

using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Runtime.Serialization;
using Microsoft.Practices.EnterpriseLibrary.Data;
using FlightUpdates.Entities;
using System.Data.Common;
using FlightUpdates.Utility.Constants;
using System.Data;

namespace FlightUpdates.Business
{
    public class AirportManager : BaseManager
    {
        /// <summary>
        /// Get a list of all US airports
        /// </summary>
        public  List<AirportInfo> GetAirports()
        {
            List<AirportInfo> AirportList = new List<AirportInfo>();

            //Set StoredProc
            DbCommand dbCommand = FlightUpdateDB.GetStoredProcCommand("spAirportActive_Select");

            //Get data
            using (IDataReader reader = FlightUpdateDB.ExecuteReader(dbCommand))
            {
                while (reader.Read())
                {
                    AirportInfo airportItem = new AirportInfo()
                    {
                        AirportCode = DataAccessUtility.GetValue<string>(reader["AirportCode"]),
                        AirportName = DataAccessUtility.GetValue<string>(reader["AirportName"]),
                        LatitudeDegree = DataAccessUtility.GetValue<double>(reader["LatitudeDeg"]),
                        LongitudeDegree = DataAccessUtility.GetValue<double>(reader["LongitudeDeg"]),
                        DelayTime = DataAccessUtility.GetValue<int>(reader["DelayTime"])
                    };

                    AirportList.Add(airportItem);
                }
            }

            return AirportList;
        }

        /// <summary>
        /// Get flight delays for an airport 
        /// </summary> 
        /// <param name="Airport">airport code</param>
        public List<FlightDelayFeed> GetFlightDelayFeed(string Airport)
        {
            List<FlightDelayFeed> FlightDelayFeedList = new List<FlightDelayFeed>();

            //Set StoredProc with paramters
            DbCommand dbCommand = FlightUpdateDB.GetStoredProcCommand("spFlightDelayFeed_Select");
            FlightUpdateDB.AddInParameter(dbCommand, "flightCity", DbType.String, Airport);

            //Get data
            using (IDataReader reader = FlightUpdateDB.ExecuteReader(dbCommand))
            {
                while (reader.Read())
                {
                    FlightDelayFeed flightDelayFeedItem = new FlightDelayFeed()
                    {
                        DelayTime = DataAccessUtility.GetValue<int>(reader["DelayTime"]),
                        DelayExpiration = DataAccessUtility.GetValue<DateTime>(reader["DelayExpiration"]),
                        FlightCity = DataAccessUtility.GetValue<string>(reader["FlightCity"]),
                        FlightNumber = DataAccessUtility.GetValue<string>(reader["FlightNumber"]),
                        LastUpdateTime = DataAccessUtility.GetValue<DateTime>(reader["LastUpdateTime"])
                    };

                    FlightDelayFeedList.Add(flightDelayFeedItem);
                }
            }

            return FlightDelayFeedList;
        }
    }
    internal class DataAccessUtility
    {
        internal static T GetValue<T>(object obj)
        {
            if (obj != DBNull.Value)
            {
                return (T)obj;
            }
            return default(T);
        }
    }
}