C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter和DataTable的使用
2014-12-16 20:52
786 查看
来自:http://blog.sina.com.cn/s/blog_6d60228f0101dg6i.html
一、数据库连接字符串
private readonly static string connectionString = ConfigurationManager.ConnectionStrings["MyConnection"].ToString(); //web.config中配置连接语句
二、ExecuteNonQuery:执行增,删,改的方法,支持存储过程
2、ExecuteScalar()也返回一个int型变量。如果SQL语句是Select查询,则仅仅返回查询结果集中第一行第一列,而忽略其他行和列。如果SQL语句不是Select查询,则这个返回结果没任何作用。(建议查询数据库时使用)。由于不知道SQL语句到底是什么样的结构(有可能是int,有可能是Char等其它,)所以ExecuteScalar()方法返回一个最基本的类型Object,这个类型是所有类型的基类,可以转换为任意类型,所以用前需强制转换。
三、GetScalar:执行查询的方法,支持存储过程
/// 参数1:命令类型,如果是sql语句,则为CommandType.Text,否则为 CommandType.StoredProcdure
/// 参数2:SQL语句或者存储过程名称
/// 参数3:SQL参数,如果没有参数,则为null
/// 返回:查询结果的第一行第一列
四、ExecuteReader:执行查询的方法,支持存储过程 /// 参数1:命令类型,如果是sql语句,则为CommandType.Text,否则为 CommandType.StoredProcdure /// 参数2:SQL语句或者存储过程名称 /// 参数3:SQL参数,如果没有参数,则为null /// 返回:读取器SqlDataReader
注:1、ExecuteReader方法存在的目的:尽可能快的对数据库进行查询并得到结果 2、ExecuteReader 返回一个DataReader对象,如果在SqlCommand对象中调用,则返回SqlDataReader;如果在OledbCommand对象中调用,返回的是OledbDataReader,可以调用DataReader的方法和属性迭代处理结果集。五、GetDataSet:执行查询的方法,支持存储过程 /// 参数1:命令类型,如果是sql语句,则为CommandType.Text,否则为CommandType.StoredProcdure
/// 参数2:SQL语句或者存储过程名称 /// 参数3:SQL参数,如果没有参数,则为null /// 返回:数据集
六、SqlDataReader与SqlDataAdapter+DataSet的区别
1、SqlDataReader //基于连接,只读访问,适合数据量较小。(连接模式)
SqlDataAdapter //基于非连接,适于数据量较大时,可以另行修改,最后再把修改结果返回给数据库。要求资源也大一点 (断开模式)
2、SqlDataAdapter 读取数据后将数据集放入DataSet,DataSet 的数据存在本地客服机内存。
3、SqlDataReader返回的是一个数据读写器,只能一条条的读,操作起来不灵活,一般在只读的时候才用到。
SqlDataAdapter返回的是数据集或者表,可以对其中的数据作任意操作
4、写法上不同:
(1)SqlDatReader执行前须先打开数据库,然后须生成一个command对象。再由command.ExecuteReader()方法赋值。完成后须手动关闭联接。
七、实例:
1、运用SqlDataReader 读取数据
八、DataTable的使用
http://holysonll.blog.163.com/blog/static/214139093201352011491680/
一、数据库连接字符串
private readonly static string connectionString = ConfigurationManager.ConnectionStrings["MyConnection"].ToString(); //web.config中配置连接语句
二、ExecuteNonQuery:执行增,删,改的方法,支持存储过程
/// 连接字符串,自满足,请用SqlHelper.connString赋值 /// 参数1:命令类型,如果是sql语句,则为CommandType.Text,否则为 CommandType.StoredProcdure /// 参数2:SQL语句或者存储过程名称 /// 参数3: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,这个类型是所有类型的基类,可以转换为任意类型,所以用前需强制转换。
三、GetScalar:执行查询的方法,支持存储过程
/// 参数1:命令类型,如果是sql语句,则为CommandType.Text,否则为 CommandType.StoredProcdure
/// 参数2:SQL语句或者存储过程名称
/// 参数3:SQL参数,如果没有参数,则为null
/// 返回:查询结果的第一行第一列
<pre name="code" class="html"> 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; } }
四、ExecuteReader:执行查询的方法,支持存储过程 /// 参数1:命令类型,如果是sql语句,则为CommandType.Text,否则为 CommandType.StoredProcdure /// 参数2:SQL语句或者存储过程名称 /// 参数3:SQL参数,如果没有参数,则为null /// 返回:读取器SqlDataReader
<pre name="code" class="html"> 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的方法和属性迭代处理结果集。五、GetDataSet:执行查询的方法,支持存储过程 /// 参数1:命令类型,如果是sql语句,则为CommandType.Text,否则为CommandType.StoredProcdure
/// 参数2:SQL语句或者存储过程名称 /// 参数3: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的区别
1、SqlDataReader //基于连接,只读访问,适合数据量较小。(连接模式)
SqlDataAdapter //基于非连接,适于数据量较大时,可以另行修改,最后再把修改结果返回给数据库。要求资源也大一点 (断开模式)
2、SqlDataAdapter 读取数据后将数据集放入DataSet,DataSet 的数据存在本地客服机内存。
3、SqlDataReader返回的是一个数据读写器,只能一条条的读,操作起来不灵活,一般在只读的时候才用到。
SqlDataAdapter返回的是数据集或者表,可以对其中的数据作任意操作
4、写法上不同:
(1)SqlDatReader执行前须先打开数据库,然后须生成一个command对象。再由command.ExecuteReader()方法赋值。完成后须手动关闭联接。
SqlCommand cmd = new SqlCommand("select * from stu", conn); conn.Open(); SqlDataReader rdr = cmd.ExecuteReader(); .................. conn.close();(2)SqlDataAdapter 执行时,自动打开数据库,且不用Command的ExecuteReader方法进行赋值,完成后自动断开联接。
SqlDataAdapter adptr = new SqlDataAdapter(sql, conn); DataSet ds = new DataSet(); adptr.Fill(ds, "stu");<span style="font-family: Arial, Helvetica, sans-serif; background-color: rgb(255, 255, 255);"> </span>
七、实例:
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(); } } }
八、DataTable的使用
http://holysonll.blog.163.com/blog/static/214139093201352011491680/
/// <summary> /// 获取车辆数据:车辆数和运力 /// </summary> /// <returns></returns> public IList<RoadTransData> GetVehicleData() { StringBuilder sb = new StringBuilder(); sb.Append(" select 'data1_Pass' as dataTitle, COUNT(*) as vehicleNum ,SUM(PassengerSeats) as apprLoadMass "); sb.Append(" from RT_VehiclePassenger A, RT_Vehicle V "); sb.Append(" where A.VehicleId = V.VehicleId and V.CertState =1 "); sb.Append(" UNION "); sb.Append(" select 'data2_Goods' as dataTitle, COUNT(*) as vehicleNum ,SUM(A.ApprLoadMass) as apprLoadMass "); sb.Append(" from RT_VehicleGoods A, RT_Vehicle V "); sb.Append(" where A.VehicleId = V.VehicleId and V.CertState =1 "); CommonService cs = new CommonService(); DataTable dt = cs.GetDataTableBySQL(sb.ToString()); IList<RoadTransData> lstRoadTransData = new List<RoadTransData>(); for (int i = 0; i < dt.Rows.Count; i++) { RoadTransData objRoadTransData = new RoadTransData(); objRoadTransData.RptName = dt.Rows[i][0].ToString(); objRoadTransData.Data1 = dt.Rows[i][1] == null ? 0 : Convert.ToDouble(dt.Rows[i][1].ToString()); objRoadTransData.Data2 = dt.Rows[i][2] == null ? 0 : Convert.ToDouble(dt.Rows[i][2].ToString()); lstRoadTransData.Add(objRoadTransData); } return lstRoadTransData; }
相关文章推荐
- C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter和DataTable的使用
- C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter应该怎么用
- C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter应该怎么用?
- C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter应该怎么用?
- C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter应该怎么用?
- sql 查询语法汇总(二)ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter
- SqlDataReader的conn关闭问题(mysqldatareader),以及 ExecuteNonQuery,ExecuteScalar,ExecuteReader,SqlDataAdapter哪些需要conn.open
- 源码: C#操作SQL数据库 SQLDataReader/SQLDataAdapter/DataSet/DataTable
- C#实现SQL全库检索数据-比较使用DataReader与DataAdapter+Datatable效率,差距惊人!
- .Net调用存储过程(有传入、传出、返回值、记录集)及SqlDataAdapter、ExecuteNonQuery、SqlDataReader、ExecuteScalar
- .Net调用存储过程(有传入、传出、返回值、记录集)及SqlDataAdapter、ExecuteNonQuery、SqlDataReader、ExecuteScalar
- .Net调用存储过程(有传入、传出、返回值、记录集)及SqlDataAdapter、ExecuteNonQuery、SqlDataReader、ExecuteScalar
- C#中ExecuteReader、ExecuteNonQuery、ExecuteScalar、SqlDataReader、SqlDataAdapter应该怎么用?
- c# sqladapter 与sqldataReader
- 收录的 SqlDataReader,ExecuteNonQuery ,ExecuteScalar,DataSet 例子
- DataSet、SqlDataAdapter、SqlCommand、ExecuteNonQuery、SqlDataReader
- sqldataReader,sqldataAdapter,DataSet的使用
- C#中使用ExecuteReader, ExecuteNonQuery, ExecuteScalar
- C# 使用SqlDataReader 注意问题
- ADO.NET访问数据库-SqlCommand的ExecuteReader方法一般配合sqldatareader使用