C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter应该怎么用?

对于C#初学者来说,我们通常遇到ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter这些对象或者方法的时候就开始犯晕,不知道哪个对象适合用增删改,哪个对象适合查询的时候用,本人通过 网上搜索和个人的一些理解,整理了一下,有错误的地方希望大家能给出指正。

一、
//数据库连接字符串
    private readonly static string connectionString =      ConfigurationManager.ConnectionStrings["MyConnection"].ToString();

///
    /// 执行增,删,改的方法,支持存储过程
    ///
    /// 连接字符串,自满足,请用SqlHelper.connString赋值
    /// 命令类型,如果是sql语句,则为CommandType.Text,否则为   CommandType.StoredProcdure
    /// SQL语句或者存储过程名称
    /// SQL参数,如果没有参数,则为null
    /// 受影响的行数
    public static int ExecuteNonQuery(CommandType commandType, string cmdText, params  SqlParameter[] para)
    {
        using (SqlConnection conn = new SqlConnection(connectionString))
        {
            SqlCommand cmd = new SqlCommand();
            cmd.Connection = conn;
            cmd.CommandType = commandType;
            cmd.CommandText = cmdText;
            if (para != null)
            {
                cmd.Parameters.AddRange(para);
            }
            conn.Open();
            return Convert.ToInt32(cmd.ExecuteNonQuery());
        }
    }
注:1、ExecuteNonQuery()执行命令对象的SQL语句,返回一个int 类型的变量,返回数据库操作之后影响的行数。适合用来验证对数据库进行增删改的情况。

2、ExecuteScalar()也返回一个int型变量。如果SQL语句是Select查询,则仅仅返回查询结果集中第一行第一列,而忽略其他行和列。如果SQL语句不是Select查询,则这个返回结果没任何作用。(建议查询数据库时使用)  由于不知道sql语句到底是什么样的结构(有可能是int,有可能是Char等其它,)所以ExecuteScalar()方法返回一个最基本的类型Object,这个类型是所有类型的基类,可以转换为任意类型,所以所以用前需强制转换。

二、

///

/// 执行查询的方法,支持存储过程

/// SQL参数,如果没有参数,则为null

/// 返回查询结果的第一行第一列

public static object GetScalar(CommandType commandType, string cmdText, params SqlParameter[] para)

{

object result = null;

using (SqlConnection conn = new SqlConnection(connectionString))

{

SqlCommand cmd = new SqlCommand();

cmd.Connection = conn;

cmd.CommandType = commandType;

cmd.CommandText = cmdText;

if (para != null)

{

cmd.Parameters.AddRange(para);

}

conn.Open();

result = cmd.ExecuteScalar();

}

return result;

}

}

注:ExecuteScalar()也返回一个int型变量。如果SQL语句是Select查询,则仅仅返回查询结果集中第一行第一列,而忽略其他行和列。如果SQL语句不是Select查询,则这个返回结果没任何作用。(建议查询数据库时使用)  由于不知道sql语句到底是什么样的结构(有可能是int,有可能是Char等其它,)所以ExecuteScalar()方法返回一个最基本的类型Object,这个类型是所有类型的基类,可以转换为任意类型,所以用前需强制转换。

三:

///

/// 执行查询的方法,支持存储过程

/// SQL参数,如果没有参数,则为null

/// 读取器SqlDataReader

public static SqlDataReader ExecuteReader(CommandType commandType, string cmdText, params SqlParameter[] para)

{

SqlConnection conn = new SqlConnection(connectionString);

SqlDataReader dr = null;

SqlCommand cmd = new SqlCommand();

cmd.Connection = conn;

cmd.CommandType = commandType;

cmd.CommandText = cmdText;

if (para != null)

{

cmd.Parameters.AddRange(para);

}

conn.Open();

dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);

return dr;

注:1、ExecuteReader方法存在的目的:尽可能快的对数据库进行查询并得到结果

2、ExecuteReader 返回一个DataReader对象,如果在SqlCommand对象中调用,

则返回SqlDataReader,如果在OledbCommand对象中调用,返回的是OledbDataReader,可以调用DataReader的方法和属性迭代处理结果集。

