几个常用得事务处理方法

    /**//// <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) 判断这个就可以了.