Spring Data JPA如何为@Query注解指定适配的数据库厂商？

当然支持，JPA可以通过数据库方言（Dialect）结合几种方式实现这种多数据库适配的原生序列查询，完美匹配你不同部署实例对接不同数据库的需求，下面是几种常用方案：

方案一：Spring Data JPA @Query结合SpEL动态选择SQL #

直接在Repository接口中使用SpEL表达式获取当前数据库方言，动态拼接对应SQL：

public interface YearlySeqRepository extends JpaRepository<YourEntity, Long> {
    @Query(value = "#{#entityManager.factory.dialect.name.contains('PostgreSQL') ? 'SELECT nextval(\'yearly_seq\')' : " +
            "(#{#entityManager.factory.dialect.name.contains('MySQL') ? 'SELECT NEXT VALUE FOR yearly_seq' : " +
            "'SELECT NEXT VALUE FOR yearly_seq'})}", 
            nativeQuery = true)
    Long getNextYearlySeqValue();
}

注：MySQL 8.0+支持原生序列对象，若用低版本MySQL，需替换为基于序列表的更新查询逻辑

方案二：自定义Repository实现类（更灵活可控） #

如果需要更复杂的逻辑（比如序列每年重置的判断），可以自定义Repository实现类，手动根据方言选择SQL执行：

1. 定义Repository接口 #

public interface YearlySeqRepository extends JpaRepository<YourEntity, Long>, YearlySeqRepositoryCustom {
}

public interface YearlySeqRepositoryCustom {
    Long getNextSeqValue();
}

2. 实现自定义逻辑 #

@Repository
public class YearlySeqRepositoryImpl implements YearlySeqRepositoryCustom {
    @PersistenceContext
    private EntityManager entityManager;

    @Override
    public Long getNextSeqValue() {
        String dialectName = entityManager.getEntityManagerFactory().getDialect().getClass().getSimpleName();
        String sql;

        if (dialectName.contains("PostgreSQL")) {
            sql = "SELECT nextval('yearly_seq')";
        } else if (dialectName.contains("MySQL")) {
            // 适配低版本MySQL的序列表逻辑（假设存在yearly_seq表，含year、current_val字段）
            sql = "INSERT INTO yearly_seq (year, current_val) VALUES (YEAR(CURDATE()), 1) ON DUPLICATE KEY UPDATE current_val = current_val + 1; " +
                  "SELECT current_val FROM yearly_seq WHERE year = YEAR(CURDATE())";
            // MySQL 8.0+可直接用：sql = "SELECT NEXT VALUE FOR yearly_seq";
        } else if (dialectName.contains("SQLServer")) {
            sql = "SELECT NEXT VALUE FOR yearly_seq";
        } else {
            throw new UnsupportedOperationException("当前数据库方言暂不支持");
        }

        Query query = entityManager.createNativeQuery(sql);
        return ((Number) query.getSingleResult()).longValue();
    }
}

方案三：自定义Hibernate序列生成器（适配实体类自动生成ID） #

如果需要让实体类的ID自动通过该序列生成（同时处理每年重置逻辑），可以自定义Hibernate序列生成器：

public class YearlyResetSequenceGenerator extends SequenceStyleGenerator {
    @Override
    protected String getSelectNextValString(String sequenceName) {
        Dialect dialect = getDialect();
        if (dialect instanceof PostgreSQLDialect) {
            return "nextval('" + sequenceName + "')";
        } else if (dialect instanceof MySQLDialect) {
            return "NEXT VALUE FOR " + sequenceName;
        } else if (dialect instanceof SQLServerDialect) {
            return "NEXT VALUE FOR " + sequenceName;
        }
        return super.getSelectNextValString(sequenceName);
    }

    @Override
    public Serializable generate(SharedSessionContractImplementor session, Object object) {
        // 这里添加序列每年重置的逻辑：
        // 1. 查询当前年份
        // 2. 查询序列关联的年份记录
        // 3. 若年份不匹配，执行SQL重置序列值为1
        // 具体逻辑根据数据库方言编写对应原生SQL
        return super.generate(session, object);
    }
}

然后在实体类中使用该生成器：

@Entity
public class YourEntity {
    @Id
    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "yearlySeqGenerator")
    @GenericGenerator(
        name = "yearlySeqGenerator",
        strategy = "com.example.YearlyResetSequenceGenerator",
        parameters = {
            @Parameter(name = "sequence_name", value = "yearly_seq"),
            @Parameter(name = "initial_value", value = "1"),
            @Parameter(name = "increment_size", value = "1")
        }
    )
    private Long id;

    // 其他字段...
}

以上三种方案都能实现运行时根据当前连接的数据库自动选择对应原生查询，你可以根据项目的复杂度和实际需求选择合适的方式。

内容的提问来源于stack exchange，提问作者mikeb