怎么跟Cap组合起来用？ 返回

\/羊驼 发布于2020/12/7

悬赏：5 飞吻

  using (var  connection = _baseRepository.GetDb().Ado.Connection)
            using (var tran = connection.Invoke_BeginTransaction(capBus, autoCommit: false))
            {              
                _baseRepository.GetDb().Updateable<sys_admin>().SetColumns(m => m.LoginName == DateTime.Now.ToString()).Where(m => m.Guid == "8").ExecuteCommand();
                capBus.Publish("xxx.services.show.time", DateTime.Now);
                tran.Commit();
            }

收藏

热忱回答（11）

• fate stay night VIP0

  2020/12/7

  http://www.donet5.com/Ask/9/4838  这个用户自个解决了

  0 回复
• fate stay night VIP0

  2020/12/7

  自动释放要关闭，然后open需要手动打开

  0 回复
• \/羊驼 VIP0

  2020/12/7

  @fate stay night：自动释放关着了

  此外这个open在哪里手动打开的？ 

  0 回复
• fate stay night VIP0

  2020/12/7

  事务之前   connection.open()

  0 回复
• fate stay night VIP0

  2020/12/7

  如果你成功了，你把你的代码以文本的方式分享出来

  0 回复
• \/羊驼 VIP0

  2020/12/7

  public static ICapTransaction BeginTransaction(this IDbConnection dbConnection,
              ICapPublisher publisher, bool autoCommit = false)
          {
              if (dbConnection.State == ConnectionState.Closed)
              {
                  dbConnection.Open();
              }
  
              var dbTransaction = dbConnection.BeginTransaction();
              publisher.Transaction.Value = publisher.ServiceProvider.GetService<ICapTransaction>();
              return publisher.Transaction.Value.Begin(dbTransaction, autoCommit);
          }

  这里会自动打开啊

  0 回复
• fate stay night VIP0

  2020/12/7

  那就行

  0 回复
• fate stay night VIP0

  2020/12/7

  不过保险还是手动打开一下更好

  0 回复
• 胖??骆驼 VIP0

  2020/12/7

  CAP 3.0之后就不兼容拉...自己魔改吧(主要是驱动不同).或者降级到2.6版本吧!!@

  \/羊驼

  
  

  0 回复
• fate stay night VIP0

  2020/12/7

  sqlSugarCore.MySqlConnector 这个版本的SqlSugar支持了MySqlConnector驱动

  0 回复
• fate stay night VIP0

  2020/12/7

  @胖??骆驼：

  0 回复