在 Cassandra 中处理 C# 嵌套类

Question

我有一个如下所示的 C# 类

public class User
{
    public string UserId { get; set; }
    public string Name { get; set; }

    public List<Address> Address { get; set; }
}

public class Address
{
    public string Line1 { get; set; }
}

我创建了如下的键空间和表

ISession session;
        IMapper Mapper;
    Table<User> table;

    var mapping = MappingConfiguration.Global.Define(
                     new Map<User>()
                    .TableName(typeof(User).Name)
                    .PartitionKey(u => u.UserId))

                    ;

        Dictionary<string, string> replication = new Dictionary<string, string>();

        replication.Add("class", "SimpleStrategy");
        replication.Add("replication_factor", "3");
        var cluster = Cluster.Builder()
                                       .AddContactPoints("127.0.1")
                                       .WithPort(9042)
                                       .WithLoadBalancingPolicy(new DCAwareRoundRobinPolicy("test"))
                                       .WithReconnectionPolicy(new FixedReconnectionPolicy(400, 5000, 2 * 60000, 60 * 60000))
                                       .Build();


        session = cluster.Connect();
        session.CreateKeyspaceIfNotExists("demo1", replication);
        session = cluster.Connect("demo1");


        table = new Table<User>(session, mapping, typeof(User).Name, "demo1");
        table.CreateIfNotExists();

我收到以下错误

Cassandra.InvalidTypeException: 'CLR 的未知 Cassandra 目标类型 键入 Casandra.Address'

Answer 1

您的 C# 类 Address 应与 Apache Cassandra 数据库中的字段类型匹配。

在这种情况下，您似乎想使用User-Defined Types (UDT)。 DataStax C# 驱动程序不支持使用Table<T>.Create() 创建嵌套子类型。

理想情况下，您应该首先定义您的架构，该架构应该针对您要用于获取数据的查询进行建模。我建议您先在 CQL 中执行此操作，然后在您的 C# 代码中添加 mapping configuration。

Answer 2

试试下面的

var mapping = MappingConfiguration.Global.Define(
                     For<User>()
                    .TableName(typeof(User).Name)
                    .PartitionKey(u => u.UserId);