zoukankan      html  css  js  c++  java
  • .net中使用mysql回滚和sqlserver回滚的区别

    关于sqlserver事务和mysql事务

    首先这是一种方法 

    public static int GetExecteQuery()
            {
                SqlConnection conn = new SqlConnection(CONN_STRING);//在这里CONN_STRING也就是连接sqlserver数据库的语句
                conn.Open();//打开
                SqlCommand command = conn.CreateCommand();//在这里也可以写成SqlCommand command=new SqlCommand();

                SqlTransaction transaction = null;
                transaction = conn.BeginTransaction(); //这两句也可以写成  SqlTransaction transaction =new SqlTransaction();
                command.Connection = conn;              
                command.Transaction = transaction;
                int count = 0;

                try
                {
                    command.CommandText = "insert into company values('AA','AAAA','true','null')";
                    command.ExecuteNonQuery();
                    command.CommandText = "insert into company values('AA','AAAA','tru1e','null')";
                    count = command.ExecuteNonQuery();
                    transaction.Commit(); //进行执行
                }
                catch
                {

                    transaction.Rollback();//发生异常进行回滚
                }

                return count;
            }

              

               关于mysql

              MySqlCommand mySqlCmd = new MySqlCommand();
                MySqlConnection mySqlConn = new MySqlConnection(connStr);
                try
                {
                    if (mySqlConn != null && mySqlConn.State == System.Data.ConnectionState.Closed)
                    {
                        mySqlConn.Open();
                    }
                    mySqlCmd.Connection = mySqlConn;
                    mySqlCmd.Transaction = mySqlConn.BeginTransaction();
                    mySqlCmd.CommandType = System.Data.CommandType.Text;
                    for (int i = 0; i < sqls.Count; i++)
                    {
                        mySqlCmd.CommandText = sqls[i].ToString();
                        mySqlCmd.ExecuteNonQuery();
                    }
                    mySqlCmd.Transaction.Commit();
                    return true;
                }
                catch (Exception)
                {
                    mySqlCmd.Transaction.Rollback();
                    throw;
                }
                finally
                {
                    this.CloseConn();
                }                              

  • 相关阅读:
    如何在linux系统中设置静态ip地址
    spring 学习
    java 反射机制和invoke方法
    CentoS7装机
    eclipse 添加jar包的方式
    No-args constructor for class does not exist. Register an InstanceCreator with G
    freemarker页面如何获取绝对路径basePath
    MySQL备份还原
    MySQL用户授权与权限
    CentOS7修改SSH远程连接端口
  • 原文地址:https://www.cnblogs.com/sdya/p/3937735.html
Copyright © 2011-2022 走看看