一、使用DataReader读取为对象List
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
|
/// <summary>
/// 获得数据列表List<>,DataReader 使用参数的
/// </summary>
/// <param
name
=
"strWhere"
>条件</param>
/// <param
name
=
"ht"
>HashTable,保存参数名及参数对应的值</param>
/// <
returns
>List<DotNet.Model.Base_Department></
returns
>
/// 使用方法：string str =
"id=@id"
;Hashtable ht = new Hashtable();ht.
Add
(
"@id"
, 10);
public
List<DotNet.Model.Base_Department> GetListUseDataReader(string strWhere, Hashtable ht=
null
)
{
StringBuilder strSql = new StringBuilder();
strSql.Append(
"Select Id,DepartmentName,NetCount,Remarks,CreatedOn,IsPublic,IsLock,SavedOn,LockVersion,Operator_Id from Base_Department"
);
if(strWhere.Trim().Length!=0)
{
strSql.Append(
" Where "
+ strWhere.Trim());
}
//获取DataReader
SqlDataReader reader;
//组织参数
if (ht !=
null
&& ht.
Count
> 0)
{
SqlParameter[] parameters = new SqlParameter[ht.
Count
];
int
i = 0;
foreach (DictionaryEntry dc
in
ht)
{
parameters[i] = new SqlParameter() ;
parameters[i].ParameterName = dc.
Key
.ToString();
parameters[i].Value = dc.Value;
i++;
}
reader = DbHelperSQL.ExecuteReader(strSql.ToString(), parameters);
}
else
reader = DbHelperSQL.ExecuteReader(strSql.ToString());
if (reader.HasRows)
{
List<DotNet.Model.Base_Department> list = new List<DotNet.Model.Base_Department>();
while (reader.
Read
())
{
DotNet.Model.Base_Department model = new DotNet.Model.Base_Department();
model.Id = reader.GetInt64(reader.GetOrdinal(
"Id"
));
model.DepartmentName = reader.GetString(reader.GetOrdinal(
"DepartmentName"
));
model.NetCount = reader.GetInt32(reader.GetOrdinal(
"NetCount"
));
model.Remarks = reader.GetString(reader.GetOrdinal(
"Remarks"
));
model.CreatedOn = reader.GetDateTime(reader.GetOrdinal(
"CreatedOn"
));
model.IsPublic = reader.GetBoolean(reader.GetOrdinal(
"IsPublic"
));
model.IsLock = reader.GetBoolean(reader.GetOrdinal(
"IsLock"
));
model.SavedOn = reader.GetDateTime(reader.GetOrdinal(
"SavedOn"
));
model.LockVersion = reader.GetInt32(reader.GetOrdinal(
"LockVersion"
));
model.Operator_Id = reader.GetInt64(reader.GetOrdinal(
"Operator_Id"
));
list.
Add
(model);
}
reader.
Close
();
return
list;
}
else
{
reader.
Close
();
return
null
;
}
}
|
二、使用DataReader对象读取数据
2.1 DataReader对象简介
DataReader对象又称数据阅读器，是DBMS所特有的，常用来检索大量的数据。DataReader对象是以连接的方式工作，它只允许以只读、顺向的方式查看其中所存储的数据，并在ExecuteReader方法执行期间进行实例化。
根据.NET Framework数据提供程序不同，DataReader也可以分成SqlDataReader、OleDbDataReader等。DataReader与底层数据库密切相联，它实际上是一个流式的DataSet。可以参照下一节的DataSet对象与之比较学习，下面我们将着重介绍SqlDataReader。
2.2 SqlDataReader对象常用属性
SqlDataReader对象常用属性如下：
| 属 性 |
说 明 |
| FieldCount |
获取当前行的列数 |
| RecordsAffected |
获取执行SQL语句所更改、添加或删除的行数 |
表1 SqlDataReader对象常用属性
2.3 常用属性
SqlDataReader对象的常用属性。
l FieldCount属性
获取DataReader对象中有几行数据，默认值为-1。如果未放在有效的记录集中，属性值则为0；否则为当前行中的列数。
l RecordsAffected属性
直到所有的行都被读取并且数据阅读器已经关闭时，才设置RecordsAffected属性，其默认值为−1。该属性的值是累积值。例如，如果以批处理模式插入3个记录，则RecordsAffected属性的值将为3。
SqlDataReader对象常用方法
SqlDataReader对象常用方法如下：
| 方 法 |
说 明 |
| Read |
使DataReader对象前进到下一条记录（如果有) |
| Close |
关闭DataReader对象。注意，关闭阅读器对象并不会自动关闭底层连接 |
| Get |
用来读取数据集的当前行的某一列的数据数据 |
表2 SqlDataReader对象常用方法
2.4 常用方法
SqlDataReader对象常用方法详解
l Read方法
语法：public override bool Read ()
返回值：如果存在多个行，则为True；否则为False。
DataReader对象中的Read()方法用来遍历整个结果集，不需要显示地向前移动指针，或者检查文件的结束，如果没有要读取的记录了，则Read方法会自动返回False。
注意：要使用SqlDataReader，必须调用SqlCommand对象的ExecuteReader()方法来创建，而不要直接使用构造函数。
SqlDataReader对象的应用
实例 使用SqlDataReader对象读取数据（源程序详见光盘中例6.6）
本示例主要讲解在ASP.NET应用程序中如何使用SqlDataReader对象读取数据库中的数据。执行程序，运行结果如图6.11所示：
图1 读取数据的结果图
程序实现的步骤：
（1）、新建一个网站，默认主页是Default.aspx。
（2）、在Web.Config文件中配置数据库连接字符串，在<configuration>下的子配置节<connectionStrings>添加连接字符串。
（3）、向Default.aspx页中添加一个label控件将其命名为lblStudent，在Page_Load中写下如下代码：
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
protected
void
Page_Load(
object
sender, EventArgs e)
{
if
(!IsPostBack)
{
SqlConnection myConn = GetConnection();
string
sqlStr =
"select * from tbStudent"
;
//查询所有学生信息的SQL
SqlCommand myCmd =
new
SqlCommand(sqlStr, myConn);
//创建Command对象
try
{
myConn.Open();
//执行SQL语句，并返回DataReader对象
SqlDataReader myDr = myCmd.ExecuteReader();
//显示标题文字
this
.lblStudent.Text = "   学号
    姓名
    性别
    班级
    系别<br>";
while
(myDr.Read())
//循环读取结果集
{
//读取数据库中的信息并显示在界面中
this
.lblStudent.Text +=myDr[
"sno"
].ToString().Trim()
+
"    "
+ myDr[
"sname"
].ToString().Trim()
+
"      "
+ myDr[
"ssex"
].ToString().Trim()
+
"    "
+ myDr[
"sclass"
].ToString().Trim()
+
"    "
+myDr[
"sdept"
].ToString().Trim()
+
"</br>"
;
}
myDr.Close();
//关闭DataReader
}
catch
{
Response.Write(
"连接失败！"
);
//异常处理
}
finally
{
myConn.Close();
//关闭数据库连接
}
}
}
|
参考文章
1. 雪夜, DataReader方式 获取数据.
2. 悠哲RHT, 使用DataReader对象读取数据.
