ASP.NET용으로 캡슐화된 SQL 데이터베이스 액세스 클래스

시스템 사용;
System.Configuration 사용;
System.Data 사용;
System.Data.SqlClient 사용;
System.Collections 사용;

네임스페이스 MyCorporation.DepartMent.DataBase
{
/// <요약>
/// 일반 사용
/// </summary>
공개 클래스 데이터베이스
{

개인 문자열 ConnStr = null;

공개 데이터베이스()
{
ConnStr = ConfigurationSettings.AppSettings["ConnStr"];
}
공개 데이터베이스(문자열 Str)
{
노력하다
{
this.ConnStr = Str;

}
catch(예외예외)
{
예를 던져;
}
}

/// <요약>
/// 返回connection对象
/// </summary>
/// <반환></반환>
공개 SqlConnection ReturnConn()
{
SqlConnection Conn = new SqlConnection(ConnStr);
Conn.Open();
반환 콘;
}
공개 무효 처리(SqlConnection Conn)
{
if(콘!=널)
{
연결.닫기();
Conn.Dispose();
}
GC.수집();
}
/// <요약>
/// 运行SQL语句
/// </summary>
/// <param 이름="SQL"></param>
공개 무효 RunProc(문자열 SQL)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SQL명령 명령 ;
Cmd = CreateCmd(SQL, Conn);
노력하다
{
Cmd.ExecuteNonQuery();
}
잡다
{
새로운 예외(SQL)를 발생시킵니다.
}
폐기(Conn);
반품;
}

/// <요약>
/// 运行SQL语句返回DataReader
/// </summary>
/// <param 이름="SQL"></param>
/// <returns>SqlDataReader가 반환됩니다.</returns>
공개 SqlDataReader RunProcGetReader(문자열 SQL)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SQL명령 명령 ;
Cmd = CreateCmd(SQL, Conn);
SqlDataReader 박사;
노력하다
{
Dr = Cmd.ExecuteReader(CommandBehavior.Default);
}
잡다
{
새로운 예외(SQL)를 발생시킵니다.
}
//Dispose(콘);
박사를 돌려보내다;
}

/// <요약>
/// 생성명령对象
/// </summary>
/// <param 이름="SQL"></param>
/// <param name="콘"></param>
/// <반환></반환>
공개 SqlCommand CreateCmd(문자열 SQL, SqlConnection Conn)
{
SQL명령 명령 ;
Cmd = new SqlCommand(SQL, Conn);
명령을 반환;
}

/// <요약>
/// 생성명령对象
/// </summary>
/// <param 이름="SQL"></param>
/// <반환></반환>
공개 SqlCommand CreateCmd(문자열 SQL)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SQL명령 명령 ;
Cmd = new SqlCommand(SQL, Conn);
명령을 반환;
}

/// <요약>
/// 返回어댑터对象
/// </summary>
/// <param 이름="SQL"></param>
/// <param name="콘"></param>
/// <반환></반환>
공개 SqlDataAdapter CreateDa(문자열 SQL)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SqlDataAdapter Da;
Da = new SqlDataAdapter(SQL, Conn);
Da를 반환;
}

/// <요약>
/// 运行SQL语句,返回DataSet对象
/// </summary>
/// <param name="procName">SQL문</param>
/// <param name="prams">DataSet의 내용</param>
공개 DataSet RunProc(문자열 SQL, DataSet Ds)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SqlDataAdapter Da;
//Da = CreateDa(SQL, Conn);
Da = new SqlDataAdapter(SQL,Conn);
노력하다
{
Da.Fill(Ds);
}
catch(예외 오류)
{
던져 오류;
}
폐기(Conn);
D를 반환합니다.
}

/// <요약>
/// 运行SQL语句,返回DataSet对象
/// </summary>
/// <param name="procName">SQL문</param>
/// <param name="prams">DataSet의 내용</param>
/// <param name="dataReader">설명</param>
공개 DataSet RunProc(문자열 SQL, DataSet Ds,문자열 테이블 이름)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SqlDataAdapter Da;
Da = CreateDa(SQL);
노력하다
{
Da.Fill(Ds,테이블명);
}
catch(예외 예)
{
Ex를 던져라;
}
폐기(Conn);
D를 반환합니다.
}

/// <요약>
/// 运行SQL语句,返回DataSet对象
/// </summary>
/// <param name="procName">SQL문</param>
/// <param name="prams">DataSet의 내용</param>
/// <param name="dataReader">설명</param>
공개 DataSet RunProc(string SQL, DataSet Ds,int StartIndex,int PageSize, string tablename)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SqlDataAdapter 다;
Da = CreateDa(SQL);
노력하다
{
Da.Fill(Ds, StartIndex, PageSize, 테이블 이름);
}
catch(예외 예)
{
Ex를 던져라;
}
폐기(Conn);
D를 반환합니다.
}

