地理位置查詢
地理位置查詢包括地理距離查詢(GeoDistanceQuery)、地理長(zhǎng)方形范圍查詢(GeoBoundingBoxQuery)和地理多邊形范圍查詢(GeoPolygonQuery)三種方式。
前提條件
- 已初始化Client。具體操作,請(qǐng)參見(jiàn)初始化OTSClient。
- 已創(chuàng)建數(shù)據(jù)表并寫(xiě)入數(shù)據(jù)。
- 已在數(shù)據(jù)表上創(chuàng)建多元索引。具體操作,請(qǐng)參見(jiàn)創(chuàng)建多元索引。
地理距離查詢(GeoDistanceQuery)
GeoDistanceQuery根據(jù)一個(gè)中心點(diǎn)和距離條件查詢表中的數(shù)據(jù),當(dāng)一個(gè)地理位置點(diǎn)到指定的中心點(diǎn)的距離不超過(guò)指定的值時(shí),滿足查詢條件。
參數(shù)
參數(shù)
說(shuō)明
FieldName
列名,類型為Geopoint。
CenterPoint
中心地理坐標(biāo)點(diǎn),是一個(gè)經(jīng)緯度值。
格式為“緯度,經(jīng)度”,緯度在前,經(jīng)度在后,且緯度范圍為-90~+90,經(jīng)度范圍-180~+180。例如“35.8,-45.91”。
DistanceInMeter
距離中心點(diǎn)的距離,類型為Double。單位為米。
Query
多元索引的查詢語(yǔ)句。設(shè)置查詢類型為GeoDistanceQuery。
TableName
數(shù)據(jù)表名稱。
IndexName
多元索引名稱。
示例
以下示例用于查詢表中Col_GeoPoint列的值距離中心點(diǎn)不超過(guò)一定距離的數(shù)據(jù)。
func GeoDistanceQuery(client *tablestore.TableStoreClient, tableName string, indexName string) { searchRequest := &tablestore.SearchRequest{} searchRequest.SetTableName(tableName) searchRequest.SetIndexName(indexName) query := &search.GeoDistanceQuery{} //設(shè)置查詢類型為GeoDistanceQuery。 query.FieldName = "Col_GeoPoint" query.CenterPoint = "5,5" //設(shè)置中心點(diǎn)。 query.DistanceInMeter = 10000.0 //設(shè)置條件為到中心點(diǎn)的距離不超過(guò)10000米。 searchQuery := search.NewSearchQuery() searchQuery.SetQuery(query) searchRequest.SetSearchQuery(searchQuery) // 設(shè)置返回所有列 searchRequest.SetColumnsToGet(&tablestore.ColumnsToGet{ ReturnAll:true, }) searchResponse, err := client.Search(searchRequest) if err != nil { fmt.Printf("%#v", err) return } fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess) //查看返回結(jié)果是否完整。 fmt.Println("TotalCount: ", searchResponse.TotalCount) //打印匹配到的總行數(shù),非返回行數(shù)。 fmt.Println("RowCount: ", len(searchResponse.Rows)) for _, row := range searchResponse.Rows { jsonBody, err := json.Marshal(row) if err != nil { panic(err) } fmt.Println("Row: ", string(jsonBody)) } }
地理長(zhǎng)方形范圍查詢(GeoBoundingBoxQuery)
GeoBoundingBoxQuery根據(jù)一個(gè)長(zhǎng)方形范圍的地理位置邊界條件查詢表中的數(shù)據(jù),當(dāng)一個(gè)地理位置點(diǎn)落在給出的長(zhǎng)方形范圍內(nèi)時(shí)滿足查詢條件。
參數(shù)
參數(shù)
說(shuō)明
FieldName
列名,類型為Geopoint。
TopLeft
長(zhǎng)方形框的左上角的坐標(biāo)。
BottomRight
長(zhǎng)方形框的右下角的坐標(biāo),通過(guò)左上角和右下角就可以確定一個(gè)唯一的長(zhǎng)方形。
格式為“緯度,經(jīng)度”,緯度在前,經(jīng)度在后,且緯度范圍為-90~+90,經(jīng)度范圍-180~+180。例如“35.8,-45.91”。
Query
多元索引的查詢語(yǔ)句。設(shè)置查詢類型為GeoBoundingBoxQuery。
TableName
數(shù)據(jù)表名稱。
IndexName
多元索引名稱。
示例
以下示例用于查詢表中Col_GeoPoint列的值在左上角為"10,0", 右下角為"0,10"的長(zhǎng)方形范圍內(nèi)的數(shù)據(jù)。
func GeoBoundingBoxQuery(client *tablestore.TableStoreClient, tableName string, indexName string) { searchRequest := &tablestore.SearchRequest{} searchRequest.SetTableName(tableName) searchRequest.SetIndexName(indexName) query := &search.GeoBoundingBoxQuery{} //設(shè)置查詢類型為GeoBoundingBoxQuery。 query.FieldName = "Col_GeoPoint" //設(shè)置列名。 query.TopLeft = "10,0" //設(shè)置長(zhǎng)方形左上角。 query.BottomRight = "0,10" //設(shè)置長(zhǎng)方形右下角。 searchQuery := search.NewSearchQuery() searchQuery.SetQuery(query) searchRequest.SetSearchQuery(searchQuery) //設(shè)置為返回所有列。 searchRequest.SetColumnsToGet(&tablestore.ColumnsToGet{ ReturnAll:true, }) searchResponse, err := client.Search(searchRequest) if err != nil { fmt.Printf("%#v", err) return } fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess) //查看返回結(jié)果是否完整。 fmt.Println("TotalCount: ", searchResponse.TotalCount) //打印匹配到的總行數(shù),非返回行數(shù)。 fmt.Println("RowCount: ", len(searchResponse.Rows)) for _, row := range searchResponse.Rows { jsonBody, err := json.Marshal(row) if err != nil { panic(err) } fmt.Println("Row: ", string(jsonBody)) } }
地理多邊形范圍查詢(GeoPolygonQuery)
GeoPolygonQuery根據(jù)一個(gè)多邊形范圍條件查詢表中的數(shù)據(jù),當(dāng)一個(gè)地理位置點(diǎn)落在指定的多邊形范圍內(nèi)時(shí)滿足查詢條件。
參數(shù)
參數(shù)
說(shuō)明
FieldName
列名,類型為Geopoint。
Points
組成多邊形的距離坐標(biāo)點(diǎn)。
格式為“緯度,經(jīng)度”,緯度在前,經(jīng)度在后,且緯度范圍為-90~+90,經(jīng)度范圍-180~+180。例如“35.8,-45.91”。
Query
多元索引的查詢語(yǔ)句。設(shè)置查詢類型為GeoPolygonQuery。
TableName
數(shù)據(jù)表名稱。
IndexName
多元索引名稱。
示例
以下示例用于查詢表中Col_GeoPoint列的值在一個(gè)給定多邊形范圍內(nèi)的數(shù)據(jù)。
func GeoPolygonQuery(client *tablestore.TableStoreClient, tableName string, indexName string) { searchRequest := &tablestore.SearchRequest{} searchRequest.SetTableName(tableName) searchRequest.SetIndexName(indexName) query := &search.GeoPolygonQuery{} //設(shè)置查詢類型為GeoDistanceQuery。 query.FieldName = "Col_GeoPoint" query.Points = []string{"0,0","5,5","5,0"} //設(shè)置多邊形的頂點(diǎn)。 searchQuery := search.NewSearchQuery() searchQuery.SetQuery(query) searchRequest.SetSearchQuery(searchQuery) //設(shè)置為返回所有列。 searchRequest.SetColumnsToGet(&tablestore.ColumnsToGet{ ReturnAll:true, }) searchResponse, err := client.Search(searchRequest) if err != nil { fmt.Printf("%#v", err) return } fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess) //查看返回結(jié)果是否完整。 fmt.Println("TotalCount: ", searchResponse.TotalCount) //打印匹配到的總行數(shù),非返回行數(shù)。 fmt.Println("RowCount: ", len(searchResponse.Rows)) for _, row := range searchResponse.Rows { jsonBody, err := json.Marshal(row) if err != nil { panic(err) } fmt.Println("Row: ", string(jsonBody)) } }
常見(jiàn)問(wèn)題
相關(guān)文檔
多元索引查詢類型包括精確查詢、多詞精確查詢、全匹配查詢、匹配查詢、短語(yǔ)匹配查詢、前綴查詢、范圍查詢、通配符查詢、多條件組合查詢、地理位置查詢、嵌套類型查詢、向量檢索和列存在性查詢,您可以選擇合適的查詢類型進(jìn)行多維度數(shù)據(jù)查詢。
如果要對(duì)結(jié)果集進(jìn)行排序或者翻頁(yè),您可以使用排序和翻頁(yè)功能來(lái)實(shí)現(xiàn)。具體操作,請(qǐng)參見(jiàn)排序和翻頁(yè)。
如果要按照某一列對(duì)結(jié)果集做折疊,使對(duì)應(yīng)類型的數(shù)據(jù)在結(jié)果展示中只出現(xiàn)一次,您可以使用折疊(去重)功能來(lái)實(shí)現(xiàn)。具體操作,請(qǐng)參見(jiàn)折疊(去重)。
如果要進(jìn)行數(shù)據(jù)分析,例如求最值、求和、統(tǒng)計(jì)行數(shù)等,您可以使用Search接口的統(tǒng)計(jì)聚合功能或者SQL查詢來(lái)實(shí)現(xiàn)。具體操作,請(qǐng)參見(jiàn)統(tǒng)計(jì)聚合和SQL查詢。
如果要快速導(dǎo)出數(shù)據(jù),而不關(guān)心整個(gè)結(jié)果集的順序時(shí),您可以使用ParallelScan接口和ComputeSplits接口實(shí)現(xiàn)多并發(fā)導(dǎo)出數(shù)據(jù)。具體操作,請(qǐng)參見(jiàn)并發(fā)導(dǎo)出數(shù)據(jù)。