博客

作者：郑凯丰

开发工具：VS、SQL Server、WPF

编写日期：2019年6月3日

代码：

1. WPF中无论是增删查改哪一种首先我们第一步都是在数据库里面先写出相应的代码；
   
   例如：
   
   

2. 先要创建一个数据层(DALMeth)
   
   

3.然后我们在数据层里面写下一步，利用服务端(Server)去连接数据库；



3. 然后在下面写数据库与服务端连接完成后所需要交互的代码；

（这样便可以实现数据库与服务端的交互）

public int UpdateData(String sql, SqlParameter[] param)

{


int count = 0;

/*数据库建立连接

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();
            SqlDataAdapter da = new SqlDataAdapter(sql, conn);
            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();
        using (SqlConnection conn = new SqlConnection(strConnect))
        {
            conn.Open();
            SqlDataAdapter da = new SqlDataAdapter(sql, conn);
            da.SelectCommand.CommandType = CommandType.StoredProcedure;
            da.SelectCommand.Parameters.AddRange(param);
            da.Fill(ds);
            conn.Close();
        }
        return ds;
    }
    #endregion
    #region 二进制文件查询方法
    public byte[] QueryDataByte(String sql, SqlParameter[] param)
    {
        using (SqlConnection conn = new SqlConnection(strConnect))
        {
            conn.Open();//打开连接
            SqlDataReader dr = null;//初始化数据读取器  
            SqlCommand cmd = new SqlCommand(sql, conn);//创建命令对象
            cmd.CommandType = CommandType.StoredProcedure;//设置命令类型
            cmd.Parameters.AddRange(param);//把参数加进命令对象
            dr = cmd.ExecuteReader();//启动dr
            byte[] File = null;//初始化byte
            if (dr.Read())//执行把二进制流加进byte[]中
            {
                File = (byte[])dr[0];
            }
            dr.Close();//关闭数据读取器
            conn.Close();//关闭连接
            return File;
        }
    }