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;
  }

}
}

转载于:https://www.cnblogs.com/lcl_1015/articles/1676829.html

为ASP.NET封装的SQL数据库访问类(转)相关推荐

  1. ASP中怎么实现SQL数据库备份、恢复！

    选择自 hanghwp 的 Blog 1.ASP中怎么实现SQL数据库备份.恢复! 答:asp在线备份sql server数据库: 1.备份 <% SQL="backup databa ...

  2. 简单程序所需要的简单　asp.net通用数据库访问类

    简单程序不需要分层,各页面共用相同的通用数据库访问类即可 using System;  using System.Data;  using System.Data.SqlClient; namespa ...

  3. 使用设计模式构建通用数据库访问类

    在应用程序的设计中,数据库的访问是非常重要的,我们通常需要将对数据库的访问集中起来,以保证良好的封装性和可维护性.在.Net中,数据库的访问,对于微软自家的SqlServer和其他数据库(支持OleD ...

  4. php操作mysql的封装类_PHP封装的mysqli数据库操作类示例

    本文实例讲述了PHP封装的mysqli数据库操作类.分享给大家供大家参考,具体如下: 由于PHPMySQL操作在PHP5.4以下被弃用而推荐使用mysqli(MySQL Improvement),这里 ...

  5. SqlHelper数据库访问类

    参考上一篇:数据库连接配置app.config 写一个通用的数据库访问类. public class SqlHelper //数据库连接类 {//获取数据库连接字符串,其属于静态变量且只读,项目中所有 ...

  6. DataAccess通用数据库访问类，简单易用，功能强悍

    以下是我编写的DataAccess通用数据库访问类,简单易用,支持:内联式创建多个参数.支持多事务提交.支持参数复用.支持更换数据库类型,希望能帮到大家,若需支持查出来后转换成实体,可以自行扩展dat ...

  7. 【ASP.NET开发】ASP.NET对SQLServer的通用数据库访问类

    怎么说呢,作为程序员,我们明天都应该学习新的知识. 以前我在对数据库进行操作的时候都是在同一页面对数据库进行操作.这样的话,就是操作繁琐,而且需要重复的书写对数据库操作的代码,这样不仅浪费了很多的时间 ...

  8. 几个重要的java数据库访问类和接口

    编写访问数据库的Java程序还需要几个重要的类和接口. DriverManager类 DriverManager类处理驱动程序的加载和建立新数据库连接.DriverManager是java.sql包中 ...

  9. ASP用DSN连接数sql数据库

    现有数据源DSN(test)用户名为z;密码为123456;有一个test数据库理由一个叫table的表,表中有三个列:用户名:×××号码:电话号码,怎样该表中的输出所有字段? 下面的代码正确吗?请多 ...

  10. KeeSoft.DBHelper.DBFactory 数据库访问类

    2019独角兽企业重金招聘Python工程师标准>>> /*------------------------------------------------------------- ...

最新文章

  1. 2015级C++第15周程序阅读 范型程序设计
  2. Android自带Monkey测试
  3. CTS(1)---谷歌CTS测试简介
  4. shell题库选择题_shell 练习题
  5. 《我也能做CTO之程序员职业规划》之七：大学生职业规划技巧
  6. [2019.2.28]BZOJ4033 [HAOI2015]树上染色
  7. c10k java_c10k问题及其解决方案
  8. 龙芯2f平台下 Debain 6编译Lighttpd并支持C语言cgi脚本编程
  9. PHP语言之正则表达式
  10. android设置闹钟日期,在Android中将闹钟设置为特定日期和时间
  11. oracle if else怎么用,oracle if else语句使用介绍
  12. MySQL学习笔记(2)
  13. springboot+cas单点登录
  14. 人工智能ai写作系统，ai智能写作机器人
  15. 用python快速群发邮件
  16. 微软CTO谈AI：逃不掉马拉松就准备好跑鞋！30秒自动化妆机；ChatGPT刷爆票圈；剪纸风格的AI绘画 | ShowMeAI资讯日报
  17. github开源代码下载并运行
  18. 【附源码】计算机毕业设计java应急互助信息管理系统设计与实现
  19. html设置了字体为什么没效果,为什么设置字体没效果，楷书不行么
  20. xlslib生成excel文件

热门文章

  1. java socket php_Web架构(二)PHP Socket与Java ServerSocket交互
  2. 阶段3 2.Spring_08.面向切面编程 AOP_9 spring基于注解的AOP配置
  3. 一个简单的python登录验证系统
  4. phpstudy配置域名后apache无法启动
  5. mybatis添加数据时返回主键 insert 返回主键值
  6. 清除SQLServer2008缓存
  7. 一、JAVA基础（数据类型、运算符、变量常量）
  8. maven环境、本地仓储配置(下载安装)idea配置maven
  9. 虫师Selenium2+Python_11、自动化测试项目实战
  10. bzoj 3451 Normal