一步步写自己SqlHelper类库（五）：Command对象

1.Command对象基础

　　当我们使用Connection对象里面的方法打开数据库后，要查询自己所需的数据或对数据库的内容进行增删改时，Command对象就派上用场了！

　　MSDN定义：建立与数据源的连接后，利用Command对象来执行命令并从数据源中返回结果。

　　 .NET Framework 提供的每个 .NET Framework 数据提供程序都具有一个 Command 对象。

名称	命名空间	描述
SqlCommand	System.Data.SqlClient	表示与SQL Server的操作对象
OleDbCommand	System.Data.OleDb	表示与OleDb数据源的操作对象
OdbcCommand	System.Data.Odbc	表示与ODBC数据源的操作对象
OracleCommand	System.Data.OracleClient	表示与Orale数据库的操作对象

2.Command对象属性和方法　

　　2.1属性

 　　CommandText: 获取或设置对数据源执行的文本命令。默认值为空字符串。

 　　CommandType: 命令类型，指示或指定如何解释CommandText属性。CommandType属性的值是一个枚举类型，定义结构如下：

 public enum CommandType
    {
        // 摘要:
        //     SQL 文本命令。（默认。）
        Text = 1,
        //
        // 摘要:
        //     存储过程的名称。
        StoredProcedure = 4,
        //
        // 摘要:
        //     表的名称。
        TableDirect = 512,
    }

　　需要特别注意的是，将CommandType 设置为 StoredProcedure 时，应将 CommandText 属性设置为存储过程的名称。 当调用 Execute 方法之一时，该命令将执行此存储过程。

　　Connection: 设置或获取与数据源的连接。

　　Parameters: 绑定SQL语句或存储过程的参数。防止SQL注入，参数化查询中不可或缺的对象，非常重要。

　　Tranction: 获取或设置在其中执行 .NET Framework 数据提供程序的 Command 对象的事务。

　　2.2方法

　　　

命令	返回值
ExecuteNonQuery	对连接执行 Transact-SQL 语句并返回受影响的行数。 对于 UPDATE、INSERT 和 DELETE 语句，返回值为该命令所影响的行数。对于所有其 他类型的语句，返回值为 -1。如果发生回滚，返回值也为 -1。
ExecuteScalar	执行查询，并返回查询所返回的结果集中第一行的第一列。
ExecuteReader	执行查询，并返回一个 DataReader 对象
ExecuteXMLReader	返回 XmlReader。 只用于 SqlCommand 对象。

 

3.使用参数化Parameter

　　3.1 基础知识点

　　对数据库进行增删改查操作时，如果使用普通的字符串拼接SQL语句，会造成SQL注入，泄露数据库中的信息，所以使用参数化的操作可以防止这一问题。

　　对于不同的数据源来说，Parameter对象不同，但都派生自DbParameter对象。下表列举了不同数据源对应的Parameter对象。

数据提供程序	对应Paramter对象	命名空间
SQLServer 数据源	使用SqlParamter对象	System.Data.SqlClient.SqlParameter
Ole DB 数据源	使用OleDbParameter对象	System.Data.OleDb.OleDbParameter
ODBC 数据源	使用OdbcParamter对象	System.Data.Odbc.OdbcParameter
Oracle数据源	使用OracleParameter对象	System.Data.OracleClient.OracleParameter

　　

　　3.2属性

　　Paramter对象的属性很多，其中常见而且非常重要的主要有以下几个：

　　DbType: 获取或设置参数的数据类型。

　　Direction: 获取或设置一个值，该值指示参数是否只可输入、只可输出、双向还是存储过程返回值参数。

　　IsNullable: 获取或设置一个值，该值指示参数是否可以为空。

　　ParamteterName: 获取或设置DbParamter的名称。

　　Size: 获取或设置列中数据的最大大小。

　　Value: 获取或设置该参数的值。

　　3.3方法

　　Paramter对象Add方法：该方法每次只能添加一个SqlParameter。下面代码的功能是将ID值等于1的字段name更新为Terrychan。

SqlParameter sp = new SqlParameter("@name", "Terrychan");
command.Parameters.Add(sp);
sp = new SqlParameter("@ID", "1");
command.Parameters.Add(sp);

　　Paramter对象Add方法：add方法在添加多个SqlParameter时不方便，此时，可以采用AddRange方法　

SqlParameter[] paras = new SqlParameter[] { new SqlParameter("@name", "Pudding"), new SqlParameter("@ID", "1") };
cmd.Parameters.AddRange(paras);

4.SqlHelper类

　　Command对象里面的几个方法很重要，基本上可以实现数据库的增删改查操作，在封装方法时，应该注意方法的重载。　　

using System;
using System.Collections.Generic;
using System.Linq;
using System.Web;
using System.Data;
using System.Data.SqlClient;
using System.Configuration;

/// <summary>
///SqlHelper create by TerryChan 2012-04-17
/// </summary>
public class SqlHelper
{
    #region 全局配置
    /// <summary>
    /// 连接字符串
    /// </summary> 
    public readonly static string connectionString = ConfigurationManager.ConnectionStrings["connstring"].ToString();
  
