README.md · dragons96/aliyun-opensearch-sql

# aliyun-opensearch-sql
### 提供阿里云开放搜索SQL支持
##### 官方文档地址：https://help.aliyun.com/product/29102.html

#### SpringBoot 集成见项目: https://gitee.com/kingons/spring-boot-data-aliyun-opensearch

#### 使用建议: 
##### 1.需要查询的字段至少创建一个与字段名同名索引
##### 2.需要查询的字段若支持设置为属性字段则添加到属性字段
##### 3.默认展示字段建议添加全部字段, 在具体业务中通过select指定需要返回的字段
##### 4.非SCROLL(全量查询)模式sql请务必加上limit以启用HIT查询模式.(HIT查询模式最大查询指定条件的top5000), SCROLL模式不支持打散与聚合
##### 5.建议聚合模式limit 1即可, 聚合结果存在facet->group->items中
##### 6.开发环境下查询时可通过调用DefaultOpenSearchQueryIterator#express()方法查询迭代器下一次查询条件, 用于快速排查问题, 生产环境建议关闭(会有性能损耗)
#### 参数建议:
##### 1.DefaultOpenSearchSqlClient客户端
##### 1.1.查询场景下建议选择填入AppName的构造方法, 填入AppName将会对sql解析进行优化。
##### 1.2.建议设置连接超时时间与读超时时间，默认连接超时时间10s，读超时时间5s
##### 1.3.若是阿里云服务器可选择带intranet参数的构造方法并将该值设置为true以启用内网访问
##### 2.DefaultOpenSearchQueryIterator默认查询迭代器
##### 2.1.若只需要接收成功的结果(即status="OK"),可使用DefaultOpenSearchQueryIterator#hasSuccessfulNext()方法判断，DefaultOpenSearchQueryIterator#next()方法失败结果也会返回，并且不会进行重试
##### 2.2.使用DefaultOpenSearchQueryIterator#hasSuccessfulNext() 可通过可使用DefaultOpenSearchQueryIterator#setRetry()方法设置失败重试次数, 通过可使用DefaultOpenSearchQueryIterator#setRetryTimeInterval()方法设置重试间隔
##### 2.3.若需要调整迭代时间间隔可通过DefaultOpenSearchQueryIterator#setPagingInterval()方法调整迭代间隔时间，单位:ms，默认:10ms(Ps:若查询速度过快而OpenSearch LCU不足可能会返回6015(资源受限)错误)
#### SQL使用语法（同Mysql语法）：  
### 查询:  
```sql
select  
        [Distinct + attribute_field_name(/*属性字段*/)]  
        [count,sum,max,min + attribute_field_name(/*属性字段*/)]  
        [field_name(/*表字段*/)..]  
from [appName1],[appName2],..  
where  
        ([index_field_name(/*索引字段*/)[=|like]character] [..OR|AND])  
        [..AND|OR]  
        ([index_field_name(/*索引字段*/)[=|>|>=|<|<=|in|between]number|literal] [..OR|AND])  
group by [attribute_field_name(/*属性字段*/)]  
order by [field_name(/*表字段*/)] [asc|desc]..  
limit min,count
```
### 插入:
```sql
-- 当前版本仅支持value方式插入, insert select 将在后续版本完成
-- 建议使用时将字段名指定，防止未指定导致顺序错乱
-- app_name可忽略
insert into app_name.table_name(field_name1, field_name2, ...) values(value1, value2, ...)
```

### 修改:
```sql
-- 当前仅支持通过主键条字段条件修改文档, 仅支持 id = xxx 或 id in (xxx, xxx) 方式
-- 必须设置where条件
-- app_name可忽略
update app_name.table_name set field_name1=value1 and field_name2=value2 where id in (1, 2, 3)
```

### 删除:
```sql
-- 当前仅支持通过主键字段删除文档, 仅支持 primary_key = xxx 或 primary_key in (xxx, xxx) 方式
-- 必须设置where条件
-- app_name可忽略
delete from app_name.table_name where id in (1, 2)
```

