using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
namespace WebProject.DAL
{
public class SqlHelper
{
public static readonly string conStr = ConfigurationManager.ConnectionStrings["conStr"].ConnectionString;
public static DataTable ExecuteTable(string sql,CommandType type,params SqlParameter[] ps)
{
DataTable dt = new DataTable();
using (SqlConnection con = new SqlConnection(conStr))
{
using (SqlDataAdapter adapter = new SqlDataAdapter(sql, con))
{
adapter.SelectCommand.CommandType = type;
if (ps != null)
{
adapter.SelectCommand.Parameters.AddRange(ps);
}
adapter.Fill(dt);
return dt;
}
}
}
public static int ExecuteNonQuery(string sql, CommandType type,params SqlParameter[] ps)
{
using (SqlConnection con = new SqlConnection(conStr))
{
using (SqlCommand cmd = new SqlCommand(sql, con))
{
cmd.CommandType = type;
if (ps!=null)
{
cmd.Parameters.AddRange(ps);
}
con.Open();
return cmd.ExecuteNonQuery();
}
}
}
}
}
/*******************************************************************************************/
//UserInfoDAL
using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using WebProject.Model;
using System.Data;
using System.Data.SqlClient;
namespace WebProject.DAL
{
public class UserInfoDAL
{
public int UpdateUserInfo(UserInfo user)
{
string sql = "update UserInfo set UserName=@UserName,UserPwd=@UserPwd where UserId=@UserId";
SqlParameter[] ps =
{
new SqlParameter("@UserId",user.UserId),
new SqlParameter("@UserName",user.UserName),
new SqlParameter("@UserPwd",user.UserPwd)
};
return SqlHelper.ExecuteNonQuery(sql, CommandType.Text, ps);
}
public UserInfo GetUserInfoById(int userId)
{
UserInfo user = new UserInfo();
string sql = "select * from UserInfo where UserID=@UserId";
SqlParameter[] ps =
{
new SqlParameter("@UserId",userId)
};
DataTable dt = SqlHelper.ExecuteTable(sql,CommandType.Text,ps);
if (dt.Rows.Count>0)
{
user = RowToUserInfo(dt.Rows[0]);
}
return user;
}
public int DeleteUserInfo(int userId)
{
string sql = "delete from UserInfo where UserId=@UserId";
SqlParameter[] ps =
{
new SqlParameter("@UserId",userId)
};
return SqlHelper.ExecuteNonQuery(sql, CommandType.Text, ps);
}
public int AddUserInfo(UserInfo user)
{
string sql = "insert into UserInfo values(@UserName,@UserPwd)";
return SqlHelper.ExecuteNonQuery(sql, CommandType.Text,
new System.Data.SqlClient.SqlParameter("@UserName", user.UserName),
new System.Data.SqlClient.SqlParameter("@UserPwd", user.UserPwd));
}
public List<UserInfo> GetAllUserInfo()
{
List<UserInfo> list = new List<UserInfo>();
string sql = "select * from UserInfo";
DataTable dt = SqlHelper.ExecuteTable(sql,CommandType.Text);
if (dt.Rows.Count>0)
{
foreach (DataRow dr in dt.Rows)
{
list.Add(RowToUserInfo(dr));
}
}
return list;
}
private UserInfo RowToUserInfo(DataRow dr)
{
UserInfo userInfo = new UserInfo();
userInfo.UserId = Convert.ToInt32(dr["UserId"]);
userInfo.UserName = dr["UserName"]==DBNull.Value ? string.Empty: dr["UserName"].ToString();
userInfo.UserPwd = dr["UserPwd"] == DBNull.Value ? string.Empty : dr["UserPwd"].ToString();
return userInfo;
}
}
}