悲观观定SQL Server和Oracle----编程资料集中营--八角123--bajiao123.com

悲观观定SQL Server和Oracle,/*www.chinaitpower.comlbRZuj8Wauthor:wuxiuxiang;Email:imessage@126.comwww.chinaitpower.comlbRZuj8W*/www.chinaitpower.comlbRZuj8Wwww.chinaitpower.comlbRZuj8WusingSystem;usingSystem.,
您现在的位置：编程资料,学习资料,c,c++,vc,vc++,java,jsp,j2ee,j2me,asp,php >> 文章中心 >> .NET 专区 >> NET 技术 >> 文章正文

【字体：小大】

悲观观定SQL Server和Oracle 进入问吧

本站地址:http://www.bajiao123.com

作者：admin 文章来源：不详点击数：更新时间：2007-6-1

悲观观定SQL Server和Oracle

/*www.c hinaitpower.comlbRZuj8W

author:wuxiuxiang;
Email:imessage@126.comwww.c hinaitpower.comlbRZuj8W

*/www.c hinaitpower.comlbRZuj8W

www.c hinaitpower.comlbRZuj8W

using System;
src=/Article/UploadFiles/200706/200761195129409.gif using System.Data;
namespace com.cuc.wu.example
{
   public class class1
   {
  //For SQL Server 需要与Connection相关的一个Transaction的隔离级别为
    //Repeatable Read或Serializable,对于Oracle,在Command中使用select for update即可
src=/Article/UploadFiles/200706/200761195130320.gif        public void LockedSQLDataRow()
       {
           DataSet ds = new DataSet();
           SqlConnection sconn = new SqlConnection("server=localhost;uid=sa;pwd=sa;database=pubs");
           sconn.Open();
src=/Article/UploadFiles/200706/200761195130320.gif            SqlTransaction tx = new sconn.BeginTransaction(IsolationLevel.Serializable);

           SqlCommand cmd = new SqlCommand("select * from authors",conn,tx);
           SqlDataAdapter da = new SqlDataAdapter(cmd);
src=/Article/UploadFiles/200706/200761195130320.gif            da.Fill(ds,"autors");
           //rows locked here

           ds.Tables[0].Rows[1][2]="Free";

           SqlCommandBuilder bld = new SqlCommandBuilder(da);
           da.Update(ds,"authors");
src=/Article/UploadFiles/200706/200761195130320.gif            tx.commit();
           //rows unlocked here
           da.Dispose();
           conn.Close();//ÏÔÊ½ÊÍ·Å×ÊÔ´
       }
       public void LockedORADataRow()
        src=/Article/UploadFiles/200706/200761195130776.gif/ {
           DataSet ds = new DataSet();
           OleDbConnection oconn = new OleDbConnection("provider=msdaora;data source=ocr11;user id=scott;password=tiger");
           conn.Open();

           OleDbTransaction tx = oconn.BeginTransaction();
src=/Article/UploadFiles/200706/200761195130320.gif            OleDbCommand cmd = new OleDbCommand("select * form emp for update ",conn,tx);

           OleDbDataAdapter da = new OleDbDataAdapter(cmd);
           da.Fill(ds,"emp");
src=/Article/UploadFiles/200706/200761195130320.gif            //rows locked here;

           ds.Tables[0].Rows[9][2] = "CLERK";
           OleDbCommandBuilder bld = new OleDbCommandBuilder(da);
           da.Update(ds,"emp");
           tx.Commit();
src=/Article/UploadFiles/200706/200761195130320.gif            //rows unlocked here
           da.Dispose();
           oconn.Close();
       }
   };

}www.c hinaitpower.comlbRZuj8W

进入问吧

本站地址:http://www.bajiao123.com

文章录入：admin 责任编辑：admin

上一篇文章： Singleton深入浅出

下一篇文章：从SQL Server中读写大数据列。

【发表评论】【加入收藏】【告诉好友】【打印此文】【关闭窗口】

没有相关文章