当前位置： > > > > Golang（带 gocql 驱动程序）未返回 Cassandra DB 中的所有条目

Golang（带 gocql 驱动程序）未返回 Cassandra DB 中的所有条目

来源：stackoverflow
2024-04-19 12:18:37
0浏览
收藏

米云今天将给大家带来《Golang（带 gocql 驱动程序）未返回 Cassandra DB 中的所有条目》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

问题内容

我在 cassandra 的 gocql 驱动程序或 cassandra 数据库本身中发现了一个奇怪的错误。

我正在尝试进行简单的写入，然后在两个单独的函数中读取所有请求。我希望能够获得读取所有请求的所有条目，但我只获得 cassandra 中的最后一个条目。

这是我编写的方式：

util.casssession, _ = util.casscluster.createsession()
    defer util.casssession.close()
    keyspacemeta, _ := util.casssession.keyspacemetadata("platypus")
    valc, exists := keyspacemeta.tables["cassmessage"]

    if exists==true {
        fmt.println("cassmessage exists!!!")
    }else{
        fmt.println("cassmessage doesnt exist!")
    }

    if valc!=nil{
        fmt.println("return from valc cassmessage: ", valc)
    }

    insertstring:=`insert into cassmessage 
    (messagefrom, messageto, messagecontent) 
    values('`+sendmsgreq.messagefrom+`', '`
    +sendmsgreq.messageto+`', '`+sendmsgreq.messagecontent+`')`

    fmt.println("insertstring value: ", insertstring)

    err := util.casssession.query(insertstring).exec()

if err != nil {
        fmt.println("there was an error in appending data to cassmessage: ", err)
    } else {
        fmt.println("inserted data into cassmessage successfully")
    }

上面的终端输出：

app_1          | [17:59:43][webserver] : cassmessage exists!!!
app_1          | [17:59:43][webserver] : return from valc cassmessage:
&{platypus cassmessage    [] []  
[0xc000400140] [] map[messagefrom:0xc0004000a0 
messageto:0xc000400140 messagecontent:0xc000400000] 
[messagecontent messagefrom messageto]}
app_1          | [17:59:43][webserver] : inserted data into cassmessage successfully

我不完全确定 valc 的输出返回什么，尽管它似乎是某种内存地址，这是一个好兆头。我还发现我在 write exec 函数上没有收到任何错误，这是有希望的。

这是我阅读的方式：

util.casssession, _ = util.casscluster.createsession()
defer util.casssession.close()
keyspacemeta, _ := util.casssession.keyspacemetadata("platypus")
valc, exists := keyspacemeta.tables["cassmessage"]

querystring := `select messageto, messagecontent, messagefrom from cassmessage where messagefrom='`+mailreq.email+`'`
//returns nothing, should return many rows
querystring2 := `select messageto, messagecontent, messagefrom from cassmessage`
//returns only last entry, should return many rows
querystring3 := `select * from cassmessage where messagefrom='`+mailreq.email+`'`
//returns nothing, should return many rows
queryallstring := `select * from cassmessage` 
//returns only last entry, should return many rows

var messageto string
var messagecontent string
var messagefrom string

iter := util.casssession.query(queryallstring).iter()
for iter.scan(&messageto, &messagecontent, &messagefrom) {
    fmt.println("iter messageto: %v", messageto)
    fmt.println("iter messagecontent: %v", messagecontent)
    fmt.println("iter messagefrom: %v", messagefrom)
}

上面的终端输出：

app_1          | [18:09:54][WEBSERVER] : Iter messageto: %v [email protected]
app_1          | [18:09:54][WEBSERVER] : Iter messagecontent: %v a
app_1          | [18:09:54][WEBSERVER] : Iter messagefrom: %v [email protected]

这不是我所期望的，因为这是多次写入数据库之后读取的输出。如果您查看对各种 querystring 值的评论，我已经尝试过，当我期望返回所有条目时，其中 2 个不会返回任何内容，而其中 2 个仅返回最后一个写入条目（据我所知，它们都是对称查询）。 p>

有谁知道为什么我无法使用 iter 返回多个条目，或者为什么我尝试过的不同查询字符串上的四个不同值返回不同的结果？

谢谢。

解决方案

我也许不应该这样做，但我会将其保留在这里，以防其他人遇到同样的问题。我不确定表中的主键是唯一的。做这样的事情：

util.CassSession.Query("CREATE TABLE cassmessage(" +
    "messageto text, messagefrom text, messagecontent text, uniqueID text, PRIMARY KEY (uniqueID))").Exec()

设法解决问题。

感谢所有看过并提供帮助的人。干杯！

今天关于《Golang（带 gocql 驱动程序）未返回 Cassandra DB 中的所有条目》的内容介绍就到此结束，如果有什么疑问或者建议，可以在米云公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！