### 示例数据源
AppName: app_name  
TableName: person
  
**字段**：  
1. unique_id  int 主键  
2. uid int  
3. name short_text  
4. age int

**索引**：  
1. default => name 中文-电商分析方式
2. id => unique_id 关键字分析方式
3. uid => uid 关键字分析方式  
4. name => name 模糊分析方式  
5. kname => name 中文-通用分析方式  
6. age => age 关键字分析方式  
7. id_range => unique_id Range分析方式

**属性**：  
unique_id, uid, age

**默认展示字段**：  
unique_id, uid, name, age

#### 普通字段查询示例 (like字段仅可用于模糊分析方式的索引中)
```sql
select id, uid, name, age
from app_name
where uid >= 1 and uid <= 1000 and name like 'dragons%' and age = 18
limit 10;

-- 内部解析结果:
query=name:'^dragons'
filter=uid>=1 AND uid<=1000 AND age=18
config.start=0
config.hit=10
```

(**PS: ~~想要触发query查询使用name like '%xxx%' 或 name="xxx" 均可~~
v0.0.3-SNAPSHOT版本仅支持使用 name like '%xxx%查询'，v0.1.0-SNAPSHOT版本在client传入appName情况下支持自动识别,即name="xxx"或name like 'xxx'或name like '%xxxx%'均可**)

#### 普通字段去重查询示例
```sql
select distinct uid
from app_name
where uid >= 1 and uid <= 1000 and name like 'dragons%' and age = 18
limit 10;
```

#### 聚合查询示例：
```sql
select name, count(), max(distinct uid)  
from app_name  
where uid>=1 and uid<=100000 and name like 'dragons%'  
group by name  
limit 0, 100
```  
(PS：建议OpenSearch默认展示字段配置全部展示字段)

#### 获取SearchResult对象使用示例（默认Iterator.next()迭代一次搜索）：

版本: v0.1.0-SNAPSHOT调用示例

