三層架構實現登陸註冊功能
阿新 • • 發佈:2019-02-03
-------------WebRegister.aspx前臺:------------------
<%@ Page Language="C#" AutoEventWireup="true" CodeBehind="WebRegister.aspx.cs" Inherits="Register.WebRegister" %>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head runat="server">
<title></title>
<style type="text/css">
#mydiv
{
width:auto;height:auto;border:solid 1px red;
position:absolute;top:50%;left:50%;margin-top:-100px;margin-left:-150px;
}
.style1
{
width: 87px;
}
</style>
</head>
<body>
<form id="form1" runat="server">
<div id="mydiv" >
<table>
<tr>
<td colspan="2" align="center" >
<asp:Label ID="lblUserId" runat="server" Text=""></asp:Label>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
使用者編號
</td>
<td>
<asp:TextBox ID="txtUserId" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
使用者名稱
</td>
<td>
<asp:TextBox ID="txtUserName" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
密碼
</td>
<td>
<asp:TextBox ID="txtPassword" runat="server" Height="19px"
ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
姓名
</td>
<td>
<asp:TextBox ID="txtRealName" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
手機
</td>
<td>
<asp:TextBox ID="txtMobile" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1">
<asp:RegularExpressionValidator ID="RegularExpressionValidator1" runat="server"
ErrorMessage="手機號碼格式不正確"
ValidationExpression="(\(\d{3}\)|\d{3}-)?\d{8}"
ControlToValidate="txtMobile" ForeColor="Red" Font-Size="Small"
ValidationGroup="org"></asp:RegularExpressionValidator>
</td>
</tr>
<tr>
<td>
部門
</td>
<td>
<asp:DropDownList ID="ddlDepartment" runat="server" AppendDataBoundItems="True"
ValidationGroup="org">
<asp:ListItem Text="---請選擇---" Value="0"></asp:ListItem>
</asp:DropDownList>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
地址
</td>
<td>
<asp:TextBox ID="txtAddress" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
身份證號
</td>
<td>
<asp:TextBox ID="txtIdCard" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1">
<asp:RegularExpressionValidator ID="RegularExpressionValidator2" runat="server"
ControlToValidate="txtIdCard" ErrorMessage="身份證號碼格式不正確" Font-Size="Small"
ForeColor="Red" ValidationExpression="\d{17}[\d|X]|\d{15}"
ValidationGroup="org"></asp:RegularExpressionValidator>
</td>
</tr>
<tr>
<td >
郵箱
</td>
<td >
<asp:TextBox ID="txtEmail" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1">
<asp:RegularExpressionValidator ID="RegularExpressionValidator3" runat="server"
ControlToValidate="txtEmail" ErrorMessage="郵箱格式不正確" Font-Size="Small"
ForeColor="Red"
ValidationExpression="\w+([-+.']\w+)*@\w+([-.]\w+)*\.\w+([-.]\w+)*"
ValidationGroup="org"></asp:RegularExpressionValidator>
</td>
</tr>
<tr>
<td>
是否結婚
</td>
<td>
<asp:DropDownList ID="ddlMarry" runat="server" AppendDataBoundItems="True"
ValidationGroup="org">
<asp:ListItem Text="---請選擇---" Value="0"></asp:ListItem>
<asp:ListItem Value="true">是</asp:ListItem>
<asp:ListItem Value="false">否</asp:ListItem>
</asp:DropDownList>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
籍貫
</td>
<td>
<asp:TextBox ID="txtCensusRegister" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td align="center" colspan="2">
<asp:Button ID="btnSave" runat="server" Text="儲存" OnClick="btnSave_Click"
ValidationGroup="a" /> <asp:Label ID="lblinfo" runat="server" Text="" ForeColor="Red"></asp:Label>
</td>
<td class="style1"></td>
</tr>
</table>
</div>
</form>
</body>
</html>
--------------------WebRegister.aspx後臺------------
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Data;
using System.Configuration;
using System.Data.SqlClient;
namespace Register
{
public partial class WebRegister : System.Web.UI.Page
{
string strcon = ConfigurationManager.ConnectionStrings["sqlserverStrcon"].ConnectionString;
protected void Page_Load(object sender, EventArgs e)
{
if (!IsPostBack)
{
LoadDepartment();
LoadUserId();
}
}
private void LoadUserId()
{
SqlConnection conn = new SqlConnection(strcon);
conn.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = conn;
cmd.CommandText = "SELECT UserId FROM T_User WHERE Id=(SELECT MAX(Id)FROM T_User)";
lblUserId.Text = "最後一條記錄Id為:" + cmd.ExecuteScalar().ToString();
cmd.Dispose();
conn.Dispose();
}
private void LoadDepartment()
{
Register.BLL.Department bdepartment = new BLL.Department();
/*使用傳統的DataSet結果集返回
DataSet ds = bdepartment.GetList("");
this.ddlDepartment.DataSource = ds.Tables[0];
*/
//使用實體層來返回資料
List<Register.Model.Department> modellist = bdepartment.GetModelList();
this.ddlDepartment.DataSource = modellist;
this.ddlDepartment.DataTextField = "Department_Name";
this.ddlDepartment.DataValueField = "Department_Id";
this.ddlDepartment.DataBind();
}
protected void btnSave_Click(object sender, EventArgs e)
{
Register.Model.T_User muserid = new Model.T_User();
muserid.UserId = txtUserId.Text;
Register.BLL.T_User buserid = new BLL.T_User();
Register.Model.T_User musername=new Model.T_User();
musername.UserName=txtUserName.Text;
Register.BLL.T_User busername=new BLL.T_User();
if (buserid.ValidatorUserId(muserid) == true)
{
ClientScript.RegisterStartupScript(this.GetType(), "information", "<script type='text/javascript'>alert('該UserId已存在!');</script>");
txtUserId.Text = "";
}
else if(busername.ValidatorUserName(musername)==true)
{
ClientScript.RegisterStartupScript(this.GetType(), "information", "<script type='text/javascript'>alert('該該使用者名稱已存在!');</script>");
txtUserName.Text = "";
}
else
{
Register.Model.T_User muser = new Model.T_User();
muser.UserId = txtUserId.Text;
muser.UserName = txtUserName.Text;
muser.Password = txtPassword.Text;
muser.RealName = txtRealName.Text;
muser.Mobile = txtMobile.Text;
muser.Department = ddlDepartment.SelectedValue;
Register.BLL.T_User buser = new BLL.T_User();
Register.Model.T_UserInfo mUserInfo = new Model.T_UserInfo();
mUserInfo.UserId = txtUserId.Text;
mUserInfo.T_Address = txtAddress.Text;
mUserInfo.T_IdCard = txtIdCard.Text;
mUserInfo.T_Email = txtEmail.Text;
mUserInfo.T_IsMarry = Convert.ToBoolean(ddlMarry.SelectedValue);
mUserInfo.T_CensusRegister = txtCensusRegister.Text;
Register.BLL.T_UserInfo bUserInfo = new BLL.T_UserInfo();
if (buser.Add(muser) > 0 && bUserInfo.Add(mUserInfo) > 0)
{
lblinfo.Text = "新增成功!";
}
else
{
lblinfo.Text = "新增失敗!";
}
}
}
}
}
-----------WebLogin.aspx前臺---------------
<%@ Page Language="C#" AutoEventWireup="true" CodeBehind="WebLogin.aspx.cs" Inherits="Register.WebLogin" %>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head runat="server">
<title></title>
<style type="text/css">
#mydiv
{
width:300px;height:200px;border:solid 1px red;
position:absolute;top:50%;left:50%;margin-top:-100px;margin-left:-150px;
}
</style>
</head>
<body>
<form id="form1" runat="server">
<div id="mydiv">
<table>
<tr>
<td>
使用者名稱:<asp:TextBox ID="txtUserName" runat="server"></asp:TextBox>
</td>
</tr>
<tr>
<td>
密 碼:<asp:TextBox ID="txtPassword" runat="server"></asp:TextBox>
</td>
</tr>
<tr>
<td align="center">
<asp:Button ID="btnLogin" runat="server" Text="登入" onclick="btnLogin_Click" />
</td>
</tr>
</table>
</div>
</form>
</body>
</html>
-----------WebLogin.aspx後臺---------------
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
namespace Register
{
public partial class WebLogin : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
}
protected void btnLogin_Click(object sender, EventArgs e)
{
Register.Model.T_User muser = new Model.T_User();
muser.UserName = txtUserName.Text;
muser.Password = txtPassword.Text;
Register.BLL.T_User btuser = new BLL.T_User();
if (btuser.ValidatorUser(muser) == true)
{
Response.Write("登入成功!");
}
else
{
Response.Write("登入失敗!");
}
}
}
}
--------------Web.config----------------------
<connectionStrings>
<add name="sqlserverStrcon" connectionString="Data Source=.;Initial Catalog=News;Persist Security Info=True;User ID=sa;Password=111111"/>
</connectionStrings>
-----------------------------------MODEL層----------------------------------------------------
-----------------------T_User.cs:
using System;
namespace Register.Model
{
/// <summary>
/// T_User:實體類(屬性說明自動提取資料庫欄位的描述資訊)
/// </summary>
[Serializable]
public partial class T_User
{
public T_User()
{}
#region Model
private int _id;
private string _userid;
private string _username;
private string _password;
private string _realname;
private string _mobile;
private string _department;
/// <summary>
///
/// </summary>
public int Id
{
set{ _id=value;}
get{return _id;}
}
/// <summary>
/// 使用者編號
/// </summary>
public string UserId
{
set{ _userid=value;}
get{return _userid;}
}
/// <summary>
/// 使用者名稱
/// </summary>
public string UserName
{
set{ _username=value;}
get{return _username;}
}
/// <summary>
/// 密碼
/// </summary>
public string Password
{
set{ _password=value;}
get{return _password;}
}
/// <summary>
/// 使用者姓名
/// </summary>
public string RealName
{
set{ _realname=value;}
get{return _realname;}
}
/// <summary>
/// 手機
/// </summary>
public string Mobile
{
set{ _mobile=value;}
get{return _mobile;}
}
/// <summary>
/// 所屬部門
/// </summary>
public string Department
{
set{ _department=value;}
get{return _department;}
}
#endregion Model
}
}
-------------------------T_UserInfo.cs:
using System;
namespace Register.Model
{
/// <summary>
/// T_UserInfo:實體類(屬性說明自動提取資料庫欄位的描述資訊)
/// </summary>
[Serializable]
public partial class T_UserInfo
{
public T_UserInfo()
{}
#region Model
private int _id;
private string _userid;
private string _t_address;
private string _t_idcard;
private string _t_email;
private bool _t_ismarry;
private string _t_censusregister;
/// <summary>
///
/// </summary>
public int Id
{
set{ _id=value;}
get{return _id;}
}
/// <summary>
///
/// </summary>
public string UserId
{
set{ _userid=value;}
get{return _userid;}
}
/// <summary>
///
/// </summary>
public string T_Address
{
set{ _t_address=value;}
get{return _t_address;}
}
/// <summary>
///
/// </summary>
public string T_IdCard
{
set{ _t_idcard=value;}
get{return _t_idcard;}
}
/// <summary>
///
/// </summary>
public string T_Email
{
set{ _t_email=value;}
get{return _t_email;}
}
/// <summary>
///
/// </summary>
public bool T_IsMarry
{
set{ _t_ismarry=value;}
get{return _t_ismarry;}
}
/// <summary>
///
/// </summary>
public string T_CensusRegister
{
set{ _t_censusregister=value;}
get{return _t_censusregister;}
}
#endregion Model
}
}
-------------------Department.cs:
using System;
namespace Register.Model
{
/// <summary>
/// Department:實體類(屬性說明自動提取資料庫欄位的描述資訊)
/// </summary>
[Serializable]
public partial class Department
{
public Department()
{}
#region Model
private int _id;
private string _department_id;
private string _department_name;
/// <summary>
///
/// </summary>
public int Id
{
set{ _id=value;}
get{return _id;}
}
/// <summary>
///
/// </summary>
public string Department_Id
{
set{ _department_id=value;}
get{return _department_id;}
}
/// <summary>
///
/// </summary>
public string Department_Name
{
set{ _department_name=value;}
get{return _department_name;}
}
#endregion Model
}
}
------------------DataAccess層:-------------------
----------------DbHelperSQL.cs:
using System;
using System.Collections;
using System.Collections.Specialized;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
using System.Data.Common;
using System.Collections.Generic;
namespace Register.DataAccess
{
/// <summary>
/// 資料訪問抽象基礎類
/// Copyright (C) Maticsoft
/// </summary>
public abstract class DbHelperSQL
{
//資料庫連線字串(web.config來配置),多資料庫可使用DbHelperSQLP來實現.
public static string connectionString = ConfigurationManager.ConnectionStrings["sqlserverStrcon"].ConnectionString;
public DbHelperSQL()
{
}
#region 公用方法
/// <summary>
/// 判斷是否存在某表的某個欄位
/// </summary>
/// <param name="tableName">表名稱</param>
/// <param name="columnName">列名稱</param>
/// <returns>是否存在</returns>
public static bool ColumnExists(string tableName, string columnName)
{
string sql = "select count(1) from syscolumns where [id]=object_id('" + tableName + "') and [name]='" + columnName + "'";
object res = GetSingle(sql);
if (res == null)
{
return false;
}
return Convert.ToInt32(res) > 0;
}
public static int GetMaxID(string FieldName, string TableName)
{
string strsql = "select max(" + FieldName + ")+1 from " + TableName;
object obj = GetSingle(strsql);
if (obj == null)
{
return 1;
}
else
{
return int.Parse(obj.ToString());
}
}
public static bool Exists(string strSql)
{
object obj = GetSingle(strSql);
int cmdresult;
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
cmdresult = 0;
}
else
{
cmdresult = int.Parse(obj.ToString()); //也可能=0
}
if (cmdresult == 0)
{
return false;
}
else
{
return true;
}
}
/// <summary>
/// 表是否存在
/// </summary>
/// <param name="TableName"></param>
/// <returns></returns>
public static bool TabExists(string TableName)
{
string strsql = "select count(*) from sysobjects where id = object_id(N'[" + TableName + "]') and OBJECTPROPERTY(id, N'IsUserTable') = 1";
//string strsql = "SELECT count(*) FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[" + TableName + "]') AND type in (N'U')";
object obj = GetSingle(strsql);
int cmdresult;
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
cmdresult = 0;
}
else
{
cmdresult = int.Parse(obj.ToString());
}
if (cmdresult == 0)
{
return false;
}
else
{
return true;
}
}
public static bool Exists(string strSql, params SqlParameter[] cmdParms)
{
object obj = GetSingle(strSql, cmdParms);
int cmdresult;
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
cmdresult = 0;
}
else
{
cmdresult = int.Parse(obj.ToString());
}
if (cmdresult == 0)
{
return false;
}
else
{
return true;
}
}
#endregion
#region 執行簡單SQL語句
/// <summary>
/// 執行SQL語句,返回影響的記錄數
/// </summary>
/// <param name="SQLString">SQL語句</param>
/// <returns>影響的記錄數</returns>
public static int ExecuteSql(string SQLString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
}
}
}
public static int ExecuteSqlByTime(string SQLString, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
cmd.CommandTimeout = Times;
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
}
}
}
/// <summary>
/// 執行多條SQL語句,實現資料庫事務。
/// </summary>
/// <param name="SQLStringList">多條SQL語句</param>
public static int ExecuteSqlTran(List<String> SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = conn;
SqlTransaction tx = conn.BeginTransaction();
cmd.Transaction = tx;
try
{
int count = 0;
for (int n = 0; n < SQLStringList.Count; n++)
{
string strsql = SQLStringList[n];
if (strsql.Trim().Length > 1)
{
cmd.CommandText = strsql;
count += cmd.ExecuteNonQuery();
}
}
tx.Commit();
return count;
}
catch
{
tx.Rollback();
return 0;
}
}
}
/// <summary>
/// 執行帶一個儲存過程引數的的SQL語句。
/// </summary>
/// <param name="SQLString">SQL語句</param>
/// <param name="content">引數內容,比如一個欄位是格式複雜的文章,有特殊符號,可以通過這個方式新增</param>
/// <returns>影響的記錄數</returns>
public static int ExecuteSql(string SQLString, string content)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand(SQLString, connection);
System.Data.SqlClient.SqlParameter myParameter = new System.Data.SqlClient.SqlParameter("@content", SqlDbType.NText);
myParameter.Value = content;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
/// <summary>
/// 執行帶一個儲存過程引數的的SQL語句。
/// </summary>
/// <param name="SQLString">SQL語句</param>
/// <param name="content">引數內容,比如一個欄位是格式複雜的文章,有特殊符號,可以通過這個方式新增</param>
/// <returns>影響的記錄數</returns>
public static object ExecuteSqlGet(string SQLString, string content)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand(SQLString, connection);
System.Data.SqlClient.SqlParameter myParameter = new System.Data.SqlClient.SqlParameter("@content", SqlDbType.NText);
myParameter.Value = content;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
/// <summary>
/// 向資料庫裡插入影象格式的欄位(和上面情況類似的另一種例項)
/// </summary>
/// <param name="strSQL">SQL語句</param>
/// <param name="fs">影象位元組,資料庫的欄位型別為image的情況</param>
/// <returns>影響的記錄數</returns>
public static int ExecuteSqlInsertImg(string strSQL, byte[] fs)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand(strSQL, connection);
System.Data.SqlClient.SqlParameter myParameter = new System.Data.SqlClient.SqlParameter("@fs", SqlDbType.Image);
myParameter.Value = fs;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
/// <summary>
/// 執行一條計算查詢結果語句,返回查詢結果(object)。
/// </summary>
/// <param name="SQLString">計算查詢結果語句</param>
/// <returns>查詢結果(object)</returns>
public static object GetSingle(string SQLString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
}
}
}
public static object GetSingle(string SQLString, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
cmd.CommandTimeout = Times;
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
}
}
}
/// <summary>
/// 執行查詢語句,返回SqlDataReader ( 注意:呼叫該方法後,一定要對SqlDataReader進行Close )
/// </summary>
/// <param name="strSQL">查詢語句</param>
/// <returns>SqlDataReader</returns>
public static SqlDataReader ExecuteReader(string strSQL)
{
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand cmd = new SqlCommand(strSQL, connection);
try
{
connection.Open();
SqlDataReader myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
return myReader;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
}
/// <summary>
/// 執行查詢語句,返回DataSet
/// </summary>
/// <param name="SQLString">查詢語句</param>
/// <returns>DataSet</returns>
public static DataSet Query(string SQLString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
DataSet ds = new DataSet();
try
{
connection.Open();
SqlDataAdapter command = new SqlDataAdapter(SQLString, connection);
command.Fill(ds, "ds");
}
catch (System.Data.SqlClient.SqlException ex)
{
throw new Exception(ex.Message);
}
return ds;
}
}
public static DataSet Query(string SQLString, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
DataSet ds = new DataSet();
try
{
connection.Open();
SqlDataAdapter command = new SqlDataAdapter(SQLString, connection);
command.SelectCommand.CommandTimeout = Times;
command.Fill(ds, "ds");
}
catch (System.Data.SqlClient.SqlException ex)
{
throw new Exception(ex.Message);
}
return ds;
}
}
#endregion
#region 執行帶引數的SQL語句
/// <summary>
/// 執行SQL語句,返回影響的記錄數
/// </summary>
/// <param name="SQLString">SQL語句</param>
/// <returns>影響的記錄數</returns>
public static int ExecuteSql(string SQLString, params SqlParameter[] cmdParms)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand())
{
try
{
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
int rows = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
}
}
}
/// <summary>
/// 執行多條SQL語句,實現資料庫事務。
/// </summary>
/// <param name="SQLStringList">SQL語句的雜湊表(key為sql語句,value是該語句的SqlParameter[])</param>
public static void ExecuteSqlTran(Hashtable SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction trans = conn.BeginTransaction())
{
SqlCommand cmd = new SqlCommand();
try
{
//迴圈
foreach (DictionaryEntry myDE in SQLStringList)
{
string cmdText = myDE.Key.ToString();
SqlParameter[] cmdParms = (SqlParameter[])myDE.Value;
PrepareCommand(cmd, conn, trans, cmdText, cmdParms);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
}
trans.Commit();
}
catch
{
trans.Rollback();
throw;
}
}
}
}
/// <summary>
/// 執行多條SQL語句,實現資料庫事務。
/// </summary>
/// <param name="SQLStringList">SQL語句的雜湊表(key為sql語句,value是該語句的SqlParameter[])</param>
public static void ExecuteSqlTranWithIndentity(Hashtable SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction trans = conn.BeginTransaction())
{
SqlCommand cmd = new SqlCommand();
try
{
int indentity = 0;
//迴圈
foreach (DictionaryEntry myDE in SQLStringList)
{
string cmdText = myDE.Key.ToString();
SqlParameter[] cmdParms = (SqlParameter[])myDE.Value;
foreach (SqlParameter q in cmdParms)
{
if (q.Direction == ParameterDirection.InputOutput)
{
q.Value = indentity;
}
}
PrepareCommand(cmd, conn, trans, cmdText, cmdParms);
int val = cmd.ExecuteNonQuery();
foreach (SqlParameter q in cmdParms)
{
if (q.Direction == ParameterDirection.Output)
{
indentity = Convert.ToInt32(q.Value);
}
}
cmd.Parameters.Clear();
}
trans.Commit();
}
catch
{
trans.Rollback();
throw;
}
}
}
}
/// <summary>
/// 執行一條計算查詢結果語句,返回查詢結果(object)。
/// </summary>
/// <param name="SQLString">計算查詢結果語句</param>
/// <returns>查詢結果(object)</returns>
public static object GetSingle(string SQLString, params SqlParameter[] cmdParms)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand())
{
try
{
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
object obj = cmd.ExecuteScalar();
cmd.Parameters.Clear();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
}
}
}
/// <summary>
/// 執行查詢語句,返回SqlDataReader ( 注意:呼叫該方法後,一定要對SqlDataReader進行Close )
/// </summary>
/// <param name="strSQL">查詢語句</param>
/// <returns>SqlDataReader</returns>
public static SqlDataReader ExecuteReader(string SQLString, params SqlParameter[] cmdParms)
{
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand cmd = new SqlCommand();
try
{
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
SqlDataReader myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
cmd.Parameters.Clear();
return myReader;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
//finally
//{
//cmd.Dispose();
//connection.Close();
//}
}
/// <summary>
/// 執行查詢語句,返回DataSet
/// </summary>
/// <param name="SQLString">查詢語句</param>
/// <returns>DataSet</returns>
public static DataSet Query(string SQLString, params SqlParameter[] cmdParms)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
using (SqlDataAdapter da = new SqlDataAdapter(cmd))
{
DataSet ds = new DataSet();
try
{
da.Fill(ds, "ds");
cmd.Parameters.Clear();
}
catch (System.Data.SqlClient.SqlException ex)
{
throw new Exception(ex.Message);
}
return ds;
}
}
}
private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, string cmdText, SqlParameter[] cmdParms)
{
if (conn.State != ConnectionState.Open)
conn.Open();
cmd.Connection = conn;
cmd.CommandText = cmdText;
if (trans != null)
cmd.Transaction = trans;
cmd.CommandType = CommandType.Text;//cmdType;
if (cmdParms != null)
{
foreach (SqlParameter parameter in cmdParms)
{
if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
(parameter.Value == null))
{
parameter.Value = DBNull.Value;
}
cmd.Parameters.Add(parameter);
}
}
}
#endregion
#region 儲存過程操作
/// <summary>
/// 執行儲存過程,返回SqlDataReader ( 注意:呼叫該方法後,一定要對SqlDataReader進行Close )
/// </summary>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <returns>SqlDataReader</returns>
public static SqlDataReader RunProcedure(string storedProcName, IDataParameter[] parameters)
{
SqlConnection connection = new SqlConnection(connectionString);
SqlDataReader returnReader;
connection.Open();
SqlCommand command = BuildQueryCommand(connection, storedProcName, parameters);
command.CommandType = CommandType.StoredProcedure;
returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);
return returnReader;
}
/// <summary>
/// 執行儲存過程
/// </summary>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <param name="tableName">DataSet結果中的表名</param>
/// <returns>DataSet</returns>
public static DataSet RunProcedure(string storedProcName, IDataParameter[] parameters, string tableName)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
DataSet dataSet = new DataSet();
connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
sqlDA.SelectCommand = BuildQueryCommand(connection, storedProcName, parameters);
sqlDA.Fill(dataSet, tableName);
connection.Close();
return dataSet;
}
}
public static DataSet RunProcedure(string storedProcName, IDataParameter[] parameters, string tableName, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
DataSet dataSet = new DataSet();
connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
sqlDA.SelectCommand = BuildQueryCommand(connection, storedProcName, parameters);
sqlDA.SelectCommand.CommandTimeout = Times;
sqlDA.Fill(dataSet, tableName);
connection.Close();
return dataSet;
}
}
/// <summary>
/// 構建 SqlCommand 物件(用來返回一個結果集,而不是一個整數值)
/// </summary>
/// <param name="connection">資料庫連線</param>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <returns>SqlCommand</returns>
private static SqlCommand BuildQueryCommand(SqlConnection connection, string storedProcName, IDataParameter[] parameters)
{
SqlCommand command = new SqlCommand(storedProcName, connection);
command.CommandType = CommandType.StoredProcedure;
foreach (SqlParameter parameter in parameters)
{
if (parameter != null)
{
// 檢查未分配值的輸出引數,將其分配以DBNull.Value.
if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
(parameter.Value == null))
{
parameter.Value = DBNull.Value;
}
command.Parameters.Add(parameter);
}
}
return command;
}
/// <summary>
/// 執行儲存過程,返回影響的行數
/// </summary>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <param name="rowsAffected">影響的行數</param>
/// <returns></returns>
public static int RunProcedure(string storedProcName, IDataParameter[] parameters, out int rowsAffected)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
int result;
connection.Open();
SqlCommand command = BuildIntCommand(connection, storedProcName, parameters);
rowsAffected = command.ExecuteNonQuery();
result = (int)command.Parameters["ReturnValue"].Value;
//Connection.Close();
return result;
}
}
/// <summary>
/// 建立 SqlCommand 物件例項(用來返回一個整數值)
/// </summary>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <returns>SqlCommand 物件例項</returns>
private static SqlCommand BuildIntCommand(SqlConnection connection, string storedProcName, IDataParameter[] parameters)
{
SqlCommand command = BuildQueryCommand(connection, storedProcName, parameters);
command.Parameters.Add(new SqlParameter("ReturnValue",
SqlDbType.Int, 4, ParameterDirection.ReturnValue,
false, 0, 0, string.Empty, DataRowVersion.Default, null));
return command;
}
#endregion
}
}
--------------------------DAL層---------------------------
-------------------Department.cs:
using System;
using System.Data;
using System.Text;
using System.Data.SqlClient;
using Register.DataAccess;
using System.Collections.Generic;//Please add references
namespace Register.DAL
{
/// <summary>
/// 資料訪問類:Department
/// </summary>
public partial class Department
{
public Department()
{}
#region BasicMethod
/// <summary>
/// 得到最大ID
/// </summary>
public int GetMaxId()
{
return DbHelperSQL.GetMaxID("Id", "Department");
}
/// <summary>
/// 是否存在該記錄
/// </summary>
public bool Exists(int Id)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select count(1) from Department");
strSql.Append(" where [email protected]");
SqlParameter[] parameters = {
new SqlParameter("@Id", SqlDbType.Int,4)
};
parameters[0].Value = Id;
return DbHelperSQL.Exists(strSql.ToString(),parameters);
}
/// <summary>
/// 增加一條資料
/// </summary>
public int Add(Register.Model.Department mode
<%@ Page Language="C#" AutoEventWireup="true" CodeBehind="WebRegister.aspx.cs" Inherits="Register.WebRegister" %>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head runat="server">
<title></title>
<style type="text/css">
#mydiv
{
width:auto;height:auto;border:solid 1px red;
position:absolute;top:50%;left:50%;margin-top:-100px;margin-left:-150px;
}
.style1
{
width: 87px;
}
</style>
</head>
<body>
<form id="form1" runat="server">
<div id="mydiv" >
<table>
<tr>
<td colspan="2" align="center" >
<asp:Label ID="lblUserId" runat="server" Text=""></asp:Label>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
使用者編號
</td>
<td>
<asp:TextBox ID="txtUserId" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
使用者名稱
</td>
<td>
<asp:TextBox ID="txtUserName" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
密碼
</td>
<td>
<asp:TextBox ID="txtPassword" runat="server" Height="19px"
ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
姓名
</td>
<td>
<asp:TextBox ID="txtRealName" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
手機
</td>
<td>
<asp:TextBox ID="txtMobile" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1">
<asp:RegularExpressionValidator ID="RegularExpressionValidator1" runat="server"
ErrorMessage="手機號碼格式不正確"
ValidationExpression="(\(\d{3}\)|\d{3}-)?\d{8}"
ControlToValidate="txtMobile" ForeColor="Red" Font-Size="Small"
ValidationGroup="org"></asp:RegularExpressionValidator>
</td>
</tr>
<tr>
<td>
部門
</td>
<td>
<asp:DropDownList ID="ddlDepartment" runat="server" AppendDataBoundItems="True"
ValidationGroup="org">
<asp:ListItem Text="---請選擇---" Value="0"></asp:ListItem>
</asp:DropDownList>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
地址
</td>
<td>
<asp:TextBox ID="txtAddress" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
身份證號
</td>
<td>
<asp:TextBox ID="txtIdCard" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1">
<asp:RegularExpressionValidator ID="RegularExpressionValidator2" runat="server"
ControlToValidate="txtIdCard" ErrorMessage="身份證號碼格式不正確" Font-Size="Small"
ForeColor="Red" ValidationExpression="\d{17}[\d|X]|\d{15}"
ValidationGroup="org"></asp:RegularExpressionValidator>
</td>
</tr>
<tr>
<td >
郵箱
</td>
<td >
<asp:TextBox ID="txtEmail" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1">
<asp:RegularExpressionValidator ID="RegularExpressionValidator3" runat="server"
ControlToValidate="txtEmail" ErrorMessage="郵箱格式不正確" Font-Size="Small"
ForeColor="Red"
ValidationExpression="\w+([-+.']\w+)*@\w+([-.]\w+)*\.\w+([-.]\w+)*"
ValidationGroup="org"></asp:RegularExpressionValidator>
</td>
</tr>
<tr>
<td>
是否結婚
</td>
<td>
<asp:DropDownList ID="ddlMarry" runat="server" AppendDataBoundItems="True"
ValidationGroup="org">
<asp:ListItem Text="---請選擇---" Value="0"></asp:ListItem>
<asp:ListItem Value="true">是</asp:ListItem>
<asp:ListItem Value="false">否</asp:ListItem>
</asp:DropDownList>
</td>
<td class="style1"></td>
</tr>
<tr>
<td>
籍貫
</td>
<td>
<asp:TextBox ID="txtCensusRegister" runat="server" ValidationGroup="org"></asp:TextBox>
</td>
<td class="style1"></td>
</tr>
<tr>
<td align="center" colspan="2">
<asp:Button ID="btnSave" runat="server" Text="儲存" OnClick="btnSave_Click"
ValidationGroup="a" /> <asp:Label ID="lblinfo" runat="server" Text="" ForeColor="Red"></asp:Label>
</td>
<td class="style1"></td>
</tr>
</table>
</div>
</form>
</body>
</html>
--------------------WebRegister.aspx後臺------------
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Data;
using System.Configuration;
using System.Data.SqlClient;
namespace Register
{
public partial class WebRegister : System.Web.UI.Page
{
string strcon = ConfigurationManager.ConnectionStrings["sqlserverStrcon"].ConnectionString;
protected void Page_Load(object sender, EventArgs e)
{
if (!IsPostBack)
{
LoadDepartment();
LoadUserId();
}
}
private void LoadUserId()
{
SqlConnection conn = new SqlConnection(strcon);
conn.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = conn;
cmd.CommandText = "SELECT UserId FROM T_User WHERE Id=(SELECT MAX(Id)FROM T_User)";
lblUserId.Text = "最後一條記錄Id為:" + cmd.ExecuteScalar().ToString();
cmd.Dispose();
conn.Dispose();
}
private void LoadDepartment()
{
Register.BLL.Department bdepartment = new BLL.Department();
/*使用傳統的DataSet結果集返回
DataSet ds = bdepartment.GetList("");
this.ddlDepartment.DataSource = ds.Tables[0];
*/
//使用實體層來返回資料
List<Register.Model.Department> modellist = bdepartment.GetModelList();
this.ddlDepartment.DataSource = modellist;
this.ddlDepartment.DataTextField = "Department_Name";
this.ddlDepartment.DataValueField = "Department_Id";
this.ddlDepartment.DataBind();
}
protected void btnSave_Click(object sender, EventArgs e)
{
Register.Model.T_User muserid = new Model.T_User();
muserid.UserId = txtUserId.Text;
Register.BLL.T_User buserid = new BLL.T_User();
Register.Model.T_User musername=new Model.T_User();
musername.UserName=txtUserName.Text;
Register.BLL.T_User busername=new BLL.T_User();
if (buserid.ValidatorUserId(muserid) == true)
{
ClientScript.RegisterStartupScript(this.GetType(), "information", "<script type='text/javascript'>alert('該UserId已存在!');</script>");
txtUserId.Text = "";
}
else if(busername.ValidatorUserName(musername)==true)
{
ClientScript.RegisterStartupScript(this.GetType(), "information", "<script type='text/javascript'>alert('該該使用者名稱已存在!');</script>");
txtUserName.Text = "";
}
else
{
Register.Model.T_User muser = new Model.T_User();
muser.UserId = txtUserId.Text;
muser.UserName = txtUserName.Text;
muser.Password = txtPassword.Text;
muser.RealName = txtRealName.Text;
muser.Mobile = txtMobile.Text;
muser.Department = ddlDepartment.SelectedValue;
Register.BLL.T_User buser = new BLL.T_User();
Register.Model.T_UserInfo mUserInfo = new Model.T_UserInfo();
mUserInfo.UserId = txtUserId.Text;
mUserInfo.T_Address = txtAddress.Text;
mUserInfo.T_IdCard = txtIdCard.Text;
mUserInfo.T_Email = txtEmail.Text;
mUserInfo.T_IsMarry = Convert.ToBoolean(ddlMarry.SelectedValue);
mUserInfo.T_CensusRegister = txtCensusRegister.Text;
Register.BLL.T_UserInfo bUserInfo = new BLL.T_UserInfo();
if (buser.Add(muser) > 0 && bUserInfo.Add(mUserInfo) > 0)
{
lblinfo.Text = "新增成功!";
}
else
{
lblinfo.Text = "新增失敗!";
}
}
}
}
}
-----------WebLogin.aspx前臺---------------
<%@ Page Language="C#" AutoEventWireup="true" CodeBehind="WebLogin.aspx.cs" Inherits="Register.WebLogin" %>
<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd">
<html xmlns="http://www.w3.org/1999/xhtml">
<head runat="server">
<title></title>
<style type="text/css">
#mydiv
{
width:300px;height:200px;border:solid 1px red;
position:absolute;top:50%;left:50%;margin-top:-100px;margin-left:-150px;
}
</style>
</head>
<body>
<form id="form1" runat="server">
<div id="mydiv">
<table>
<tr>
<td>
使用者名稱:<asp:TextBox ID="txtUserName" runat="server"></asp:TextBox>
</td>
</tr>
<tr>
<td>
密 碼:<asp:TextBox ID="txtPassword" runat="server"></asp:TextBox>
</td>
</tr>
<tr>
<td align="center">
<asp:Button ID="btnLogin" runat="server" Text="登入" onclick="btnLogin_Click" />
</td>
</tr>
</table>
</div>
</form>
</body>
</html>
-----------WebLogin.aspx後臺---------------
using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Web.UI;
using System.Web.UI.WebControls;
namespace Register
{
public partial class WebLogin : System.Web.UI.Page
{
protected void Page_Load(object sender, EventArgs e)
{
}
protected void btnLogin_Click(object sender, EventArgs e)
{
Register.Model.T_User muser = new Model.T_User();
muser.UserName = txtUserName.Text;
muser.Password = txtPassword.Text;
Register.BLL.T_User btuser = new BLL.T_User();
if (btuser.ValidatorUser(muser) == true)
{
Response.Write("登入成功!");
}
else
{
Response.Write("登入失敗!");
}
}
}
}
--------------Web.config----------------------
<connectionStrings>
<add name="sqlserverStrcon" connectionString="Data Source=.;Initial Catalog=News;Persist Security Info=True;User ID=sa;Password=111111"/>
</connectionStrings>
-----------------------------------MODEL層----------------------------------------------------
-----------------------T_User.cs:
using System;
namespace Register.Model
{
/// <summary>
/// T_User:實體類(屬性說明自動提取資料庫欄位的描述資訊)
/// </summary>
[Serializable]
public partial class T_User
{
public T_User()
{}
#region Model
private int _id;
private string _userid;
private string _username;
private string _password;
private string _realname;
private string _mobile;
private string _department;
/// <summary>
///
/// </summary>
public int Id
{
set{ _id=value;}
get{return _id;}
}
/// <summary>
/// 使用者編號
/// </summary>
public string UserId
{
set{ _userid=value;}
get{return _userid;}
}
/// <summary>
/// 使用者名稱
/// </summary>
public string UserName
{
set{ _username=value;}
get{return _username;}
}
/// <summary>
/// 密碼
/// </summary>
public string Password
{
set{ _password=value;}
get{return _password;}
}
/// <summary>
/// 使用者姓名
/// </summary>
public string RealName
{
set{ _realname=value;}
get{return _realname;}
}
/// <summary>
/// 手機
/// </summary>
public string Mobile
{
set{ _mobile=value;}
get{return _mobile;}
}
/// <summary>
/// 所屬部門
/// </summary>
public string Department
{
set{ _department=value;}
get{return _department;}
}
#endregion Model
}
}
-------------------------T_UserInfo.cs:
using System;
namespace Register.Model
{
/// <summary>
/// T_UserInfo:實體類(屬性說明自動提取資料庫欄位的描述資訊)
/// </summary>
[Serializable]
public partial class T_UserInfo
{
public T_UserInfo()
{}
#region Model
private int _id;
private string _userid;
private string _t_address;
private string _t_idcard;
private string _t_email;
private bool _t_ismarry;
private string _t_censusregister;
/// <summary>
///
/// </summary>
public int Id
{
set{ _id=value;}
get{return _id;}
}
/// <summary>
///
/// </summary>
public string UserId
{
set{ _userid=value;}
get{return _userid;}
}
/// <summary>
///
/// </summary>
public string T_Address
{
set{ _t_address=value;}
get{return _t_address;}
}
/// <summary>
///
/// </summary>
public string T_IdCard
{
set{ _t_idcard=value;}
get{return _t_idcard;}
}
/// <summary>
///
/// </summary>
public string T_Email
{
set{ _t_email=value;}
get{return _t_email;}
}
/// <summary>
///
/// </summary>
public bool T_IsMarry
{
set{ _t_ismarry=value;}
get{return _t_ismarry;}
}
/// <summary>
///
/// </summary>
public string T_CensusRegister
{
set{ _t_censusregister=value;}
get{return _t_censusregister;}
}
#endregion Model
}
}
-------------------Department.cs:
using System;
namespace Register.Model
{
/// <summary>
/// Department:實體類(屬性說明自動提取資料庫欄位的描述資訊)
/// </summary>
[Serializable]
public partial class Department
{
public Department()
{}
#region Model
private int _id;
private string _department_id;
private string _department_name;
/// <summary>
///
/// </summary>
public int Id
{
set{ _id=value;}
get{return _id;}
}
/// <summary>
///
/// </summary>
public string Department_Id
{
set{ _department_id=value;}
get{return _department_id;}
}
/// <summary>
///
/// </summary>
public string Department_Name
{
set{ _department_name=value;}
get{return _department_name;}
}
#endregion Model
}
}
------------------DataAccess層:-------------------
----------------DbHelperSQL.cs:
using System;
using System.Collections;
using System.Collections.Specialized;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;
using System.Data.Common;
using System.Collections.Generic;
namespace Register.DataAccess
{
/// <summary>
/// 資料訪問抽象基礎類
/// Copyright (C) Maticsoft
/// </summary>
public abstract class DbHelperSQL
{
//資料庫連線字串(web.config來配置),多資料庫可使用DbHelperSQLP來實現.
public static string connectionString = ConfigurationManager.ConnectionStrings["sqlserverStrcon"].ConnectionString;
public DbHelperSQL()
{
}
#region 公用方法
/// <summary>
/// 判斷是否存在某表的某個欄位
/// </summary>
/// <param name="tableName">表名稱</param>
/// <param name="columnName">列名稱</param>
/// <returns>是否存在</returns>
public static bool ColumnExists(string tableName, string columnName)
{
string sql = "select count(1) from syscolumns where [id]=object_id('" + tableName + "') and [name]='" + columnName + "'";
object res = GetSingle(sql);
if (res == null)
{
return false;
}
return Convert.ToInt32(res) > 0;
}
public static int GetMaxID(string FieldName, string TableName)
{
string strsql = "select max(" + FieldName + ")+1 from " + TableName;
object obj = GetSingle(strsql);
if (obj == null)
{
return 1;
}
else
{
return int.Parse(obj.ToString());
}
}
public static bool Exists(string strSql)
{
object obj = GetSingle(strSql);
int cmdresult;
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
cmdresult = 0;
}
else
{
cmdresult = int.Parse(obj.ToString()); //也可能=0
}
if (cmdresult == 0)
{
return false;
}
else
{
return true;
}
}
/// <summary>
/// 表是否存在
/// </summary>
/// <param name="TableName"></param>
/// <returns></returns>
public static bool TabExists(string TableName)
{
string strsql = "select count(*) from sysobjects where id = object_id(N'[" + TableName + "]') and OBJECTPROPERTY(id, N'IsUserTable') = 1";
//string strsql = "SELECT count(*) FROM sys.objects WHERE object_id = OBJECT_ID(N'[dbo].[" + TableName + "]') AND type in (N'U')";
object obj = GetSingle(strsql);
int cmdresult;
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
cmdresult = 0;
}
else
{
cmdresult = int.Parse(obj.ToString());
}
if (cmdresult == 0)
{
return false;
}
else
{
return true;
}
}
public static bool Exists(string strSql, params SqlParameter[] cmdParms)
{
object obj = GetSingle(strSql, cmdParms);
int cmdresult;
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
cmdresult = 0;
}
else
{
cmdresult = int.Parse(obj.ToString());
}
if (cmdresult == 0)
{
return false;
}
else
{
return true;
}
}
#endregion
#region 執行簡單SQL語句
/// <summary>
/// 執行SQL語句,返回影響的記錄數
/// </summary>
/// <param name="SQLString">SQL語句</param>
/// <returns>影響的記錄數</returns>
public static int ExecuteSql(string SQLString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
}
}
}
public static int ExecuteSqlByTime(string SQLString, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
cmd.CommandTimeout = Times;
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
}
}
}
/// <summary>
/// 執行多條SQL語句,實現資料庫事務。
/// </summary>
/// <param name="SQLStringList">多條SQL語句</param>
public static int ExecuteSqlTran(List<String> SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
SqlCommand cmd = new SqlCommand();
cmd.Connection = conn;
SqlTransaction tx = conn.BeginTransaction();
cmd.Transaction = tx;
try
{
int count = 0;
for (int n = 0; n < SQLStringList.Count; n++)
{
string strsql = SQLStringList[n];
if (strsql.Trim().Length > 1)
{
cmd.CommandText = strsql;
count += cmd.ExecuteNonQuery();
}
}
tx.Commit();
return count;
}
catch
{
tx.Rollback();
return 0;
}
}
}
/// <summary>
/// 執行帶一個儲存過程引數的的SQL語句。
/// </summary>
/// <param name="SQLString">SQL語句</param>
/// <param name="content">引數內容,比如一個欄位是格式複雜的文章,有特殊符號,可以通過這個方式新增</param>
/// <returns>影響的記錄數</returns>
public static int ExecuteSql(string SQLString, string content)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand(SQLString, connection);
System.Data.SqlClient.SqlParameter myParameter = new System.Data.SqlClient.SqlParameter("@content", SqlDbType.NText);
myParameter.Value = content;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
/// <summary>
/// 執行帶一個儲存過程引數的的SQL語句。
/// </summary>
/// <param name="SQLString">SQL語句</param>
/// <param name="content">引數內容,比如一個欄位是格式複雜的文章,有特殊符號,可以通過這個方式新增</param>
/// <returns>影響的記錄數</returns>
public static object ExecuteSqlGet(string SQLString, string content)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand(SQLString, connection);
System.Data.SqlClient.SqlParameter myParameter = new System.Data.SqlClient.SqlParameter("@content", SqlDbType.NText);
myParameter.Value = content;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
/// <summary>
/// 向資料庫裡插入影象格式的欄位(和上面情況類似的另一種例項)
/// </summary>
/// <param name="strSQL">SQL語句</param>
/// <param name="fs">影象位元組,資料庫的欄位型別為image的情況</param>
/// <returns>影響的記錄數</returns>
public static int ExecuteSqlInsertImg(string strSQL, byte[] fs)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand(strSQL, connection);
System.Data.SqlClient.SqlParameter myParameter = new System.Data.SqlClient.SqlParameter("@fs", SqlDbType.Image);
myParameter.Value = fs;
cmd.Parameters.Add(myParameter);
try
{
connection.Open();
int rows = cmd.ExecuteNonQuery();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
finally
{
cmd.Dispose();
connection.Close();
}
}
}
/// <summary>
/// 執行一條計算查詢結果語句,返回查詢結果(object)。
/// </summary>
/// <param name="SQLString">計算查詢結果語句</param>
/// <returns>查詢結果(object)</returns>
public static object GetSingle(string SQLString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
}
}
}
public static object GetSingle(string SQLString, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand(SQLString, connection))
{
try
{
connection.Open();
cmd.CommandTimeout = Times;
object obj = cmd.ExecuteScalar();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
connection.Close();
throw e;
}
}
}
}
/// <summary>
/// 執行查詢語句,返回SqlDataReader ( 注意:呼叫該方法後,一定要對SqlDataReader進行Close )
/// </summary>
/// <param name="strSQL">查詢語句</param>
/// <returns>SqlDataReader</returns>
public static SqlDataReader ExecuteReader(string strSQL)
{
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand cmd = new SqlCommand(strSQL, connection);
try
{
connection.Open();
SqlDataReader myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
return myReader;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
}
/// <summary>
/// 執行查詢語句,返回DataSet
/// </summary>
/// <param name="SQLString">查詢語句</param>
/// <returns>DataSet</returns>
public static DataSet Query(string SQLString)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
DataSet ds = new DataSet();
try
{
connection.Open();
SqlDataAdapter command = new SqlDataAdapter(SQLString, connection);
command.Fill(ds, "ds");
}
catch (System.Data.SqlClient.SqlException ex)
{
throw new Exception(ex.Message);
}
return ds;
}
}
public static DataSet Query(string SQLString, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
DataSet ds = new DataSet();
try
{
connection.Open();
SqlDataAdapter command = new SqlDataAdapter(SQLString, connection);
command.SelectCommand.CommandTimeout = Times;
command.Fill(ds, "ds");
}
catch (System.Data.SqlClient.SqlException ex)
{
throw new Exception(ex.Message);
}
return ds;
}
}
#endregion
#region 執行帶引數的SQL語句
/// <summary>
/// 執行SQL語句,返回影響的記錄數
/// </summary>
/// <param name="SQLString">SQL語句</param>
/// <returns>影響的記錄數</returns>
public static int ExecuteSql(string SQLString, params SqlParameter[] cmdParms)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand())
{
try
{
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
int rows = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
return rows;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
}
}
}
/// <summary>
/// 執行多條SQL語句,實現資料庫事務。
/// </summary>
/// <param name="SQLStringList">SQL語句的雜湊表(key為sql語句,value是該語句的SqlParameter[])</param>
public static void ExecuteSqlTran(Hashtable SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction trans = conn.BeginTransaction())
{
SqlCommand cmd = new SqlCommand();
try
{
//迴圈
foreach (DictionaryEntry myDE in SQLStringList)
{
string cmdText = myDE.Key.ToString();
SqlParameter[] cmdParms = (SqlParameter[])myDE.Value;
PrepareCommand(cmd, conn, trans, cmdText, cmdParms);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
}
trans.Commit();
}
catch
{
trans.Rollback();
throw;
}
}
}
}
/// <summary>
/// 執行多條SQL語句,實現資料庫事務。
/// </summary>
/// <param name="SQLStringList">SQL語句的雜湊表(key為sql語句,value是該語句的SqlParameter[])</param>
public static void ExecuteSqlTranWithIndentity(Hashtable SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction trans = conn.BeginTransaction())
{
SqlCommand cmd = new SqlCommand();
try
{
int indentity = 0;
//迴圈
foreach (DictionaryEntry myDE in SQLStringList)
{
string cmdText = myDE.Key.ToString();
SqlParameter[] cmdParms = (SqlParameter[])myDE.Value;
foreach (SqlParameter q in cmdParms)
{
if (q.Direction == ParameterDirection.InputOutput)
{
q.Value = indentity;
}
}
PrepareCommand(cmd, conn, trans, cmdText, cmdParms);
int val = cmd.ExecuteNonQuery();
foreach (SqlParameter q in cmdParms)
{
if (q.Direction == ParameterDirection.Output)
{
indentity = Convert.ToInt32(q.Value);
}
}
cmd.Parameters.Clear();
}
trans.Commit();
}
catch
{
trans.Rollback();
throw;
}
}
}
}
/// <summary>
/// 執行一條計算查詢結果語句,返回查詢結果(object)。
/// </summary>
/// <param name="SQLString">計算查詢結果語句</param>
/// <returns>查詢結果(object)</returns>
public static object GetSingle(string SQLString, params SqlParameter[] cmdParms)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
using (SqlCommand cmd = new SqlCommand())
{
try
{
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
object obj = cmd.ExecuteScalar();
cmd.Parameters.Clear();
if ((Object.Equals(obj, null)) || (Object.Equals(obj, System.DBNull.Value)))
{
return null;
}
else
{
return obj;
}
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
}
}
}
/// <summary>
/// 執行查詢語句,返回SqlDataReader ( 注意:呼叫該方法後,一定要對SqlDataReader進行Close )
/// </summary>
/// <param name="strSQL">查詢語句</param>
/// <returns>SqlDataReader</returns>
public static SqlDataReader ExecuteReader(string SQLString, params SqlParameter[] cmdParms)
{
SqlConnection connection = new SqlConnection(connectionString);
SqlCommand cmd = new SqlCommand();
try
{
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
SqlDataReader myReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
cmd.Parameters.Clear();
return myReader;
}
catch (System.Data.SqlClient.SqlException e)
{
throw e;
}
//finally
//{
//cmd.Dispose();
//connection.Close();
//}
}
/// <summary>
/// 執行查詢語句,返回DataSet
/// </summary>
/// <param name="SQLString">查詢語句</param>
/// <returns>DataSet</returns>
public static DataSet Query(string SQLString, params SqlParameter[] cmdParms)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
SqlCommand cmd = new SqlCommand();
PrepareCommand(cmd, connection, null, SQLString, cmdParms);
using (SqlDataAdapter da = new SqlDataAdapter(cmd))
{
DataSet ds = new DataSet();
try
{
da.Fill(ds, "ds");
cmd.Parameters.Clear();
}
catch (System.Data.SqlClient.SqlException ex)
{
throw new Exception(ex.Message);
}
return ds;
}
}
}
private static void PrepareCommand(SqlCommand cmd, SqlConnection conn, SqlTransaction trans, string cmdText, SqlParameter[] cmdParms)
{
if (conn.State != ConnectionState.Open)
conn.Open();
cmd.Connection = conn;
cmd.CommandText = cmdText;
if (trans != null)
cmd.Transaction = trans;
cmd.CommandType = CommandType.Text;//cmdType;
if (cmdParms != null)
{
foreach (SqlParameter parameter in cmdParms)
{
if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
(parameter.Value == null))
{
parameter.Value = DBNull.Value;
}
cmd.Parameters.Add(parameter);
}
}
}
#endregion
#region 儲存過程操作
/// <summary>
/// 執行儲存過程,返回SqlDataReader ( 注意:呼叫該方法後,一定要對SqlDataReader進行Close )
/// </summary>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <returns>SqlDataReader</returns>
public static SqlDataReader RunProcedure(string storedProcName, IDataParameter[] parameters)
{
SqlConnection connection = new SqlConnection(connectionString);
SqlDataReader returnReader;
connection.Open();
SqlCommand command = BuildQueryCommand(connection, storedProcName, parameters);
command.CommandType = CommandType.StoredProcedure;
returnReader = command.ExecuteReader(CommandBehavior.CloseConnection);
return returnReader;
}
/// <summary>
/// 執行儲存過程
/// </summary>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <param name="tableName">DataSet結果中的表名</param>
/// <returns>DataSet</returns>
public static DataSet RunProcedure(string storedProcName, IDataParameter[] parameters, string tableName)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
DataSet dataSet = new DataSet();
connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
sqlDA.SelectCommand = BuildQueryCommand(connection, storedProcName, parameters);
sqlDA.Fill(dataSet, tableName);
connection.Close();
return dataSet;
}
}
public static DataSet RunProcedure(string storedProcName, IDataParameter[] parameters, string tableName, int Times)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
DataSet dataSet = new DataSet();
connection.Open();
SqlDataAdapter sqlDA = new SqlDataAdapter();
sqlDA.SelectCommand = BuildQueryCommand(connection, storedProcName, parameters);
sqlDA.SelectCommand.CommandTimeout = Times;
sqlDA.Fill(dataSet, tableName);
connection.Close();
return dataSet;
}
}
/// <summary>
/// 構建 SqlCommand 物件(用來返回一個結果集,而不是一個整數值)
/// </summary>
/// <param name="connection">資料庫連線</param>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <returns>SqlCommand</returns>
private static SqlCommand BuildQueryCommand(SqlConnection connection, string storedProcName, IDataParameter[] parameters)
{
SqlCommand command = new SqlCommand(storedProcName, connection);
command.CommandType = CommandType.StoredProcedure;
foreach (SqlParameter parameter in parameters)
{
if (parameter != null)
{
// 檢查未分配值的輸出引數,將其分配以DBNull.Value.
if ((parameter.Direction == ParameterDirection.InputOutput || parameter.Direction == ParameterDirection.Input) &&
(parameter.Value == null))
{
parameter.Value = DBNull.Value;
}
command.Parameters.Add(parameter);
}
}
return command;
}
/// <summary>
/// 執行儲存過程,返回影響的行數
/// </summary>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <param name="rowsAffected">影響的行數</param>
/// <returns></returns>
public static int RunProcedure(string storedProcName, IDataParameter[] parameters, out int rowsAffected)
{
using (SqlConnection connection = new SqlConnection(connectionString))
{
int result;
connection.Open();
SqlCommand command = BuildIntCommand(connection, storedProcName, parameters);
rowsAffected = command.ExecuteNonQuery();
result = (int)command.Parameters["ReturnValue"].Value;
//Connection.Close();
return result;
}
}
/// <summary>
/// 建立 SqlCommand 物件例項(用來返回一個整數值)
/// </summary>
/// <param name="storedProcName">儲存過程名</param>
/// <param name="parameters">儲存過程引數</param>
/// <returns>SqlCommand 物件例項</returns>
private static SqlCommand BuildIntCommand(SqlConnection connection, string storedProcName, IDataParameter[] parameters)
{
SqlCommand command = BuildQueryCommand(connection, storedProcName, parameters);
command.Parameters.Add(new SqlParameter("ReturnValue",
SqlDbType.Int, 4, ParameterDirection.ReturnValue,
false, 0, 0, string.Empty, DataRowVersion.Default, null));
return command;
}
#endregion
}
}
--------------------------DAL層---------------------------
-------------------Department.cs:
using System;
using System.Data;
using System.Text;
using System.Data.SqlClient;
using Register.DataAccess;
using System.Collections.Generic;//Please add references
namespace Register.DAL
{
/// <summary>
/// 資料訪問類:Department
/// </summary>
public partial class Department
{
public Department()
{}
#region BasicMethod
/// <summary>
/// 得到最大ID
/// </summary>
public int GetMaxId()
{
return DbHelperSQL.GetMaxID("Id", "Department");
}
/// <summary>
/// 是否存在該記錄
/// </summary>
public bool Exists(int Id)
{
StringBuilder strSql=new StringBuilder();
strSql.Append("select count(1) from Department");
strSql.Append(" where
SqlParameter[] parameters = {
new SqlParameter("@Id", SqlDbType.Int,4)
};
parameters[0].Value = Id;
return DbHelperSQL.Exists(strSql.ToString(),parameters);
}
/// <summary>
/// 增加一條資料
/// </summary>
public int Add(Register.Model.Department mode