执行连接环境下的数据库操作.ppt

《执行连接环境下的数据库操作.ppt》由会员分享，可在线阅读，更多相关《执行连接环境下的数据库操作.ppt（33页珍藏版）》请在淘文阁 - 分享文档赚钱的网站上搜索。

1、ADO.NETADO.NET程序设计程序设计执行连接环境下的数据库操作执行连接环境下的数据库操作第第第3 33章章章1ADO.NET程序设计程序设计17 二月 2023内容连接环境下对数据库的操作连接环境下对数据库的操作1数据命令对象数据命令对象2使用参数的数据命令对象使用参数的数据命令对象3数据阅读器数据阅读器4事务事务52ADO.NET程序设计程序设计17 二月 2023连接环境下对数据库的操作v连接环境下应用程序的对象模型连接环境下应用程序的对象模型数据源数据源XxxConnectionXxxParameterXxxDataReaderXxxCommandXxxParameterXxxP

2、arameterXmlReader3ADO.NET程序设计程序设计17 二月 2023连接环境下应用程序的对象模型vXxxConnectionXxxConnection建立与数据源的连接，如建立与数据源的连接，如 SqlConnection SqlConnection 用于建立用于建立与与 Microsoft SQL Server Microsoft SQL Server 的连接，的连接，OleDbConnectionOleDbConnection用于建立与任何支持用于建立与任何支持 OLEDBOLEDB 的数据的数据源的连接源的连接vXxxCommandXxxCommand执行数据源的命令，

3、如执行数据源的命令，如 SqlCommand SqlCommand 可以调用一个可以调用一个 Microsoft SQL Server Microsoft SQL Server 的存储过程，的存储过程，XxxCommand XxxCommand 对象的对象的 ExecuteReader ExecuteReader 方法可以返回一个方法可以返回一个 XxxDataReader XxxDataReader 对象对象4ADO.NET程序设计程序设计17 二月 2023连接环境下应用程序的对象模型vXxxDataReaderXxxDataReader以只读的、前向的方式，以流的形式读取数据，例以只读的

4、、前向的方式，以流的形式读取数据，例如如 SqlDataReader SqlDataReader 可以读取可以读取 Microsoft SQL Microsoft SQL Server Server 中的数据中的数据XxxDataReader XxxDataReader 由由 XxxCommandXxxCommand（通常是通常是SELECTSELECT命令）命令）的的 ExecuteReader ExecuteReader 方法返回方法返回vXxxXmlReaderXxxXmlReader提供以快速的、无缓存的、前向的方式读取提供以快速的、无缓存的、前向的方式读取XMLXML数据数据5ADO

5、.NET程序设计程序设计17 二月 2023连接环境中对数据库操作的步骤SQL Server 7.0（或更高版本）（或更高版本）SqlConnectionSqlCommandSqlDataReader6ADO.NET程序设计程序设计17 二月 2023连接环境下对数据库的操作连接环境下对数据库的操作1数据命令对象数据命令对象2使用参数的数据命令对象使用参数的数据命令对象3数据阅读器数据阅读器4事务事务57ADO.NET程序设计程序设计17 二月 2023数据命令对象的概念v一个一个 Command Command 对象是一个对象是一个SQLSQL语句或者存储过程的引用语句或者存储过程的引用Co

6、mmand Command 对象可以直接被执行对象可以直接被执行v属性属性NameName：可选属性，可以用于引用该对象可选属性，可以用于引用该对象ConnectionConnection：连接对象的引用，与数据库交互连接对象的引用，与数据库交互CommandTypeCommandType：TextText、StoredProcedureStoredProcedure、DirectTable DirectTable 的的一种一种CommandTextCommandText：SQL SQL 语句或者存储过程的名字语句或者存储过程的名字Parameters Parameters：可以有零个或多个参

7、数可以有零个或多个参数8ADO.NET程序设计程序设计17 二月 2023数据命令对象的概念v方法方法ExecuteScalarExecuteScalar返回一个惟一的值返回一个惟一的值ExecuteReaderExecuteReader返回数据行的集合返回数据行的集合ExecuteNonQueryExecuteNonQuery用于更新数据库或改变数据库结构，返回被影响的行用于更新数据库或改变数据库结构，返回被影响的行数数 ExecuteXmlReader(ExecuteXmlReader(仅限于仅限于SqlCommand)SqlCommand)返回一个返回一个 XML XML 的结果集的结果

