springcloud读写doris

Spring Cloud Alibaba是阿里巴巴开源的 Spring Cloud 的扩展，它提供了对阿里云中间件的支持，包括数据服务。当涉及到使用Spring Cloud与Doris（阿里云的分布式OLAP数据库）进行读写操作时，通常会利用Spring Data JPA或MyBatis Plus等持久层框架与Doris的SDK进行集成。

1. **Spring Data JPA + Doris**: Spring Data JPA允许你在Spring应用中使用声明式查询和乐观并发控制，与Doris结合时，你需要配置JPA仓库来连接Doris集群，并定义实体类映射表结构。例如，配置数据源和JPA属性，如`spring.jpa.properties.jdbc.url`指向Doris的JDBC URL。

@Configuration
public class DorisConfig {
    @Value("${spring.datasource.url}")
    private String dorisUrl;

    @Bean
    public DataSource jpaDataSource() {
        return new EmbeddedDatabaseBuilder()
                .addScript("classpath:schema.sql") // 假设有一个初始化脚本
                .setType(EmbeddedDatabaseType.H2)
                .build();
    }

    @Bean
    public JpaVendorAdapter dorisVendorAdapter() {
        return new HibernateJpaVendorAdapter().setDatabasePlatform("org.apache.doris.jdbc.DorisDialect");
    }

    @Bean
    public DorisEntityManagerFactory entityManagerFactory(JpaVendorAdapter adapter, DataSource dataSource) {
        Map<String, Object> properties = new HashMap<>();
        properties.put("hibernate.dialect", adapter.getDatabasePlatform());
        properties.put("hibernate.connection.url", dorisUrl);
        // ... 其他JPA配置

        return new DorisEntityManagerFactory("entityManagerFactory", adapter, dataSource, properties);
    }

    // ... 泛型JpaRepository的配置
}

2. **MyBatis Plus + Doris**: 如果你选择使用MyBatis Plus，你需要创建对应的Mapper接口，然后在XML配置文件或者注解驱动中配置Doris的连接信息，以及自定义SQL查询。

@Mapper
public interface DorisMapper {
    @Select("SELECT * FROM your_table WHERE conditions")
    List<YourEntity> selectByConditions(...);
}

@Configuration
public class DorisMybatisPlusConfig {
    @Value("${spring.datasource.url}")
    private String dorisUrl;

    @Bean
    public DorisSqlSessionFactory sqlSessionFactory() {
        SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();
        factoryBean.setDataSource(dataSource());
        factoryBean.setMapperLocations("mapper/*.xml"); // 指向你的mapper文件目录
        factoryBean.setDorisDatabaseType(DorisDatabaseType.DRDS); // 根据实际情况设置数据库类型
        factoryBean.setDorisDatabaseURL(dorisUrl);
        return factoryBean.getObject();
    }
}