备案控制台
探索云世界
开发者社区 数据库 文章 正文

SQLHelper.cs文件代码

2010-08-17 660
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： using System;using System.Data;using System.Configuration;using System.

using System;
using System.Data;
using System.Configuration;
using System.Web;
using System.Web.Security;
using System.Web.UI;
using System.Web.UI.WebControls;
using System.Web.UI.WebControls.WebParts;
using System.Web.UI.HtmlControls;
using System.Data.SqlClient;
using System.IO;
/// <summary>
/// SQLHelper 的摘要说明
/// </summary>
public class SQLHelper
{
    public SqlConnection myConnection = null;
    private readonly string RETURNVALUE = "RETURNVALUE";

    /// <summary>
    /// 打开数据库连接.
    /// </summary>
    private void Open()
    {
        // 打开数据库连接
        if (myConnection == null)
        {
            myConnection = new SqlConnection(System.Configuration.ConfigurationManager.AppSettings["SQLCONNECTIONSTRING"].ToString());
        }
        if (myConnection.State == ConnectionState.Closed)
        {
            try
            {
                ///打开数据库连接
                myConnection.Open();
            }
            catch (Exception ex)
            {
                SystemError.CreateErrorLog(ex.Message);
            }
            finally
            {
                ///关闭已经打开的数据库连接   
            }
        }
    }
    /// <summary>
    /// 关闭数据库连接
    /// </summary>
    public void Close()
    {
        ///判断连接是否已经创建
        if (myConnection != null)
        {
            ///判断连接的状态是否打开
            if (myConnection.State == ConnectionState.Open)
            {
                myConnection.Close();
            }
        }
    }
    /// <summary>
    /// 释放资源
    /// </summary>
    public void Dispose()
    {
        // 确认连接是否已经关闭
        if (myConnection != null)
        {
            myConnection.Dispose();
            myConnection = null;
        }
    }
    /// <summary>
    /// 执行存储过程
    /// </summary>
    /// <param name="procName">存储过程的名称</param>
    /// <returns>返回存储过程返回值</returns>
    public int RunProc(string procName)
    {
        SqlCommand cmd = CreateProcCommand(procName, null);
        try
        {
            ///执行存储过程
            cmd.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
        finally
        {
            ///关闭数据库的连接
            Close();
        }
        ///返回存储过程的参数值
        return (int)cmd.Parameters[RETURNVALUE].Value;
    }
    /// <summary>
    /// 执行存储过程
    /// </summary>
    /// <param name="procName">存储过程名称</param>
    /// <param name="prams">存储过程所需参数</param>
    /// <returns>返回存储过程返回值</returns>
    public int RunProc(string procName, SqlParameter[] prams)
    {
        SqlCommand cmd = CreateProcCommand(procName, prams);
        try
        {
            ///执行存储过程
            cmd.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
        finally
        {
            ///关闭数据库的连接
            Close();
        }
        ///返回存储过程的参数值
        return (int)cmd.Parameters[RETURNVALUE].Value;
    }
    /// <summary>
    /// 执行存储过程
    /// </summary>
    /// <param name="procName">存储过程的名称</param>
    /// <param name="dataReader">返回存储过程返回值</param>
    public void RunProc(string procName, out SqlDataReader dataReader)
    {
        ///创建Command
        SqlCommand cmd = CreateProcCommand(procName, null);
        try
        {
            ///读取数据
            dataReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
        }
        catch (Exception ex)
        {
            dataReader = null;
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
    }
    /// <summary>
    /// 执行存储过程
    /// </summary>
    /// <param name="procName">存储过程的名称</param>
    /// <param name="prams">存储过程所需参数</param>
    /// <param name="dataSet">返回DataReader对象</param>
    public void RunProc(string procName, SqlParameter[] prams, out SqlDataReader dataReader)
    {
        ///创建Command
        SqlCommand cmd = CreateProcCommand(procName, prams);
        try
        {
            ///读取数据
            dataReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
        }
        catch (Exception ex)
        {
            dataReader = null;
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
    }
    /// <summary>
    /// 执行存储过程
    /// </summary>
    /// <param name="procName">存储过程的名称</param>
    /// <param name="dataSet">返回DataSet对象</param>
    public void RunProc(string procName, ref DataSet dataSet)
    {
        if (dataSet == null)
        {
            dataSet = new DataSet();
        }
        ///创建SqlDataAdapter
        SqlDataAdapter da = CreateProcDataAdapter(procName, null);
        try
        {
            ///读取数据
            da.Fill(dataSet);
        }
        catch (Exception ex)
        {
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
        finally
        {
            ///关闭数据库的连接
            Close();
        }
    }
    /// <summary>
    /// 执行存储过程
    /// </summary>
    /// <param name="procName">存储过程的名称</param>
    /// <param name="prams">存储过程所需参数</param>
    /// <param name="dataSet">返回DataSet对象</param>
    public void RunProc(string procName, SqlParameter[] prams, ref DataSet dataSet)
    {
        if (dataSet == null)
        {
            dataSet = new DataSet();
        }
        ///创建SqlDataAdapter
        SqlDataAdapter da = CreateProcDataAdapter(procName, prams);
        try
        {
            ///读取数据
            da.Fill(dataSet);
        }
        catch (Exception ex)
        {
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
        finally
        {
            ///关闭数据库的连接
            Close();
        }
    }
    /// <summary>
    /// 执行SQL语句
    /// </summary>
    /// <param name="cmdText">SQL语句</param>
    /// <returns>返回值</returns>
    public int RunSQL(string cmdText)
    {
        SqlCommand cmd = CreateSQLCommand(cmdText, null);
        int i = 0;
        try
        {
            ///执行存储过程
            cmd.ExecuteNonQuery();
            i = 1;
        }
        catch (Exception ex)
        {
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
            i = 0;
        }
        finally
        {
            ///关闭数据库的连接
            Close();
        }
        ///返回存储过程的参数值
        return i;
    }

    /// <summary>
    /// 执行SQL语句
    /// </summary>
    /// <param name="cmdText">SQL语句</param>
    /// <param name="prams">SQL语句所需参数</param>
    /// <returns>返回值</returns>
    public int RunSQL(string cmdText, SqlParameter[] prams)
    {
        SqlCommand cmd = CreateSQLCommand(cmdText, prams);
        try
        {
            ///执行存储过程
            cmd.ExecuteNonQuery();
        }
        catch (Exception ex)
        {
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
        finally
        {
            ///关闭数据库的连接
            Close();
        }
        ///返回存储过程的参数值
        return (int)cmd.Parameters[RETURNVALUE].Value;
    }
    /// <summary>
    /// 执行SQL语句
    /// </summary>
    /// <param name="cmdText">SQL语句</param> 
    /// <param name="dataReader">返回DataReader对象</param>
    public void RunSQL(string cmdText, out SqlDataReader dataReader)
    {
        ///创建Command
        SqlCommand cmd = CreateSQLCommand(cmdText, null);
        try
        {
            ///读取数据
            dataReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
        }
        catch (Exception ex)
        {
            dataReader = null;
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
    }
    /// <summary>
    /// 执行SQL语句
    /// </summary>
    /// <param name="cmdText">SQL语句</param>
    /// <param name="prams">SQL语句所需参数</param>
    /// <param name="dataReader">返回DataReader对象</param>
    public void RunSQL(string cmdText, SqlParameter[] prams, out SqlDataReader dataReader)
    {
        ///创建Command
        SqlCommand cmd = CreateSQLCommand(cmdText, prams);
        try
        {
            ///读取数据
            dataReader = cmd.ExecuteReader(CommandBehavior.CloseConnection);
        }
        catch (Exception ex)
        {
            dataReader = null;
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
    }
    /// <summary>
    /// 执行SQL语句
    /// </summary>
    /// <param name="cmdText">SQL语句</param>
    /// <param name="dataSet">返回DataSet对象</param>
    public void RunSQL(string cmdText, ref DataSet dataSet)
    {
        if (dataSet == null)
        {
            dataSet = new DataSet();
        }
        ///创建SqlDataAdapter
        SqlDataAdapter da = CreateSQLDataAdapter(cmdText, null);
        try
        {
            ///读取数据
            da.Fill(dataSet);
        }
        catch (Exception ex)
        {
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
        finally
        {
            ///关闭数据库的连接
            Close();
        }
    }
    /// <summary>
    /// 执行SQL语句
    /// </summary>
    /// <param name="cmdText">SQL语句</param>
    /// <param name="prams">SQL语句所需参数</param>
    /// <param name="dataSet">返回DataSet对象</param>
    public void RunSQL(string cmdText, SqlParameter[] prams, ref DataSet dataSet)
    {
        if (dataSet == null)
        {
            dataSet = new DataSet();
        }
        ///创建SqlDataAdapter
        SqlDataAdapter da = CreateProcDataAdapter(cmdText, prams);
        try
        {
            ///读取数据
            da.Fill(dataSet);
        }
        catch (Exception ex)
        {
            ///记录错误日志
            SystemError.CreateErrorLog(ex.Message);
        }
        finally
        {
            ///关闭数据库的连接
            Close();
        }
    }
    /// <summary>
    /// 创建一个SqlCommand对象以此来执行存储过程
    /// </summary>
    /// <param name="procName">存储过程的名称</param>
    /// <param name="prams">存储过程所需参数</param>
    /// <returns>返回SqlCommand对象</returns>
    private SqlCommand CreateProcCommand(string procName, SqlParameter[] prams)
    {
        ///打开数据库连接
        Open();
        ///设置Command
        SqlCommand cmd = new SqlCommand(procName, myConnection);
        cmd.CommandType = CommandType.StoredProcedure;
        ///添加把存储过程的参数
        if (prams != null)
        {
            foreach (SqlParameter parameter in prams)
            {
                cmd.Parameters.Add(parameter);
            }
        }
        ///添加返回参数ReturnValue
        cmd.Parameters.Add(
            new SqlParameter(RETURNVALUE, SqlDbType.Int, 4, ParameterDirection.ReturnValue,
            false, 0, 0, string.Empty, DataRowVersion.Default, null));
        ///返回创建的SqlCommand对象
        return cmd;
    }
    /// <summary>
    /// 创建一个SqlCommand对象以此来执行存储过程
    /// </summary>
    /// <param name="cmdText">SQL语句</param>
    /// <param name="prams">SQL语句所需参数</param>
    /// <returns>返回SqlCommand对象</returns>
    private SqlCommand CreateSQLCommand(string cmdText, SqlParameter[] prams)
    {
        ///打开数据库连接
        Open();
        ///设置Command
        SqlCommand cmd = new SqlCommand(cmdText, myConnection);
        ///添加把存储过程的参数
        if (prams != null)
        {
            foreach (SqlParameter parameter in prams)
            {
                cmd.Parameters.Add(parameter);
            }
        }
        ///添加返回参数ReturnValue
        cmd.Parameters.Add(
            new SqlParameter(RETURNVALUE, SqlDbType.Int, 4, ParameterDirection.ReturnValue,
            false, 0, 0, string.Empty, DataRowVersion.Default, null));
        ///返回创建的SqlCommand对象
        return cmd;
    }
    /// <summary>
    /// 创建一个SqlDataAdapter对象，用此来执行存储过程
    /// </summary>
    /// <param name="procName">存储过程的名称</param>
    /// <param name="prams">存储过程所需参数</param>
    /// <returns>返回SqlDataAdapter对象</returns>
    private SqlDataAdapter CreateProcDataAdapter(string procName, SqlParameter[] prams)
    {
        ///打开数据库连接
        Open();
        ///设置SqlDataAdapter对象
        SqlDataAdapter da = new SqlDataAdapter(procName, myConnection);
        da.SelectCommand.CommandType = CommandType.StoredProcedure;
        ///添加把存储过程的参数
        if (prams != null)
        {
            foreach (SqlParameter parameter in prams)
            {
                da.SelectCommand.Parameters.Add(parameter);
            }
        }
        ///添加返回参数ReturnValue
        da.SelectCommand.Parameters.Add(
            new SqlParameter(RETURNVALUE, SqlDbType.Int, 4, ParameterDirection.ReturnValue,
            false, 0, 0, string.Empty, DataRowVersion.Default, null));
        ///返回创建的SqlDataAdapter对象
        return da;
    }
    /// <summary>
    /// 创建一个SqlDataAdapter对象，用此来执行SQL语句
    /// </summary>
    /// <param name="cmdText">SQL语句</param>
    /// <param name="prams">SQL语句所需参数</param>
    /// <returns>返回SqlDataAdapter对象</returns>
    private SqlDataAdapter CreateSQLDataAdapter(string cmdText, SqlParameter[] prams)
    {
        ///打开数据库连接
        Open();
        ///设置SqlDataAdapter对象
        SqlDataAdapter da = new SqlDataAdapter(cmdText, myConnection);
        ///添加把存储过程的参数
        if (prams != null)
        {
            foreach (SqlParameter parameter in prams)
            {
                da.SelectCommand.Parameters.Add(parameter);
            }
        }
        ///添加返回参数ReturnValue
        da.SelectCommand.Parameters.Add(
            new SqlParameter(RETURNVALUE, SqlDbType.Int, 4, ParameterDirection.ReturnValue,
            false, 0, 0, string.Empty, DataRowVersion.Default, null));
        ///返回创建的SqlDataAdapter对象
        return da;
    }
    /// <summary>
    /// 生成存储过程参数
    /// </summary>
    /// <param name="ParamName">存储过程名称</param>
    /// <param name="DbType">参数类型</param>
    /// <param name="Size">参数大小</param>
    /// <param name="Direction">参数方向</param>
    /// <param name="Value">参数值</param>
    /// <returns>新的 parameter 对象</returns>
    public SqlParameter CreateParam(string ParamName, SqlDbType DbType, Int32 Size, ParameterDirection Direction, object Value)
    {
        SqlParameter param;
        ///当参数大小为0时，不使用该参数大小值
        if (Size > 0)
        {
            param = new SqlParameter(ParamName, DbType, Size);
        }
        else
        {
            ///当参数大小为0时，不使用该参数大小值
            param = new SqlParameter(ParamName, DbType);
        }
        ///创建输出类型的参数
        param.Direction = Direction;
        if (!(Direction == ParameterDirection.Output && Value == null))
        {
            param.Value = Value;
        }
        ///返回创建的参数
        return param;
    }
    /// <summary>
    /// 传入输入参数
    /// </summary>
    /// <param name="ParamName">存储过程名称</param>
    /// <param name="DbType">参数类型</param></param>
    /// <param name="Size">参数大小</param>
    /// <param name="Value">参数值</param>
    /// <returns>新的parameter 对象</returns>
    public SqlParameter CreateInParam(string ParamName, SqlDbType DbType, int Size, object Value)
    {
        return CreateParam(ParamName, DbType, Size, ParameterDirection.Input, Value);
    }
    /// <summary>
    /// 传入返回值参数
    /// </summary>
    /// <param name="ParamName">存储过程名称</param>
    /// <param name="DbType">参数类型</param>
    /// <param name="Size">参数大小</param>
    /// <returns>新的 parameter 对象</returns>
    public SqlParameter CreateOutParam(string ParamName, SqlDbType DbType, int Size)
    {
        return CreateParam(ParamName, DbType, Size, ParameterDirection.Output, null);
    }
    /// <summary>
    /// 传入返回值参数
    /// </summary>
    /// <param name="ParamName">存储过程名称</param>
    /// <param name="DbType">参数类型</param>
    /// <param name="Size">参数大小</param>
    /// <returns>新的 parameter 对象</returns>
    public SqlParameter CreateReturnParam(string ParamName, SqlDbType DbType, int Size)
    {
        return CreateParam(ParamName, DbType, Size, ParameterDirection.ReturnValue, null);
    }
}

文章标签：
日志服务
存储
SQL
数据库
数据库连接
相关实践学习
日志服务之使用Nginx模式采集日志
本文介绍如何通过日志服务控制台创建Nginx模式的Logtail配置快速采集Nginx日志并进行多维度分析。
暖枫无敌
目录
相关文章
老朱教授
|
C++ 数据库管理
SQLite 解决：Could not load file or assembly 'System.Data.SQLite ... 试图加载格式不正确的程序/or one of its dependencies. 找不到指定的模块。
老朱教授
3752 0
王卫
|
9月前
|
SQL 数据库
编写SQLHelper类
编写SQLHelper类
王卫
46 1
谷艳爽faye
|
9月前
|
数据库 C#
C#，.net,winform导入Excel功能以及下载Excel文件到本地，并使用SqlBulkCopy把DataTable类型的数据写入到sqlserver数据库中
C#，.net,winform导入Excel功能以及下载Excel文件到本地，并使用SqlBulkCopy把DataTable类型的数据写入到sqlserver数据库中
谷艳爽faye
218 0
优惠码发放
|
图形学 Windows
构建项目时发生错误 - 错误：CS0006“... \ Assembly-CSharp-firstpass.dll”找不到
构建项目时发生错误 - 错误：CS0006“... \ Assembly-CSharp-firstpass.dll”找不到 我正在为Hololens建立一个简单的项目。 独特的场景与简单的立方体。 我遵循这个教程做出来： - > https://developer.
优惠码发放
3485 0
老朱教授
|
数据库 数据库连接 SQL
SQLHelper.cs介绍
老朱教授
1256 0
橘子红了呐
|
SQL 存储 Oracle
数据操作类 SQLHelper.cs
橘子红了呐
856 0
最美的回忆
|
数据库 SQL
TXT->Access 使用DAO数据源!(VB Code)
最美的回忆
972 0
技术小甜
|
XML .NET 数据库
使用asp.net 2.0中的SqlBulkCopy类批量复制数据
技术小甜
1124 0
长征2号
|
SQL 数据库 安全
DB-->Excel/Word[DLL]
长征2号
1487 0
吞吞吐吐的
cs-Panination
吞吞吐吐的
957 0

热门文章

最新文章

  • 1
    Mac安装并使用telnet命令操作
  • 2
    OSS回源的几种方式和应用场景
  • 3
    [剑指offer] 孩子们的游戏(圆圈中最后剩下的数)
  • 4
    网络安全系列之二十二 Windows用户账号加固
  • 5
    我理解的一个程序员如何学习前端开发
  • 6
    《社交网站界面设计（原书第2版）》——1.9　为设备之间的空间进行设计
  • 7
    《Microduino实战》——1.2　为什么要开源
  • 8
    .Net函数Math.Round你会用吗？
  • 9
    麻省理工大学新发明：暗黑WiFi透视技术
  • 10
    2014秋C++第19周 补充代码 哈希法的存储与查找
  • 1
    R语言关联规则模型(Apriori算法)挖掘杂货店的交易数据与交互可视化
    26
  • 2
    R语言近似贝叶斯计算MCMC（ABC-MCMC）轨迹图和边缘图可视化
    22
  • 3
    r语言中对LASSO回归，Ridge岭回归和弹性网络Elastic Net模型实现-4
    31
  • 4
    Sentieon | 每周文献-Multi-omics-第四十一期
    27
  • 5
    数据分享|R语言广义线性模型GLM：线性最小二乘、对数变换、泊松、二项式逻辑回归分析冰淇淋销售时间序列数据和模拟-2
    17
  • 6
    数据分享|R语言广义线性模型GLM：线性最小二乘、对数变换、泊松、二项式逻辑回归分析冰淇淋销售时间序列数据和模拟-1
    24
  • 7
    基于RT-Thread摄像头车牌图像采集系统
    23
  • 8
    R语言极值理论：希尔HILL统计量尾部指数参数估计可视化
    17
  • 9
    【视频】R语言中的分布滞后非线性模型（DLNM）与发病率，死亡率和空气污染示例
    25
  • 10
    sql语句创建数据库
    19

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    部署LAMP环境（Alibaba Cloud Linux 3）