Guice进阶之整合mybatis和druid

其他 2018-10-31 09:32:50 阅读次数: 0
版权声明：本文为博主原创文章，未经博主允许不得转载。 https://blog.csdn.net/zwx19921215/article/details/83341814

上一篇文章中介绍了guice的基本使用配置，关于guice和spring的对比可以自行baidu或者google，我所了解的guice只是实现了依赖注入，而且相对于spring来说周边生态还是比较弱的，所以我把guice定义为一个轻量级依赖注入框架，由于guice非常小且速度快，对于我们快速开发一些小型项目是非常适合的。

接下来队guice+mybatis简单整合下，实现对数据的查询

项目结构如下：

首先pom中添加相关依赖

<!-- https://mvnrepository.com/artifact/com.google.inject/guice -->
        <dependency>
            <groupId>com.google.inject</groupId>
            <artifactId>guice</artifactId>
            <version>4.2.0</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.mybatis/mybatis-guice -->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis-guice</artifactId>
            <version>3.10</version>
        </dependency>

        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.4.5</version>
        </dependency>
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.45</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>druid</artifactId>
            <version>1.1.9</version>
        </dependency>

        <!-- https://mvnrepository.com/artifact/org.springframework/spring-context -->
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>5.0.7.RELEASE</version>
        </dependency>

配置文件（app.properties）

#dev
#jdbc
jdbc.driverClassName=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://10.0.2.30:3306/xxx_test?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&failOverReadOnly=true&zeroDateTimeBehavior=convertToNull
jdbc.username=test
jdbc.password=test
jdbc.filters=stat,wall
jdbc.maxActive=20
jdbc.initialSize=5
jdbc.maxWait=60000
jdbc.minIdle=10
jdbc.timeBetweenEvictionRunsMillis=60000
jdbc.minEvictableIdleTimeMillis=300000
jdbc.validationQuery=SELECT 1
jdbc.testWhileIdle=true
jdbc.testOnBorrow=false
jdbc.testOnReturn=false
jdbc.maxOpenPreparedStatements=20
jdbc.removeAbandoned=true
jdbc.removeAbandonedTimeout=1800
jdbc.logAbandoned=true

#web redis
redis.database=0
#redis host & port
redis.host=10.0.2.13
redis.port=6379
redis.password=
#连接池最大连接数（使用负值表示没有限制）
redis.pool.max.active=1000
# 连接池中的最大空闲连接
redis.pool.max.idle=100
#连接池最大阻塞等待时间（使用负值表示没有限制）
redis.pool.max.wait=-1
# 连接池中的最小空闲连接
redis.pool.min.idle=0
# 连接超时时间（毫秒）
redis.timeout=0

mybatis.environment.id = scheduled-task

新建自定义数据源provider（当然可以使用guice已注册好的数据源）我这里使用的自定义的alibaba的druid数据源

package com.yingda.xsignal.scheduled.provider;

import com.google.inject.Inject;
import com.google.inject.Provider;
import com.google.inject.name.Named;

import com.alibaba.druid.pool.DruidDataSource;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.sql.SQLException;
import java.util.Properties;

import javax.sql.DataSource;

/**
 * @author xiaofeng
 * @version V1.0
 * @title: DruidDataSourceProvider
 * @package: com.yingda.xsignal.scheduled.provider
 * @description: Provides the Druid DataSource
 * @date 2018/6/26 16:46
 */
public class DruidDataSourceProvider implements Provider<DataSource> {

    Logger logger = LoggerFactory.getLogger(getClass());

    DruidDataSource dataSource = new DruidDataSource();

    @Inject
    public void setDriverClassName(@Named("jdbc.driverClassName") final String driverClassName) {
        dataSource.setDriverClassName(driverClassName);
    }

    @Inject
    public void setUrl(@Named("jdbc.url") final String url) {
        dataSource.setUrl(url);
    }

    @Inject
    public void setUsername(@Named("jdbc.username") final String username) {
        dataSource.setUsername(username);
    }

    @Inject
    public void setPassword(@Named("jdbc.password") final String password) {
        dataSource.setPassword(password);
    }