8、集9ADO.NET程序设计程序设计17 二月 2023数据命令对象的创建v编程命令实现编程命令实现使用使用 New New 关键字创建一个新实例并设置其属性关键字创建一个新实例并设置其属性cmd=new OleDbCommand();cmd=new OleDbCommand();cmd.CommandText=strSQL;cmd.CommandText=strSQL;cmd.Connection=cn;cmd.Connection=cn;使用指定了查询字符串与连接的构造函数使用指定了查询字符串与连接的构造函数cmd=new OleDbCommand(strSQL,cn);cmd=new Ol

9、eDbCommand(strSQL,cn);调用调用 Connection Connection 对象的对象的 CreateCommand CreateCommand 方法方法cmd=cn.CreateCommand();cmd=cn.CreateCommand();cmd.CommandText=strSQL;cmd.CommandText=strSQL;10ADO.NET程序设计程序设计17 二月 2023连接SQL Server 2000实例SqlConnection connSQL=new SqlConnection();SqlConnection connSQL=new SqlCon

10、nection();connSQL.ConnectionString=Initial Catalog=Sales;Data connSQL.ConnectionString=Initial Catalog=Sales;Data Source=YUJIE;Integrated Security=true;Source=YUJIE;Integrated Security=true;SqlCommand cmd=new Sqlcommand();SqlCommand cmd=new Sqlcommand();cmd.Connection=connSQL;cmd.Connection=connSQL;

11、cmd.CommandType=CommandType.Text;cmd.CommandType=CommandType.Text;cmd.CommandText=“select*from products”cmd.CommandText=“select*from products”/如果操作数据的存储过程则：如果操作数据的存储过程则：cmd.CommandType=CommandType.StoredProcedure;cmd.CommandType=CommandType.StoredProcedure;cmd.CommandText=“cmd.CommandText=“存储过程的名称存储

12、过程的名称”11ADO.NET程序设计程序设计17 二月 2023连接环境下对数据库的操作连接环境下对数据库的操作1数据命令对象数据命令对象2使用参数的数据命令对象使用参数的数据命令对象3数据阅读器数据阅读器4事务事务512ADO.NET程序设计程序设计17 二月 2023Command 对象参数v参数介绍参数介绍SQL SQL 语句和存储过程可以有输入输出参数以及返回语句和存储过程可以有输入输出参数以及返回值值CommandCommand对象参数用来设置或者返回这些参数对象参数用来设置或者返回这些参数使用使用SqlParameterSqlParameter、OleDbParameterOle

13、DbParameter创建参数对象创建参数对象v参数属性参数属性ParameterNameParameterName、DbTypeDbType、SizeSize、DirectionDirection13ADO.NET程序设计程序设计17 二月 2023为 Command 对象创建参数v编程实现编程实现ParameterNameParameterName：命令参数的名称，例如命令参数的名称，例如 CatIdCatIdDbTtypeDbTtype：连接到数据库的类型，有连接到数据库的类型，有 SqlType SqlType 和和 OleDbTypeOleDbTypeDirectionDirecti

14、on：ParameterDirection ParameterDirection 枚举集指定的值，枚举集指定的值，可以是可以是:ParameterDirection.InputParameterDirection.Input（默认值）默认值）ParameterDirection.InputOutputParameterDirection.InputOutputParameterDirection.Output ParameterDirection.Output ParameterDirection.ReturnValueParameterDirection.ReturnValue14ADO.N

15、ET程序设计程序设计17 二月 2023使用参数的步骤v创建创建ConnectionConnection对象对象v打开打开ConnectionConnection对象对象v创建创建CommandCommand对象并设置相应的属性值对象并设置相应的属性值v创建参数对象创建参数对象ParameterParameter，并设置相应的属性值，并设置相应的属性值（有多少个参数就要创建多少个参数对象）（有多少个参数就要创建多少个参数对象）v将建立好的参数添加到将建立好的参数添加到CommandCommand对象的对象的ParametersParameters集合中。集合中。v执行数据命令（我将在下一节中进