```java
import club.kingon.sql.opensearch.DefaultOpenSearchSqlClient;
import club.kingon.sql.opensearch.OpenSearchQueryIterator;
import club.kingon.sql.opensearch.OpenSearchSqlClient;
import club.kingon.sql.opensearch.api.Endpoint;
import club.kingon.sql.opensearch.entry.OpenSearchQueryResult;
import com.alibaba.fastjson.TypeReference;
import com.aliyun.opensearch.sdk.generated.commons.OpenSearchResult;
import com.aliyun.opensearch.sdk.generated.search.general.SearchResult;

import java.util.Iterator;

public class Test {

public static void queryDemo(OpenSearchSqlClient client) {
          String SQL = "select * from " + APP_NAME + " where name like '%咸鱼%' limit 10";
          OpenSearchQueryIterator it1 = client.query(SQL);
          // v0.1.0-SNAPSHOT版本后hasNext方法不对结果做校验, 转而使用OpenSearchQueryIterator.hasSuccessfulNext()方法对结果状态与数据进行校验
          while (it1.hasNext()) {
                System.out.println(it1.next());
          }
      
          // 使用hasSuccessfulNext
          OpenSearchQueryIterator it2 = client.query(SQL);
          while (it2.hasSuccessfulNext()) {
              // 获取指定结构Bean, 需继承QueryObject
              class A extends club.kingon.sql.opensearch.entry.QueryObject {
                  private String name;
          
                  public String getName() {
                     return name;
                  }
          
                  @Override
                  public String toString() {
                     return "A{" +
                             "name='" + name + '\'' +
                               '}';
                  }
              }
              // Demo 简写，生产环境TypeReference对象创建一个复用即可, 避免重复创建对象占用资源
              OpenSearchQueryResult<A> result = it2.next(new TypeReference<OpenSearchQueryResult<A>>() {});
              System.out.println(result);
        }
    }
  
    public static void insertDemo(OpenSearchSqlClient client) {
        String SQL = "insert into person(id, name) values(1, '咸鱼')";
        OpenSearchResult result = client.insert(SQL);
        System.out.println(result.getResult());
    }
  
    public static void updateDemo(OpenSearchSqlClient client) {
        String SQL = "update person set name='咸鱼...' where id=1";
        OpenSearchResult result = client.update(SQL);
        System.out.println(result.getResult());
    }
  
    public static void deleteDemo(OpenSearchSqlClient client) {
        String SQL = "delete from person where id=1";
        OpenSearchResult result = client.delete(SQL);
        System.out.println(result.getResult());
    }
  
    public static void main(String[] args) {
        // APP_NAME可以传null，若传正确的APP_NAME将会对SQL语法做自动适配
        String ACCESS_KEY = "xxx", SECRET = "xxx", APP_NAME = "app_name";
        OpenSearchSqlClient client = new DefaultOpenSearchSqlClient(ACCESS_KEY, SECRET, Endpoint.SHENZHEN, APP_NAME);
    
        insertDemo(client);
        updateDemo(client);
        queryDemo(client);
        deleteDemo(client);
    }
}
```
版本: v0.0.3-SNAPSHOT调用示例
```java
import com.aliyun.opensearch.OpenSearchClient;
import com.aliyun.opensearch.SearcherClient;
import com.aliyun.opensearch.sdk.generated.OpenSearch;

public class Test {
    public static void main(String[] args) {
        OpenSearch openSearch = new OpenSearch(ACCESS_KEY, SECRET, HOST);
        OpenSearchClient openSearchClient = new OpenSearchClient(openSearch);
        SearcherClient searcherClient = new SearcherClient(openSearchClient);
        SearcherClientQueryIterator iterator = new DefaultSearcherClientQueryIterator(searcherClient, SQL);
        while (iterator.hasNext()) {
            System.out.println(iterator.next());  // SearchResult对象
        }
    }
}
```
#### 获取单个元素对象使用示例（使用SearcherClientQueryIterator.hasNextOne() 与 SearcherClientQueryIterator.nextOne()获取单个元素对象）
```java
import com.aliyun.opensearch.OpenSearchClient;
import com.aliyun.opensearch.SearcherClient;
import com.aliyun.opensearch.sdk.generated.OpenSearch;

public class Test {
    public static void main(String[] args) {
        OpenSearch openSearch = new OpenSearch(ACCESS_KEY, SECRET, HOST);
        OpenSearchClient openSearchClient = new OpenSearchClient(openSearch);
        SearcherClient searcherClient = new SearcherClient(openSearchClient);
        SearcherClientQueryIterator iterator = new DefaultSearcherClientQueryIterator(searcherClient, SQL);
        while (iterator.hasNextOne()) {
            System.out.println(iterator.nextOne());  // com.aliyun.opensearch.sdk.dependencies.org.json.JSONObject对象
        }
    }
}
```
#### 实战(常见问题汇总)
```
1.like 语法比较的值若不是OpenSearch模糊搜索索引左右需均带上%,即使是关键词索引需要精确匹配两边也需带上%(v0.1.0-SNAPSHOT可忽略)。OpenSearch模糊查询文档：https://help.aliyun.com/document_detail/179439.html
select *
from app_name
where kname like '%dragons%' 
limit 10;

内部解析结果:
query=kname:'dragons'
若不加%,即where id like 'dragons'将会解析为
query=kname:'^dragons$'
索引若不支持模糊查询将无法查询得到结果

2.不要在like与其他表达式中混入OR连接符,OpenSearch查询是同时传入query与filter，若混用则可能导致结果不符合预期,示例如下:
select *
from app_name
where kname like '%dragons%' or unique_id=1
limit 10;

内部解析结果：
query=kname:'dragons'
filter=unique_id=1

不符合查询预期，应使用like统一转为query查询,改写如下：
select *
from app_name
where kname like '%dragons%' or id like '%1%'
limit 10;

这里id是unique_id的关键词索引，所以即使左右均加入%也是精确搜索,内部解析结果:
query=kname:'dragons' OR id:'1'
```

