如何使用gocql在cassandra中创建密钥空间

Question

有没有办法用gocql在cassandra中创建一个新的密钥空间？

Answer 1

我认为库中没有任何特定的命令，但是他们通过使用create命令- reference/cqlCreateKeyspace.html发出一个普通查询来创建键空间作为测试的一部分(在下面复制)。

func createKeyspace(tb testing.TB, cluster *ClusterConfig, keyspace string) {
    c := *cluster
    c.Keyspace = "system"
    c.Timeout = 20 * time.Second
    session, err := c.CreateSession()
    if err != nil {
        tb.Fatal("createSession:", err)
    }

    err = session.control.query(`DROP KEYSPACE IF EXISTS ` + keyspace).Close()
    if err != nil {
        tb.Fatal(err)
    }

    err = session.control.query(fmt.Sprintf(`CREATE KEYSPACE %s
    WITH replication = {
        'class' : 'SimpleStrategy',
        'replication_factor' : %d
    }`, keyspace, *flagRF)).Close()

    if err != nil {
        tb.Fatal(err)
    }
}

有关测试中的源代码的问题和链接，请参见这里- https://github.com/gocql/gocql/issues/566。

Answer 2

你试过用CREARE KEYSPACE ....执行session.Query吗？键空间创建只是另一个CQL语句..。