DalDiaDiem.cs

Màu nền
Font chữ
Font size
Chiều cao dòng

using System;

using System.Collections.Generic;

using System.Linq;

using System.Text;

using System.Data.SqlClient;

using TourDuLich.BIZ;

namespace TourDuLich.DAL

{

    class DalDiaDiem

    {

        public static List<BizDiaDiem> getAllDiaDiem()

        {

            List<BizDiaDiem> result = new List<BizDiaDiem>();

            // 1. Instantiate the connection

            SqlConnection conn = new SqlConnection(

                @"Data Source=CAOTH-LAPTOP\SQLEXPRESS2K5_2N;Initial Catalog=TourDB;User ID=sa;Password=sa");

            SqlDataReader rdr = null;

            try

            {

                // 2. Open the connection

                conn.Open();

                // 3. Pass the connection to a command object

                SqlCommand cmd = new SqlCommand("select * from DiaDiem", conn);               

                // get query results

                rdr = cmd.ExecuteReader();               

                while (rdr.Read())

                {

                    BizDiaDiem dd = new BizDiaDiem(Int32.Parse(rdr["Id"].ToString()),

                        rdr["MaDiaDiem"].ToString(), rdr["TenDiaDiem"].ToString());

                    result.Add(dd);

                }

            }

            finally

            {

                // close the reader

                if (rdr != null)

                {

                    rdr.Close();

                }

                // 5. Close the connection

                if (conn != null)

                {

                    conn.Close();

                }

            }   

            return result;

        }

        internal static int Insert(BizDiaDiem bizDiaDiem)

        {

            int result = bizDiaDiem.Id;

            // 1. Instantiate the connection

            SqlConnection conn = new SqlConnection(

                @"Data Source=CAOTH-LAPTOP\SQLEXPRESS2K5_2N;Initial Catalog=TourDB;User ID=sa;Password=sa");

            SqlDataReader rdr = null;

            try

            {

                // 2. Open the connection

                conn.Open();

                // 3. Pass the connection to a command object

                String s = String.Format("insert into DiaDiem(MaDiaDiem, TenDiaDiem) values('{0}', '{1}')", bizDiaDiem.MaDD, bizDiaDiem.TenDD);

                SqlCommand cmd = new SqlCommand(s, conn);

                if (cmd.ExecuteNonQuery() > 0)

                {

                    s = String.Format("select Id from DiaDiem where MaDiaDiem='{0}'", bizDiaDiem.MaDD);

                    cmd.CommandText = s;

                    rdr = cmd.ExecuteReader();

                    if(rdr.HasRows)

                    {

                        rdr.Read();

                        result = Int32.Parse(rdr["Id"].ToString());

                    }

                }

            }

            finally

            {

                // close the reader

                if (rdr != null)

                {

                    rdr.Close();

                }

                // 5. Close the connection

                if (conn != null)

                {

                    conn.Close();

                }

            }

            return result;

        }

        internal static void Delete(BizDiaDiem bizDiaDiem)

        {

            // 1. Instantiate the connection

            SqlConnection conn = new SqlConnection(

                @"Data Source=CAOTH-LAPTOP\SQLEXPRESS2K5_2N;Initial Catalog=TourDB;User ID=sa;Password=sa");

            try

            {

                // 2. Open the connection

                conn.Open();

                // 3. Pass the connection to a command object

                String s = String.Format("delete DiaDiem where id={0}", bizDiaDiem.Id);

                SqlCommand cmd = new SqlCommand(s, conn);

                if (cmd.ExecuteNonQuery() > 0)

                {                   

                }

            }

            finally

            {

                // 5. Close the connection

                if (conn != null)

                {

                    conn.Close();

                }

            }

        }

        internal static void Update(BizDiaDiem bizDiaDiem)

        {

            // 1. Instantiate the connection

            SqlConnection conn = new SqlConnection(

                @"Data Source=CAOTH-LAPTOP\SQLEXPRESS2K5_2N;Initial Catalog=TourDB;User ID=sa;Password=sa");

            try

            {

                // 2. Open the connection

                conn.Open();

                // 3. Pass the connection to a command object

                String s = String.Format("update DiaDiem set MaDiaDiem = '{0}', TenDiaDiem = '{1}' where id={2}", bizDiaDiem.MaDD, bizDiaDiem.TenDD, bizDiaDiem.Id);

                SqlCommand cmd = new SqlCommand(s, conn);

                if (cmd.ExecuteNonQuery() > 0)

                {

                }

            }

            finally

            {

                // 5. Close the connection

                if (conn != null)

                {

                    conn.Close();

                }

            }

        }

        internal static List<BizDiaDiem> getDiaDiemByTour(BizTour bizTour)

        {

            List<BizDiaDiem> result = new List<BizDiaDiem>();

            // 1. Instantiate the connection

            SqlConnection conn = new SqlConnection(

                @"Data Source=CAOTH-LAPTOP\SQLEXPRESS2K5_2N;Initial Catalog=TourDB;User ID=sa;Password=sa");

            SqlDataReader rdr = null;

            try

            {

                // 2. Open the connection

                conn.Open();

                // 3. Pass the connection to a command object

                string s = String.Format(@"select dd.Id, dd.MaDiaDiem, dd.TenDiaDiem 

                    from DanhSachDiemThamQuan dtq, DiaDiem dd

                    where dtq.DiaDiemId = dd.Id and

                    dtq.TourId = {0} order by dtq.Stt", bizTour.Id);

                SqlCommand cmd = new SqlCommand(s, conn);

                // get query results

                rdr = cmd.ExecuteReader();

                while (rdr.Read())

                {

                    BizDiaDiem dd = new BizDiaDiem(Int32.Parse(rdr["Id"].ToString()),

                        rdr["MaDiaDiem"].ToString(), rdr["TenDiaDiem"].ToString());

                    result.Add(dd);

                }

            }

            finally

            {

                // close the reader

                if (rdr != null)

                {

                    rdr.Close();

                }

                // 5. Close the connection

                if (conn != null)

                {

                    conn.Close();

                }

            }

            return result;

        }

    }

}

Bạn đang đọc truyện trên: Truyen2U.Pro