Golang（w/gocql 驱动程序）不返回 Cassandra DB 中的所有条目答案

【问题标题】：Golang (w/gocql driver) not returning all entries in Cassandra DBGolang（w/gocql 驱动程序）不返回 Cassandra DB 中的所有条目
【发布时间】：2018-09-12 18:13:52
【问题描述】：

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

我正在尝试进行简单的写入，然后在两个单独的函数中读取所有请求。我希望我会在 read all 请求中获得所有条目，但我只获得 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 xyz@xyz.com
app_1          | [18:09:54][WEBSERVER] : Iter messagecontent: %v a
app_1          | [18:09:54][WEBSERVER] : Iter messagefrom: %v abc@abc.com

这不是我所期望的，因为这是读取的输出，多次写入数据库。如果您查看各种 queryString 值上的 cmets，我尝试过其中 2 个在我期望返回所有条目时什么都不返回，其中 2 个只返回最后一个写入条目（据我所知，它们都是对称查询）。

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

谢谢。

【问题讨论】：

标签： database docker go cassandra crud

【解决方案1】：

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

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

设法解决了这个问题。

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

【讨论】：