zoukankan      html  css  js  c++  java
  • 几个常用得事务处理方法


        
    /// <summary>
        
    /// 启动事务
        
    /// </summary>
        
    /// <param name="cn">数据库连接</param>
        
    /// <param name="cmd">命令对象</param>
        
    /// <param name="transaction">事务</param>
        
    /// <param name="executeString">Sql语句</param>
        
    /// <returns></returns>

        public static int ExecuteNonQuery(DbConnection cn,DbCommand cmd,DbTransaction transaction,string executeString)
        
    {
            
    if (cn.State == ConnectionState.Closed)
            
    {
                cn.Open();
            }

            cmd.Connection 
    = cn;
            
    if (transaction != null)
            
    {
                cmd.Transaction 
    = transaction;
            }

            cmd.CommandText 
    = executeString;
            cmd.CommandType 
    = CommandType.Text;
            
    int i = cmd.ExecuteNonQuery();
            
    return i;
        }

        
    /// <summary>
        
    /// 返回首行首列得值
        
    /// </summary>
        
    /// <param name="cn">数据库连接</param>
        
    /// <param name="cmd">命令对象</param>
        
    /// <param name="transaction">事务</param>
        
    /// <param name="executeString">Sql语句</param>
        
    /// <returns></returns>

        public static object ExecuteScalar(DbConnection cn, DbCommand cmd, DbTransaction transaction, string executeString)
        
    {
            
    if (cn.State == ConnectionState.Closed)
            
    {
                cn.Open();
            }

            cmd.Connection 
    = cn;
            
    if (transaction != null)
            
    {
                cmd.Transaction 
    = transaction;
            }

            cmd.CommandText 
    = executeString;
            cmd.CommandType 
    = CommandType.Text;
            
    object i = cmd.ExecuteScalar();
            
    return i;
        }


        
    /// <summary>
        
    /// 返回一个DataReader
        
    /// </summary>
        
    /// <param name="cn">数据库连接</param>
        
    /// <param name="cmd">命令对象</param>
        
    /// <param name="transaction">事务</param>
        
    /// <param name="executeString">Sql语句</param>
        
    /// <returns></returns>

        public static DbDataReader ExecuteReader(DbConnection cn, DbCommand cmd, DbTransaction transaction, string executeString)
        
    {
            
    if (cn.State == ConnectionState.Closed)
            
    {
                cn.Open();
            }

            cmd.Connection 
    = cn;
            
    if (transaction != null)
            
    {
                cmd.Transaction 
    = transaction;
            }

            cmd.CommandText 
    = executeString;
            cmd.CommandType 
    = CommandType.Text;
            DbDataReader reader 
    = cmd.ExecuteReader();
            
    return reader;
        }

    如果要用到上面这此只是给它几个参数就行了,成功就Commit一下,不成功就Rollback一下.

    如:

            DbConnection cn = GetConnection();
            if (cn.State == ConnectionState.Closed)
            {
                cn.Open();
            }
            DbTransaction transaction = cn.BeginTransaction(IsolationLevel.ReadCommitted);
            DbCommand cmd = GetCommand();

          XXX.ExecuteNonQuery(cn, cmd, transaction, executeString) 判断这个就可以了.

  • 相关阅读:
    [Luogu]小Z的AK计划
    [POI2006]OKR-Periods of Words
    [NOI2014]动物园
    [NOI2009]管道取珠
    [IOI2005]河流
    [国家集训队]Crash的文明世界
    [HDU5382]GCD?LCM!
    [AGC027E]ABBreviate
    [CF]Round510
    [NOIp2005]篝火晚会
  • 原文地址:https://www.cnblogs.com/xiaotuni/p/2365768.html
Copyright © 2011-2022 走看看