复制代码 代码如下:

using System;
using System.Collections.Generic;
using System.Text;
using System.Data;
using System.Data.SqlClient;
using System.Windows.Forms;
namespace yjgl
{
    ///

   
    /// 数据访问基础类(SQL)   
    ///

    class BaseOperate
    {
        #region  建立数据库连接
        ///

        /// 建立数据库连接.
        ///

        /// 返回SqlConnection对象
        public SqlConnection getcon()
        {
            string M_str_sqlcon = \"Data Source=PC-200201010009 ;Database=db_yjzl;User ID=sa;PWD=123\";//连接字符串
            SqlConnection mycon = new SqlConnection(M_str_sqlcon);      //创建连接对象
            return mycon;
        }
        #endregion
        #region  执行SqlCommand命令
        ///

        /// 执行SqlCommand
        ///

        /// SQL语句
        public void getcom(string M_str_sqlstr)
        {
            SqlConnection sqlcon = this.getcon();   //获取连接字符串
            sqlcon.Open();       //打开连接
            try
            {
                SqlCommand sqlcom = new SqlCommand(M_str_sqlstr, sqlcon);  //通过SQL语句和连接对象创建命令对象
                sqlcom.ExecuteNonQuery();     //对sqlcon执行SQL语句并返回受影响的行数
                sqlcom.Dispose();           //释放sqlcom\'
            }
            catch (SqlException e)
            {
                MessageBox.Show(e.ToString(), \"信息提示\", MessageBoxButtons.OK, MessageBoxIcon.Information);
            }
            finally
            {
                sqlcon.Close();
                sqlcon.Dispose();
            }
        }
        #endregion
        #region  创建DataSet对象
        ///

        /// 创建一个DataSet对象
        ///

        /// SQL语句
        /// 表名
        /// 返回DataSet对象
        public DataSet getds(string M_str_sqlstr, string M_str_table)  //查询
        {
            SqlConnection sqlcon = this.getcon();
            SqlDataAdapter sqlda = new SqlDataAdapter(M_str_sqlstr, sqlcon);
            DataSet myds = new DataSet();
            sqlda.Fill(myds, M_str_table);
            return myds;
         }
        #endregion
         #region  创建SqlDataReader对象
         ///

         /// 创建一个SqlDataReader对象
         ///

         /// SQL语句
         /// 返回SqlDataReader对象
        public SqlDataReader getread(string M_str_sqlstr)
        {
            SqlConnection sqlcon = this.getcon();
            SqlCommand sqlcom = new SqlCommand(M_str_sqlstr, sqlcon);
            sqlcon.Open();
            SqlDataReader sqlread = sqlcom.ExecuteReader(CommandBehavior.CloseConnection);
            return sqlread;
           
         }
        #endregion
    }
}