首页 文章

Cassandra UDT嵌套集InvalidTypeExeception

提问于
浏览
2

我正在使用Cassandra 2.1中的UDT进行实验,并在使用InvalidTypeExeception时遇到困难 .

我将表格设置为:

session.execute("CREATE TYPE mykeyspace.address (" +
                    "  street text," +
                    "  city text," +
                    "  zip_code int," +
                    "  phones set<text>" +
                    ");"
    );
    session.execute("CREATE TYPE mykeyspace.fullname (" +
                    "  firstname text," +
                    "  lastname text" +
                    ");"
    );
    session.execute(
            "CREATE TABLE mykeyspace.users (" +
                    "  id uuid PRIMARY KEY," +
                    "  name frozen <fullname>," +
                    "  direct_reports set<frozen <fullname>>," +
                    "  addresses map<text, frozen <address>>" +
                    ");  ");

然后运行以下测试:

PreparedStatement statement = session.prepare("INSERT INTO mykeyspace.users (id, name, addresses) VALUES (?, ?, ?);");

UserType fullNameType = session.getCluster().getMetadata().getKeyspace("mykeyspace").getUserType("fullname");
UserType addresType = session.getCluster().getMetadata().getKeyspace("mykeyspace").getUserType("address");

BoundStatement boundStatement = new BoundStatement(statement);

UUID uuid = UUID.randomUUID();

UDTValue name = fullNameType.newValue().setString("firstname", "john").setString("lastname", "smith");


UDTValue address = addresType.newValue()
        .setString("street", "1 long st")
        .setString("city", "sydney")
        .setInt("zip_code", 2000)
        .setSet("phones",ImmutableSet.of("123", "456", "789")); // ERROR THROWN HERE

Map<String, UDTValue> addresses = new HashMap<String, UDTValue>();
addresses.put("home", address);
session.execute(boundStatement.bind(
        uuid,
        name,
        addresses
));

我收到针对.setSet(“phone”...)行的以下错误:

Exception in thread "main" com.datastax.driver.core.exceptions.InvalidTypeException: 
Column phones is of type 'org.apache.cassandra.db.marshal.FrozenType(org.apache.cassandra.db.marshal.SetType(org.apache.cassandra.db.marshal.UTF8Type))', cannot set to a set

只是对我做错了什么以及我错过了哪些东西感到困惑,我确信它显而易见但是无法弄清楚...

谢谢!

1 回答

  • 1

    那将是驱动程序中的一个错误 . 如果您've made sure that you'使用上次发布的驱动程序版本(以确保它尚未修复),请在java driver jira上报告 .

相关问题