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();
}
}
查询结果:
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();
}
}
查询结果:
1.创建Connection对象 2.组合Select类型的sql语句 3.创建Command对象,并封装Connection和sql语句 4.打开连接 5.执行ExecuteReader()方法,返回DataReader对象 6.逐行读取查询结果 7.跳转下一结果集 8.逐行读取查询结果 9.关闭读取器 10.关闭连接