Connection 物件
Connection 对象主要是开启程序和数据库之间的连结。没有利用连结对象将数据库打开，是无法从数据库中取得数据的。这个物件在ADO.NET 的最底层，我们可以自己产生这个对象，或是由其它的对象自动产生。
Command 物件
Command 对象主要可以用来对数据库发出一些指令，例如可以对数据库下达查询、新增、修改、删除数据等指令，以及呼叫存在数据库中的预存程序等。这个对象是架构在Connection 对象上，也就是Command 对象是透过连结到数据源
DataAdapter 物件
DataSetCommand 对象主要是在数据源以及DataSet 之间执行数据传输的工作，它可以透过Command 对象下达命令后，并将取得的数据放入DataSet 对象中。这个对象是架构在Command对象上，并提供了许多配合DataSet 使用的功能。在Beta 2 版中DataSetCommand 物件会更名为DataAdapter。
DataSet 物件
DataSet 这个对象可以视为一个暂存区（Cache），可以把从数据库中所查询到的数据保留起来，甚至可以将整个数据库显示出来。DataSet 的能力不只是可以储存多个Table 而已，还可以透过DataSetCommand 对象取得一些例如主键等的数据表结构，并可以记录数据表间的关联。DataSet 对象可以说是ADO.NET 中重量级的对象，这个对象架构在DataSetCommand 对象上，本身不具备和数据源沟通的能力；也就是说我们是将DataSetCommand 对象当做DataSet 对象以及数据源间传输数据的桥梁。
DataReader 物件
当我们只需要循序的读取数据而不需要其它操作时，可以使用DataReader 对象。DataReader对象只是一次一笔向下循序的读取数据源中的数据，而且这些数据是只读的，并不允许作其它的操作。因为DataReader 在读取数据的时候限制了每次只读取一笔，而且只能只读，所以使用起来不但节省资源而且效率很好。使用DataReader 对象除了效率较好之外，因为不用把数据全部传回，故可以降低网络的负载。
ADO.NET 使用Connection 对象来连接数据库，使用Command 或DataAdapter对象来执行SQL语句，并将执行的结果返回给DataReader 或 DataAdapter ,然后再使用取得的DataReader 或DataAdapter 对象操作数据结果
6.2.1 Connection 对象
建立Connection 对象的代码：
OLEDB: OleDbConnection MyConnection=new OleDbConnection();
SQL: SqlConnection MyConnection=new SqlConnection();
◆他们的ConnectionString属性：获取或设置连接语句。 MyConnection.ConnectionString="server=(local);database=pubs;uid=sa;pwd=''";
◆DataBase 属性：获取当前打开数据库
◆DataSource属性：获取打开数据库的连接实例
◆Open 方法：打开连接
◆Close 方法：关闭连接
6.2.2 Command与DataReader 对象
Command 对象中包含了提交数据库系统的访问信息。OleDbCommand 与SqlCommand 对象，它们的基本对象和操作方法是相同的,在此介绍OleDbCommand的用法，SqlCommand的用法类推即可.
如： OleDbCommand myComm = new OleDbCommand(strQuery,myConnection);
第一个参数是sql语句或存储过程名，第二个参数是前面的Connection 对象的实例
Command 对象的只要的属性和方法有：
◆Connection 属性：设置或获取 Command对象使用的Connection 对象实例
◆CommandText 属性：设置或获取需要执行的sql语句或存储过程名
◆CommandType 属性：设置或获取执行语句的类型。它有3个属性值:StoredProceduce(存储过程) TableDirect Text(标准的SQL语句) 默认是Text
◆Parameters 属性：取得参数值集合
◆ExecuteReader 方法：执行CommandText指定的SQL语句或存储过程名，返回值类型为DataReader
◆ExecuteNonQuery 方法：与ExecuteReader 功能相同，只是返回值为执行sql语句或存储过程受影响的记录行数
DataReader 的主要属性和方法有：
◆FieldCount 属性：显示当前数据记录的字段总和
◆IsClosed 属性： 判断DataReader 对象是否已经关闭
◆Close 方法：关闭DataReader 对象
◆GetString方法：以String类型返回指定列中的值
◆Getvalue 方法：以自身的类型返回指定列中的值
◆Getvalues 方法：返回当前记录所有字段的集合
◆Read 方法：将“光标”指向DataReader对象的下一记录
Sql连接实例：
<%@ Import Namespace="System.Data" %>
<%@ Import Namespace="System.Data.SqlClient" %>
<script language="C#" runat="server">
void Page_Load(Object sender, EventArgs e) {
SqlConnection Conn=new SqlConnection();
Conn.ConnectionString="server=(local);database=pubs;uid=sa;pwd=''";
Conn.Open();
SqlCommand Comm=new SqlCommand("select * from Authors ",Conn);
SqlDataReader dr=Comm.ExecuteReader();
dg.DataSource=dr;
dg.DataBind();
Conn.Close();
}
</script>
<asp:DataGrid id="dg" runat="server" />
Aeccess 数据库连接实例 （OleDbCommand 和 OleDbDataReader 使用实例）
<%@ Page Language="C#" %>
<%@ Import Namespace="System.Data"%>
<%@ Import Namespace="System.Data.OleDb"%>
<script Language="C#" Runat="Server">
OleDbDataReader dr;
public void Page_Load(Object src,EventArgs e)
{
string
myConnstring="provider=Microsoft.Jet.OLEDB.4.0; Data
Source="+Server.MapPath(".")+"..\\DataBase\\db2.mdb;";
string strSel="Select * from BookMark";
OleDbConnection myConn= new OleDbConnection
(myConnstring);
OleDbCommand myComm=new OleDbCommand(strSel,myConn);
myComm.Connection.Open();
dr=myComm.ExecuteReader();
dg.DataSource=dr;
dg.DataBind();
myConn.Close();
}
</script>
<html>
<body>
<form Runat="Server">
<asp:DataGrid id="dg" runat="server" />
</form>
</body>
</html>
++++++++++++++++++++++++++++++++++++++++++++++++
++++++++++++++++++++++++++++++++++++++++++++++++
6.3.3 DataSet 与DataAdapter
DataReader 对象只能实现对数据的读取，不能完成其他的操作
DO.NET提供一款更强大的数据操作对象――DataSet 可以将DataSet看成一个非连接的数据库，因为DataSet的内部存储结构与数据库很类似，拥有数据表（DataTable）数据表关联（DataRelation）。DataSet中可以存储多张表等。DataSet拥有类似于数据库的结构，但它并不等同于数据库。首先他可以存储来自数据库的数据，而且还可以存储其他格式的数据，比如 XML格式文档；
1.查询数据
讲到DataSet的数据库应用，先要了解ADO.NET中的另一个对象DataAdapter .
它也分为SqlDataAdapter 和OleDbDataAdapter
建DataAdapte:
OleDbDataAdapter MyAdapter=new OleDbDataAdapter();
SqlDataAdapter MyAdapter=new SqlDataAdapter();
取得的DataAdapter 对象时必须赋予一个连接对象：
MyAdapter.SelectCommand.Connection = MyConn; 或
MyAdapter.UpdateCommand.Connection =Myconn; 或
MyAdapter.DeleteCommand.Connection = MyConn; 或
MyAdapter.InsertCommand.Connection =Myconn;
如果需要执行SQL语句，那么还必须给相应的CommandText 属性赋值。代码为：
MyAdapter.*Command.CommandText = SQL语句；
写这么多行代码似乎有些麻烦，如果你只是查询数据库，则可以在建立 DataAdapter实例时就完成上述工作。
OleDbDataAdapter MyAdapter = new OleDbDataAdapter(strSelect,objConnection);
<%@ Page Language="C#" Runat="Server"%>
<%@ Import Namespace="System.Data"%>
<%@ Import Namespace="System.Data.OleDb"%>
<script Language="C#" Runat="Server">
public void Page_Load(Object src,EventArgs e)
{
string
MyConnString="Provider=Microsoft.Jet.OLEDB.4.0;Data
Source="+Server.MapPath(".")+"\\DataBase\\db3.mdb;";
string strSel="select * from Score";
//建立一个DataSet 实例
DataSet ds=new DataSet();
OleDbConnection MyConn= new OleDbConnection(MyConnString);
OleDbDataAdapter MyAdapter = new OleDbDataAdapter(strSel,MyConn);
MyAdapter.Fill(ds,"Score");
dg1.DataSource=ds.Tables["Score"].DefaultView;
dg1.DataBind();
}
</script>
<asp:DataGrid id="dg1" runat="Server"
Headerstyle-BackColor="#aaaadd"
AlternatingItemstyle-BackColor="#eeeeee"
/>
将DataAdapter 于 DataSet 相联系的是 DataAdapter 对象的 Fill 方法。他有很多中用法: MyDataAdapter.Fill(DataSet) MyDataAdapter.Fill(DataSet,TableName)
MyDataAdapter.Fill(DataSet, StartRow , RowsCount, TableName)
DataSet 绑定至 DataGrid 控件显示:
1.dg1.DataSource= ds.Tables[“Score”].DefaultView;
dg1.DataBind();
2.dg1.DataSource=ds;
dg1.DataMember=”Score”;
dg1.DataBind();
提示: DataSet中的各种集合,访问子项有两种方法,一种是用子项的名,一种是用数字索引.比如要访问表”Score”,可以用: DataSet.Tables[0] 访问 (多张表依次类推)
2. 插入数据: DataSet 的结构和数据库相似,所有插入数据实质上就是在DataSet 的数据表里插入一行(DataRow)
//新建一行
DataRow dr= ds.Tables[“Score”].NewRow();
dr. [“Name”] = “addme”;
dr. [“class”] =”201”;
ds.Tables[“Score”].Rows.Add(dr); //将新建的行加到DataTable 的DataRow集合中
这样对DataSet的操作仅仅是在DataSet中执行,并不影响数据库中的数据,要使用DataAdapter 的 Update 方法(有多种方法).
1. DataAdapter.Update(DataSet) ; 2. DataAdapter.Update(DataSet, TableName);
3.更新数据: 实际就是在DataSet 数据行上面直接修改数据
DataRow dr = ds .Tables[“Score”].Rows[0]; //取出第一行
dr. [“Name”] = “比尔”; //修改
dr. [“class”] =”201”;
如果要更新数据库,则再调用 Update 方法
4.删除数据: 找到相应的数据行,然后删除
DataRow dr =ds.Tables[“Score”].Row[0]; dr.Delete();
注意: DataAdapter 对象在数据发生改变时,并不能自动产生数据库系统所需的交易sql语句,所有要建立一个CommandBuilder 对象 它能自动产生交易的sql语句.
OleDbCommandBuilder custcb = new OleDbCommandBuilder(MyAdapter);
5.DataSet 的其他特征
DataSet 、DataTable 和DataRow 都有一个十分有用的方法----RejectChanges,
它时操作对象拒绝已经发生的改变,将数据复原.该方法于AcceptChanges HasErrors等属性连用非常有用.
If (DataSet.HasErrors)
{
DataSet.RejectChanges();
}
else
{
DataSet.AcceptChanges();
在前面一讲中，我们应该已经熟悉了如何使用DataAdapter对象来进行数据更新（在前面一篇如何处理出错里面写了一个简单的例子），下面我们先进行一下总结，然后再讲解一下通过Command对象如何更新数据。
一、通过DataAdpater对象的Update方法
DataAdapter对象的update方法可以调用来讲Dataset中的更改解析回数据源。其工作原理本质上还是通过执行所引用的Command对象进行更新的。当调用Update方法的时候，DataAdpater将分析出已经发生的变化，并执行相应的命令（insertCommand、updateCommand或者deleteCommand）。因此，要提供性能，就要尽可能的显示设置DataAdpater的命令。
当然，如果DataTable映射到单个数据表上，或者它是由单个表填充生产的，也可以利用CommandBuilder对象自动生成DataAdapter的DeleteCommand、InsertCommand和UpdateCommand。其方法是：先生成SqlCommandBuilder对象：SqlCommandBuilder scb=new SqlCommandBuilder(sqlDataAdpater);这样，就能够自动通过CommandBuilder来设置适配器sqlDataAdapter的命令形式：类似于sqlDataAdpter.UpdateCommand=scb.getUpdateCommand() 。
如果使用OleDb、Odbc、Oracle连接数据库，只需要做相应的调整就行了。
在使用CommandBuilder为DataAdapter生成Command命令更新数据源时，需要注意以下事项：
1、SelectCommand使用的select命令中必须包含主键（其实在数据表中如果声明了主键即可）
2、填充数据集时，必须要加载主键。方法如下：
da.Fill(ds, "dataTableName");
ds.Tables["dataTableName"].PrimaryKey=new DataColumns[]{ds.Tables["dataTableName"].Columns["ColulmnsName"]};
或者也可以这么做：
da.FillSchema(ds, SchemaType.Source, "dataTableName"); //加载表结构
da.Fill(ds, "dataTableName"); //加载表数据
3、DataAdapter的MissingSchemaAction属性设置为AddWithKey
4、更新数据源成功后，使用ds的Acceptchanges方法，更新数据集。
二、通过Command对象进行更新
下面举个使用适配器进行数据更新的例子。
首先，为了不破坏了SQL2005上原有的示例数据库的数据，我们先使用“select * into salesreason from sales.salesreason”，将sales.salesreason表复制一份到dbo.salesreson中去。然后就对dbo.salesreson进行操作。下面是界面设计图。
几个控件：customerid后面的的文本框 textBox1，下面分别是textBox2、textBox3以及右下角的textBox4.
几个按钮：“数据插入”名为button1，下面依次是button2、button3；“< <”是button4，右边依次是5/6/7
“查找”是button8.
下面是详细代码：
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;
using System.Drawing;
using System.Text;
using System.Windows.Forms;
using System.Data.SqlClient;
namespace WindowsApplication1
{
public partial class Form1 : Form
{
int i = 0; //用i来确定其坐在数据表的行号。一开始时i=0，则是表中的第一行
DataSet ds;
SqlDataAdapter sda;
string strcon = "Data Source=localhost; Initial Catalog=adventureWorks; Integrated Security=sspi";
string strsql = "select SalesReasonID,name,ReasonType from dbo.SalesReason";
SqlConnection scon;
public Form1()
{
InitializeComponent();
}
private void Form1_Load(object sender, EventArgs e)
{
scon = new SqlConnection(strcon);
}
public void show(int i)
{
if (ds != null)
{
ds.Clear();
}
else
{
ds = new DataSet();
sda = new SqlDataAdapter(strsql,strcon);
}
sda.Fill(ds, "SalesReason");
textBox1.Text = ds.Tables["SalesReason"].Rows[i]["SalesReasonID"].ToString();
textBox2.Text = ds.Tables["SalesReason"].Rows[i]["Name"].ToString();
textBox3.Text = ds.Tables["SalesReason"].Rows[i]["ReasonType"].ToString();
}
private void button4_Click(object sender, EventArgs e)
{
i = 0;
show(i);
}
private void button5_Click(object sender, EventArgs e)
{
if (i != 0)
{
i--;
show(i);
}
else
MessageBox.Show("已经是第一条记录了");
}
private void button6_Click(object sender, EventArgs e)
{
if (i < ds.Tables["SalesReason"].Rows.Count - 1)
{
i++;
show(i);
}
else
MessageBox.Show("已经是最后一条记录了");
}
private void button7_Click(object sender, EventArgs e)
{
i=ds.Tables["SalesReason"].Rows.Count - 1;
show(i);
}
private void button8_Click(object sender, EventArgs e)
{
int k = 0;//用来确定要查找记录的下标
if (textBox4.Text.Trim() == "")
{
MessageBox.Show("查找内容不能为空");
}
else
{
for (k = 0; k < ds.Tables["SalesReason"].Rows.Count; k++)
{
if (ds.Tables["SalesReason"].Rows[k]["SalesReasonID"].ToString() == textBox4.Text)
{//找到了和textBox4中的id号相匹配的记录了，其行号为k
i = k;
show(i);
break;
}
}
}
if (k == ds.Tables["SalesReason"].Rows.Count)
MessageBox.Show("无此客户信息");
textBox4.Text = "";
}
private void button1_Click(object sender, EventArgs e)
{
SqlCommand sqlcmd = new SqlCommand("select count(*) from sales.SalesReason where SalesReasonID='" + textBox1.Text + "'", scon);
sqlcmd.Connection.Open();
int a = (int)sqlcmd.ExecuteScalar();//返回源表中与输入的客户id相等的个数
sqlcmd.Connection.Close();
if (a > 0)
{
MessageBox.Show("此客户已经存在，请重新插入");
return;
}
ds.Clear();
sda.Fill(ds, "SalesReason");
ds.Tables["SalesReason"].PrimaryKey = new DataColumn[] { ds.Tables["SalesReason"].Columns["SalesReasonID"] };
SqlCommandBuilder sqlCommandBuilder1 = new SqlCommandBuilder(sda);
DataRow dr = ds.Tables["SalesReason"].NewRow();
dr["SalesReasonID"] = Int32.Parse(textBox1.Text);
dr["name"] = textBox2.Text;
dr["ReasonType"] = textBox3.Text;
ds.Tables["SalesReason"].Rows.Add(dr);
sda.Update(ds, "SalesReason");
ds.AcceptChanges();
MessageBox.Show("数据插入成功");
}
private void button2_Click(object sender, EventArgs e)
{
for (int j = 0; j < ds.Tables["SalesReason"].Rows.Count; j++)
{
if (ds.Tables["SalesReason"].Rows[j]["SalesReasonID"].ToString() == "" &&
ds.Tables["SalesReason"].Rows[j]["SalesReasonID"].ToString() != ds.Tables["SalesReason"].Rows[i]["SalesReasonID"].ToString())
{
MessageBox.Show("此SalesReasonid已经存在，请重新输入");
textBox1.Text = "";
return;
}
}
ds.Clear();
sda.Fill(ds, "SalesReason");
ds.Tables["SalesReason"].PrimaryKey = new DataColumn[] { ds.Tables["SalesReason"].Columns["SalesReasonID"] };
SqlCommandBuilder sqlCommandBuilder1 = new SqlCommandBuilder(sda);
ds.BeginInit(); //挂起修改数据
ds.Tables["SalesReason"].Rows[i]["SalesReasonID"] = Int32.Parse(textBox1.Text);
ds.Tables["SalesReason"].Rows[i]["Name"] = textBox2.Text;
ds.Tables["SalesReason"].Rows[i]["ReasonType"] = textBox3.Text;
ds.EndInit(); //结束挂起
sda.Update(ds, "SalesReason");
ds.AcceptChanges();
MessageBox.Show("数据修改成功");
}
private void button3_Click(object sender, EventArgs e)
{
DataSet ds = new DataSet();
SqlDataAdapter da = new SqlDataAdapter(strsql,strcon);
da.Fill(ds, "SalesReason");
ds.Tables["SalesReason"].PrimaryKey = new DataColumn[] { ds.Tables["SalesReason"].Columns["SalesReasonID"] };
SqlCommandBuilder sqlCommandBuilder1 = new SqlCommandBuilder(da);
// da.DeleteCommand = sqlCommandBuilder1.GetDeleteCommand();
ds.Tables["SalesReason"].Rows[i].Delete();
da.Update(ds,"SalesReason");
ds.AcceptChanges();
MessageBox.Show("数据删除成功");
i = 0;
show(i);//删除成功后，重新显示第一条数据
}
}
}
如果使用SQL Command的方式来直接更新数据源，写起来就更简单了，举个例子，拿前面删除部分的例子来举例好了：
private void button3_Click(object sender, EventArgs e)
{
SqlCommand cmd=new SqlCommand();
cmd.Connection=scon;
cmd.CommandText="delete from dbo.SalesReason where SalesReasonID=' "+textBox1.Text+" ' ";
scon.Open();
cmd.ExecuteNonQuery();
scon.Close(); //更新完毕，下面代码刷新显示，将记录定位到第一行
i=0; refresh();
show(i);
MessageBox.Show("数据删除成功");
refresh();
}
ADO.NET中的五个主要对象
2012-08-07
979
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《
阿里云开发者社区用户服务协议》和
《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写
侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介：
Connection 物件 Connection 对象主要是开启程序和数据库之间的连结。没有利用连结对象将数据库打开，是无法从数据库中取得数据的。这个物件在ADO.NET 的最底层，我们可以自己产生这个对象，或是由其它的对象自动产生。
目录
相关文章
|
XML
SQL
Oracle
|
SQL
数据库连接
数据处理
|
SQL
安全
数据库连接
|
存储
开发框架
.NET
|
SQL
Oracle
关系型数据库
ADO.Net简介 140
ADO.NET是.Net中一组类库,通过这组类库可以让我们通过程序的方式访问数据库中数据;之前学习的都是在数据库管理器中通过设计器或者SQL语句进行增删改查等操作数据库中的数据,对于普通用户不可能每个人都必须学习SQL,才能查看使用数据库,我们使用ADO.Net中的类库通过搭建比如窗体程序,使普通用户通过窗体上的按钮就可以很方便地操作和使用数据库中的数据,比如去买火车飞机等票时,窗口的出票员他们不可能每个人都去学习过SQL的知识后才能上岗,他们也是通过窗体或者网页方式查询使用数据库的数据的
ADO.NET中最重要的两个类:1)Connection用来连接数据库 2)Command用
117
0
0
|
SQL
安全
数据库
ADO.net学习
1374
0
0
|
数据库
ADO.NET 2.0 操作实例
1083
0
0
|
SQL
安全
关系型数据库
ADO.NET连接字符串
1305
0
0
|
索引
SQL
ADO.NET DataReader对象简介
1337
0
0
|
存储
大数据
程序员
4-1 ADO.NET简介
1487
0
0