    @Inject(optional = true)
    public void setDefaultAutoCommit(@Named("jdbc.autoCommit") final boolean defaultAutoCommit) {
        dataSource.setDefaultAutoCommit(defaultAutoCommit);
    }

    @Inject(optional = true)
    public void setDefaultReadOnly(@Named("jdbc.readOnly") final boolean defaultReadOnly) {
        dataSource.setDefaultReadOnly(defaultReadOnly);
    }

    @Inject(optional = true)
    public void setDefaultTransactionIsolation(
            @Named("jdbc.transactionIsolation") final int defaultTransactionIsolation) {
        dataSource.setDefaultTransactionIsolation(defaultTransactionIsolation);
    }

    @Inject(optional = true)
    public void setDefaultCatalog(@Named("jdbc.catalog") final String defaultCatalog) {
        dataSource.setDefaultCatalog(defaultCatalog);
    }

    @Inject(optional = true)
    public void setMaxActive(@Named("jdbc.maxActive") final int maxActive) {
        dataSource.setMaxActive(maxActive);
    }

    @Inject(optional = true)
    public void setMinIdle(@Named("jdbc.minIdle") final int minIdle) {
        dataSource.setMinIdle(minIdle);
    }

    @Inject(optional = true)
    public void setInitialSize(@Named("jdbc.initialSize") final int initialSize) {
        dataSource.setInitialSize(initialSize);
    }

    @Inject(optional = true)
    public void setMaxWait(@Named("jdbc.maxWait") final long maxWait) {
        dataSource.setMaxWait(maxWait);
    }

    @Inject(optional = true)
    public void setTestOnBorrow(@Named("jdbc.testOnBorrow") final boolean testOnBorrow) {
        dataSource.setTestOnBorrow(testOnBorrow);
    }

    @Inject(optional = true)
    public void setTestOnReturn(@Named("jdbc.testOnReturn") final boolean testOnReturn) {
        dataSource.setTestOnReturn(testOnReturn);
    }

    @Inject(optional = true)
    public void setTimeBetweenEvictionRunsMillis(
            @Named("jdbc.timeBetweenEvictionRunsMillis") final long timeBetweenEvictionRunsMillis) {
        dataSource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
    }

    @Inject(optional = true)
    public void setMinEvictableIdleTimeMillis(
            @Named("jdbc.minEvictableIdleTimeMillis") final long minEvictableIdleTimeMillis) {
        dataSource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
    }

    @Inject(optional = true)
    public void setTestWhileIdle(@Named("jdbc.testWhileIdle") final boolean testWhileIdle) {
        dataSource.setTestWhileIdle(testWhileIdle);
    }

    @Inject(optional = true)
    public void setValidationQuery(@Named("jdbc.validationQuery") final String validationQuery) {
        dataSource.setValidationQuery(validationQuery);
    }

    @Inject(optional = true)
    public void setValidationQueryTimeout(@Named("jdbc.validationQueryTimeout") final int validationQueryTimeout) {
        dataSource.setValidationQueryTimeout(validationQueryTimeout);
    }

    @Inject(optional = true)
    public void setAccessToUnderlyingConnectionAllowed(
            @Named("jdbc.accessToUnderlyingConnectionAllowed") final boolean accessToUnderlyingConnectionAllowed) {
        dataSource.setAccessToUnderlyingConnectionAllowed(accessToUnderlyingConnectionAllowed);
    }

    @Inject(optional = true)
    public void setRemoveAbandoned(@Named("jdbc.removeAbandoned") final boolean removeAbandoned) {
        dataSource.setRemoveAbandoned(removeAbandoned);
    }

    @Inject(optional = true)
    public void setRemoveAbandonedTimeout(@Named("jdbc.removeAbandonedTimeout") final int removeAbandonedTimeout) {
        dataSource.setRemoveAbandonedTimeout(removeAbandonedTimeout);
    }

    @Inject(optional = true)
    public void setLogAbandoned(@Named("jdbc.logAbandoned") final boolean logAbandoned) {
        dataSource.setLogAbandoned(logAbandoned);
    }

    @Inject(optional = true)
    public void setPoolPreparedStatements(@Named("jdbc.poolPreparedStatements") final boolean poolPreparedStatements) {
        dataSource.setPoolPreparedStatements(poolPreparedStatements);
    }