    /// <summary>
    /// SqlConnection对象
    /// </summary> 
    private static SqlConnection conn = new SqlConnection(connectionString);

    #endregion

    #region 打开数据库
    /// <summary>
    /// 打开数据库
    /// </summary>
    public static void OpenConnection()
    {
        if (conn.State != ConnectionState.Open)
        {
            try
            {
                conn.Open();
            }
            catch (Exception ex)
            {
                conn.Dispose();
                throw new Exception("打开数据库失败!" + ex.Message);
            }
        }
    }
    #endregion

    #region 关闭数据库
    /// <summary>
    /// 关闭数据库
    /// </summary>
    public static void CloseConnection()
    {
        if (conn.State == ConnectionState.Open)
        {
            try
            {
                conn.Close();
            }
            catch (Exception ex)
            {
                conn.Dispose();
                throw new Exception("关闭数据库失败!" + ex.Message);
            }
        }
    }
    #endregion

    #region ExecuteNoQuery 执行不返回数据行的操作，并返回一个int类型的数据

    /// <summary>
    /// 执行不返回数据行的操作，返回一个int类型的数据
    /// </summary>
    /// <param name="sql">要执行的SQL文本命令</param>
    /// <returns>返回受影响的行数</returns>
    public static int ExecuteNoQuery(string sql)
    {
        return ExecuteNoQuery(sql, CommandType.Text, null);
    }

    /// <summary>
    /// 执行不返回数据行的操作，返回一个int类型的数据
    /// </summary>
    /// <param name="sql">要执行的SQL文本命令或存储过程名称</param>
    /// <param name="type">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <returns>返回受影响的行数</returns>
    public static int ExecuteNoQuery(string sql, CommandType type)
    {
        return ExecuteNoQuery(sql, type, null);
    }

    /// <summary>
    /// 执行不返回数据行的操作，返回一个int类型的数据
    /// </summary>
    /// <param name="sql">要查询的SQL文本命令或存储过程名称</param>
    /// <param name="type">要执行的查询语句的类型，存储过程或SQL文本命令</param>
    /// <param name="sp">T-SQL语句或存储过程的参数数组</param>
    /// <returns>返回受影响的行数</returns>
    public static int ExecuteNoQuery(string sql, CommandType type, SqlParameter[] sp)
    {
        try
        {
            OpenConnection();
            SqlCommand command = new SqlCommand(sql, conn);
            command.CommandType = type;
            if (sp != null)
            {
                foreach (SqlParameter parameter in sp)
                {
                    command.Parameters.Add(parameter);
                }
            }
            int result = command.ExecuteNonQuery();
            return result;
        }
        catch (Exception ex)
        {
            throw new Exception("ExecuteNoQuery错误：" + ex);
        }
        finally
        {
            CloseConnection();
        }
    }

    #endregion

    #region ExecuteScalar 执行查询，并返回查询结果集中第一行的第一列

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

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

        /// <summary>
        /// 执行查询结果，返回第一行的第一列
        /// </summary>
        /// <param name="sql">要查询的SQL文本命令或存储过程名称</param>
        /// <param name="type">要执行的查询语句的类型，存储过程或SQL文本命令</param>
        /// <param name="sp">T-SQL语句或存储过程的参数数组</param>
        /// <returns>返回第一行的第一列</returns>
        public static object ExecuteScalar(string sql,CommandType type,SqlParameter [] sp)
        {
            try
            {
                object result = null;
                OpenConnection();
                SqlCommand command = new SqlCommand(sql,conn);
                command.CommandType = type;
                if (sp != null)
                {
                    foreach (SqlParameter parameter in sp)
                    {
                        command.Parameters.Add(parameter);
                    }
                }
                result = command.ExecuteScalar();
                return result;
            }
            catch (Exception ex)
            {
                throw new Exception("ExecuteScalar错误：" + ex);
            }
            finally
            {
                CloseConnection();
            }
        }
        #endregion

        #region ExecuteReader 执行查询，并返回一个 DataReader 对象

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

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

        /// <summary>
        /// 执行查询，并返回一个 DataReader 对象
        /// </summary>
        /// <param name="sql">要查询的SQL文本命令或存储过程名称</param>
        /// <param name="type">要执行的查询语句的类型，存储过程或SQL文本命令</param>
        /// <param name="sp">T-SQL语句或存储过程的参数数组</param>
        /// <returns>返回DataReader对象实例</returns>
        public static SqlDataReader ExecuteReader(string sql, CommandType type, SqlParameter[] sp)
        {
            try
            {
                OpenConnection();
                SqlCommand command = new SqlCommand(sql, conn);
                command.Parameters.Clear();
                if (sp != null)
                {
                    foreach (SqlParameter parameter in sp)
                    {
                        command.Parameters.Add(parameter);
                    }
                }
                SqlDataReader reader = command.ExecuteReader();
                return reader;
            }
            catch (Exception ex)
            {
                throw new Exception("ExecuteReader错误：" + ex);
            }
            finally
            {
                CloseConnection();
            }
        }

        #endregion
}

 　

作者： ForEvErNoME
出处： http://www.cnblogs.com/ForEvErNoME/
欢迎转载或分享，但请务必声明文章出处。如果文章对您有帮助，希望你能 推荐 或 关注