四:

///

/// 执行查询的方法,支持存储过程

/// SQL语句或者存储过程名称

/// SQL参数,如果没有参数,则为null

/// 数据集

public static DataSet GetDataSet(CommandType commandType, string cmdText, params SqlParameter[] para)

{

using (SqlConnection conn = new SqlConnection(connectionString))

{

SqlDataAdapter da = new SqlDataAdapter();

da.SelectCommand = new SqlCommand();

da.SelectCommand.Connection = conn;

da.SelectCommand.CommandText = cmdText;

da.SelectCommand.CommandType = commandType;

if (para != null)

{

da.SelectCommand.Parameters.AddRange(para);

}

DataSet  ds = new DataSet();

conn.Open();

da.Fill(ds);

return ds;

}

}

SqlDataReader与SqlDataAdapter+DataSet的区别

一,SqlDataReader //基于连接,只读访问 适合数据量较小。(连接模式)

SqlDataAdapter //基于非连接,适于数据量较大时,可以另行修改,最后再把修改结果返回给数据库。要求资源也大一点  (断开模式)

二,SqlDataAdapter 读取数据后将数据集放入DataSet ,DataSet 的数据存在本地客服机内存。

三,SqlDataReader返回的是一个数据读写器,只能一条条的读,操作起来不灵活,一般在只读的时候才用到。

SqlDataAdapter返回的是数据集或者表,可以对其中的数据作任意操作

四,写法上不同:

SqlDatReader执行前须先打开数据库,然后须生成一个command对象。再由command.ExecuteReader()方法赋值。完成后须手动关闭联接。

SqlCommand cmd = new SqlCommand("select * from stu", conn);

conn.Open();

SqlDataReader rdr = cmd.ExecuteReader();

。。。。。

conn.close();

SqlDataAdapter 执行时,自动打数据库,且不用Command的ExecuteReader方法进行赋值,完成后自动断开联接。

SqlDataAdapter adptr = new SqlDataAdapter(sql, conn);

DataSet ds = new DataSet();

adptr.Fill(ds, "stu");

实例:

1,运用SqlDataReader 读取数据

class DataReader

