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(); |
|