Springboot+MybatisPlus+Druid整合ClickHouse(附源码)

r囧r小猫 2022-10-14 05:28 741阅读 0赞

## 核心依赖 ##

<properties>
            <java.version>1.8</java.version>
            <mybatis-plus.version>3.3.0</mybatis-plus.version>
            <druid.version>1.1.18</druid.version>
            <clikchouse>0.2.4</clikchouse>
        </properties>
    
            <dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>mybatis-plus-boot-starter</artifactId>
                <version>${ mybatis-plus.version}</version>
            </dependency>
            
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>${ druid.version}</version>
            </dependency>
            
            <dependency>
                <groupId>ru.yandex.clickhouse</groupId>
                <artifactId>clickhouse-jdbc</artifactId>
                <version>${ clikchouse}</version>
            </dependency>

## 项目整体结构 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70]

## 核心配置 ##

@Data
    @Configuration
    @MapperScan(basePackages ={ "com.zou.dao.mapper"},sqlSessionFactoryRef = "clickHouseSqlSessionFactoryBean")
    @ConfigurationProperties(prefix = "clickhouse.jdbc.datasource")
    public class ClickhouseConfig { 
    
        private String username;
        private String driverClassName;
        private String password;
        private String url;
        private String type;
        private long maxWait;
        /** * 最小连接池数量 */
        private int minIdle;
        /** * 最大连接数量 */
        private int maxActive;
    
        @Bean
        public DataSource dataSource() throws Exception { 
            Class classes = Class.forName(type);
            DruidDataSource dataSource = (DruidDataSource) DataSourceBuilder
                    .create()
                    .driverClassName(driverClassName)
                    .type(classes)
                    .url(url)
                    .username(username)
                    .password(password)
                    .build();
            dataSource.setMaxWait(maxWait);
            dataSource.setMinIdle(minIdle);
            dataSource.setMaxActive(maxActive);
            // 设置druid 连接池非公平锁模式
            dataSource.setUseUnfairLock(true);
            return dataSource;
        }
    
        @Bean
        public MybatisSqlSessionFactoryBean clickHouseSqlSessionFactoryBean() throws Exception { 
            MybatisSqlSessionFactoryBean factory = new MybatisSqlSessionFactoryBean();
            factory.setDataSource(dataSource());
            factory.setTypeAliasesPackage("com.zou.dao.entity");
            //添加XML目录
            ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
            factory.setMapperLocations(resolver.getResources("classpath:clickhouse/*.xml"));
            //开启驼峰命名转换
            MybatisConfiguration configuration = new MybatisConfiguration();
            configuration.setMapUnderscoreToCamelCase(true);
            configuration.setJdbcTypeForNull(JdbcType.NULL);
    
            /*GlobalConfig globalConfig = new GlobalConfig(); globalConfig.setBanner(false); factory.setGlobalConfig(globalConfig);*/
            factory.setConfiguration(configuration);
            return factory;
        }
    }

## application.properties ##

clickhouse.jdbc.datasource.url = jdbc:clickhouse://127.0.0.1:8123/order_serice
    clickhouse.jdbc.datasource.username = default
    clickhouse.jdbc.datasource.password = ck123
    clickhouse.jdbc.datasource.driver-class-name = ru.yandex.clickhouse.ClickHouseDriver
    clickhouse.jdbc.datasource.type = com.alibaba.druid.pool.DruidDataSource
    clickhouse.jdbc.datasource.min-idle = 2
    clickhouse.jdbc.datasource.max-active = 20
    clickhouse.jdbc.datasource.max-wait = 60000
    clickhouse.validationQuery = SELECT 1
    logging.level.com.zou.dao.mapper=debug

## DAO相关代码 ##

*  entity

@Data
    public class Order { 
    
        private Integer customerId;
        private Integer buyDate;
        private String cardNo;
        private BigDecimal payMoney;
        private BigDecimal originMoney;
        private String storeNo;
        private String storeUserNo;
        private String orderNo;
        private Integer year;
        private Integer month;
        private Integer day;
        private String payWay;
        private Date createDate;
        private Integer sign;
        private Integer version;
    }

*  mapper

@Mapper
    public interface OrderMapper extends BaseMapper<Order> { 
    }

*  Dao

public interface OrderDao extends IService<Order> { 
    }

*  DaoImpl

@Service
    public class OrderDaoImpl extends ServiceImpl<OrderMapper, Order> implements OrderDao { 
    }

## 简单的测试 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70 1]

## 源码下载 ##

[源码][Link 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70]: /images/20221014/d2db49dd17ec4620bae9b99073ffd15b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzQyNjUxOTA0_size_16_color_FFFFFF_t_70 1]: /images/20221014/9945bea5059a42cdba04a1dd2945e5fe.png
[Link 1]: https://github.com/weihubeats/springcloud-shopping-parent