/// <요약>
/// 检验是否存재재数据
/// </summary>
/// <반환></반환>
공개 bool ExistDate(문자열 SQL)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SqlDataReader 박사;
Dr = CreateCmd(SQL,Conn).ExecuteReader();
if (Dr.Read())
{
폐기(Conn);
사실을 반환;
}
또 다른
{
폐기(Conn);
거짓을 반환;
}
}

/// <요약>
/// 返回SQL语句执行结果의 第一行第一列
/// </summary>
/// <returns>문자열</returns>
공개 문자열 ReturnValue(문자열 SQL)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
문자열 결과;
SqlDataReader 박사;
노력하다
{
Dr = CreateCmd(SQL,Conn).ExecuteReader();
if (Dr.Read())
{
결과 = Dr[0].ToString();
Dr.Close();
}
또 다른
{
결과 = "";
Dr.Close();
}
}
잡다
{
새로운 예외(SQL)를 발생시킵니다.
}
폐기(Conn);
결과 반환;
}

/// <요약>
/// 返回SQL语句第一列,第ColumnI列,
/// </summary>
/// <returns>문자열</returns>
공개 문자열 ReturnValue(문자열 SQL, int ColumnI)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
문자열 결과;
SqlDataReader 박사;
노력하다
{
Dr = CreateCmd(SQL,Conn).ExecuteReader();
}
잡다
{
새로운 예외(SQL)를 발생시킵니다.
}
if (Dr.Read())
{
결과 = Dr[ColumnI].ToString();
}
또 다른
{
결과 = "";
}
Dr.Close();
폐기(Conn);
결과 반환;
}

/// <요약>
/// sqlcommand를 사용하여 생성합니다.
/// </summary>
/// <param name="procName">이름.</param>
/// <param name="prams">存储过程入参数组.</param>
/// <returns>sqlcommand对象.</returns>
공개 SqlCommand CreateCmd(문자열 procName, SqlParameter[] 유모차)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SqlCommand Cmd = new SqlCommand(procName, Conn);
Cmd.CommandType = CommandType.StoredProcedure;
if (유모차 != null)
{
foreach(유모차의 SqlParameter 매개변수)
{
if(매개변수 != null)
{
Cmd.Parameters.Add(매개변수);
}
}
}
명령을 반환;
}

/// <요약>
/// 为存储过程生成一个SqlCommand对象
/// </summary>
/// <param name="procName">이름</param>
/// <param name="prams">存储过程参数</param>
/// <returns>SqlCommand对象</returns>
개인 SqlCommand CreateCmd(문자열 procName, SqlParameter[] 유모차, SqlDataReader Dr)
{
SqlConnection 연결;
Conn = new SqlConnection(ConnStr);
Conn.Open();
SqlCommand Cmd = new SqlCommand(procName, Conn);
Cmd.CommandType = CommandType.StoredProcedure;
if (유모차 != null)
{
foreach(유모차의 SqlParameter 매개변수)
Cmd.Parameters.Add(매개변수);
}
Cmd.매개변수.추가(
new SqlParameter("ReturnValue", SqlDbType.Int, 4,
ParameterDirection.ReturnValue, 거짓, 0, 0,
string.Empty, DataRowVersion.Default, null));

명령을 반환;
}

/// <요약>
/// 运行存储过程,返回.
/// </summary>
/// <param name="procName">이름</param>
/// <param name="prams">存储过程参数</param>
/// <param name="dataReader">SqlDataReader의 내용</param>
공개 무효 RunProc(문자열 procName, SqlParameter[] 유모차, SqlDataReader Dr)
{

SqlCommand Cmd = CreateCmd(procName, prams, Dr);
Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
반품;
}

/// <요약>
/// 运行存储过程,返回.
/// </summary>
/// <param name="procName">이름</param>
/// <param name="prams">存储过程参数</param>
공개 문자열 RunProc(string procName, SqlParameter[] prams)
{
SqlDataReader 박사;
SqlCommand Cmd = CreateCmd(procName, prams);
Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
if(닥터리드())
{
Dr.GetValue(0).ToString()을 반환합니다.
}
또 다른
{
반품 "";
}
}

/// <요약>
/// 运行存储过程,返回dataset.
/// </summary>
/// <param name="procName">이름.</param>
/// <param name="prams">存储过程入参数组.</param>
/// <returns>데이터세트를 반환합니다.</returns>
공개 DataSet RunProc(문자열 procName,SqlParameter[] 유모차,DataSet Ds)
{
SqlCommand Cmd = CreateCmd(procName,prams);
SqlDataAdapter Da = new SqlDataAdapter(Cmd);
노력하다
{
Da.Fill(Ds);
}
catch(예외 예)
{
Ex를 던져라;
}
D를 반환합니다.
}

}
}