如何使用gocql查询cassandra udt？

dw1jzc5e 于 2021-06-09 发布在 Cassandra

关注(0)|答案(1)|浏览(434)

Cassandra表和udt

CREATE TYPE IF NOT EXISTS phone_type(
   code TEXT,
   phone TEXT,
);

CREATE TABLE IF NOT EXISTS user_by_phone(
    user_id UUID,
    phone FROZEN<phone_type>,
    password TEXT,
    PRIMARY KEY (phone)
);

golang构造

type PhoneType struct {
    Code  string `json:"code"`
    Phone string `json:"phone"`
}
phone := PhoneType{
    Code:  "+1",
    Phone: "7777777777",
}

gqcql查询

err := Session.Query("SELECT user_id, password FROM user_by_phone WHERE phone=?;", phone).Scan(
    &user.UserID,
    &user.Password,
)

在cassandra表中有记录时，使用此代码返回not found event。如何使用gocql进行udt查询？

cassandra go gocql

来源：https://stackoverflow.com/questions/64215104/how-to-query-cassandra-udt-using-gocql

1条答案

按热度按时间

13z8s7eq1#

尝试这样定义结构（使用 cql 而不是 json 在结构定义中）

type PhoneType struct {
    Code  string `cql:"code"`
    Phone string `cql:"phone"`
}

phone := PhoneType{
    Code:  "+1",
    Phone: "7777777777",
}

举个例子：https://github.com/gocql/gocql/blob/master/udt_test.go
这对我很有用：

var id gocql.UUID
    var password string

    iter := session.Query("SELECT user_id, password FROM user_by_phone WHERE phone=?;", phone).Iter()
    for iter.Scan(&id, &password) {
        fmt.Println("Phone Record:", id, password)
    }
    if err := iter.Close(); err != nil {
        log.Fatal(err)
    }

赞(0）回复(0）举报 2021-06-09

我来回答

如何使用gocql查询cassandra udt？

1条答案

相关问题

热门标签

最新问答