最新版连接oracle出现错误 返回

冬天 发布于2025/8/21

悬赏：0 飞吻

收藏

热忱回答（10）

• fate sta VIP0

  2025/8/21

  

  0 回复
• fate sta VIP0

  2025/8/21

  和using没有关系。看文档：遇发

  如果对异步使用不熟悉你还是用老版本吧

  0 回复
• fate sta VIP0

  2025/8/21

  或者还有疑问提供完整的DEMO。

  0 回复
• fate sta VIP0

  2025/8/21

  如果定时任务只有这一个方法是没有问题，目前代码OK

  

  0 回复
• fate sta VIP0

  2025/8/21

  检查AOP中有没有异步方法，可能问题出在AOP中。 表达式Action类型是不受等待效果的

  0 回复
• 冬天 VIP0

  2025/8/22

  @fate sta：Aop中只有输出sql语句，没有执行方法

  0 回复
• fate sta VIP0

  2025/8/22

  还有疑问可以自个写个DEMO测试，能重现发我

  0 回复
• fate sta VIP0

  2025/8/22

  当然也可能是驱动版不一样引起的其他因素。你可以写DEMO验证。能重现在发我

  0 回复
• 冬天 VIP0

  2025/8/22

  @fate sta：使用sqlsugar自带的Oracle.ManagedDataAccess.Core23.8版本，用原生方法写就正常

  private static async Task<int> GetCountByDateRangeAsync(DateTime start, DateTime end)

  {

      var sql = @"SELECT COUNT(*) FROM " + TableName +

          @" WHERE TO_DATE(RQ, 'YYYY-MM-DD') BETWEEN TO_DATE(:startDate, 'YYYY-MM-DD') AND TO_DATE(:endDate, 'YYYY-MM-DD')";

      var param = new

      {

          startDate = start.ToString("yyyy-MM-dd"),

          endDate = end.ToString("yyyy-MM-dd")

      };

  
  

      try

      {

          NativeOracleHelper nativeOracleHelper = new();

  
  

          object result = await nativeOracleHelper.GetScalarAsync(

              sqlCommand: sql,

              parameters: param,

              commandTimeout: 180); // 覆盖默认超时时间

  
  

          //Oracle的COUNT(*)返回类型为NUMBER，在.NET中默认映射为decimal类型。直接强制转换为int会触发InvalidCastException。

          decimal decimalCount = Convert.ToDecimal(result);

  
  

          if (decimalCount > int.MaxValue)

          {

              throw new OverflowException("数值超出int范围");

          }

          return (int)decimalCount;

      }

      catch (OracleException ex)

      {

          // 处理连接错误

          throw Oops.Oh($"{ex.Message} | 堆栈:{ex.StackTrace} | 异常:{ex.InnerException}", ex);

      }

  }

  
  

  
  

  0 回复
• 冬天 VIP0

  2025/8/22

  public async Task<object> GetScalarAsync(

      string sqlCommand, 

      object parameters = null,

      int commandTimeout = 60,

      CancellationToken cancellationToken = default)

  {

      using (var connection = new OracleConnection(_connectionString))

      {

          // 创建双重超时控制机制：

          // 1. 内部默认30秒全局超时

          // 2. 合并外部传入的取消令牌

          using var cts = new CancellationTokenSource(TimeSpan.FromSeconds(30));

          using var linkedToken = CancellationTokenSource.CreateLinkedTokenSource(cancellationToken, cts.Token);

  
  

          await connection.OpenAsync(linkedToken.Token);

  
  

          using var command = CreateCommand(connection, sqlCommand, parameters);

          command.CommandTimeout = commandTimeout;

  
  

          object scalar = await command.ExecuteScalarAsync(linkedToken.Token);

  
  

          return scalar;

      }

  }

  
  

  0 回复