大家好,又见面了,我是全栈君。
1 存储过程
1.1 不带参数,没有返回值
创建表
create table test (ID number, NAME varchar2(10), SEX varchar2(4), AGE number, ADDRESS varchar2(200) );
创建不带参数的存储过程
create or replace procedure proc1 is begin insert into test(ID,NAME,SEX,AGE) values (1,'moses','man',25); commit; end; /
C#代码调用
protected void Button2_Click(object sender, EventArgs e) { String oc = ConfigurationManager.ConnectionStrings["conn"].ToString(); OracleConnection conn = new OracleConnection(oc); conn.Open(); OracleCommand orm = conn.CreateCommand(); orm.CommandType = CommandType.StoredProcedure; orm.CommandText = "proc1"; orm.ExecuteNonQuery(); conn.Close(); }
1.2 没有返回值的带参数的存储过程
create or replace proc2 (v_id number, v_name varchar2 ) is begin insert into test(id,name) values(v_id,v_name); commit; end; /
C#调用
View Code
1.3 带参数有返回值的存储过程
create or replace procedure proc3 (recount out number ) is begin select count(*) into reccount from test; commit; end; /
C#调用
View Code
2 事务 (OracleTransaction )
应用程序通过针对OracleConnection对象调用 BeginTransaction 来创建OracleTransaction对象。对OracleTransaction对象执行与该事务关联的所有后续操作(例如提交或中止该事务)。
对何时使用事务来操作有以下初步认识:
对多个表同时进行操作时,其他还有何注意呢?
Connection一旦开了一个事务,则执行的命令就必须和事务相关。
要注意的是,在事务进行中,不能再对同一个数据库连接(OracleConnection)再进行事务外的数据的查询和读取,
if (trans != null)
mAdp.SelectCommand.Transaction = trans;
总结:在事务块内,如果使用同样的Connection对象查询,但不指定事务,会报错,在事务提交后,或者不使用相同的Connection的对象查询,不会报错。
using System; using System.Collections.Generic; using System.Linq; using System.Text; using System.Configuration; using System.Data; using Oracle.DataAccess.Client; using System.Runtime.InteropServices; using System.Text.RegularExpressions; using System.Diagnostics; using System.Data.Common; using System.Collections; namespace DB_Server { #region //操作Oracle数据库 public class OracleDBService { public OracleDBService(string ConnectionString) { OracleConStr = ConnectionString; } #region//连接数据库所需变量及方法 private string OracleConStr = ""; private OracleConnection conn;//创建sql连接 private OracleCommand com;//创建sql命令对象 private OracleDataReader dr;//创建sql数据阅读器 private OracleDataAdapter sdr;//创建sql适配器 private DataSet ds;//创建数据集 /// <summary> /// 创建数据库连接并打开 /// </summary> public void open() { //创建连接 conn = new OracleConnection(OracleConStr); if (conn.State == ConnectionState.Closed) { conn.Open(); } else if (conn.State == ConnectionState.Broken) { conn.Close(); conn.Open(); } } #region//事务操作数据库 /// <summary> /// 提交一组(多条)SQL语句操作数据库 /// </summary> /// <param name="commandStringList">SQL列表</param> /// <returns>执行结果</returns> public int UpdateBatchCommand(ArrayList commandStringList) { open(); OracleTransaction m_OraTrans = conn.BeginTransaction();//创建事务对象 com = new OracleCommand(); com.Connection = conn; string tmpStr = ""; int influenceRowCount = 0; try { foreach (string commandString in commandStringList) { tmpStr = commandString; com.CommandText = tmpStr; influenceRowCount += com.ExecuteNonQuery(); } m_OraTrans.Commit(); return influenceRowCount; } catch (OracleException ex) { m_OraTrans.Rollback(); throw ex; } } #endregion
参考文章
,如需转载请自行联系原作者
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/107929.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...