databaseoperate.cs

用C#编写的实现火车查询功能的程序功能比较完整

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;

namespace TrainSystem.Common
{
    public class DataBaseOperate
    {
        // 保存数据库连接字符串
        private string m_sConnectionString;

        // 数据库连接标志
        private bool m_bConnected;

        

        //数据库连接对象
        private SqlConnection m_sqlConnection;
        private SqlCommand m_sqlCommand;
      
        private SqlDataAdapter m_sqlDataAdapter;

        /// <summary>
        /// 构造函数，初始化内部变量
        /// </summary>
        public DataBaseOperate()
            : this("server=.;database=TrainTime;uid=sa;pwd=sa")
        {
            //
            // TODO: 在此处添加构造函数逻辑
            //
        }

        public DataBaseOperate(
            string sConnectionString)
        {
            if (sConnectionString != "")
            {
                m_sConnectionString = sConnectionString;
                m_bConnected = false;
            }
          
        }

        /// <summary>
        /// 连接数据库，并打开数据库连接
        /// </summary>
        /// <returns>成功返回true</returns>
        private bool ConnectDataBase()
        {
            if (!m_bConnected)
            {
                try
                {
                    if (m_sqlConnection == null)
                    {
                        m_sqlConnection = new SqlConnection(m_sConnectionString);
                        m_sqlConnection.Open();
                    }

                    if (m_sqlCommand == null)
                    {
                        m_sqlCommand = new SqlCommand();
                    }
                    m_bConnected = true;
                    m_sqlCommand.Connection = m_sqlConnection;
                }
                catch (SqlException e)
                {
                    throw e;
                }
            }
            return true;
        }

        /// <summary>
        /// 关闭数据库，释放数据库资源
        /// </summary>
        /// <returns>成功返回true</returns>
        public bool CloseDataBase()
        {
            //Dispose();
            return true;
        }

        /// <summary>
        /// 执行数据库查询操作
        /// </summary>
        /// <param name="sQuery">查询的Sql语句</param>
        /// <param name="sTableName">返回数据集的表名</param>
        /// <returns>返回数据集</returns>
        public DataSet Search(
            string sQuery,
            string sTableName)
        {

            //若连接数据库失败抛出错误
            bool isCon = ConnectDataBase();
            if (!isCon)
            {
                throw (new ApplicationException("没有建立数据库连接。"));
            }

            DataSet dataSet = new DataSet();
            m_sqlCommand.CommandType = System.Data.CommandType.Text;
            m_sqlCommand.CommandText = sQuery;
            m_sqlDataAdapter = new SqlDataAdapter();
            m_sqlDataAdapter.SelectCommand = m_sqlCommand;
            try
            {
                m_sqlDataAdapter.Fill(dataSet,sTableName);
            }
            catch (SqlException e)
            {
                ////如果正在执行事务，回滚
                //if (m_bTransaction)
                //{
                //    m_sqlTransaction.Rollback();
                //}
                throw e;
            }
            return dataSet;
        }

        
        /// <summary>
        ///  执行修改数据库操作，修改、删除等无返回值的操作
        /// </summary>
        /// <param name="sSql">执行的SQL语句</param>
        /// <returns>成功执行返回True</returns>
        public bool Execute(
            string sSql)
        {

            if (!ConnectDataBase())
            {
                throw (new ApplicationException("没有建立数据库连接"));
            }

            m_sqlCommand.CommandType = System.Data.CommandType.Text;
            m_sqlCommand.CommandText = sSql;
            try
            {
                m_sqlCommand.ExecuteNonQuery();
            }
            catch (SqlException e)
            {
                ////如果正在执行事务，回滚
                //if (m_bTransaction)
                //{
                //    m_sqlTransaction.Rollback();
                //}
                throw e;
            }
            return true;
        }

    }
}