gocql не может демаршалировать blob-объект в * [20] uint8

У меня вопрос, связанный с использованием типа blob в качестве ключа раздела. Я использую его, так как мне нужно сохранить хеш-значение. (хеш-значение возвращает двоичные данные. обычно в шестнадцатеричном формате.)

Я попробовал выбрать запрос с помощью gocql, но он не прошел со следующей ошибкой. Есть ли способ получить успешный результат для такого рода запросов?

Ваш совет высоко оценен !!

- результат hash_value: [208 61 222 22 16 214 223 135 169 6 25 65 44 237 166 229 50 5 40 221] / hash_value:? = ?? ߇? A, ??? 2 (? / hash_value: 0xd03dde1610d6df87a90619412ceda6e5320528dd string 2018 / 03/22 10:03:17 не может демаршалировать blob в * [20] uint8

- select.go

package main


import (
  "fmt"
  "log"
  "crypto/sha1"
  "reflect"
  "github.com/gocql/gocql"
)


func main() {
  cluster := gocql.NewCluster("10.0.0.1")
  cluster.Keyspace = "ks"
  cluster.Consistency = gocql.Quorum
  cluster.ProtoVersion = 4
  cluster.Authenticator = gocql.PasswordAuthenticator{
    Username: "cassandra",
    Password: "cassandra",
  }


  session, _ := cluster.CreateSession()
  defer session.Close()


  text := "text before hashed"
  data := []byte(text)
  hash_value := sha1.Sum(data)
  hexa_string := fmt.Sprintf("0x%x", hash_value)


  fmt.Println("hash_value: ", hash_value)
  fmt.Println(" / string: ", string(hash_value[:]))
  fmt.Println(" / column1: ", hexa_string)
  fmt.Println(reflect.TypeOf(hexa_string))


  // *** select  ***
  var column1 int
  returned_hash := sha1.Sum(data)


  //if err := session.Query(`SELECT hash_value, column1 FROM sample WHERE hash_value= ? LIMIT 1`,
  //  hexa_string).Consistency(gocql.One).Scan(&returned_hash, &column1); err != nil {
  if err := session.Query(`SELECT hash_value, column1 FROM sample WHERE hash_value=0xd03dde1610d6df87a90619412ceda6e5320528dd`).Consistency(gocql.One).Scan(&returned_hash, &column1); err != nil {
      //fmt.Println(err)
      log.Fatal(err)
  }
  fmt.Println("comment: ", returned_hash, user_id)


}

- определение таблицы -

CREATE TABLE IF NOT EXISTS ks.samle (
  hash_value blob,
  column1 int,
  ...
  PRIMARY KEY((hash_value), column1)
) WITH CLUSTERING ORDER BY (column1 DESC);

go cassandra gocql
person simotunes    schedule 23.03.2018    source источник

Ответы (1)


arrow_upward
0
arrow_downward

Я исправил проблему, изменив тип переменной: return_hash.

  • return_hash (var для хранения возвращенного результата) должен быть [] байт.

Я понимаю следующее.

  • marshal: преобразовать данные, указанные в коде, в тип, который может обрабатывать cassandra.
  • unmarshal: преобразовать данные, возвращенные cassandra, обратно в тип, который может обрабатывать golang-code.
  • исходная ошибка означает, что последний шаблон не работает. поэтому тип return_hash должен быть неправильным.

Поправьте меня если я ошибаюсь. благодаря.

package main

import (
  "fmt"
  "log"
  "crypto/sha1"
  "reflect"
  "github.com/gocql/gocql"
)

func main() {
  cluster := gocql.NewCluster("127.0.0.1")
  cluster.Keyspace = "browser"
  cluster.Consistency = gocql.Quorum
  //cluster.ProtoVersion = 4
  //cluster.Authenticator = gocql.PasswordAuthenticator{
  //  Username: "cassandra",
  //  Password: "cassandra",
  //}

  session, _ := cluster.CreateSession()
  defer session.Close()

  text := "text before hashed"
  data := []byte(text)
  hash_value := sha1.Sum(data)
  hexa_string := fmt.Sprintf("0x%x", hash_value)

  fmt.Println("hash_value: ", hash_value)
  fmt.Println(" / string(hash_value): ", string(hash_value[:]))
  fmt.Println(" / hexa(hash_value): ", hexa_string)
  fmt.Println(reflect.TypeOf(hexa_string))

  // *** select  ***
  var column1 int
  //returned_hash := sha1.Sum(data)
  //var returned_hash *[20]uint8
  var returned_hash []byte

  if err := session.Query(`SELECT hash_value, column1 FROM sample WHERE hash_value=? LIMIT 1`,
  hash_value[:]).Consistency(gocql.One).Scan(&returned_hash, &column1); err != nil {
  //if err := session.Query(`SELECT hash_value, column1 FROM sample WHERE hash_value=0xd03dde1610d6df87a90619412ceda6e5320528dd`).Consistency(gocql.One).Scan(&returned_hash, &column1); err != nil {
      log.Fatal(err)
  }
  fmt.Printf("Returned: %#x %d \n", returned_hash, column1)

}
person simotunes    schedule 23.03.2018