我在尝试编译时遇到此错误:
package main
import "fmt"
import "log"
import "github.com/gocql/gocql"
var (
name, sex string
age int
)
func main() {
// connect to the cluster
cluster := gocql.NewCluster("127.0.0.1")
cluster.Keyspace = "dbaccess"
session, _ := cluster.CreateSession()
defer session.Close()
cluster.ProtoVersion = 4
if err := session.Query("SELECT name, age FROM people WHERE name='doug'").Scan(&name, &age);
err != nil {
log.Fatal(err)
}
fmt.Println(name, age)
}
我加了线
cluster.ProtoVersion = 4
在阅读了here之后,但我太新了,无法理解这是我的问题,还是在其他地方做错了什么。我是否必须等待gocql的更新才能解决此问题,还是应该怎么办?
最佳答案
好的,我在github问题#538线程上使用@Zariel进行了整理。您必须通过第一个gocql东西将ProtoVersion = 4上调为:
package main
import "fmt"
import "log"
import "github.com/gocql/gocql"
var (
name, sex, age string
)
func main() {
// connect to the cluster
cluster := gocql.NewCluster("127.0.0.1")
cluster.ProtoVersion = 4
cluster.Keyspace = "dbaccess"
session, _ := cluster.CreateSession()
defer session.Close()
if err := session.Query("SELECT name, age FROM people WHERE name='doug'").Scan(&name, &age);
err != nil {
log.Fatal(err)
}
fmt.Println(name, age)
}
希望对别人有帮助:)