16、行具体讲解）执行数据命令（我将在下一节中进行具体讲解）v关闭相关对象关闭相关对象15ADO.NET程序设计程序设计17 二月 2023使用参数的一个实例v假如我们有如下的存储过程，可以根据销售人员的假如我们有如下的存储过程，可以根据销售人员的代号，查询到该销售人员的人销售定单情况：代号，查询到该销售人员的人销售定单情况：create proc create proc OrderListOrderList Sale_ID varchar(3)Sale_ID varchar(3)asas select OrderID,OrderDate from Orders select OrderID,Ord

17、erDate from Orders where SaleID where SaleID=Sale_ID=Sale_ID16ADO.NET程序设计程序设计17 二月 2023/1/1、创建连接对象创建连接对象 SqlConnection conn=new SqlConnection();SqlConnection conn=new SqlConnection();conn.ConnectionString=Initial Catalog=Sales;Data conn.ConnectionString=Initial Catalog=Sales;Data Source=YUJIE;Integr

18、ated Security=true;Source=YUJIE;Integrated Security=true;conn.Open();conn.Open();/2/2、创建创建commandcommand对象对象 SqlCommand cmd=new SqlCommand();SqlCommand cmd=new SqlCommand();cmd.Connection=conn;cmd.Connection=conn;cmd.CommandType=cmd.CommandType=CommandType.StoredProcedure;CommandType.StoredProcedure

19、;cmd.CommandText=cmd.CommandText=OrderList;OrderList;代码实现:17ADO.NET程序设计程序设计17 二月 2023/3/3、创建创建ParameterParameter对象对象 SqlParameter prmSID=new SqlParameter();SqlParameter prmSID=new SqlParameter();prmSID.ParameterName=prmSID.ParameterName=Sale_ID;Sale_ID;prmSID.Direction=ParameterDirection.Input;prmSI

20、D.Direction=ParameterDirection.Input;prmSID.SqlDbType=SqlDbType.VarChar;prmSID.SqlDbType=SqlDbType.VarChar;prmSID.Value=prmSID.Value=this.txtSID.Text.Trim();this.txtSID.Text.Trim();/获得文本框中用户输入的内容获得文本框中用户输入的内容 /4/4、将参数对象添加到参数集合中将参数对象添加到参数集合中 cmd.Parameters.Add(prmSID);cmd.Parameters.Add(prmSID);/SqlP

