ใช้ระบบ;
โดยใช้ระบบการกำหนดค่า;
ใช้ System.Data;
โดยใช้ System.Data.SqlClient;
ใช้ System.Collections;
เนมสเปซ MyCorporation.DepartMent.DataBase
-
/// <สรุป>
/// 通用数据库类
/// </สรุป>
ฐานข้อมูลคลาสสาธารณะ
{
สตริงส่วนตัว ConnStr = null;
ฐานข้อมูลสาธารณะ ()
-
ConnStr = ConfigurationSettings.AppSettings["ConnStr"];
-
ฐานข้อมูลสาธารณะ (สตริง Str)
-
พยายาม
-
this.ConnStr = Str;
-
จับ (ข้อยกเว้นเช่น)
-
โยนอดีต;
-
}
/// <สรุป>
/// 返回การเชื่อมต่อ对象
/// </สรุป>
/// <ส่งคืน></ส่งคืน>
SqlConnection ReturnConn สาธารณะ ()
-
SqlConnection Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
กลับคอน;
-
โมฆะสาธารณะกำจัด (SqlConnection Conn)
-
ถ้า(Conn!=null)
-
Conn.ปิด();
Conn.ทิ้ง();
-
GC.รวบรวม();
-
/// <สรุป>
/// คำสั่ง SQL
/// </สรุป>
/// <ชื่อพารามิเตอร์ = "SQL" ></ พารามิเตอร์>
โมฆะสาธารณะ RunProc (สตริง SQL)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
คำสั่ง SQLCommand ;
Cmd = CreateCmd(SQL, Conn);
พยายาม
-
Cmd.ExecuteNonQuery();
-
จับ
-
โยนข้อยกเว้นใหม่ (SQL);
-
กำจัด(คอนน์);
กลับ;
}
/// <สรุป>
/// คำสั่ง SQL ของ DataReader
/// </สรุป>
/// <ชื่อพารามิเตอร์ = "SQL" ></ พารามิเตอร์>
/// <returns>SqlDataReader对象</returns>
SqlDataReader สาธารณะ RunProcGetReader (สตริง SQL)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
คำสั่ง SQLCommand ;
Cmd = CreateCmd(SQL, Conn);
ดร. SqlDataReader;
พยายาม
-
ดร = Cmd.ExecuteReader (CommandBehavior.Default);
-
จับ
-
โยนข้อยกเว้นใหม่ (SQL);
-
// กำจัด (Conn);
กลับ ดร.;
}
/// <สรุป>
/// 生成คำสั่ง对象
/// </สรุป>
/// <ชื่อพารามิเตอร์ = "SQL" ></ พารามิเตอร์>
/// <param name="Conn"></param>
/// <ส่งคืน></ส่งคืน>
SqlCommand CreateCmd สาธารณะ (สตริง SQL, SqlConnection Conn)
-
คำสั่ง SQLCommand ;
Cmd = SqlCommand ใหม่ (SQL, Conn);
กลับคำสั่ง;
-
/// <สรุป>
/// 生成คำสั่ง对象
/// </สรุป>
/// <ชื่อพารามิเตอร์ = "SQL" ></ พารามิเตอร์>
/// <ส่งคืน></ส่งคืน>
SqlCommand CreateCmd สาธารณะ (สตริง SQL)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
คำสั่ง SQLCommand ;
Cmd = SqlCommand ใหม่ (SQL, Conn);
กลับคำสั่ง;
}
/// <สรุป>
/// 返回adapter对象
/// </สรุป>
/// <ชื่อพารามิเตอร์ = "SQL" ></ พารามิเตอร์>
/// <param name="Conn"></param>
/// <ส่งคืน></ส่งคืน>
SqlDataAdapter CreateDa สาธารณะ (สตริง SQL)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
SqlDataAdapter ดา;
Da = SqlDataAdapter ใหม่ (SQL, Conn);
กลับดา;
}
/// <สรุป>
/// คำสั่ง SQL คำสั่ง, คำสั่ง DataSet คำสั่ง
/// </สรุป>
/// <param name="procName">คำสั่ง SQL</param>
/// <param name="prams">ชุดข้อมูล</param>
ชุดข้อมูลสาธารณะ RunProc (สตริง SQL, ชุดข้อมูล Ds)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
SqlDataAdapter ดา;
//ดา = CreateDa(SQL, Conn);
Da = SqlDataAdapter ใหม่ (SQL, Conn);
พยายาม
-
ดา.เติม(Ds);
-
catch (ข้อผิดพลาดข้อยกเว้น)
-
โยนผิดพลาด;
-
กำจัด(คอนน์);
กลับ Ds;
}
/// <สรุป>
/// คำสั่ง SQL คำสั่ง, คำสั่ง DataSet คำสั่ง
/// </สรุป>
/// <param name="procName">คำสั่ง SQL</param>
/// <param name="prams">ชุดข้อมูล</param>
/// <param name="dataReader">表名</param>
ชุดข้อมูลสาธารณะ RunProc (สตริง SQL, ชุดข้อมูล Ds, ชื่อตารางสตริง)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
SqlDataAdapter ดา;
ดา = CreateDa(SQL);
พยายาม
-
Da.Fill(Ds,ชื่อตาราง);
-
จับ (ข้อยกเว้นเช่น)
-
โยนอดีต;
-
กำจัด(คอนน์);
กลับ Ds;
}
/// <สรุป>
/// คำสั่ง SQL คำสั่ง, คำสั่ง DataSet คำสั่ง
/// </สรุป>
/// <param name="procName">คำสั่ง SQL</param>
/// <param name="prams">ชุดข้อมูล</param>
/// <param name="dataReader">表名</param>
ชุดข้อมูลสาธารณะ RunProc (สตริง SQL, ชุดข้อมูล Ds, int StartIndex, int PageSize, ชื่อตารางสตริง)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
SqlDataAdapter ดา ;
ดา = CreateDa(SQL);
พยายาม
-
Da.Fill(Ds, StartIndex, PageSize, ชื่อตาราง);
-
จับ (ข้อยกเว้นเช่น)
-
โยนอดีต;
-
กำจัด(คอนน์);
กลับ Ds;
}
/// <สรุป>
/// 检验是否存在数据
/// </สรุป>
/// <ส่งคืน></ส่งคืน>
บูลสาธารณะ ExistDate (สตริง SQL)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
ดร. SqlDataReader ;
ดร = CreateCmd(SQL,Conn).ExecuteReader();
ถ้า (Dr.Read())
-
กำจัด(คอนน์);
กลับเป็นจริง;
-
อื่น
-
กำจัด(คอนน์);
กลับเท็จ;
-
}
/// <สรุป>
/// 返回SQL 语句执行结果的第一行第一列
/// </สรุป>
/// <returns>字符串</returns>
สตริงสาธารณะ ReturnValue (สตริง SQL)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
ผลลัพธ์สตริง;
ดร. SqlDataReader ;
พยายาม
-
ดร = CreateCmd(SQL,Conn).ExecuteReader();
ถ้า (Dr.Read())
-
ผลลัพธ์ = ดร.[0].ToString();
ดร.ปิด();
-
อื่น
-
ผลลัพธ์ = "";
ดร.ปิด();
-
-
จับ
-
โยนข้อยกเว้นใหม่ (SQL);
-
กำจัด(คอนน์);
ส่งคืนผลลัพธ์;
}
/// <สรุป>
/// 返回SQL 句第一列, คอลัมน์ I 列,
/// </สรุป>
/// <returns>字符串</returns>
สตริงสาธารณะ ReturnValue (สตริง SQL, int ColumnI)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
ผลลัพธ์สตริง;
ดร. SqlDataReader ;
พยายาม
-
ดร = CreateCmd(SQL,Conn).ExecuteReader();
-
จับ
-
โยนข้อยกเว้นใหม่ (SQL);
-
ถ้า (Dr.Read())
-
ผล = ดร.[คอลัมน์I].ToString();
-
อื่น
-
ผลลัพธ์ = "";
-
ดร.ปิด();
กำจัด(คอนน์);
ส่งคืนผลลัพธ์;
}
/// <สรุป>
/// 生成一个存储过程使用คำสั่ง sql.
/// </สรุป>
/// <param name="procName">存储过程名.</param>
/// <param name="prams">存储过程入参数组.</param>
/// <returns>คำสั่ง sql คำสั่ง</returns>
SqlCommand CreateCmd สาธารณะ (สตริง procName, SqlParameter [] รถเข็นเด็ก)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
SqlCommand Cmd = SqlCommand ใหม่ (procName, Conn);
Cmd.CommandType = CommandType.StoredProcedure;
ถ้า (รถเข็น!= null)
-
foreach (พารามิเตอร์ SqlParameter ในรถเข็น)
-
ถ้า (พารามิเตอร์ != null)
-
Cmd.Parameters.Add(พารามิเตอร์);
-
-
-
กลับคำสั่ง;
}
/// <สรุป>
/// 为存储过程生成一个SqlCommand对象
/// </สรุป>
/// <param name="procName">存储过程名</param>
/// <param name="prams">存储过程参数</param>
/// <returns>SqlCommand คำสั่ง</returns>
SqlCommand CreateCmd ส่วนตัว (สตริง procName, SqlParameter [] prams, SqlDataReader Dr)
-
การเชื่อมต่อ SqlConnection;
Conn = SqlConnection ใหม่ (ConnStr);
Conn.เปิด();
SqlCommand Cmd = SqlCommand ใหม่ (procName, Conn);
Cmd.CommandType = CommandType.StoredProcedure;
ถ้า (รถเข็น!= null)
-
foreach (พารามิเตอร์ SqlParameter ในรถเข็น)
Cmd.Parameters.Add(พารามิเตอร์);
-
Cmd.Parameters.Add(
ใหม่ SqlParameter("ReturnValue", SqlDbType.Int, 4,
ParameterDirection.ReturnValue, เท็จ, 0, 0,
string.Empty, DataRowVersion.Default, null));
กลับคำสั่ง;
}
/// <สรุป>
/// 运行存储过程,返回.
/// </สรุป>
/// <param name="procName">存储过程名</param>
/// <param name="prams">存储过程参数</param>
/// <param name="dataReader">SqlDataReader对象</param>
RunProc โมฆะสาธารณะ (สตริง procName, SqlParameter [] prams, SqlDataReader Dr)
{
SqlCommand Cmd = CreateCmd(procName, รถเข็นเด็ก, Dr);
ดร = Cmd.ExecuteReader (System.Data.CommandBehavior.CloseConnection);
กลับ;
}
/// <สรุป>
/// 运行存储过程,返回.
/// </สรุป>
/// <param name="procName">存储过程名</param>
/// <param name="prams">存储过程参数</param>
RunProc สตริงสาธารณะ (สตริง procName, SqlParameter [] prams)
-
ดร. SqlDataReader;
SqlCommand Cmd = CreateCmd(procName, รถเข็นเด็ก);
ดร = Cmd.ExecuteReader (System.Data.CommandBehavior.CloseConnection);
ถ้า(ดร.อ่าน())
-
กลับ Dr.GetValue(0).ToString();
-
อื่น
-
กลับ "";
-
}
/// <สรุป>
/// ชุดข้อมูล 运行存储过程,返回.
/// </สรุป>
/// <param name="procName">存储过程名.</param>
/// <param name="prams">存储过程入参数组.</param>
/// <returns>ชุดข้อมูล</returns>
ชุดข้อมูลสาธารณะ RunProc (สตริง procName, SqlParameter [] prams, ชุดข้อมูล Ds)
-
SqlCommand Cmd = CreateCmd(procName,รถเข็นเด็ก);
SqlDataAdapter Da = SqlDataAdapter ใหม่ (Cmd);
พยายาม
-
ดา.เติม(Ds);
-
จับ (ข้อยกเว้นเช่น)
-
โยนอดีต;
-
กลับ Ds;
}
}
-