SQL 事務

public bool UpdateQsRegisterSql(List<string> ids, int newQueueId, string newQueueName){using (SqlConnection con = new SqlConnection(DBHelper.Instance.ConStr)){SqlTransaction tran = null;try{con.Open();SqlCommand cmd = con.CreateCommand();tran = con.BeginTransaction(IsolationLevel.ReadCommitted);cmd.Transaction = tran;foreach (string item in ids){cmd.CommandText = @"update qs_register set queueid='" + newQueueId+ "',queuename='" + newQueueName + "' where id='" + item + "'";cmd.ExecuteNonQuery();}tran.Commit();return true;}catch (Exception ex){tran.Rollback();return false;}}}

Oracle事務

public bool UpdateQsRegisterOrcl(List<string> ids, int newQueueId, string newQueueName){using (OleDbConnection con = new OleDbConnection(DBHelper.Instance.ConStr)){OleDbTransaction tran = null;try{con.Open();OleDbCommand cmd = con.CreateCommand();tran = con.BeginTransaction(IsolationLevel.ReadCommitted);cmd.Transaction = tran;foreach (string item in ids){cmd.CommandText = @"update qs_register set queueid='" + newQueueId+ "',queuename='" + newQueueName + "' where id='" + item + "'";cmd.ExecuteNonQuery();}tran.Commit();return true;}catch (Exception ex){tran.Rollback();return false;}}}

Sql存儲過程

　　　　/// <summary>/// 直接登記/// </summary>/// <param name="hisExamno">申請單號</param>/// <param name="enrolDoctor">登記醫生</param>/// <param name="engname">患者英文名稱</param>/// <param name="queueName">隊列名稱</param>/// <returns></returns>public bool DirectRegisterSql(string hisExamno, string enrolDoctor, string engname, string queueName){using (SqlConnection conn = new SqlConnection(DBHelper.Instance.ConnectionStr)){conn.Open();SqlCommand cmd = conn.CreateCommand();try{//插入號源屬性cmd.CommandType = CommandType.StoredProcedure;cmd.CommandText = "PROC_HISEXAMTOENROL";cmd.Parameters.Add("@p_HISEXAMNO", SqlDbType.VarChar).Value = hisExamno;cmd.Parameters.Add("@p_ENROLDOCTOR", SqlDbType.VarChar).Value = enrolDoctor;cmd.Parameters.Add("@p_ENGNAME", SqlDbType.VarChar).Value = engname;cmd.Parameters.Add("@p_AppKind", OleDbType.VarChar).Value = PubVariable.Instance.CurrentDept;cmd.Parameters.Add("@p_QueueName", OleDbType.VarChar).Value = queueName;cmd.Parameters.Add("@p_result", SqlDbType.Int).Value = -1;if (cmd.ExecuteNonQuery() > 0) return true;}catch { return false; }finally{if (conn.State != ConnectionState.Closed){conn.Close();}}}return false;}

Oracle存儲過程

/// <summary>/// 直接登記/// </summary>/// <param name="hisExamno">申請單號</param>/// <param name="enrolDoctor">登記醫生</param>/// <param name="engname">患者英文名稱</param>/// <param name="queueName">隊列名稱</param>/// <returns></returns>public bool DirectRegisterOrcl(string hisExamno, string enrolDoctor, string engname, string queueName){using (OleDbConnection conn = new OleDbConnection(DBHelper.Instance.ConnectionStr)){conn.Open();OleDbCommand cmd = conn.CreateCommand();try{//插入號源屬性cmd.CommandType = CommandType.StoredProcedure;cmd.CommandText = "PROC_HISEXAMTOENROL";cmd.Parameters.Add("@p_HISEXAMNO", OleDbType.VarChar).Value = hisExamno;cmd.Parameters.Add("@p_ENROLDOCTOR", OleDbType.VarChar).Value = enrolDoctor;cmd.Parameters.Add("@p_ENGNAME", OleDbType.VarChar).Value = engname;cmd.Parameters.Add("@p_AppKind", OleDbType.VarChar).Value = PubVariable.Instance.CurrentDept;cmd.Parameters.Add("@p_QueueName", OleDbType.VarChar).Value = queueName;cmd.Parameters.Add("@p_result", OleDbType.Integer).Value = -1;if (cmd.ExecuteNonQuery() > 0) return true;}catch { return false; }finally{if (conn.State != ConnectionState.Closed){conn.Close();}}}return false;}

　　

轉載于:https://www.cnblogs.com/YYkun/p/9359513.html

總結

以上是生活随笔為你收集整理的C#中数据库事务、存储过程基本用法的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。