{

static void Main()

{

string str = "server=localhost;uid=sa;pwd=123;database=northwind";

SqlConnection conn = new SqlConnection(str);

SqlCommand cmd = new SqlCommand("select * from stu", conn);

conn.Open();

SqlDataReader rdr = cmd.ExecuteReader();

DataTable table=new Datable();

table.Load(rdr);

rdr.Close();

conn.Close();

}

2,运用SqlDataAdapter +DataSet 读取修改数据

class SqlDataAdapter

{

static void Main()

{

string str = "server=localhost;uid=sa;pwd=123;database=northwind";

SqlConnection conn = new SqlConnection(str);

string sql = "select * from stu";

SqlDataAdapter adptr = new SqlDataAdapter(sql, conn);//Adepter对象

DataSet ds = new DataSet();//DataSet对象

adptr.Fill(ds, "stu");//填充DataSet 并为当前表命名

DataTableReader rdr = ds.CreateDataReader();

while (rdr.Read())//读取表中数据

{

for (int i = 0; i < rdr.FieldCount; i++)

{

Console.Write(rdr.GetName(i) + "\t" + rdr.GetValue(i) + "\t");

}

Console.WriteLine();

}

}

参考链接:
 http://blog.163.com/[email protected]/blog/static/1314263812009111381920187/
 由于小宁博主对

SqlDataReader与SqlDataAdapter+DataSet的区别

总结的很到位,所以就把他的文章整体粘贴下来了

原文地址:https://www.cnblogs.com/zhangruifeng/p/9349559.html

时间: 2024-11-13 09:49:26

C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter应该怎么用?的相关文章

ExecuteNonQuery(),ExecuteScalar(),ExecuteReader的用法的区别

关于MyCommand的ExecuteNonQuery(),ExecuteScalar(),ExecuteReader方法的区别: 1.ExecuteNonQuery():执行SQL,返回一个整型变量,如果SQL是对数据库的记录进行操作,那么返回操作影响的记录条数,如果是SQL="CREATE TABLE LookupCodes (code_id smallint IDENTITY(1,1) PRIMARY KEY CLUSTERED, code_desc varchar(50) NOT NUL

C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter的区别

ExecuteNonQuery()执行命令对象的SQL语句,返回一个int 类型的变量,返回数据库操作之后影响的行数.适合用来验证对数据库进行增删改的情况. 2.ExecuteScalar()也可以执行sql语句.如果SQL语句是Select查询,则仅仅返回查询结果集中第一行第一列,而忽略其他行和列.如果SQL语句不是Select查询,则这个返回结果没任何作用.(建议查询数据库时使用) 由于不知道sql语句到底是什么样的结构(有可能是int,有可能是Char等其它,)所以ExecuteScala

如果分配给命令的连接位于本地挂起事务中,ExecuteNonQuery 要求命令拥有事务。命令的 Transaction 属性尚未初始化

在 System.Data.OleDb.OleDbConnectionInternal.ValidateTransaction(OleDbTransaction transaction, String method) 在 System.Data.OleDb.OleDbConnection.ValidateTransaction(OleDbTransaction transaction, String method) 在 System.Data.OleDb.OleDbCommand.Validat

理解SQL Server是如何执行查询的 (1/3)

查询执行的总图: 根据总图的流程,详细说明每个部分: 1. 请求(Request) SQL Server是C/S架构的平台.与它交互的唯一方式就是发送包含数据库命令的请求.应用程序和数据库之前的通信协议叫做TDS(Tabular Data Stream)协议.应用程序可以使用以下几种实现了TDS协议的客户端: The CLR managed SqlClient, OleDB, ODBC, JDBC, PHP Driver for SQL Server 开源的FreeTDS TDS的请求分为以下几

Understanding how SQL Server executes a query

https://www.codeproject.com/Articles/630346/Understanding-how-SQL-Server-executes-a-query https://www.codeproject.com/Articles/732812/How-to-analyse-SQL-Server-performance This article will help you write better database code and will help you get st

sql是如何执行一个查询的!

引用自:http://rusanu.com/2013/08/01/understanding-how-sql-server-executes-a-query/ Understanding how SQL Server executes a query August 1st, 2013 If you are a developer writing applications that use SQL Server and you are wondering what exactly happens

ADO.NET中COMMAND对象的ExecuteNonQuery、ExcuteReader和ExecuteScalar方法

1.ExecuteNonQuery方法.该方法执行更新操作,即与UPDATE.INSERT.DELETE等语句有关的操作,在这种情况下,返回值是命令影响的行数.对其他语句,如SET或CREATE,则返回-1,如果发生回滚,返回值也是-1. 2.ExcuteReader方法.它与查询命令一起使用,返回一个数据阅读器对象SqlDataReader类的一个实例.该方法执行更新语句,执行成功后,不会返回任何受影响的数据行. 3.ExecuteScalar方法.如果只想检索数据库信息中的已个值,而不需要返

浅谈ADO.NET中的对象——Connection、Command、DataReader、DataAdapter、DataSet、DataTable

可能是当初没有好好总结的缘故,学习.NET以来,对ADO.NET中的对象一直有些模糊,今天重新回顾了一下,通过查资料,总结,结合自己的观点整理一下ADO.NET中Connection.Command.DataReader.DataAdapter. DataSet.DataTable这几个对象的相关知识,希望对初学者能起到一个全局把控的作用,希望大牛能留下宝贵的指导意见. 以下的例子仅以连接 SQL Server数据库为例,所以分别以SqlConnection.SqlCommand.SqlData

如何在Asp.net中备份Access数据库?

public   void   Create(   string   mdbPath   ) { if(   File.Exists(mdbPath)   )   //检查数据库是否已存在 { throw   new   Exception( "目标数据库已存在,无法创建 "); } //   可以加上密码,这样创建后的数据库必须输入密码后才能打开 mdbPath   =   "Provider=Microsoft.Jet.OLEDB.4.0;Data   Source= &