当前位置: 首页 > article >正文

dapper+mysql查询报Error parsing column 0 (Id=<null>)

之前的分页接口都是正常的,突然就报错了Error parsing column 0 (Id=<null>)

{
    "error": {
        "code": null,
        "message": "Error parsing column 0 (Id=<null>)",
        "details": "DataException: Error parsing column 0 (Id=<null>)\r\nSTACK TRACE:    at Dapper.SqlMapper.ThrowDataException(Exception ex, Int32 index, IDataReader reader, Object value) in /_/Dapper/SqlMapper.cs:line 3706\r\n   at Deserialize38f40c2b-6cb7-408c-8e8a-4c264ff79615(IDataReader)\r\n   at Dapper.SqlMapper.GridReader.ReadBufferedAsync[T](Int32 index, Func`2 deserializer)\r\n   at Dapper.SqlMapper.GridReader.ReadBufferedAsync[T](Int32 index, Func`2 deserializer)\r\n   at Tzkj.Superhard.Talent.Query.TalentServiceDapperRepositoryBase.GetPagedResultAsync[T](String tablesJoinStr, String columnsStr, String whereStr, String orderByStr, Int32 pageIndex, Int32 pageSize, DynamicParameters queryParams)\r\n   at Tzkj.Superhard.Talent.Query.ExpertAdvices.ExpertAdviceDapperRepository.GetPagedResultAsyncAdmin(String keyword, String create_time, Int32 pageIndex, Int32 pageSize)\r\n   at Tzkj.Superhard.Talent.ExpertAdvices.ExpertAdviceAppService.GetPagedResultAsyncAdmin(GetExpertAdviceListInput getExpertAdviceListInput)\r\n   at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo)\r\n   at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapterWithReturnValue`1.ProceedAsync()\r\n   at Volo.Abp.GlobalFeatures.GlobalFeatureInterceptor.InterceptAsync(IAbpMethodInvocation invocation)\r\n   at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed)\r\n   at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo)\r\n   at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapterWithReturnValue`1.ProceedAsync()\r\n   at Volo.Abp.Validation.ValidationInterceptor.InterceptAsync(IAbpMethodInvocation invocation)\r\n   at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed)\r\n   at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo)\r\n   at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapterWithReturnValue`1.ProceedAsync()\r\n   at Volo.Abp.Auditing.AuditingInterceptor.ProceedByLoggingAsync(IAbpMethodInvocation invocation, AbpAuditingOptions options, IAuditingHelper auditingHelper, IAuditLogScope auditLogScope)\r\n   at Volo.Abp.Auditing.AuditingInterceptor.InterceptAsync(IAbpMethodInvocation invocation)\r\n   at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed)\r\n   at Castle.DynamicProxy.AsyncInterceptorBase.ProceedAsynchronous[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo)\r\n   at Volo.Abp.Castle.DynamicProxy.CastleAbpMethodInvocationAdapterWithReturnValue`1.ProceedAsync()\r\n   at Volo.Abp.Uow.UnitOfWorkInterceptor.InterceptAsync(IAbpMethodInvocation invocation)\r\n   at Volo.Abp.Castle.DynamicProxy.CastleAsyncAbpInterceptorAdapter`1.InterceptAsync[TResult](IInvocation invocation, IInvocationProceedInfo proceedInfo, Func`3 proceed)\r\n   at Tzkj.Superhard.Talent.ExpertAdvices.ExpertAdviceController.GetPagedResultAsyncAdmin(GetExpertAdviceListInput getTalentPoolListInput)\r\n   at lambda_method1332(Closure, Object)\r\n   at Microsoft.AspNetCore.Mvc.Infrastructure.ActionMethodExecutor.AwaitableObjectResultExecutor.Execute(ActionContext actionContext, IActionResultTypeMapper mapper, ObjectMethodExecutor executor, Object controller, Object[] arguments)\r\n   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeActionMethodAsync>g__Logged|12_1(ControllerActionInvoker invoker)\r\n   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeNextActionFilterAsync>g__Awaited|10_0(ControllerActionInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)\r\n   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.Rethrow(ActionExecutedContextSealed context)\r\n   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.Next(State& next, Scope& scope, Object& state, Boolean& isCompleted)\r\n   at Microsoft.AspNetCore.Mvc.Infrastructure.ControllerActionInvoker.<InvokeInnerFilterAsync>g__Awaited|13_0(ControllerActionInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)\r\n   at Microsoft.AspNetCore.Mvc.Infrastructure.ResourceInvoker.<InvokeNextExceptionFilterAsync>g__Awaited|26_0(ResourceInvoker invoker, Task lastTask, State next, Scope scope, Object state, Boolean isCompleted)\r\nFormatException: Could not parse CHAR(36) value as Guid: 3\r\nSTACK TRACE:    at MySqlConnector.Core.TextRow.GetValueCore(ReadOnlySpan`1 data, ColumnDefinitionPayload columnDefinition) in /_/src/MySqlConnector/Core/TextRow.cs:line 57\r\n   at MySqlConnector.Core.Row.GetValue(Int32 ordinal) in /_/src/MySqlConnector/Core/Row.cs:line 38\r\n   at MySqlConnector.Core.Row.get_Item(Int32 ordinal) in /_/src/MySqlConnector/Core/Row.cs:line 392\r\n   at MySqlConnector.MySqlDataReader.get_Item(Int32 ordinal) in /_/src/MySqlConnector/MySqlDataReader.cs:line 191\r\n   at Deserialize38f40c2b-6cb7-408c-8e8a-4c264ff79615(IDataReader)\r\n",
        "data": {},
        "validationErrors": null
    }
}

