gocql

1熱度

1回答

使用GOCQL（Golang，Cassandra），我完成128個請求，然後一切都掛起。我相信getTicksForCassandraKey（）函數我正確地發佈查詢，但不知道。 GOCQL只支持多達128個併發查詢，所以我一定在做錯事。所有查詢都是讀取。主要代碼： inboundChannel := make(chan []bson.M, 30) maxGoRoutinesCount := 3

2熱度

1回答

如何使用gocql獲取查詢返回的行數

我正在使用此處記錄的gocql庫：https://godoc.org/github.com/relops/cqlc/cqlc#Fetchable，並且正試圖在golang中編寫一個API調用，它將要求我的數據庫中的所有元素完成特定的字段並返回返回的元素總數。我知道當我在Cassandra界面中時，我可以使用調用SELECT COUNT(*) from table1 WHERE ...;，其中tab

0熱度

1回答

UDT並非適用於協議小於3，請更新配置」

使用UDT：注：cqlsh：show version [cqlsh 5.0.1 | Cassandra 2.2.1 | CQL spec 3.3.0 | Native protocol v4] 表 CREATE TYPE fullname ( firstname text, lastname text ); CREATE TABLE sample ( id i

1熱度

1回答

無法創建連接到Cassandra的會話

我正在使用此gocql程序包。我想讓這個例子工作。 func main() { // connect to the cluster cluster := gocql.NewCluster("192.168.1.1", "192.168.1.2", "192.168.1.3") cluster.ProtoVersion = 3 cluster.Keyspac

0熱度

1回答

帶連接池支持的Golang cassandra客戶端

我們使用gocql（https://github.com/gocql/gocql）驅動程序從我們的golang服務器連接到Cassandra。對於每個http請求，我們正在創建一個新會話並將行插入cassandra。我們覺得爲每個請求創建一個會話需要非常多的資源。典型代碼 func NewSession() (*gocql.Session, error) { config := New

1熱度

1回答

掃描不起作用

我的掃描未更新其目標變量。我有點得到它的工作： ValueName := reflect.New(reflect.ValueOf(value).Elem().Type()) 但我不認爲它是按我想要的方式工作。 func (self LightweightQuery) Execute(incrementedValue interface{}) { existingObj := refl

0熱度

1回答

SliceMap當使用PageSize

我想實現分頁，但是當我使用帶有PageSize的SliceMap時，我得到了所有的行 - 你知道爲什麼和做什麼嗎？注意：我需要由CQL列專家鍵入的行映射。 iter := session.Query("SELECT * FROM paging").PageSize(10).Iter() slicemap, err := iter.SliceMap() saveState := iter.Pa

0熱度

1回答

使用gocql驅動程序在Cassandra中存儲一部分字節

如何使用gocql驅動程序將字節片段存儲爲cassandra blob類型？

1熱度

1回答

尋呼大查詢：總數

關於Cassandra和尋呼。我可能會猜測答案，但只是爲了確定; 我知道如何要求頁面大小，但是有可能獲得查詢的最終總數。就像你查詢select * from tableName的頁面大小爲10，但是如果你沒有使用分頁，你會得到100.使用頁面大小10時可以得到數字100嗎？注意：如果它有任何用處，我正在使用gocql。

0熱度

1回答

GoCQL：元帥字符串轉換成時間戳

我開發聚類列中的時間序列數據模型，即 CREATE TABLE events ( id text, time timestamp, type text, val double, PRIMARY KEY (id, time) ) WITH CLUSTERING ORDER BY (time DESC) 我想與分隔欄「身份證」和集羣列「時間」進行選