zhuyijun/nacos
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

[ISSUE #4311] Fix Derby data source related SQL LIMIT exception (#4313)

Browse Source 
* for #4311，Fixed Derby data source related SQL LIMIT exception.

* fix code style.

* code format.
This commit is contained in:
mai.jh 2020-11-24 13:21:15 +08:00 committed by GitHub
parent 7f2a3307d6
commit 3bf8844992
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
config/src/main/java/com/alibaba/nacos/config/server/service/repository/embedded/EmbeddedStoragePersistServiceImpl.java
View File

@ -1116,16 +1116,26 @@ public class EmbeddedStoragePersistServiceImpl implements PersistService {
@Override @Override
public List<String> getTenantIdList(int page, int pageSize) { public List<String> getTenantIdList(int page, int pageSize) {
PaginationHelper<String> helper = createPaginationHelper();
String sql = "SELECT tenant_id FROM config_info WHERE tenant_id != '' GROUP BY tenant_id LIMIT ?,?"; String sql = "SELECT tenant_id FROM config_info WHERE tenant_id != '' GROUP BY tenant_id LIMIT ?,?";
int from = (page - 1) * pageSize; int from = (page - 1) * pageSize;
return databaseOperate.queryMany(sql, new Object[] {from, pageSize}, String.class);
Page<String> pageList = helper.fetchPageLimit(sql, new Object[] {from, pageSize}, page, pageSize,
(resultSet, i) -> resultSet.getString("tenant_id"));
return pageList.getPageItems();
} }
@Override @Override
public List<String> getGroupIdList(int page, int pageSize) { public List<String> getGroupIdList(int page, int pageSize) {
PaginationHelper<String> helper = createPaginationHelper();
String sql = "SELECT group_id FROM config_info WHERE tenant_id ='' GROUP BY group_id LIMIT ?,?"; String sql = "SELECT group_id FROM config_info WHERE tenant_id ='' GROUP BY group_id LIMIT ?,?";
int from = (page - 1) * pageSize; int from = (page - 1) * pageSize;
return databaseOperate.queryMany(sql, new Object[] {from, pageSize}, String.class);
Page<String> pageList = helper.fetchPageLimit(sql, new Object[] {from, pageSize}, page, pageSize,
(resultSet, i) -> resultSet.getString("group_id"));
return pageList.getPageItems();
} }
@Override @Override