zoukankan      html  css  js  c++  java
  • .Net中使用数据库事务机制


           在初始化SqlTransaction类时,你需要使用SqlConnection类的BeginTranscation()方法:
    SqlTransaction myTran; myTran=myConn.BeginTransaction(); 
       该方法返回一个SqlTransaction类型的变量。在调用BeginTransaction()方法以后,所有基于该数据连接对象的SQL语句执行动作都将被认为是事务MyTran的一部分。同时,你也可以在该方法的参数中指定事务隔离级别和事务名称,如:
    SqlTransaction myTran;
    myTran=myConn.BeginTransaction(IsolationLevel.ReadCommitted,"SampleTransaction"); 

    程序实例:

    1.  SQL SERVER

         SqlConnection myConn=GetConn();
      myConn.Open();
      SqlCommand myComm=new SqlCommand();

      SqlTransaction myTran;                                           //创建一个事务
      myTran=myConn.BeginTransaction();                     //注意,SqlTransaction类无公开的构造函数

       //从此开始,基于该连接的数据操作都被认为是事务的一部分
       myComm.Connection=myConn;
       myComm.Transaction=myTran;
       myComm.CommandText="USE pubs";
       myComm.ExecuteNonQuery();
       myComm.CommandText="UPDATE roysched SET royalty = royalty * 1.10 WHERE title_id LIKE 'Pc%'";
       myComm.ExecuteNonQuery();

          myTran.Commit();              //提交事务

    2.下面的示例创建一个 OracleConnection 和一个 OracleTransaction。它还演示了如何使用 BeginTransaction、Commit 和 Rollback 方法。

    public void RunOracleTransaction(string myConnString)
    {
       OracleConnection myConnection = new OracleConnection(myConnString);
       myConnection.Open();

       OracleCommand myCommand = myConnection.CreateCommand();
       OracleTransaction myTrans;

       // Start a local transaction
       myTrans = myConnection.BeginTransaction(IsolationLevel.ReadCommitted);
       // Assign transaction object for a pending local transaction
       myCommand.Transaction = myTrans;

       try
       {
         myCommand.CommandText = "INSERT INTO Dept (DeptNo, Dname, Loc) values (50, 'TECHNOLOGY', 'DENVER')";
         myCommand.ExecuteNonQuery();
         myCommand.CommandType= CommandType.StoredProcedure;
         myCommand.CommandText="prc_test";
         myCommand.ExecuteNonQuery();
         myTrans.Commit();
         Console.WriteLine("Both records are written to database.");
       }
       catch(Exception e)
       {
         myTrans.Rollback();
         Console.WriteLine(e.ToString());
         Console.WriteLine("Neither record was written to database.");
       }
       finally
       {
         myConnection.Close();
       }
    }


  • 相关阅读:
    网站图片上传,水印,预览,截图
    go语言中的数组切片:特立独行的可变数组
    Android ADB server didn't ACK * failed to start daemon * 简单有效的解决方案
    MongoDB删除文档
    顺为资本CEO许达来:为什么说中国创业者很幸福?(附PPT)
    星瀚资本杨歌:我七次创业失败的内心感悟(比较真实,可以看看创业的36条军规)
    晨兴资本刘芹:入行16年我才刚理解创投,有8个最深感悟
    20 个免费开源的 CSS3 用户界面工具包
    Google浏览器的缓存文件过大(mega网站导致的)
    FastSocket客户端/服务端通讯示例
  • 原文地址:https://www.cnblogs.com/xiaolin/p/586614.html
Copyright © 2011-2022 走看看