DataReader读取数据的原理
DataReader读取数据数据采用循环的方式检查并读取数据,数据是一条一条被拿出的。
一、单个结果集的查询
class Program
{
static void Main(string[] args)
{
//定义连接字符串
string connString = "Server=.;DataBase=StudentManageDB;Uid=sa;Pwd=admin";
//创建连接对象
SqlConnection conn = new SqlConnection(connString);
string sql = "select StudentId,StudentName,Gender from Students";
SqlCommand sqlCommand = new SqlCommand(sql,conn);
//打开连接
conn.Open();
//执行查询方法,返回DataReader对象
SqlDataReader objRader = sqlCommand.ExecuteReader();
//读取数据
while (objRader.Read())
{
Console.WriteLine(objRader["StudentId"].ToString()+"\t"+objRader["StudentName"].ToString() + "\t" + objRader["Gender"].ToString() + "\t");
}
//关闭读取器
conn.Close();
Console.ReadKey();
}
}
查询结果:
ExecuteReader()方法基本步骤
1.创建Connection对象
2.组合Select类型的sql语句
3.创建Command对象,并封装Connection和sql语句
4.打开连接
5.执行ExecuteReader()方法,返回DataReader对象
6.逐行读取查询结果
7.关闭读取器
8.关闭连接
二、多个结果集的查询(单个结果集)
class Program
{
static void Main(string[] args)
{
//定义连接字符串
string connString = "Server=.;DataBase=StudentManageDB;Uid=sa;Pwd=admin";
//创建连接对象
SqlConnection conn = new SqlConnection(connString);
string sql = "select StudentId,StudentName,Gender from Students;Select ClassId,ClassName from StudentClass";
SqlCommand sqlCommand = new SqlCommand(sql,conn);
//打开连接
conn.Open();
//执行查询方法,返回DataReader对象
SqlDataReader objRader = sqlCommand.ExecuteReader();
//读取数据
while (objRader.Read())
{
Console.WriteLine(objRader["StudentId"].ToString()+"\t"+objRader["StudentName"].ToString() + "\t" + objRader["Gender"].ToString() + "\t");
}
Console.WriteLine("---------------------");
//判断是否有下一个结果集,跳转结果集
if (objRader.NextResult())
{
while (objRader.Read())
{
Console.WriteLine(objRader["ClassId"].ToString() + "\t" + objRader["ClassName"].ToString() + "\t" );
}
}
//关闭读取器
conn.Close();
Console.ReadKey();
}
}
查询结果:
ExecuteReader()方法基本步骤(多个结果集)
1.创建Connection对象
2.组合Select类型的sql语句
3.创建Command对象,并封装Connection和sql语句
4.打开连接
5.执行ExecuteReader()方法,返回DataReader对象
6.逐行读取查询结果
7.跳转下一结果集
8.逐行读取查询结果
9.关闭读取器
10.关闭连接