zoukankan      html  css  js  c++  java
  • 为ASP.NET封装的SQL数据库访问类

    using System;
    using System.Configuration;
    using System.Data;
    using System.Data.SqlClient;
    using System.Collections;

    namespace MyCorporation.DepartMent.DataBase
    {
     /// <summary>
     /// 通用数据库类
     /// </summary>
     public class DataBase
     {

      private string ConnStr = null;

      public DataBase()
      {
       ConnStr = ConfigurationSettings.AppSettings["ConnStr"];
      }
      public DataBase(string Str)
      {
       try
       {
        this.ConnStr = Str;

       }
       catch(Exception ex)
       {
        throw ex;
       }
      }

      /// <summary>
      /// 返回connection对象
      /// </summary>
      /// <returns></returns>
      public SqlConnection ReturnConn()
      {
       SqlConnection Conn = new SqlConnection(ConnStr);
       Conn.Open();
       return Conn;
      }
      public void Dispose(SqlConnection Conn)
      {
       if(Conn!=null)
       {
        Conn.Close();
        Conn.Dispose();
       }
       GC.Collect();
      }
      /// <summary>
      /// 运行SQL语句
      /// </summary>
      /// <param name="SQL"></param>
      public void RunProc(string SQL)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlCommand Cmd ;
       Cmd = CreateCmd(SQL, Conn);
       try
       {
        Cmd.ExecuteNonQuery();
       }
       catch
       {
        throw new Exception(SQL);
       }
       Dispose(Conn);
       return;
      }    

      /// <summary>
       /// 运行SQL语句返回DataReader
      /// </summary>
        /// <param name="SQL"></param>
        /// <returns>SqlDataReader对象.</returns>
      public SqlDataReader RunProcGetReader(string SQL)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlCommand Cmd ;
       Cmd = CreateCmd(SQL, Conn);
       SqlDataReader Dr;
       try
       {
        Dr = Cmd.ExecuteReader(CommandBehavior.Default);
       }
       catch
       {
        throw new Exception(SQL);
       }
       //Dispose(Conn);
       return Dr;
      }

      /// <summary>
      /// 生成Command对象
      /// </summary>
      /// <param name="SQL"></param>
      /// <param name="Conn"></param>
      /// <returns></returns>
      public SqlCommand CreateCmd(string SQL, SqlConnection  Conn)
      {
       SqlCommand Cmd ;
       Cmd = new SqlCommand(SQL, Conn);
       return Cmd;
      }
      
      /// <summary>
      /// 生成Command对象
      /// </summary>
      /// <param name="SQL"></param>
      /// <returns></returns>
      public SqlCommand CreateCmd(string SQL)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlCommand Cmd ;
       Cmd = new SqlCommand(SQL, Conn);
       return Cmd;
      }

      /// <summary>
      /// 返回adapter对象
      /// </summary>
      /// <param name="SQL"></param>
      /// <param name="Conn"></param>
      /// <returns></returns>
      public SqlDataAdapter CreateDa(string SQL)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlDataAdapter Da;
       Da = new SqlDataAdapter(SQL, Conn);
       return Da;
      }

      /// <summary>
      /// 运行SQL语句,返回DataSet对象
      /// </summary>
      /// <param name="procName">SQL语句</param>
      /// <param name="prams">DataSet对象</param>
      public DataSet RunProc(string SQL ,DataSet Ds)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlDataAdapter Da;
       //Da = CreateDa(SQL, Conn);
       Da = new SqlDataAdapter(SQL,Conn);
       try
       {
        Da.Fill(Ds);
       }
       catch(Exception Err)
       {
        throw Err;
       }
       Dispose(Conn);
       return Ds;
      }

      /// <summary>
      /// 运行SQL语句,返回DataSet对象
      /// </summary>
      /// <param name="procName">SQL语句</param>
      /// <param name="prams">DataSet对象</param>
      /// <param name="dataReader">表名</param>
      public DataSet RunProc(string SQL ,DataSet Ds,string tablename)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlDataAdapter Da;
       Da = CreateDa(SQL);
       try
       {
        Da.Fill(Ds,tablename);
       }
       catch(Exception Ex)
       {
        throw Ex;
       }
       Dispose(Conn);
       return Ds;
      }

      /// <summary>
      /// 运行SQL语句,返回DataSet对象
      /// </summary>
      /// <param name="procName">SQL语句</param>
      /// <param name="prams">DataSet对象</param>
      /// <param name="dataReader">表名</param>
      public DataSet RunProc(string SQL , DataSet Ds ,int  StartIndex ,int PageSize, string tablename )
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlDataAdapter Da ;
       Da = CreateDa(SQL);
       try
       {
        Da.Fill(Ds, StartIndex, PageSize, tablename);
       }
       catch(Exception Ex)
       {
        throw Ex;
       }
       Dispose(Conn);
       return Ds;
      }

      /// <summary>
      /// 检验是否存在数据
      /// </summary>
      /// <returns></returns>
      public bool ExistDate(string SQL)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlDataReader Dr ;
       Dr = CreateCmd(SQL,Conn).ExecuteReader();
       if (Dr.Read())
       {
        Dispose(Conn);
        return true;
       }
       else
       {
        Dispose(Conn);
        return false;
       }
      }

      /// <summary>
      /// 返回SQL语句执行结果的第一行第一列
      /// </summary>
      /// <returns>字符串</returns>
      public string ReturnValue(string SQL)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       string result;
       SqlDataReader Dr ;
       try
       {
        Dr = CreateCmd(SQL,Conn).ExecuteReader();
        if (Dr.Read())
        {
         result = Dr[0].ToString();
         Dr.Close(); 
        }
        else
        {
         result = "";
         Dr.Close(); 
        }
       }
       catch
       {
        throw new Exception(SQL);
       }
       Dispose(Conn);
       return result;
      }

      /// <summary>
      /// 返回SQL语句第一列,第ColumnI列,
      /// </summary>
      /// <returns>字符串</returns>
      public string ReturnValue(string SQL, int ColumnI)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       string result;
       SqlDataReader Dr ;
       try
       {
        Dr = CreateCmd(SQL,Conn).ExecuteReader();
       }
       catch
       {
        throw new Exception(SQL);
       }
       if (Dr.Read())
       {
        result = Dr[ColumnI].ToString();
       }
       else
       {
        result = "";
       }
       Dr.Close();
       Dispose(Conn);
       return result;
      }

      /// <summary>
      /// 生成一个存储过程使用的sqlcommand.
      /// </summary>
      /// <param name="procName">存储过程名.</param>
      /// <param name="prams">存储过程入参数组.</param>
      /// <returns>sqlcommand对象.</returns>
      public SqlCommand CreateCmd(string procName, SqlParameter[] prams)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlCommand Cmd = new SqlCommand(procName, Conn);
       Cmd.CommandType = CommandType.StoredProcedure;
       if (prams != null)
       {
        foreach (SqlParameter parameter in prams)
        {
         if(parameter != null)
         {
          Cmd.Parameters.Add(parameter);
         }
        }
       }
       return Cmd;
      }

      /// <summary>
      /// 为存储过程生成一个SqlCommand对象
      /// </summary>
      /// <param name="procName">存储过程名</param>
      /// <param name="prams">存储过程参数</param>
      /// <returns>SqlCommand对象</returns>
      private SqlCommand CreateCmd(string procName, SqlParameter[] prams,SqlDataReader Dr)
      {
       SqlConnection Conn;
       Conn = new SqlConnection(ConnStr);
       Conn.Open();
       SqlCommand Cmd = new SqlCommand(procName, Conn);
       Cmd.CommandType = CommandType.StoredProcedure;
       if (prams != null)
       {
        foreach (SqlParameter parameter in prams)
         Cmd.Parameters.Add(parameter);
       }
       Cmd.Parameters.Add(
        new SqlParameter("ReturnValue", SqlDbType.Int, 4,
        ParameterDirection.ReturnValue, false, 0, 0,
        string.Empty, DataRowVersion.Default, null));

       return Cmd;
      }

      /// <summary>
      /// 运行存储过程,返回.
      /// </summary>
      /// <param name="procName">存储过程名</param>
      /// <param name="prams">存储过程参数</param>
      /// <param name="dataReader">SqlDataReader对象</param>
      public void RunProc(string procName, SqlParameter[] prams, SqlDataReader Dr)
      {

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

      /// <summary>
      /// 运行存储过程,返回.
      /// </summary>
      /// <param name="procName">存储过程名</param>
      /// <param name="prams">存储过程参数</param>
      public string RunProc(string procName, SqlParameter[] prams)
      {
       SqlDataReader Dr;
       SqlCommand Cmd = CreateCmd(procName, prams);
       Dr = Cmd.ExecuteReader(System.Data.CommandBehavior.CloseConnection);
       if(Dr.Read())
       {
        return Dr.GetValue(0).ToString();
       }
       else
       {
        return "";
       }
      }

      /// <summary>
      /// 运行存储过程,返回dataset.
      /// </summary>
      /// <param name="procName">存储过程名.</param>
      /// <param name="prams">存储过程入参数组.</param>
      /// <returns>dataset对象.</returns>
      public DataSet RunProc(string procName,SqlParameter[] prams,DataSet Ds)
      {
       SqlCommand Cmd = CreateCmd(procName,prams);
       SqlDataAdapter Da = new SqlDataAdapter(Cmd);
       try
       {
        Da.Fill(Ds);
       }
       catch(Exception Ex)
       {
        throw Ex;
       }
       return Ds;
      }

     }
    }

  • 相关阅读:
    公用表表达式(CTE)的递归调用
    c# 如何让tooltip显示文字换行
    实战 SQL Server 2008 数据库误删除数据的恢复
    SQL SERVER数据库中 是否可以对视图进行修改删除
    asp.net中实现文件批量上传
    sql server 2008学习2 文件和文件组
    sql server 2008学习3 表组织和索引组织
    sql server 2008学习4 设计索引的建议
    sql server 2008学习10 存储过程
    .net 调用 sql server 自定义函数,并输出返回值
  • 原文地址:https://www.cnblogs.com/studio313/p/266568.html
Copyright © 2011-2022 走看看