集合 CassandraCSharpDriver 中不允许使用非冻结的 UDT答案

【问题标题】：Non-frozen UDTs are not allowed inside collections CassandraCSharpDriver集合 CassandraCSharpDriver 中不允许使用非冻结的 UDT
【发布时间】：2019-11-23 09:09:40
【问题描述】：

我是自定义记录我的 .netcore 项目的 cassandra，我正在使用 CassandraCSharpDriver。

问题： 我已经为日志中的参数创建了 UDT，并将日志表中的 paramUDT 列表添加为冻结。但我收到错误：Non-frozen UDTs are not allowed inside collections。我不知道为什么会出现此错误，因为我在日志模型中使用的列表中使用了 Frozen 属性。

logSession.Execute($"CREATE TYPE IF NOT EXISTS {options.Keyspaces.Log}.{nameof(LogParamsCUDT)} (Key text, ValueString text);");

这是型号：

   public class Log
    {
        public int LoggingLevel { get; set; }
        public Guid UserId { get; set; }
        public string TimeZone { get; set; }
        public string Text { get; set; }
        [Frozen]
        public IEnumerable<LogParamsCUDT> LogParams { get; set; }
    }

问题是我做错了什么，我的 UDT 脚本不正确还是需要更改模型。

提前致谢

【问题讨论】：

你能显示你的表定义吗？
@AlexOtt 我正在使用 C# 创建表并在创建表时出错。 var Log = new Table(logSession); Log.CreateIfNotExists();

标签： c# asp.net-core cassandra cassandra-3.0

【解决方案1】：

我已经尝试使用该模型，Table.CreateIfNotExists 运行成功。

代码如下：

public class Program
    {
        public static void Main()
        {
            var cluster = Cluster.Builder().AddContactPoint("127.0.0.1").Build();
            var session = cluster.Connect();
            session.CreateKeyspaceIfNotExists("testks");
            session.ChangeKeyspace("testks");
            session.Execute($"CREATE TYPE IF NOT EXISTS testks.{nameof(LogParamsCUDT)} (Key text, ValueString text);");
            session.UserDefinedTypes.Define(UdtMap.For<LogParamsCUDT>($"{nameof(LogParamsCUDT)}", "testks"));
            var table = new Table<Log>(session);
            table.CreateIfNotExists();
            table.Insert(new Log
            {
                LoggingLevel = 1,
                UserId = Guid.NewGuid(),
                TimeZone = "123",
                Text = "123",
                LogParams = new List<LogParamsCUDT>
                {
                    new LogParamsCUDT
                    {
                        Key = "123",
                        ValueString = "321"
                    }
                }
            }).Execute();
            var result = table.First(l => l.Text == "123").Execute();
            Console.WriteLine(JsonConvert.SerializeObject(result));
            Console.ReadLine();
            table.Where(l => l.Text == "123").Delete().Execute();
        }
    }

    public class Log
    {
        public int LoggingLevel { get; set; }
        public Guid UserId { get; set; }
        public string TimeZone { get; set; }
        [Cassandra.Mapping.Attributes.PartitionKey]
        public string Text { get; set; }
        [Frozen]
        public IEnumerable<LogParamsCUDT> LogParams { get; set; }
    }

    public class LogParamsCUDT
    {
        public string Key { get; set; }

        public string ValueString { get; set; }
    }

请注意，我必须添加 PartitionKey 属性，否则它将无法运行。

这是它生成的 CQL 语句：

CREATE TABLE Log (
    LoggingLevel int, 
    UserId uuid, 
    TimeZone text, 
    Text text, 
    LogParams frozen<list<"testks"."logparamscudt">>, 
    PRIMARY KEY (Text)
)

如果我删除Frozen 属性，则会出现此错误：Cassandra.InvalidQueryException: 'Non-frozen collections are not allowed inside collections: list<testks.logparamscudt>'。

如果您的意图是创建一个类似LogParams frozen<list<"testks"."logparamscudt">> 的列，那么Frozen 属性将起作用。相反，如果您只想冻结 UDT，即 LogParams list<frozen<"testks"."logparamscudt">>，那么 AFAIK 的 Frozen 属性将不起作用，您不能依赖驱动程序为您生成 CREATE 语句。

我所有的测试都是使用最新的 C# 驱动程序 (3.10.1) 针对 cassandra 3.0.18 完成的。

【讨论】：