#### 当前版本: v0.1.0-SNAPSHOT

#### 历史变更：v0.0.3-SNAPSHOT
1. 在v0.0.2-SNAPSHOT版本上,剔除了动态选择query与filter功能(防止判错导致查询失败), 转而使用强类型声明方式:  
```
1. 强制要求使用 like 方式声明query查询
2. 使用=, !=或<>, >=, <= 查询时内部均通过filter查询
 ```

2. 新增支持in语法(in语法也是通过filter查询)、between语法(between语法内部使用filter range功能, 仅支持数值类型与时间类型)、函数功能。具体参考: <a href="https://help.aliyun.com/document_detail/204346.html">OpenSearch Filter字句</a>。使用示例如下：
```sql
select *
from app_name
where id_range between 1 and 5 and age in (18, 19, 20)
limit 10;
-- 插件内部将转换为: filter=id_range:[1,5] AND in(age, "18|19|20")
```
3. 新增default like查询支持, 示例如下:
```sql
select *
from app_name
where default like '%咸鱼%'
limit 10;
```
4. 增加查询分析qp参数支持, 示例如下:
```sql
select *
from app_name
where name like '%dragons%' and qp in ('sys_default')
limit 10;
-- 或
select *
from app_name
where name like '%dragons%' and qp = 'sys_default'
limit 10;
```
5. 转换器内部结构优化
6. 增加粗排表达式、精排表达式、自定义kvpairs参数支持, 示例如下：
```sql
select *
from app_name
where name like '%dragons%'
  -- 粗排表达式, 字段名为 first_rank_name、firstRankName 均可
  and first_rank_name='default' 
  -- 精排表达式, 字段名为 second_rank_name、secondRankName 均可
  and second_rank_name='default'
limit 10;

select *
from app_name
where name like '%dragons%' 
  -- OpenSearch上的排序表达式使用了kvpairs函数提取age_min与age_max值
  -- 也可通过in语法分隔多个参数, 可改写为 kvpairs in ('age_min:10', 'age_max:20')
  and kvpairs = 'age_min:10,age_max:20'
limit 10;
```
7. 增加query ANDNOT 支持,示例如下, not like 使用之前需要通过and连接
```sql
select *
from app_name
where name like '%drag%' and name not like '%dragons%'
limit 10;

-- 内部改写
query=name:'drag' ANDNOT name:'dragons'
```

<font style="font-weight: 700" color="red">PS: 新版本使用"="需要注意名称是否为属性名称(若不是则会导致查询失败, 旧版本使用"=" + 动态探测类型可能会注入query中, 新版本将"="改为"like"注入进query中, 旧版本使用"="注入进filter中则不用处理)
</font>

#### 历史变更：v0.0.2-SNAPSHOT
1. 仅支持查询功能  
2. 支持语法  
  2.1. 仅支持4种聚合函数：**count**，**min**，**max**，**sum**  
  2.2. **select** 仅支持查询字段，暂不支持别名功能（聚合函数不支持嵌套，使用聚合函数必须要分组，暂不支持having语法，参考：<a href="https://help.aliyun.com/document_detail/180049.html">aggregate字句</a>。  
  2.3. **where** 中暂不支持 **in** 语法以及嵌套查询（目前支持 **=**, **>=**, **<=**, **<**, **>**, **like**, **!=**, **<>**），PS：比较运算符暂时仅通过 **filter** 实现，**range** 实现正在开发中。  
  2.4. 默认使用 **scroll** 方式召回（ **scroll** 不支持 **distinct**, **aggregate** 语法; **sort** 语法仅支持 **int** 类型字段排序），若明确知道召回数小于等于 **5000**，则建议使用 **limit** 来触发 **hit** 方式召回。  
  2.5. 暂不支持地理位置查询  
