flights.cs

ASP.net实现的在线航空订票查询系统

using System;
using System.Data;
using System.Data.SqlClient;

namespace Air.Class
{
	using Air.entity;

	/// <summary>
	/// Flights 的摘要说明。
	/// </summary>
	public class Flights
	{
		public Flights()
		{
			//
			// TODO: 在此处添加构造函数逻辑
			//
		}

		public struct Condition
		{
			public int _DepartureCityId;
			public int _ArrivalCityId;
			public DateTime _BeginDate;
			public DateTime _EndDate;
		}

		public FlightData GetFlights(Condition condition)
		{
			FlightData flight = new FlightData();
			SqlConnection sqlConnection = new SqlConnection();
			sqlConnection.ConnectionString = 
				"workstation id=YAOYANG;packet size=4096;user id=sa;data source=\"YAOYANG\\yaoyang\";"
				+ "persist security info=True;initial catalog=AirTicket;password=510902";
			SqlDataAdapter sqlDataAdapter = new SqlDataAdapter();
			SqlCommand sqlCommand = new SqlCommand();
			sqlDataAdapter.SelectCommand = sqlCommand;
			sqlCommand.CommandType = CommandType.StoredProcedure;
			sqlCommand.Connection = sqlConnection;
		
			sqlCommand.Parameters.Add(new SqlParameter("@DepartureCityId",condition._DepartureCityId));
			sqlCommand.Parameters.Add(new SqlParameter("@ArrivalCityId", condition._ArrivalCityId));
			sqlCommand.Parameters.Add(new SqlParameter("@DepartureDateMin", condition._BeginDate));
			sqlCommand.Parameters.Add(new SqlParameter("@DepartureDateMax",condition._EndDate));

			try
			{
				sqlConnection.Open();
				sqlCommand.CommandText = "SelectFlight";
				sqlDataAdapter.Fill(flight.Flight);
				sqlCommand.CommandText = "SelectCabin";
				sqlDataAdapter.Fill(flight.Cabin);
			}
			catch(Exception e)
			{
				throw new ApplicationException("数据库错误。", e);
			}
			finally
			{
				sqlConnection.Close();
			}

			return flight;
		}
	}
}