Golang (с драйвером gocql) не возвращает все записи в базе данных Cassandra - PullRequest
Новая
       12

Golang (с драйвером gocql) не возвращает все записи в базе данных Cassandra

0 голосов
/ 12 сентября 2018

У меня есть странная ошибка в драйвере 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, хотя, похоже, это какой-то адрес памяти, что является хорошим признаком. Я также вижу, что я не получаю никакой ошибки в функции записи 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 из них возвращают только последнюю запись записи (насколько мне известно, все они являются симметричными запросами).

Кто-нибудь знает, почему я не могу вернуть несколько записей, используя Iter, или почему мои четыре разных значения в разных строках запроса, которые я пробовал, возвращают разные результаты?

Спасибо.

1 Ответ

0 голосов
/ 12 сентября 2018

Я, возможно, не должен, но я собираюсь оставить это здесь на случай, если кто-то столкнется с той же проблемой. Я не был уверен, что мой первичный ключ в моей таблице был уникальным. Делать что-то вроде этого: 

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

удалось исправить проблему.

Спасибо всем, кто посмотрел и помог. Ура! * * 1006

...