SpringBoot项目整合mybatis的方法步骤与实例

2023-08-26 21:12:04 331

1.导入依赖的jar包

springboot项目整合mybatis之前首先要导入依赖的jar包，配置pom.xml文件如下：



4.0.0
com.u
springboot-mybatis
1.0-SNAPSHOT

org.springframework.boot
spring-boot-starter-parent
1.3.0.RELEASE


com.us.Application
3.2.7
1.2.2
1.8
1.8




org.springframework.boot
spring-boot-starter-web



mysql
mysql-connector-java
6.0.5


com.mchange
c3p0
0.9.5.2


commons-logging
commons-logging





org.springframework
spring-jdbc


org.mybatis
mybatis
${mybatis.version}


org.mybatis
mybatis-spring
${mybatis-spring.version}



org.apache.commons
commons-lang3
3.4

2.配置数据源

pom.xml配置完毕后需要配置数据源了。新建DBConfig类配置数据源，代码如下：

importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.core.env.Environment;
importcom.alibaba.druid.pool.DruidDataSource;
importcom.google.common.base.Preconditions;
@Configuration
publicclassDBConfig{
@Autowired
privateEnvironmentenv;
@Bean(name="dataSource")
publicDruidDataSourcedataSource(){
finalStringurl=Preconditions.checkNotNull(env.getProperty("ms.db.url"));
finalStringusername=Preconditions.checkNotNull(env.getProperty("ms.db.username"));
finalStringpassword=env.getProperty("ms.db.password");
finalintmaxActive=Integer.parseInt(env.getProperty("ms.db.maxActive","200"));
DruidDataSourcedataSource=newDruidDataSource();
dataSource.setUrl(url);
dataSource.setUsername(username);
dataSource.setPassword(password);
dataSource.setMaxActive(maxActive);
returndataSource;
}
}

3.添加数据库连接信息

在配置文件application.properties中添加数据库连接信息如下：

ms.db.url=jdbc:mysql://localhost:3306/dev?prepStmtCacheSize=517&cachePrepStmts=true&autoReconnect=true&characterEncoding=utf-8&allowMultiQueries=true
ms.db.username=root
ms.db.password=admin
ms.db.maxActive=500

4.配置mybatis的SqlSessionFactoryBean

数据源配置完以后要配置mybatis的SqlSessionFactoryBean进行扫描mapper，新建MyBatisConfig类代码如下（classpath*:mapper/*.xml为mapper.xml文件路径）：

importjavax.sql.DataSource;
importorg.mybatis.spring.SqlSessionFactoryBean;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.context.ApplicationContext;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
@Configuration
publicclassMyBatisConfig{
@Autowired
privateDataSourcedataSource;
@Bean(name="sqlSessionFactory")
publicSqlSessionFactoryBeansqlSessionFactory(ApplicationContextapplicationContext)throwsException{
SqlSessionFactoryBeansessionFactory=newSqlSessionFactoryBean();
sessionFactory.setDataSource(dataSource);
sessionFactory.setMapperLocations(applicationContext.getResources("classpath*:mapper/*.xml"));
returnsessionFactory;
}
}

5.配置MapperScannerConfigurer扫描dao层

然后配置MapperScannerConfigurer扫描dao层，新建类MyBatisScannerConfig代码如下（注意与MyBatisConfig不要写在一个类里）：

importorg.mybatis.spring.mapper.MapperScannerConfigurer;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
@Configuration
publicclassMyBatisScannerConfig{
@Bean
publicMapperScannerConfigurerMapperScannerConfigurer(){
MapperScannerConfigurermapperScannerConfigurer=newMapperScannerConfigurer();
mapperScannerConfigurer.setBasePackage("com.example.*.dao");
mapperScannerConfigurer.setSqlSessionFactoryBeanName("sqlSessionFactory");
returnmapperScannerConfigurer;
}
}

6.开启数据库事务（必须）代码如下

importjavax.sql.DataSource;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.context.annotation.Bean;
importorg.springframework.context.annotation.Configuration;
importorg.springframework.jdbc.datasource.DataSourceTransactionManager;
importorg.springframework.transaction.PlatformTransactionManager;
importorg.springframework.transaction.annotation.TransactionManagementConfigurer;
@Configuration
publicclassTransactionConfigimplementsTransactionManagementConfigurer{
@Autowired
privateDataSourcedataSource;
@Bean(name="transactionManager")
@Override
publicPlatformTransactionManagerannotationDrivenTransactionManager(){
returnnewDataSourceTransactionManager(dataSource);
}
}

7.实战

配置大致就是如此，然后就是新建javabean（省略，文章底部有源码地址）

新建mapper.xml文件（省略，文章底部有源码地址，关于mapper.xml文件编写的疑问可以看我以前的springmvc＋mybatis系列文章）

新建dao层。代码如下：

importjava.util.List;
importjava.util.Map;
importcom.example.base.model.User;
importcom.example.config.MyBatisRepository;
publicinterfaceUserDao{
publicListgetList(Mapmap);
}

service层要在实现类上添加@service注解，代码如下：

importjava.util.Map;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.stereotype.Service;
importcom.example.base.dao.UserDao;
importcom.example.base.service.UserService;
@Service
publicclassUserServiceImplimplementsUserService{
@Autowired
privateUserDaouserDao;
publicObjectgetList(Mapmap){
returnuserDao.getList(map);
}
}

controller层也要加@controller注解代码如下：

importjavax.servlet.http.HttpServletRequest;
importjava.util.Map;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.http.HttpStatus;
importorg.springframework.http.ResponseEntity;
importorg.springframework.stereotype.Controller;
importorg.springframework.web.bind.annotation.RequestMapping;
importorg.springframework.web.bind.annotation.RequestMethod;
importorg.springframework.web.bind.annotation.ResponseBody;
importcom.example.base.service.UserService;
importcom.example.base.util.CommonUtil;
importcom.example.demo.ServiceEmail;
@Controller
@RequestMapping(value="/users")
publicclassUserController{
@Autowired
privateUserServiceuserService;
@Autowired
privateServiceEmailserviceEmail;
/***
*api:localhost:8099/users?id=99localhost:8099/users
*
*@paramrequest
*@return
*/
@RequestMapping(method=RequestMethod.GET,produces="application/json;charset=UTF-8")
@ResponseBody
publicResponseEntitylist(HttpServletRequestrequest){
Mapmap=CommonUtil.getParameterMap(request);
returnnewResponseEntity

SpringBoot项目整合mybatis的方法步骤与实例

热门推荐

随机推荐