Spring Data JPA Specification中正确构建MySQL全文检索Match...Against表达式的方法

嗨，我完全明白你遇到的问题——之前的写法把整个MATCH...AGAINST语句当成了普通字符串参数，导致JPA把它当成了占位符，生成了?<>?这种无效的对比逻辑，根本没触发MySQL的全文索引。下面我给你两种可行的解决方案，都是安全且能正确利用全文索引的：

方法一：利用Hibernate扩展的SQL表达式（推荐，适用于Hibernate作为JPA实现的场景） #

Hibernate的HibernateCriteriaBuilder提供了直接嵌入原生SQL片段的能力，我们可以用它来构建正确的MATCH...AGAINST表达式，同时还能安全绑定参数避免SQL注入：

import org.hibernate.query.criteria.HibernateCriteriaBuilder;

public static Specification<DpToLeadDbMappingEntity> search(String searchText) {
    if (searchText == null || searchText.isEmpty()) {
        return (root, query, criteriaBuilder) -> criteriaBuilder.conjunction();
    }

    String searchPattern = searchText + "*";

    return (root, query, criteriaBuilder) -> {
        // 转换为Hibernate的CriteriaBuilder，获取原生SQL表达式能力
        HibernateCriteriaBuilder hcb = (HibernateCriteriaBuilder) criteriaBuilder;
        
        // 构建MATCH...AGAINST的原生SQL表达式，安全绑定搜索参数
        Expression<Integer> matchResult = hcb.sqlExpression(
            "MATCH(inquired_business_name, message) AGAINST(? IN BOOLEAN MODE)",
            Integer.class,
            criteriaBuilder.literal(searchPattern)
        );
        
        // 判断全文检索结果不等于0（即匹配到内容）
        return criteriaBuilder.notEqual(matchResult, 0);
    };
}

方法二：使用CriteriaBuilder的function方法（通用JPA方式，无需依赖Hibernate特定API） #

我们可以把MATCH...AGAINST当作一个自定义函数来调用，JPA会帮我们正确解析并生成对应的SQL：

public static Specification<DpToLeadDbMappingEntity> search(String searchText) {
    if (searchText == null || searchText.isEmpty()) {
        return (root, query, criteriaBuilder) -> criteriaBuilder.conjunction();
    }

    String searchPattern = searchText + "*";

    return (root, query, criteriaBuilder) -> {
        // 获取实体对应的字段表达式
        Expression<String> businessName = root.get("inquired_business_name");
        Expression<String> message = root.get("message");
        
        // 调用MySQL的MATCH...AGAINST逻辑，将其视为返回Integer的函数
        Expression<Integer> matchResult = criteriaBuilder.function(
            "MATCH",
            Integer.class,
            businessName,
            message,
            criteriaBuilder.literal(searchPattern),
            criteriaBuilder.literal("IN BOOLEAN MODE")
        );
        
        return criteriaBuilder.notEqual(matchResult, 0);
    };
}

关键注意事项： #

• 字段名匹配：确保root.get("inquired_business_name")和root.get("message")对应的是实体类中正确的属性名，且数据库列名和属性名一致（或通过@Column注解指定了列名）。
• 全文索引已创建：必须提前在MySQL表上创建对应字段的全文索引，比如：

  CREATE FULLTEXT INDEX idx_ft_business_msg ON b2b_dp_to_leaddb_mapping(inquired_business_name, message);
  

• 避免SQL注入：绝对不要直接把searchPattern拼接进SQL字符串里，一定要用criteriaBuilder.literal()或者参数绑定的方式，防止注入风险。

这样修改后，生成的SQL就会正确包含MATCH(inquired_business_name, message) AGAINST('Busi*' IN BOOLEAN MODE) <> 0的逻辑，完美利用MySQL的全文索引啦！

备注：内容来源于stack exchange，提问作者VenomFate