    @Inject(optional = true)
    public void setMaxOpenPreparedStatements(
            @Named("jdbc.maxOpenPreparedStatements") final int maxOpenPreparedStatements) {
        dataSource.setMaxOpenPreparedStatements(maxOpenPreparedStatements);
    }

    @Inject(optional = true)
    public void setConnectProperties(@Named("jdbc.connectProperties") final Properties connectionProperties) {
        dataSource.setConnectProperties(connectionProperties);
    }

    @Inject(optional = true)
    public void setConnectionProperties(@Named("jdbc.connectionProperties") final String connectionProperties) {
        dataSource.setConnectionProperties(connectionProperties);
    }

    @Inject(optional = true)
    public void setFilters(@Named("jdbc.filters") final String filters) throws SQLException {
        dataSource.setFilters(filters);
    }

    @Inject(optional = true)
    public void setExceptionSorter(@Named("jdbc.exceptionSorter") final String exceptionSorter) throws SQLException {
        dataSource.setExceptionSorter(exceptionSorter);
    }

    @Inject(optional = true)
    public void setExceptionSorterClassName(@Named("jdbc.exceptionSorterClassName") final String exceptionSorterClassName)
            throws Exception {
        dataSource.setExceptionSorterClassName(exceptionSorterClassName);
    }

    @Override
    public String toString() {
        return "DruidDataSourceProvider{" +
                "jdbc.url=" + dataSource.getUrl() +
                ",username='" + dataSource.getUsername() +
                '}';
    }

    @Override
    public DataSource get() {
        logger.info("dataSource config ---> " + toString());
        return dataSource;
    }

}

新建module用于依赖绑定

package com.yingda.xsignal.scheduled.module;

import com.google.inject.AbstractModule;
import com.google.inject.Scopes;
import com.google.inject.name.Names;
import com.yingda.xsignal.scheduled.dao.ExtraScoreInfoMapper;
import com.yingda.xsignal.scheduled.provider.DruidDataSourceProvider;
import com.yingda.xsignal.scheduled.provider.MasterRedisClientProvider;
import com.yingda.xsignal.scheduled.provider.RedisExtendClientProvider;
import com.yingda.xsignal.scheduled.redis.MasterRedisExtendClient;
import com.yingda.xsignal.scheduled.service.DbQueryService;
import com.yingda.xsignal.scheduled.service.DispathResourceService;
import com.yingda.xsignal.scheduled.service.impl.DbQueryServiceImpl;
import com.yingda.xsignal.scheduled.service.impl.DispathResourceServiceImpl;
import com.yingda.xsignal.scheduled.util.PropertyUtil;
import com.yingda.xsignal2.util.redis.RedisExtendClient;
import org.apache.ibatis.transaction.jdbc.JdbcTransactionFactory;
import org.mybatis.guice.MyBatisModule;

/**
 * @author xiaofeng
 * @version V1.0
 * @title: MybatisModule
 * @package: com.yingda.xsignal.scheduled.module
 * @description: TODO
 * @date 2018/6/26 18:24
 */
public class ScheduledModule extends AbstractModule {
    private String file = "config/app.properties";

    @Override
    protected void configure() {
        Names.bindProperties(binder(), PropertyUtil.loadFile(file, getClass()));
        bind(DbQueryService.class).to(DbQueryServiceImpl.class);
        this.install(new MyBatisModule() {
            @Override
            protected void initialize() {
                //绑定我们自定义的数据源provider，也可以使用guice已经编写好的
                bindDataSourceProviderType(DruidDataSourceProvider.class);
                bindTransactionFactoryType(JdbcTransactionFactory.class);
                //添加我们的mapper接口，可以按类注入（即通过类名注入），也可以指定整个包的路径
//                addMapperClass(ExtraScoreInfoMapper.class);
                addMapperClasses("com.yingda.xsignal.scheduled.dao");
            }
        });
    }
}

新建mapper(dao)，用于查询数据库表

package com.yingda.xsignal.scheduled.dao;