21、arameter prmSID=cmd.Parameters.Add(new SqlParameter(Sale_ID,SqlDbType.VarChar,4);SqlParameter prmSID=cmd.Parameters.Add(new SqlParameter(Sale_ID,SqlDbType.VarChar,4);/cmd.ParametersSale_ID.Value=this.txtSID.Text.Trim();/cmd.ParametersSale_ID.Value=this.txtSID.Text.Trim();18ADO.NET程序设计程序设计17 二月 2023/

22、5/5、执行执行 SqlDataReader dr;SqlDataReader dr;dr=cmd.ExecuteReader();dr=cmd.ExecuteReader();while(dr.Read()while(dr.Read()this.lsOrderID.Items.Add(dr.GetInt32(0);this.lsOrderID.Items.Add(dr.GetInt32(0);this.lOrderDate.Items.Add(dr.GetDateTime(1);this.lOrderDate.Items.Add(dr.GetDateTime(1);/6/6、关闭、关闭 dr

23、.Close();dr.Close();conn.Close();conn.Close();此此例演示：实例例演示：实例OrderListOrderList中的中的 查询查询 19ADO.NET程序设计程序设计17 二月 2023Command对象的方法应用举例v方法方法ExecuteScalarExecuteScalar返回一个惟一的值返回一个惟一的值ExecuteReaderExecuteReader返回数据行的集合返回数据行的集合ExecuteNonQueryExecuteNonQuery用于更新数据库或改变数据库结构，返回被影响的行用于更新数据库或改变数据库结构，返回被影响的行数数演示

24、：实例演示：实例OrderListOrderList20ADO.NET程序设计程序设计17 二月 2023连接环境下对数据库的操作连接环境下对数据库的操作1数据命令对象数据命令对象2使用参数的数据命令对象使用参数的数据命令对象3数据阅读器数据阅读器4事务事务521ADO.NET程序设计程序设计17 二月 2023数据阅读器v当执行命令对象后，返回多行数据时就会使用数据当执行命令对象后，返回多行数据时就会使用数据阅读器阅读器vDataReaderDataReader只读、前向，数据行的流vCommandCommand的的ExecuteReaderExecuteReader方法方法返回一个 Dat

25、aReader例如：SqlDataReader、OleDbDataReader22ADO.NET程序设计程序设计17 二月 2023数据阅读器DataReader 的属性与方法vRead Read 方法方法得到下一行得到下一行如果还有后续数据行存在，返回如果还有后续数据行存在，返回TrueTrue；反之返回；反之返回FalseFalsevItem Item 属性属性 aReader“aColumnName”aReader“aColumnName”或或aReadercolumnPosition aReadercolumnPosition vGetXxx GetXxx 方法，例如：方法，例如：Ge

26、tStringGetString、GetInt32 GetInt32GetStringColumnPositionGetStringColumnPosition（以基数零开始）以基数零开始）23ADO.NET程序设计程序设计17 二月 2023数据阅读器DataReader 的属性与方法vGetValues GetValues 方法方法一次返回当前行所有的列，高效一次返回当前行所有的列，高效vIsDbNull IsDbNull 方法方法用于测试是否返回用于测试是否返回NULLNULLvClose Close 方法方法Read Read 方法返回方法返回 False False 时，应该调用时，

27、应该调用 Close Close 方法关方法关闭闭 DataReaderDataReader，释放连接释放连接24ADO.NET程序设计程序设计17 二月 2023使用 DataReader 对象处理一个结果集示例代码SqlCommand cmdProducts=new SqlCommand(“SELECT ProductName,UnitsInStock FROM Products”,cnNorthwind);cnNorthwind.Open();SqlDataReader rdrProducts=cmdProducts.ExecuteReader(）;While(rdrProducts.R

28、ead()ListBox1.Items.Add(rdrProducts.GetString(0);rdrProducts.Close();25ADO.NET程序设计程序设计17 二月 2023连接环境下对数据库的操作连接环境下对数据库的操作1数据命令对象数据命令对象2使用参数的数据命令对象使用参数的数据命令对象3数据阅读器数据阅读器4事务事务526ADO.NET程序设计程序设计17 二月 2023使用事务机制v事务是一系列相互关联的任务，作为一个整体成功提交或者事务是一系列相互关联的任务，作为一个整体成功提交或者失败（提交或者回滚）失败（提交或者回滚）vACIDACIDAtomicity At

29、omicity（原子）原子）：事务或者全部提交，或者全不提交事务或者全部提交，或者全不提交ConsistencyConsistency（一致）：一致）：事务保证了数据的完整性事务保证了数据的完整性IsolationIsolation（分离）：分离）：事务处理了数据操作的并发性事务处理了数据操作的并发性DurabilityDurability（持续）：持续）：即使在事务结束后发生系统崩溃等灾难性情况，事务即使在事务结束后发生系统崩溃等灾难性情况，事务涉及的数据操作也将正常保存涉及的数据操作也将正常保存27ADO.NET程序设计程序设计17 二月 2023使用 SQL 语句管理事务vSQLSQL事

30、务语句事务语句BEGIN TRANSBEGIN TRANS、COMMIT TRANSCOMMIT TRANS、ROLLBACK TRANSROLLBACK TRANSv代码示例代码示例BEGIN TRANSBEGIN TRANSDECLARE orderDetailsError int,productError intDECLARE orderDetailsError int,productError intDELETE FROM Order Details WHERE ProductID=42DELETE FROM Order Details WHERE ProductID=42SELECT

31、 orderDetailsError=ERRORSELECT orderDetailsError=ERRORDELETE FROM Products WHERE ProductID=42DELETE FROM Products WHERE ProductID=42SELECT productError=ERRORSELECT productError=ERRORIF orderDetailsError=0 AND productError=0IF orderDetailsError=0 AND productError=0 COMMIT TRANS COMMIT TRANSELSE ELSE

32、ROLLBACK TRANS ROLLBACK TRANS28ADO.NET程序设计程序设计17 二月 2023使用 ADO.NET 管理事务vXxxConnection XxxConnection 例如例如 SqlConnectionSqlConnectionBeginTransactionBeginTransactionvXxxTransaction XxxTransaction 例如例如 SqlTransactionSqlTransactionCommitCommitRollbackRollbackv代码示例如下代码示例如下29ADO.NET程序设计程序设计17 二月 2023v/Ope

33、n the database connection,and begin a transaction./Open the database connection,and begin a transaction./Execute two DELETE statements within the transaction./Execute two DELETE statements within the transaction./Commit or rollback the transaction,as appropriate/Commit or rollback the transaction,as

34、 appropriate cnNorthwind.Open();cnNorthwind.Open();SqlTransaction trans=cnNorthwind.BeginTransaction();SqlTransaction trans=cnNorthwind.BeginTransaction();SqlCommand cmd=new SqlCommand();SqlCommand cmd=new SqlCommand();cmd.Connection=cnNorthwind;cmd.Connection=cnNorthwind;cmd.Transaction=trans;cmd.T

35、ransaction=trans;trytry cmd.CommandText=DELETE Order Details WHERE ProductID=42;cmd.CommandText=DELETE Order Details WHERE ProductID=42;cmd.ExecuteNonQuery();cmd.ExecuteNonQuery();cmd.CommandText=DELETE Products WHERE ProductID=42;cmd.CommandText=DELETE Products WHERE ProductID=42;cmd.ExecuteNonQuer

36、y();cmd.ExecuteNonQuery();trans.Commit();trans.Commit();catch(Exception e)catch(Exception e)trans.Rollback();trans.Rollback();30ADO.NET程序设计程序设计17 二月 2023隔离级别v并发问题举例并发问题举例Dirty ReadsDirty Reads（脏读）（脏读）当一个查询选择了正在被更改的一行时，正在读当一个查询选择了正在被更改的一行时，正在读取的数据可能还没有提交，而这时另一个查询可取的数据可能还没有提交，而这时另一个查询可能更改数据能更改数据Non-re

37、peatable ReadsNon-repeatable Reads（不可重复读取）（不可重复读取）一个查询两次读取得到的数据不一致，这是由于一个查询两次读取得到的数据不一致，这是由于在两次查询之间另一个事务更新了数据在两次查询之间另一个事务更新了数据Phantom ReadsPhantom Reads（幻象读）（幻象读）一个事务读取一个当前正在被删除的数据，而重一个事务读取一个当前正在被删除的数据，而重新读取的时候，该行数据已经不存在了新读取的时候，该行数据已经不存在了31ADO.NET程序设计程序设计17 二月 2023隔离级别（续）v设置隔离级别的方法设置隔离级别的方法设置其隔离级别设置

38、其隔离级别：read committed read committed，repeatable read repeatable read和和serializableserializablev代码举例代码举例trans=cnNorthwind.BeginTransaction(_trans=cnNorthwind.BeginTransaction(_IsolationLevel.Serializable)IsolationLevel.Serializable)v对隔离级别的支持取决于数据库的类型对隔离级别的支持取决于数据库的类型不同的数据库可能有不同的对锁的支持不同的数据库可能有不同的对锁的支持32ADO.NET程序设计程序设计17 二月 2023回顾学习完本章后，将能够：学习完本章后，将能够：v创建创建CommandCommand对象对象v执行返回单一值的执行返回单一值的CommandCommand对象对象v执行返回记录行集的命令，并处理结果执行返回记录行集的命令，并处理结果v执行命令，通过使用执行命令，通过使用DDLDDL和和DCDCL L定义数据库结构和权定义数据库结构和权限限v执行修改数据的命令执行修改数据的命令v使用事务使用事务33