DAL数据库查询

Posted 2023-02-02 牧云的少年

namespace DAL

    public class DALMethod
   
        //1.连接数据库
        /*Sqlserver数据库连接方式有多种，这里只介绍最常用的通过SqlConnection和Sqlserver数据库用户名和密码验证来进行操作数据库。
       这里data source 是指数据库地址和端口号，需要注意的是地址和端口号之间是用","进行分隔的；initial catalog 是数据库名字 ；user id和pwd分别指用户名和密码。
       */
        public string strConnect = @"Data Source=LAPTOP-BHEH9TEB;Initial Catalog=TTBMS;User ID=sa;Password=123";

        #region 插入、更新、删除
        public int UpdateData(String sql, SqlParameter[] param)
       
            int count = 0;
            /*数据库建立连接
            SqlConnection sqlConnection = new SqlConnection(this.connString);
            sqlConnection.Open();
            */
            using (SqlConnection conn = new SqlConnection(strConnect))
           
                //打开数据库连接
                conn.Open();
                //执行存储过程
                SqlCommand cmd = new SqlCommand(sql, conn);
                //获取存储过程名称
                cmd.CommandType = CommandType.StoredProcedure;
                //添加序列化数组参数
                cmd.Parameters.AddRange(param);
                //数据库插入更新操作
                count = cmd.ExecuteNonQuery();
                //关闭数据库连接
                conn.Close();
           
            return count;
       
        #endregion

        #region 查询数据表
        public DataTable QueryDataTable(String sql, SqlParameter[] param)
       
            DataTable dt = new DataTable();
            //数据库建立连接
            using (SqlConnection conn = new SqlConnection(strConnect))
           
                //打开数据库连接
                conn.Open();
                //表示用于填充 System.Data.DataSet 和更新 SQL Server 数据库的一组数据命令和一个数据库连接
                SqlDataAdapter da = new SqlDataAdapter(sql, conn);
                //获取或设置一个 Transact-SQL 语句或存储过程，用于在数据源中选择记录。
                da.SelectCommand.CommandType = CommandType.StoredProcedure;
                da.SelectCommand.Parameters.AddRange(param);
                //数据库查询
                da.Fill(dt);
                conn.Close();
           
            return dt;
       
        #endregion

        #region 查询数据集
        public DataSet QueryDataSet(String sql, SqlParameter[] param)
       
            DataSet ds = new DataSet();
            /*数据库建立连接
           SqlConnection sqlConnection = new SqlConnection(this.connString);
           sqlConnection.Open();
           */
            using (SqlConnection conn = new SqlConnection(strConnect))
           
                //打开数据库连接
                conn.Open();
                //表示用于填充 System.Data.DataSet 和更新 SQL Server 数据库的一组数据命令和一个数据库连接
                SqlDataAdapter da = new SqlDataAdapter(sql, conn);
                //指定存储过程名称
                da.SelectCommand.CommandType = CommandType.StoredProcedure;
                //获取存储语句参数数组
                da.SelectCommand.Parameters.AddRange(param);
                //在ds 里面添加行
                da.Fill(ds);
                //关闭与数据库的连接。
                conn.Close();
           
            return ds;
       
        #endregion