我想得到一个给定表的分区列表。
public record Partition(string PartitionName, int OrdinalPosition);
public class MysqlService
{
//...
public IEnumerable<Partition> GetPartitions(string tableName)
{
using var conn = new MySqlConnection(_dbConnString);
conn.Open();
return conn.Query<Partition>(
$"SELECT PARTITION_NAME, PARTITION_ORDINAL_POSITION " +
$"FROM information_schema.partitions WHERE TABLE_NAME = '{tableName}';");
}
}
但是我的代码给出了一个错误
Unhandled exception. System.InvalidOperationException: A parameterless default constructor or one matching signature (System.String PARTITION_NAME, System.UInt64 PARTITION_ORDINAL_POSITION) is required for Services.Partition materialization
at Dapper.SqlMapper.GenerateDeserializerFromMap(Type type, IDataReader reader, Int32 startBound, Int32 length, Boolean returnNullIfFirstMissing, ILGenerator il) in /_/Dapper/SqlMapper.cs:line 3297
at Dapper.SqlMapper.GetTypeDeserializerImpl(Type type, IDataReader reader, Int32 startBound, Int32 length, Boolean returnNullIfFirstMissing) in /_/Dapper/SqlMapper.cs:line 3131
at Dapper.SqlMapper.TypeDeserializerCache.GetReader(IDataReader reader, Int32 startBound, Int32 length, Boolean returnNullIfFirstMissing) in /_/Dapper/SqlMapper.TypeDeserializerCache.cs:line 151
at Dapper.SqlMapper.TypeDeserializerCache.GetReader(Type type, IDataReader reader, Int32 startBound, Int32 length, Boolean returnNullIfFirstMissing) in /_/Dapper/SqlMapper.TypeDeserializerCache.cs:line 50
at Dapper.SqlMapper.GetTypeDeserializer(Type type, IDataReader reader, Int32 startBound, Int32 length, Boolean returnNullIfFirstMissing) in /_/Dapper/SqlMapper.cs:line 3085
at Dapper.SqlMapper.GetDeserializer(Type type, IDataReader reader, Int32 startBound, Int32 length, Boolean returnNullIfFirstMissing) in /_/Dapper/SqlMapper.cs:line 1835
at Dapper.SqlMapper.QueryImpl[T](IDbConnection cnn, CommandDefinition command, Type effectiveType)+MoveNext() in /_/Dapper/SqlMapper.cs:line 1105
at System.Collections.Generic.List`1..ctor(IEnumerable`1 collection)
at System.Linq.Enumerable.ToList[TSource](IEnumerable`1 source)
at Dapper.SqlMapper.Query[T](IDbConnection cnn, String sql, Object param, IDbTransaction transaction, Boolean buffered, Nullable`1 commandTimeout, Nullable`1 commandType) in /_/Dapper/SqlMapper.cs:line 734
...
我该怎么补救呢?
对于OrdinalPosition
类型,我尝试使用UInt64
而不是int
,但发生了相同的错误。
我的环境:
- C# .NET核心控制台应用程序(net6.0)
- 接头2.0.123
- MySQL 8.0
2条答案
按热度按时间xpszyzbs1#
类型和名称必须匹配(或者使用自定义Map)。在C#中,可以使用别名来获得“更好的”名称:
public record Partion(string PartitionName, uint64 OrdinalPosition)
您还应该通过使用WHERE子句构建字符串来处理潜在的SQL注入问题。
Dapper让这一切变得很容易:
k7fdbhmy2#
相同异常。您可以按如下方式创建ctor: