SQL Server 数据库访问操作通用类五种方法

对SQL Server数据库的操作，最常见的有如下五种：

　　1.非连接式查询，获取DataTable。

　　2.连接式查询，获取DataReader。

　　3.查询结果只有1行1列，获取单一数据。

　　4.对数据库进行增、删、改操作，进行数据编辑。

　　5.判断与数据库是否已连接。（更新）

　　针对以上情况，分享的一个SQL Server数据库访问通用类。该通用类可用于ASP.NET和C/S系统中开发。

 1.非连接式查询，获取DataTable。

利用SqlDataAdapter对象的Fill()返回DataTable的结果集。

View Code

 代码如下 复制代码

#region 执行一个查询，并返回结果集

    /// <summary>
    /// 执行一个查询，并返回结果集
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <returns>查询结果集</returns>
    public DataTable ExecuteDataTable(string sql)
    {
        return ExecuteDataTable(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 执行一个查询，并返回结果集
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">查询语句类型，存储过程或SQL文本命令</param>
    /// <returns>查询结果集</returns>
    public DataTable ExecuteDataTable(string sql, CommandType commandType)
    {
        return ExecuteDataTable(sql, commandType, null);
    }

    /// <summary>
    /// 执行一个查询，并返回结果集
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">查询语句类型，存储过程或SQL文本命令</param>
    /// <param name="parameters">T-SQL语句或存储过程的参数组</param>
    /// <returns>查询结果集</returns>
    public DataTable ExecuteDataTable(string sql, CommandType commandType, SqlParameter[] parameters)
    {
        //实例化DataTable，用于装载查询结果集
        DataTable data = new DataTable();
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                //指定CommandType
                command.CommandType = commandType;

                if (parameters != null)
                {
                    foreach (SqlParameter parameter in parameters)
                    {
                        command.Parameters.Add(parameter);
                    }
                }
                //实例化SqlDataAdapter
                SqlDataAdapter adapter = new SqlDataAdapter(command);
                //填充DataTable
                adapter.Fill(data);
            }
        }
        return data;

    }

    #endregion

 

2.连接式查询，获取DataReader。

利用SqlReader()返回DataReader对象实例。

View Code

 代码如下 复制代码

