欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

c#实现数据库事务示例分享

程序员文章站 2024-02-26 09:44:25
复制代码 代码如下:using system;using system.data.sqlclient; namespace executesqltran{ &n...


复制代码 代码如下:

using system;
using system.data.sqlclient;

namespace executesqltran
{
    class program
    {
        class result<t>
        {
            public t data;
            public string message;
            public bool success;
            public string stacktrace;
        }

        struct executeableunit
        {
            public string sql;
            public sqlparameter[] param;
        }

        /// <summary>
        /// 执行多条sql语句,实现数据库事务。
        /// </summary>
        /// <param name="sqlstringlist">sql语句的哈希表(key为sql语句,value是该语句的sqlparameter[])</param>
        private static result<int> executesqltransaction(params executeableunit[] executeableunits)
        {
            using (sqlconnection connection = new sqlconnection(""))
            {
                connection.open();
                sqlcommand command = connection.createcommand();
                sqltransaction transaction = connection.begintransaction();
                command.connection = connection;
                command.transaction = transaction;
                int result = 0;
                try
                {
                    foreach(executeableunit exeunit in executeableunits)
                    {
                        command.commandtext = exeunit.sql;
                        if(exeunit.param.getlength(1) > 0)
                        {
                            foreach(sqlparameter p in exeunit.param)
                                command.parameters.add(p);
                        }
                        result += command.executenonquery();
                    }
                    transaction.commit();
                }
                catch (exception ex)
                {
                    // attempt to roll back the transaction.
                    try
                    {
                        transaction.rollback();
                    }
                    catch (exception ex2)
                    {
                        return new result<int>()
                        {
                            success = false, message = ex2.message, stacktrace = ex2.stacktrace
                        };
                    }
                    return new result<int>()
                    {
                        success = false, message = ex.message, stacktrace = ex.stacktrace
                    };
                }
                finally
                {
                    // attempt to roll back the transaction.
                    try
                    {
                  connection.close();
                    }
                    catch (exception ex)
                    {
                    }
                }
                return new result<int>()
                {
                    success = true, data = result
                };
            }
        }

        public static void main(string[] args)
        {
        }
    }
}