Chào các bạn! Vì nhiều lý do từ nay Truyen2U chính thức đổi tên là Truyen247.Pro. Mong các bạn tiếp tục ủng hộ truy cập tên miền mới này nhé! Mãi yêu... ♥

DalDiaDiem.cs

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: Truyen247.Pro

Tags: