golang(带gocql驱动程序)未返回cassandra db中的所有条目

az31mfrm  于 2021-06-15  发布在  Cassandra
关注(0)|答案(1)|浏览(344)

我在这两个地方都有一个奇怪的虫子 gocql cassandra的驱动程序,或者在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 我尝试过的值,其中2个在我期望返回所有条目时不返回任何内容,其中2个只返回最后一个write条目(据我所知,它们都是对称查询)。
有人知道为什么我不能使用iter返回多个条目,或者为什么我在不同的查询字符串上的四个不同值返回不同的结果吗?
谢谢您。

5m1hhzi4

5m1hhzi41#

我也许不应该,但我会把这个放在这里,以防其他人遇到同样的问题。我不确定我表中的主键是唯一的。这样做:

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

设法解决了这个问题。
感谢每一位看了一眼并给予帮助的人。干杯!

相关问题