#region 返回一个DataReader对象实例

    /// <summary>
    /// 返回一个DataReader对象实例
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <returns>DataReader对象实例</returns>
    public SqlDataReader ExecuteReader(string sql)
    {
        return ExecuteReader(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 返回一个DataReader对象实例
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <returns>DataReader对象实例</returns>
    public SqlDataReader ExecuteReader(string sql, CommandType commandType)
    {
        return ExecuteReader(sql, commandType, null);
    }

    /// <summary>
    /// 返回一个DataReader对象实例
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <param name="parameters">T-SQL语句或存储过程的参数数组</param>
    /// <returns>DataReader对象实例</returns>
    public SqlDataReader ExecuteReader(string sql, CommandType commandType, SqlParameter[] parameters)
    {
        SqlConnection connection = new SqlConnection(connectionString);
        SqlCommand command = new SqlCommand(sql, connection);

        if (parameters != null)
        {
            foreach (SqlParameter parameter in parameters)
            {
                command.Parameters.Add(parameter);
            }
        }
        connection.Open();
        //参数CommandBehavior.CloseConnection表示，关闭Reader对象的同时关闭Connection对象
        return command.ExecuteReader(CommandBehavior.CloseConnection);
    }
    #endregion
 

3.查询结果只有1行1列，获取单一数据。

利用SqlCommand的ExecuteScalar()。

View Code

 代码如下 复制代码

#region 执行查询结果，返回第一行的第一列

    /// <summary>
    /// 执行查询结果，返回第一行的第一列
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <returns>返回第一行的第一列</returns>
    public object ExecuteScalar(string sql)
    {
        return ExecuteScalar(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 执行查询结果，返回第一行的第一列
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <returns>返回第一行的第一列</returns>
    public object ExecuteScalar(string sql, CommandType commandType)
    {
        return ExecuteScalar(sql, commandType, null);
    }

    /// <summary>
    /// 执行查询结果，返回第一行的第一列
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <param name="parameters">T-SQL语句或存储过程的参数数组</param>
    /// <returns>返回第一行的第一列</returns>
    public object ExecuteScalar(string sql, CommandType commandType, SqlParameter[] parameters)
    {
        object result = null;
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                command.CommandType = commandType;

                if (parameters != null)
                {
                    foreach (SqlParameter parameter in parameters)
                    {
                        command.Parameters.Add(parameter);
                    }
                }

                connection.Open();
                result = command.ExecuteScalar();
            }

        }
        return result;
    }

    #endregion
 

4.对数据库进行增、删、改操作，进行数据编辑。

利用ExecuteNonQuery()。

View Code

 代码如下 复制代码

#region 对数据库进行增删改操作

    /// <summary>
    /// 对数据库进行增删改操作
    /// </summary>
    /// <param name="sql">要执行的SQL文本命令</param>
    /// <returns>返回受影响的函数</returns>
    public int ExecuteNonQuery(string sql)
    {
        return ExecuteNonQuery(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 对数据库进行增删改操作
    /// </summary>
    /// <param name="sql">要执行的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <returns>返回受影响的函数</returns>
    public int ExecuteNonQuery(string sql, CommandType commandType)
    {
        return ExecuteNonQuery(sql, commandType, null);
    }

    /// <summary>
    /// 对数据库进行增删改操作
    /// </summary>
    /// <param name="sql">要执行的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <param name="parameters">T-SQL语句或存储过程的参数数组</param>
    /// <returns>返回受影响的函数</returns>
    public int ExecuteNonQuery(string sql, CommandType commandType, SqlParameter[] parameters)
    {
        int count = 0;
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                command.CommandType = commandType;

                if (parameters != null)
                {
                    foreach (SqlParameter parameter in parameters)
                    {
                        command.Parameters.Add(parameter);
                    }
                }
                connection.Open();
                count = command.ExecuteNonQuery();

            }

        }
        return count;

    }

    #endregion
 

5.判断与数据库是否连接（更新）

View Code

 代码如下 复制代码

#region 判断数据库是否连接

    /// <summary>
    /// 判断数据库是否连接
    /// </summary>
    /// <returns>是否连接</returns>
    public bool IsConnected()
    {
        SqlConnection connection = new SqlConnection(connectionString);
        try
        {
            if (connection.State != ConnectionState.Open)
            {
                connection.Open();
            }
            return true;
        }
        catch
        {
            return false;
        }
    }

    #endregion
 

 

该类全部代码

View Code

 代码如下 复制代码

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

/// <summary>
/// SqlDbHelper:操作SQL Server数据库的通用类
/// 作者：李宝亨
/// 日期：2012-03-15
/// Version:1.0
/// </summary>
public class SqlDbHelper
{
    #region 字段
    /// <summary>
    /// 私有字段
    /// </summary>
    private string connectionString;

    #endregion

    #region 属性

    /// <summary>
    /// 公共属性 数据库连接字符串
    /// </summary>
    public string ConnectiongString
    {
        set { connectionString = value; }
    }

    #endregion

    #region 构造函数

    /// <summary>
    /// 构造函数
    /// </summary>
    public SqlDbHelper()
    {
        //修改connectionString为项目中的数据库连接字符串
        //connectionString="";
    }

    /// <summary>
    /// 构造函数
    /// </summary>
    /// <param name="strConnectionString">数据库连接字符串</param>
    public SqlDbHelper(string strConnectionString)
    {
        connectionString = strConnectionString;
    }

    #endregion

    #region 判断数据库是否连接

    /// <summary>
    /// 判断数据库是否连接
    /// </summary>
    /// <returns>是否连接</returns>
    public bool IsConnected()
    {
        SqlConnection connection = new SqlConnection(connectionString);
        try
        {
            if (connection.State != ConnectionState.Open)
            {
                connection.Open();
            }
            return true;
        }
        catch
        {
            return false;
        }
    }

    #endregion

    #region 执行一个查询，并返回结果集

    /// <summary>
    /// 执行一个查询，并返回结果集
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <returns>查询结果集</returns>
    public DataTable ExecuteDataTable(string sql)
    {
        return ExecuteDataTable(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 执行一个查询，并返回结果集
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">查询语句类型，存储过程或SQL文本命令</param>
    /// <returns>查询结果集</returns>
    public DataTable ExecuteDataTable(string sql, CommandType commandType)
    {
        return ExecuteDataTable(sql, commandType, null);
    }

    /// <summary>
    /// 执行一个查询，并返回结果集
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">查询语句类型，存储过程或SQL文本命令</param>
    /// <param name="parameters">T-SQL语句或存储过程的参数组</param>
    /// <returns>查询结果集</returns>
    public DataTable ExecuteDataTable(string sql, CommandType commandType, SqlParameter[] parameters)
    {
        //实例化DataTable，用于装载查询结果集
        DataTable data = new DataTable();
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                //指定CommandType
                command.CommandType = commandType;

                if (parameters != null)
                {
                    foreach (SqlParameter parameter in parameters)
                    {
                        command.Parameters.Add(parameter);
                    }
                }
                //实例化SqlDataAdapter
                SqlDataAdapter adapter = new SqlDataAdapter(command);
                //填充DataTable
                adapter.Fill(data);
            }
        }
        return data;

    }

    #endregion

    #region 返回一个DataReader对象实例

    /// <summary>
    /// 返回一个DataReader对象实例
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <returns>DataReader对象实例</returns>
    public SqlDataReader ExecuteReader(string sql)
    {
        return ExecuteReader(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 返回一个DataReader对象实例
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <returns>DataReader对象实例</returns>
    public SqlDataReader ExecuteReader(string sql, CommandType commandType)
    {
        return ExecuteReader(sql, commandType, null);
    }

    /// <summary>
    /// 返回一个DataReader对象实例
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <param name="parameters">T-SQL语句或存储过程的参数数组</param>
    /// <returns>DataReader对象实例</returns>
    public SqlDataReader ExecuteReader(string sql, CommandType commandType, SqlParameter[] parameters)
    {
        SqlConnection connection = new SqlConnection(connectionString);
        SqlCommand command = new SqlCommand(sql, connection);

        if (parameters != null)
        {
            foreach (SqlParameter parameter in parameters)
            {
                command.Parameters.Add(parameter);
            }
        }
        connection.Open();
        //参数CommandBehavior.CloseConnection表示，关闭Reader对象的同时关闭Connection对象
        return command.ExecuteReader(CommandBehavior.CloseConnection);
    }
    #endregion

    #region 执行查询结果，返回第一行的第一列

    /// <summary>
    /// 执行查询结果，返回第一行的第一列
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <returns>返回第一行的第一列</returns>
    public object ExecuteScalar(string sql)
    {
        return ExecuteScalar(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 执行查询结果，返回第一行的第一列
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <returns>返回第一行的第一列</returns>
    public object ExecuteScalar(string sql, CommandType commandType)
    {
        return ExecuteScalar(sql, commandType, null);
    }

    /// <summary>
    /// 执行查询结果，返回第一行的第一列
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <param name="parameters">T-SQL语句或存储过程的参数数组</param>
    /// <returns>返回第一行的第一列</returns>
    public object ExecuteScalar(string sql, CommandType commandType, SqlParameter[] parameters)
    {
        object result = null;
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                command.CommandType = commandType;

                if (parameters != null)
                {
                    foreach (SqlParameter parameter in parameters)
                    {
                        command.Parameters.Add(parameter);
                    }
                }

                connection.Open();
                result = command.ExecuteScalar();
            }

        }
        return result;
    }

    #endregion

    #region 对数据库进行增删改操作

    /// <summary>
    /// 对数据库进行增删改操作
    /// </summary>
    /// <param name="sql">要执行的SQL文本命令</param>
    /// <returns>返回受影响的函数</returns>
    public int ExecuteNonQuery(string sql)
    {
        return ExecuteNonQuery(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 对数据库进行增删改操作
    /// </summary>
    /// <param name="sql">要执行的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <returns>返回受影响的函数</returns>
    public int ExecuteNonQuery(string sql, CommandType commandType)
    {
        return ExecuteNonQuery(sql, commandType, null);
    }

    /// <summary>
    /// 对数据库进行增删改操作
    /// </summary>
    /// <param name="sql">要执行的SQL文本命令</param>
    /// <param name="commandType">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <param name="parameters">T-SQL语句或存储过程的参数数组</param>
    /// <returns>返回受影响的函数</returns>
    public int ExecuteNonQuery(string sql, CommandType commandType, SqlParameter[] parameters)
    {
        int count = 0;
        using (SqlConnection connection = new SqlConnection(connectionString))
        {
            using (SqlCommand command = new SqlCommand(sql, connection))
            {
                command.CommandType = commandType;

                if (parameters != null)
                {
                    foreach (SqlParameter parameter in parameters)
                    {
                        command.Parameters.Add(parameter);
                    }
                }
                connection.Open();
                count = command.ExecuteNonQuery();

            }

        }
        return count;

    }

    #endregion

}

总结
关于数据库连接访问类也就是大家知道的常用的数据库的读取、连接，删除、修改等常规操作了，无非就是对数据库性能会有所帮助，有需要的朋友可以看看。

时间： 2024-07-30 05:16:08

SQL Server 数据库访问操作通用类五种方法的相关文章

编程-关于C#使用OleDbCommand对sql server数据库进行操作的问题

问题描述 关于C#使用OleDbCommand对sql server数据库进行操作的问题 有个编程作业是要模拟一个ATM机,我用vs2013来编写的,sql server版本是2012 数据库ATM中已经有表account(card_id , account_owner , account_password , account_sum) 怎样利用OleDbCommand来执行语句:update account set account_sum=new_sum where card_id=00000

ASP语言实现对SQL SERVER数据库的操作_应用技巧

目前管理信息系统已从传统的客户机/服务器(C/S)模式转向了浏览器/服务器(B/S)模式,特别是微软公司推出它的新产品ASP语言之后,这种转变更加迅猛.管理信息系统的核心是对数据库进行包括添加.修改和查询等等操作,ASP提供的ADO数据库接口控件,使得程序员再也勿需编写复杂的CGI程序了,而只要用几句简单的语句即可实现以上操作.1.系统环境 PII 350,Ram 64M,WINNT Server 4.0, Service Pack4, IIS 4.0, SQL Server7.0. 2.系统功

ASP语言实现对SQL SERVER数据库的操作

目前管理信息系统已从传统的客户机/服务器(C/S)模式转向了浏览器/服务器(B/S)模式,特别是微软公司推出它的新产品ASP语言之后,这种转变更加迅猛.管理信息系统的核心是对数据库进行包括添加.修改和查询等等操作,ASP提供的ADO数据库接口控件,使得程序员再也勿需编写复杂的CGI程序了,而只要用几句简单的语句即可实现以上操作.1.系统环境 PII 350,Ram 64M,WINNT Server 4.0, Service Pack4, IIS 4.0, SQL Server7.0. 2.系统功

动态改变EnterpriseLibary数据库访问链接字符串的三种方法

使用EnterpriseLibary做数据库访问底层是我一贯的做法,除了其能兼容多种数据库,且使用其进行数据库访问,对各种数据库操作均是透明的,基本不需要对特定的数据库进行操作,编写一次操作代码,基本在各种数据库都适用.对于一些特殊的数据库,很多同行已经编写出各种各样的扩展类库,直接适用即可. 言归正传,动态改变EnterpriseLibary数据库访问链接字符串一般在使用Access数据库.Sqlite数据库等文件式的数据库比较常见,因为我们不知道客户会把程序拷贝到哪里进行使用(即使是做了安装

PowerShell连接SQL SERVER数据库进行操作的实现代码_PowerShell

核心代码 #配置信息 $Database = 'DemoDB' $Server = '"WIN-AHAU9NO5R6U\DOG"' $UserName = 'kk' $Password = '123456' #创建连接对象 $SqlConn = New-Object System.Data.SqlClient.SqlConnection #使用账号连接MSSQL $SqlConn.ConnectionString = "Data Source=$Server;Initial

用ASP语言实现对SQL SERVER 数据库的操作

目前管理信息系统已从传统的客户机/服务器(C/S)模式转向了浏览器/服务器(B/S)模式,特别是微软公司推出它的新产品ASP语言之后,这种转变更加迅猛.管理信息系统的核心是对数据库进行包括添加.修改和查询等等操作,ASP提供的ADO数据库接口控件,使得程序员再也勿需编写复杂的CGI程序了,而只要用几句简单的语句即可实现以上操作.目前有很多介绍用ASP开发网络数据库的程序例子,但绝大部分是利用ACCESS作底层数据库.相对于ACCESS而言,SQL SERVER数据库系统要复杂得多,因此在程序开发

SQL Server数据库重命名、数据导出的方法说明_MsSql

第一个问题是重命名数据库问题:在企业管理器中是无法直接对数据库重命名的,只能在查询分析器中操作 复制代码 代码如下: create proc killspid (@dbname varchar(20))         as         begin         declare     @sql     nvarchar(500),@temp   varchar(1000)     declare     @spid     int         set     @sql='declar

SQL Server数据库重命名、数据导出的方法说明

第一个问题是重命名数据库问题:在企业管理器中是无法直接对数据库重命名的,只能在查询分析器中操作 复制代码 代码如下:create proc killspid (@dbname varchar(20))         as         begin         declare     @sql     nvarchar(500),@temp   varchar(1000)     declare     @spid     int         set     @sql='declare

SQL Server数据库复制失败的原因及解决方法_MsSql

在SQL Server数据库操作中,对数据库复制时出现了以下的错误,错误信息如下图所示: SQL Server数据库复制失败的原因及解决方案 出现上面的提示信息,会是什么原因导致的呢?笔者经过一番推敲终于找到了上述的原因. 原因:在复制数据库时,必须先停止mssqlserver服务,然后才能复制. 解决方法: 开始-->运行-->services.msc打开服务管理器,找到mssqlserver服务,然后停止该服务. 或者 开始-->运行-->cmd-->net stop m