C#连接oracle以及控制事务方法

 

// 创建一个 OracleConnection 对象连接到 Oracle 数据库，然后打开该连接。

OracleConnection myOracleConnection =

new OracleConnection("User Id=store;Password=store;Data Source=ORCL" );

myOracleConnection.Open();

// 创建一个 OracleTransaction 对象，然后调用 OracleConnection 对象

//的 BeginTransaction() 方法启动事务。

OracleTransaction myOracleTransaction = myOracleConnection.BeginTransaction();

// 创建一个 OracleCommand 对象，用于存储 SQL 语句。

OracleCommand myOracleCommand = myOracleConnection.CreateCommand();

// 因为 OracleCommand 对象使用 OracleConnection 对象的 CreateCommand()

//方法创建的，所以它自动使用在第 2 步中为 OracleConnection 对象设置的事务。

// 将 OracleCommand 对象的 CommandText 属性设为向表 product_types 中添加

//一行的第一条 INSERT 语句。

myOracleCommand.CommandText =

"INSERT INTO product_types (" + " product_type_id, name" +

") VALUES (" + " 3, 'Magazine'" + ")";

// 使用 OracleCommand 对象的 ExecuteNonQuery() 方法运行 INSERT 语句。

myOracleCommand.ExecuteNonQuery();

// 将 OracleCommand 对象的 CommandText 属性设为向表 Products 中添加一行

//的第二条 INSERT 语句，并运行它。

myOracleCommand.CommandText =

"INSERT INTO products (" +

" product_id, product_type_id, name, description, price" +

") VALUES (" +

" 5, 3, 'Oracle Magazine', 'Magazine about Oracle', 4.99" + ")";

myOracleCommand.ExecuteNonQuery();

// 使用 OracleTransaction 对象的 Commit() 方法提交数据库中的事务。

myOracleTransaction.Commit();

// 在完成 Commit() 方法之后，由 INSERT 语句添加的两行将在数据库中永久记录。

// 使用 Close() 方法关闭 OracleConnection 对象。

myOracleConnection.Close();