分页查询代码如下,执行到这里报错的 var list = await reader.ReadAsync<T>();

 /// <summary>
    /// 
    /// </summary>
    /// <typeparam name="T"></typeparam>
    /// <param name="pageIndex"></param>
    /// <param name="pageSize"></param>
    /// <param name="tablesJoinStr"></param>
    /// <param name="columnsStr"></param>
    /// <param name="whereStr"></param>
    /// <param name="orderByStr"></param>
    /// <param name="queryParams"></param>
    /// <returns></returns>
    /// <exception cref="ArgumentException"></exception>
    protected async Task<PagedResultQto<T>> GetPagedResultAsync<T>(
        string tablesJoinStr,
        string columnsStr,
        string whereStr,
        string orderByStr,
        int pageIndex,
        int pageSize,
        DynamicParameters queryParams = null)
    {
        if (pageIndex <= 0 || pageSize <= 0)
        {
            //throw new ArgumentException("pageIndex与pageSize 不可以小于或等于0");
            throw new UserFriendlyException("pageIndex与pageSize 不可以小于或等于0");
        }
        var skip = (pageIndex - 1) * pageSize;
        var sb = new StringBuilder();
        sb.AppendFormat("SELECT COUNT(1) FROM {0} where {1};", tablesJoinStr, whereStr);
        sb.AppendFormat(@"SELECT {0}
                                FROM {1}
                                WHERE {2}
                                ORDER BY {3}
                                LIMIT @skip,@take", columnsStr, tablesJoinStr, whereStr, orderByStr);

        queryParams ??= new DynamicParameters();
        queryParams.Add("skip", skip, DbType.Int32);
        queryParams.Add("take", pageSize, DbType.Int32);
        var connection = await GetDbConnectionAsync();
        var dbTransaction = await GetDbTransactionAsync();
        using var reader = await connection.QueryMultipleAsync(sb.ToString(), queryParams, transaction: dbTransaction);
        //using var reader = await connection.QueryMultipleAsync(sb.ToString(), queryParams);
        var total = await reader.ReadFirstAsync<long>();
        var list = await reader.ReadAsync<T>();//这里报错了
        return new PagedResultQto<T>(total, list.ToList());
    }

查看返回的报错信息是id字段那报错了,网上说是代码里定义的模型跟数据库表里的类型不一致导致的,我看了下不是这个原因,最后查看查询出来的数据如下:id是1和2两列,那就不对了,代码里定义的是guid类型的,查询出来应该是36位的字符串才能正常转换成guid,所以报错了

综上,是数据库中的异常数据导致的


http://www.kler.cn/a/152904.html

相关文章:

  • 企业营销管理能够实现自动化吗?怎么做?
  • Zigbee—基于Z-STACK组网
  • nodejs_vue+vscode美容理发店会员管理系统un1dm
  • Linux5-计划任务、进程
  • Django同时连接多种数据库
  • postgresql-shared_buffers参数详解
  • 二 使用GPIO的复用功能 利用USART 实现printf()
  • git commmit type格式
  • 树莓派用CSI摄像头,ROS调用时报错Could not find vchostif library
  • MFC中updatedata(False)和Updatedata(TRUE)区别
  • 华为OD机试 - 执行任务赚积分(Java JS Python C)
  • Tomcat-安装与基础配置
  • 【动手学深度学习】(七)丢弃法
  • MySQL之性能分析和系统调优
  • Electron+Ts+Vue+Vite桌面应用系列:TypeScript常用语法详解
  • vue3+vite 批量引入局部组件及使用
  • 【开源视频联动物联网平台】libmodbus 写一个modbus tcp客户端
  • Linux系统:使用CloudDrive实现云盘本地挂载
  • 【PyTorch】(一)简介
  • Git——使用Git进行程序开发