悲观观定SQL Server和Oracle

/*

author:wuxiuxiang;

Email:imessage@126.com

*/

using System;

using System.Data;

namespace com.cuc.wu.example

{

public class class1

{

//For SQL Server 需要与Connection相关的一个Transaction的隔离级别为

//Repeatable Read或Serializable,对于Oracle,在Command中使用select for update即可

public void LockedSQLDataRow()

{

DataSet ds = new DataSet();

SqlConnection sconn = new SqlConnection("server=localhost;uid=sa;pwd=sa;database=pubs");

sconn.Open();

SqlTransaction tx = new sconn.BeginTransaction(IsolationLevel.Serializable);

SqlCommand cmd = new SqlCommand("select * from authors",conn,tx);

SqlDataAdapter da = new SqlDataAdapter(cmd);

da.Fill(ds,"autors");

//rows locked here

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

SqlCommandBuilder bld = new SqlCommandBuilder(da);

da.Update(ds,"authors");

tx.commit();

//rows unlocked here

da.Dispose();

conn.Close();//ÏÔʽÊÍ·Å×ÊÔ´

}

public void LockedORADataRow()

{

DataSet ds = new DataSet();

OleDbConnection oconn = new OleDbConnection("provider=msdaora;data source=ocr11;user id=scott;password=tiger");

conn.Open();

OleDbTransaction tx = oconn.BeginTransaction();

OleDbCommand cmd = new OleDbCommand("select * form emp for update ",conn,tx);

OleDbDataAdapter da = new OleDbDataAdapter(cmd);

da.Fill(ds,"emp");

//rows locked here;

ds.Tables[0].Rows[9][2] = "CLERK";

OleDbCommandBuilder bld = new OleDbCommandBuilder(da);

da.Update(ds,"emp");

tx.Commit();

//rows unlocked here

da.Dispose();

oconn.Close();

}

};

}

 

 

 

免责声明：本文为网络用户发布，其观点仅代表作者个人观点，与本站无关，本站仅提供信息存储服务。文中陈述内容未经本站证实，其真实性、完整性、及时性本站不作任何保证或承诺，请读者仅作参考，并请自行核实相关内容。