#### 历史变更：  
1. 初始化版本**v0.0.1-SNAPSHOT**，提供默认的 **OpenSearch** 搜索迭代器  
2. 优化"="比较表达式在数值比较时使用filter处理
3. 修复Aggregate多分组时无法解析问题

### 优化记录
##### 2021-08-27
1. OpenSearchSqlClient 添加超时参数配置，connectionTimeout配置连接超时时间, readTimeout配置读超时时间, 单位均为ms.
2. 修复DefaultOpenSearchQueryIterator#next()方法在非scroll模式的不必要的Json解析.
3. 调整scroll模式触发条件, 原触发条件为无limit或limit最大值超过5000，现调整为无limit触发,若limit最大/小值超过5000将设定为5000. 
4. 增加aggregate参数化方式注入。（OpenSearch聚合仅支持某一属性的多个不同方法，通过sql表达容易让人误解以为可以通过多个属性一起聚合，所以为了更容易表明含义及提供更强的功能，将aggregate以参数化形式注入。原sql提供的aggregate与distinct功能不变）

```sql
-- sql尚未解决示例：以age分组统计最大unique_id以及最大uid
-- 由于OpenSearch仅支持同一aggregate同一属性同一方法仅支持使用一次，所以如下的sql仅会查出最大的uid值
select max(unique_id), max(uid)
from app_name
group by age;
```
解决方案：使用参数化注入aggregate
```java

public class Test {
    public static void main(String[] args){
        String appName = "app_name";
        String sql = "select unique_id from " + appName + " limit 1";
        String accessKey = "...";
        String secret = "...";
        OpenSearchSqlClient client = new DefaultOpenSearchSqlClient(accessKey, secret, (Endpoint).SHENZHEN, appName);
        
        Set<Aggregate> aggregateSet = new HashSet<>();
        Aggregate agg1 = new Aggregate();
        agg1.setGroupKey("age");
        agg1.setAggFun("max(unique_id)");
        Aggregate agg2 = new Aggregate();
        agg2.setGroupKey("age");
        agg2.setAggFun("max(uid)");
        aggregateSet.add(agg1);
        aggregateSet.add(agg2);
        OpenSearchQueryIterator it = client.query(sql, null, aggregateSet);
        while (it.hasSuccessfulNext()) {
            System.out.println(it.next().getResult());
        }
    }
}
```
##### 2021-08-05
1. 要求显示声明query与filter, query通过"like"方式, 其他表达式均为filter, 示例如下:
```
filter示例-内部使用语法：filter=unique_id=1
select *
from app_name
where unique_id=1

query示例-内部使用：query=id:'1'
select *
from app_name
where id like '%1%'
(PS:这里id_kw为关键字索引, 该索引类型不支持模糊查询,因此带上%也为精确查询, 
为了支持OpenSearch模糊查询语法, 即^前缀起始符与$后缀终止符,普通查询若不带上%则会在生成的语句前后带分别带上^与$符
,后续将通过获取表信息与字段信息优化)
```
2. 新增in、between、filter内置函数功能(均通过filter查询)。
##### 2021-05-28
1. 增强filter中中文不等于支持，使用示例如下：
```sql
selec * from APP_NAME where title!='咸鱼' 
```
(PS: 使用!=与<>均可表示不等于)
其中要求title字段在Opensearch后台中添加为属性字段(目前字符类型支持属性字段的类型有: LITERAL)

dragons96/aliyun-opensearch-sql

简介

发行版

贡献者

近期动态

dragons96/aliyun-opensearch-sql .gitee-modal { width: 500px !important; }

简介

发行版

贡献者

近期动态

搜索帮助

dragons96/aliyun-opensearch-sql