地理位置查询包括地理距离查询(GeoDistanceQuery)、地理长方形范围查询(GeoBoundingBoxQuery)和地理多边形范围查询(GeoPolygonQuery)三种方式。
前提条件
地理距离查询(GeoDistanceQuery)
GeoDistanceQuery根据一个中心点和距离条件查询表中的数据,当一个地理位置点到指定的中心点的距离不超过指定的值时,满足查询条件。
- 参数
参数 说明 FieldName 列名,类型为Geopoint。 CenterPoint 中心地理坐标点,是一个经纬度值。 格式为“纬度,经度”,纬度在前,经度在后,且纬度范围为-90~+90,经度范围-180~+180。例如“35.8,-45.91”。
DistanceInMeter 距离中心点的距离,类型为Double。单位为米。 Query 多元索引的查询语句。设置查询类型为GeoDistanceQuery。 TableName 数据表名称。 IndexName 多元索引名称。 - 示例
查询表中Col_GeoPoint列的值距离中心点不超过一定距离的数据。
func GeoDistanceQuery(client *tablestore.TableStoreClient, tableName string, indexName string) { searchRequest := &tablestore.SearchRequest{} searchRequest.SetTableName(tableName) searchRequest.SetIndexName(indexName) query := &search.GeoDistanceQuery{} //设置查询类型为GeoDistanceQuery。 query.FieldName = "Col_GeoPoint" query.CenterPoint = "5,5" //设置中心点。 query.DistanceInMeter = 10000.0 //设置条件为到中心点的距离不超过10000米。 searchQuery := search.NewSearchQuery() searchQuery.SetQuery(query) searchRequest.SetSearchQuery(searchQuery) // 设置返回所有列 searchRequest.SetColumnsToGet(&tablestore.ColumnsToGet{ ReturnAll:true, }) searchResponse, err := client.Search(searchRequest) if err != nil { fmt.Printf("%#v", err) return } fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess) //查看返回结果是否完整。 fmt.Println("TotalCount: ", searchResponse.TotalCount) //打印匹配到的总行数,非返回行数。 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)) } }
地理长方形范围查询(GeoBoundingBoxQuery)
GeoBoundingBoxQuery根据一个长方形范围的地理位置边界条件查询表中的数据,当一个地理位置点落在给出的长方形范围内时满足查询条件。
- 参数
参数 说明 FieldName 列名,类型为Geopoint。 TopLeft 长方形框的左上角的坐标。 BottomRight 长方形框的右下角的坐标,通过左上角和右下角就可以确定一个唯一的长方形。 格式为“纬度,经度”,纬度在前,经度在后,且纬度范围为-90~+90,经度范围-180~+180。例如“35.8,-45.91”。
Query 多元索引的查询语句。设置查询类型为GeoBoundingBoxQuery。 TableName 数据表名称。 IndexName 多元索引名称。 - 示例
Col_GeoPoint是Geopoint类型,查询表中Col_GeoPoint列的值在左上角为"10,0", 右下角为"0,10"的长方形范围内的数据。
func GeoBoundingBoxQuery(client *tablestore.TableStoreClient, tableName string, indexName string) { searchRequest := &tablestore.SearchRequest{} searchRequest.SetTableName(tableName) searchRequest.SetIndexName(indexName) query := &search.GeoBoundingBoxQuery{} //设置查询类型为GeoBoundingBoxQuery。 query.FieldName = "Col_GeoPoint" //设置列名。 query.TopLeft = "10,0" //设置长方形左上角。 query.BottomRight = "0,10" //设置长方形右下角。 searchQuery := search.NewSearchQuery() searchQuery.SetQuery(query) searchRequest.SetSearchQuery(searchQuery) //设置为返回所有列。 searchRequest.SetColumnsToGet(&tablestore.ColumnsToGet{ ReturnAll:true, }) searchResponse, err := client.Search(searchRequest) if err != nil { fmt.Printf("%#v", err) return } fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess) //查看返回结果是否完整。 fmt.Println("TotalCount: ", searchResponse.TotalCount) //打印匹配到的总行数,非返回行数。 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根据一个多边形范围条件查询表中的数据,当一个地理位置点落在指定的多边形范围内时满足查询条件。
- 参数
参数 说明 FieldName 列名,类型为Geopoint。 Points 组成多边形的距离坐标点。 格式为“纬度,经度”,纬度在前,经度在后,且纬度范围为-90~+90,经度范围-180~+180。例如“35.8,-45.91”。
Query 多元索引的查询语句。设置查询类型为GeoPolygonQuery。 TableName 数据表名称。 IndexName 多元索引名称。 - 示例
查询表中Col_GeoPoint列的值在一个给定多边形范围内的数据。
func GeoPolygonQuery(client *tablestore.TableStoreClient, tableName string, indexName string) { searchRequest := &tablestore.SearchRequest{} searchRequest.SetTableName(tableName) searchRequest.SetIndexName(indexName) query := &search.GeoPolygonQuery{} //设置查询类型为GeoDistanceQuery。 query.FieldName = "Col_GeoPoint" query.Points = []string{"0,0","5,5","5,0"} //设置多边形的顶点。 searchQuery := search.NewSearchQuery() searchQuery.SetQuery(query) searchRequest.SetSearchQuery(searchQuery) //设置为返回所有列。 searchRequest.SetColumnsToGet(&tablestore.ColumnsToGet{ ReturnAll:true, }) searchResponse, err := client.Search(searchRequest) if err != nil { fmt.Printf("%#v", err) return } fmt.Println("IsAllSuccess: ", searchResponse.IsAllSuccess) //查看返回结果是否完整。 fmt.Println("TotalCount: ", searchResponse.TotalCount) //打印匹配到的总行数,非返回行数。 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)) } }