import com.yingda.xsignal.scheduled.model.ScoreInfo;
import org.apache.ibatis.annotations.Select;

import java.util.List;
import java.util.Map;
/**
  * @author xiaofeng
  * @version V1.0
  * @title: ExtraScoreInfoMapper
  * @package: com.yingda.xsignal.scheduled.dao
  * @description: 用户积分mapper
  * @date 2018/6/27 15:59
  */
public interface ExtraScoreInfoMapper {
    /**
     * 根据更新时间查询积分信息
     *
     * @param params
     * @return
     */
    @Select("<script> " +
            "SELECT id, user_id, company_id, current_point, recharge_point, present_point, profit_point, " +
            "    invite_point, share_point, blocking_point, recharge_deposit, present_deposit, profit_deposit, " +
            "    invite_deposit, share_deposit, update_time, create_time, create_by, update_by, remark " +
            "FROM tb_score_info " +
            "WHERE 1=1 " +
            "<if test='date!=null'> " +
            "AND UNIX_TIMESTAMP(update_time) &gt; UNIX_TIMESTAMP(#{date}) " +
            "</if> " +
            "</script>")
    List<ScoreInfo> selectListByUpdateTime(Map<String, Object> params);

}

service实现

package com.yingda.xsignal.scheduled.service.impl;

import com.google.inject.Inject;
import com.yingda.xsignal.scheduled.dao.ExtraScoreInfoMapper;
import com.yingda.xsignal.scheduled.model.ScoreInfo;
import com.yingda.xsignal.scheduled.service.DbQueryService;

import java.util.List;
/**
  * @author xiaofeng
  * @version V1.0
  * @title: DbQueryServiceImpl
  * @package: com.yingda.xsignal.scheduled.service.impl
  * @description: TODO
  * @date 2018/6/28 11:16
  */
public class DbQueryServiceImpl implements DbQueryService {

    @Inject
    ExtraScoreInfoMapper extraScoreInfoMapper;

    @Override
    public List<ScoreInfo> queryList() {
        return extraScoreInfoMapper.selectListByUpdateTime(null);
    }
}

主函数入口

package com.yingda.xsignal.scheduled;

import com.google.inject.Guice;
import com.google.inject.Injector;
import com.yingda.xsignal.scheduled.model.ScoreInfo;
import com.yingda.xsignal.scheduled.module.ScheduledModule;
import com.yingda.xsignal.scheduled.service.DbQueryService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;

/**
 * @author xiaofeng
 * @version V1.0
 * @title: TaskWorkerApplication
 * @package: com.yingda.xsignal.task
 * @description: scheduled task
 * @date 2018/6/26 14:54
 */
public class TaskWorkerApplication {

    private Logger logger = LoggerFactory.getLogger(getClass());
    private Injector injector;
    private DbQueryService queryService;

    private TaskWorkerApplication() {
        logger.info("init something......");
        injector = Guice.createInjector(new ScheduledModule());
        queryService = injector.getInstance(DbQueryService.class);
    }

    private void run() {
        logger.info("doing something......");
        queryService.queryList()

    }

    public static void main(String[] args) {
        TaskWorkerApplication taskWorkerApplication = new TaskWorkerApplication();
        try {
            taskWorkerApplication.run();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

右键运行即可！至此，我们已成整合了guice + mybatis 包括redis，已满足项目的基本开发！

猜你喜欢

转载自blog.csdn.net/zwx19921215/article/details/83341814
今日推荐
周排行
Leetcode简单题61~80
解决zookeeper磁盘IO高的问题
多线程相关方法详解
Maven-setting.xml文件详解
Maven 项目的 classpath 理解
渊亭科技大数据笔试题
配置JVM内存分配
计算机网络个人学习笔记 （三）网络层 ：第三部分 连载
js中两个等号(==)和三个等号(===)的区别
用C程序自动打开电脑上的程序
每日归档
更多
2024-09-18(0)
2024-09-17(0)
2024-09-16(0)
2024-09-15(0)
2024-09-14(0)
2024-09-13(0)
2024-09-12(0)
2024-09-11(0)
2024-09-10(0)
2024-09-09(0)

代码天地 © 2018 codetd.com

境外服务器   最新电视剧2022