ADO数据库C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter
ADO数据库C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter
大家好，又见面了，我是你们的朋友全栈君。
用于执行增，删，改的方法，支持存储过程
1.ExecuteNonQuery
数据库连接字符串：
private readonly static string connectionString = ConfigurationManager.ConnectionStrings["MyConnection"].ToString();连接字符串，自满足，请用SqlHelper.connString赋值。
CommandType 命令类型，如果是sql语句，则为CommandType.Text,否则为 CommandType.StoredProcdure
cmdTextSQL语句或者存储过程名称 paraSQL参数，如果没有参数，则为null 返回值int受影响的行数
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()也可以执行sql语句。如果SQL语句是Select查询，则仅仅返回查询结果集中第一行第一列，而忽略其他行和列。如果SQL语句不是Select查询，则这个返回结果没任何作用。（建议查询数据库时使用） 由于不知道ｓｑｌ语句到底是什么样的结构（有可能是int，有可能是Char等其它，）所以ExecuteScalar（）方法返回一个最基本的类型Object，这个类型是所有类型的基类，可以转换为任意类型，所以所以用前需强制转换。一般用在插入语句后加上一个 select @@identity； 返回插入ID
2. GetScalar
二、
///
/// 执行查询的方法，支持存储过程
/// 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查询，则这个返回结果没任何作用。（建议查询数据库时使用） 由于不知道ｓｑｌ语句到底是什么样的结构（有可能是int，有可能是Char等其它，）所以ExecuteScalar（）方法返回一个最基本的类型Object，这个类型是所有类型的基类，可以转换为任意类型，所以用前需强制转换。
3. SqlDataReader
使用sqlDataReader时，链接必须是打开的；设置此参数后，关闭SqlDataReader时会自动关闭使用的连接（CommondBehavior.CloseConnection）
/// 执行查询的方法，支持存储过程
/// 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();
// 使用sqlDataReader时，链接必须是打开的；设置此参数后，关闭SqlDataReader时会自动关闭使用的连接（CommondBehavior.CloseConnection）
dr = cmd.ExecuteReader(CommandBehavior.CloseConnection);
return dr;注：1、ExecuteReader方法存在的目的:尽可能快的对数据库进行查询并得到结果
2、ExecuteReader 返回一个DataReader对象，如果在SqlCommand对象中调用，
则返回SqlDataReader，如果在OledbCommand对象中调用，返回的是OledbDataReader，可以调用DataReader的方法和属性迭代处理结果集。
4. GetDataSet
/// 执行查询的方法，支持存储过程
/// 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();
}
}发布者：全栈程序员栈长，转载请注明出处：https://javaforall.cn/151533.html原文链接：https://javaforall.cn
腾讯云开发者
