Guice进阶之整合mybatis和druid

上一篇文章中介绍了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=0mybatis.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();@Injectpublic void setDriverClassName(@Named("jdbc.driverClassName") final String driverClassName) {dataSource.setDriverClassName(driverClassName);}@Injectpublic void setUrl(@Named("jdbc.url") final String url) {dataSource.setUrl(url);}@Injectpublic void setUsername(@Named("jdbc.username") final String username) {dataSource.setUsername(username);}@Injectpublic 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);}@Overridepublic String toString() {return "DruidDataSourceProvider{" +"jdbc.url=" + dataSource.getUrl() +",username='" + dataSource.getUsername() +'}';}@Overridepublic 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";@Overrideprotected void configure() {Names.bindProperties(binder(), PropertyUtil.loadFile(file, getClass()));bind(DbQueryService.class).to(DbQueryServiceImpl.class);this.install(new MyBatisModule() {@Overrideprotected 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 {@InjectExtraScoreInfoMapper extraScoreInfoMapper;@Overridepublic 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，已满足项目的基本开发！

Guice进阶之整合mybatis和druid相关推荐

【SpringBoot】SpringBoot整合Mybatis、druid
文章目录
SpringBoot进阶教程 | 第四篇：整合Mybatis实现多数据源
这篇文章主要介绍,通过Spring Boot整合Mybatis后如何实现在一个工程中实现多数据源.同时可实现读写分离. 准备工作环境: windows jdk 8 maven 3.0 IDEA 创建 ...
SpringBoot进阶教程 | 第四篇：整合Mybatis实现多数据源 1
这篇文章主要介绍,通过Spring Boot整合Mybatis后如何实现在一个工程中实现多数据源.同时可实现读写分离. 准备工作环境: windows jdk 8 maven 3.0 IDEA 创建 ...
java使用druid maven_SpringMVC+Spring+Mybatis整合，使用druid连接池，声明式事务，maven配置...
一直对springmvc和mybatis挺怀念的,最近想自己再搭建下框架,然后写点什么. 暂时没有整合缓存,druid也没有做ip地址的过滤.Spring的AOP简单配置了下,也还没具体弄,不知道能不 ...
SpringMVC+Spring+Mybatis整合，使用druid连接池，声明式事务，maven配置
一直对springmvc和mybatis挺怀念的,最近想自己再搭建下框架,然后写点什么. 暂时没有整合缓存,druid也没有做ip地址的过滤.Spring的AOP简单配置了下,也还没具体弄,不知道能不 ...
使用Druid数据库连接池整合MyBatis Plus时，出现Error attempting to get column 'startTime' from result set. 类似错误
问题描述: 使用Druid数据库连接池整合MyBatis Plus3.2.0时,出现Error attempting to get column 'startTime' from result set ...
Spring Boot2.0 整合mybatis、分页插件、druid
2019独角兽企业重金招聘Python工程师标准>>> 前言本文主要是针对SpringBoot2.0.2版本,实现整合mybatis.分页插件.druid等组件,实现完整的web服 ...
springboot update数据_SpringBoot整合Mybatis+Druid+数据库（注解版）
运行展示正题 Spring boot :2.1.5RELEASE :数据库(Mysql.Oracle):Mybatis:阿里云的连接池 : Druid : 步骤 1．POM依赖 <!-- My ...
Springboot整合Mybatis，p6spy，druid
首先,贴出完整POM文件 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http:// ...

Guice进阶之整合mybatis和druid

Guice进阶之整合mybatis和druid相关推荐

最新文章

热门文章