是否对executeSQL进行sql查询扩展，仿照mybatiplus根据LambdaEsQueryWrapper构建出sql进行查询？

是否可以仿照mybatiplus根据LambdaEsQueryWrapper构建出sql进行查询？如：

```
    public static <T,K> List<Map<String, Object>> selectListMap(BaseEsMapper<K> mapper, QueryWrapper<T> wrapper, Class<T> clazz) {
           // 通过MyBatis-Plus的SQL辅助类获取查询SQL语句
        String sql = MpSqlHelper.getSelectListSQL(wrapper, clazz);
        // 执行SQL查询并获取结果字符串
        String resStr = mapper.executeSQL(sql);
        // 将JSON格式结果字符串解析为Map列表
        return parseJsonToMapList(resStr);
    }
    
    public class MpSqlHelper {
    
        public static String getSelectListSQL(QueryWrapper<?> ew, Class<?> entityClass) {
    
            // wrapper 会作为参数传入 mapper
            Map<String, Object> params = Collections.singletonMap("ew", ew);
    
            SqlSessionFactory sqlSessionFactory = SpringUtil.getBean(SqlSessionFactory.class);
            // sqlSessionFactory 从 Spring 容器中获得
            Configuration configuration = sqlSessionFactory.getConfiguration();
    
            String mapperClassName = MybatisPlusUtil.getMapperName(entityClass);
            // 使用类引用+方法名得到 mapper 语句
            MappedStatement mappedStatement = configuration.getMappedStatement(mapperClassName+ ".selectList");
            BoundSql boundSql = mappedStatement.getBoundSql(params);
    
            String sql = getExecuteSql(boundSql, params);
            System.out.println(sql);
            return sql;
        }
    
        private static String getExecuteSql(BoundSql boundSql, Object paramObject) {
            // 带有问号占位符的 SQL 语句
            String sql = boundSql.getSql();
            // 参数信息列表
            List<ParameterMapping> paramMappings = boundSql.getParameterMappings();
            SqlSessionFactory sqlSessionFactory = SpringUtil.getBean(SqlSessionFactory.class);
            // MetaObject 是 mybatis 通过表达式取出对象内容的工具
            MetaObject metaObject = sqlSessionFactory.getConfiguration().newMetaObject(paramObject);
            for (ParameterMapping p : paramMappings) {
                String paramName = p.getProperty();
                Object paramValue = metaObject.getValue(paramName);
                String value = ""+paramValue;
                if (paramValue instanceof String) {
                    value = "'" + paramValue + "'";
                }
                sql = sql.replaceFirst("\\?", value);
            }
            return sql;
        }
    }

// 使用
    QueryWrapper<EsRelationModel> wrapper = new QueryWrapper<>();
    wrapper.lambda().eq(EsRelationModel::getFlag, 0);
    wrapper.lambda().gt(EsRelationModel::getSubjectID, 0);
    if(termId != null && termId > 0){
        wrapper.lambda().eq(EsRelationModel::getTermID, termId);
    }
    if (year != null && year > 0){
        wrapper.lambda().eq(EsRelationModel::getResYear, year);
    }
    wrapper.lambda().isNotNull(EsRelationModel::getSubjectName);
    wrapper.lambda().ne(EsRelationModel::getSubjectName, "");
    wrapper.lambda().or(i-> i.isNull(EsRelationModel::getOrgID).eq(EsRelationModel::getOrgID,orgId));

wrapper.lambda().groupBy(EsRelationModel::getSubjectID, EsRelationModel::getSubjectName,EsRelationModel::getLibraryID, EsRelationModel::getLibraryName);
    wrapper.select( "subjectID","subjectName","libraryID","libraryName", "count(distinct resCode) as count");
    authorize(wrapper.lambda());
    List<Map<String, Object>> resList = EsUtils.selectListMap(esSRelationMapper, wrapper, EsRelationModel.class);

```

GVP dromara/easy-es

内容风险标识

评论 (0)

GVPdromara/easy-es

内容风险标识