您的位置：首页 > 编程语言 > Java开发

spring mvc高级篇(八):Spring+SpringMVC+Mybatis整合(采用泛型和注解优化)

2017-08-13 01:34 591 查看

8.1整合思路分析

用Spring对MyBatis进行整合，将使得采用MyBatis操作数据库更加方便和简单。由于Spring 3的开发在MyBatis 3官方发布前就结束了，Spring开发团队不想发布一个基于非发布版本的MyBatis的整合支持，因此Spring 3没有提供对MyBatis3的支持。为了使Spring 3支持MyBatis 3，MyBatis团队开发出整合类，让开发者直接在Spring中使用MyBatis。

8.2 Spring和MyBatis整合核心类的介绍

在使用MyBatis-Spring整合之前，我们需要先下载相应的整合JAR包。在MyBatis的官方网站( http://code.google.com/p/mybatis/)上，找到MyBatis Integration，下载整合需要的mybatis-spring-1.2.0-bundle.zip，下载并解压后的目录如下图所示。整合时，在工程中只要包含mybatis-spring-1.2.0.jar就可以了。

MyBatis-Spring包的目录结构
要在Spring中使用MyBatis，需要在Spring的配置文件中定义一些类。下面先了解一下这些核心类。

1. SqlSessionFactoryBean

在MyBatis中，SqlSessionFactory可以使用SqISessionFactoryBuilder来创建，而在MyBatis-Spring中，使用SqISessinFacotryBean来代替，可以直接在Spring通过配置文件的形式配置。

2．MapperFactoryBean

MapperFactoryBean实现了Spring的FactoryBean接口，通过mapperlnterface属性注入接口，将映射接口变成可以注射的Spring Bean。

3. SqlSessionTemplate

SqlSessinTemplate类负责管理MyBatis的SqlSession，调用MyBatis的SQL映射语句，轻松实现数据库的访问。SqlSessionTernplate是线程安全的。当调用SQL方法时，包括通过从映射器getMapper()方法返回的映射器的方法，SqlSessionTemplate会保证使用的SqlSession是和当前Spring事务相关联的。此外，它管理会话的生命周期，包括必要的关闭、提交和回滚操作。

8.3注解配置简介

注解配置相对于 XML 配置具有很多的优势：

(1)它可以充分利用 Java 的反射机制获取类结构信息，这些信息可以有效减少配置的工作。如使用 JPA 注释配置 ORM 映射时，我们就不需要指定 PO 的属性名、类型等信息，如果关系表字段和 PO 属性名、类型都一致，您甚至无需编写任务属性映射信息——因为这些信息都可以通过 Java 反射机制获取。

(2)注释和 Java 代码位于一个文件中，而 XML 配置采用独立的配置文件，大多数配置信息在程序开发完成后都不会调整，如果配置信息和 Java 代码放在一起，有助于增强程序的内聚性。而采用独立的 XML 配置文件，程序员在编写一个功能时，往往需要在程序文件和配置文件中不停切换，这种思维上的不连贯会降低开发效率。

因此在很多情况下，注释配置比 XML 配置更受欢迎，注释配置有进一步流行的趋势。但是大量使用注解会影响项目后期维护，因为只要改了一点点配置，就要修改源代码，整个项目需要重新编译再上线。那么，到底是使用注释配置还是XML 配置呢？这就要取决于整个项目的取舍。

8.4 泛型介绍

泛型，即“参数化类型”。一提到参数，最熟悉的就是定义方法时有形参，然后调用此方法时传递实参。那么参数化类型怎么理解呢？顾名思义，就是将类型由原来的具体的类型参数化，类似于方法中的变量参数，此时类型也定义成参数形式（可以称之为类型形参），然后在使用/调用时传入具体的类型（类型实参）。

使用泛型可以让我们简化大量类似代码。例如我们要写一个方法交换两个整数,我们可以定义方法：public void swap(int a,int b){},如果我们又要求交换两个double型数据，交换两个String型数据，按照我们一般的思路，我们就要定义方法public void swap(doublea,double b){}，public void swap(String a,String b){}。但是如果我们使用泛型，我们定义一个方法即可：public void swap(T a,T b){}。同样道理，我们在做业务开发的时候，我们可能需要对每张表都编写方法getById,
save, update,deleteById …，这样的话就会重复大量的代码，带来大量重复的工作。如果我们使用实体类结合泛型，就能很容易避免这样的问题，让项目开发如虎添翼。

8.5 开发环境

开发工具:myeclipse8.6.1

数据库:mysql5.5.23

服务器: tomcat6.0.37

框架版本: spring3.2.2+mybatis3.2.2

8.6 案例开发步骤

步骤一:在myeclipse8.6中新建web工程AnnoGenericSMMvc，拷贝如下包到lib目下：

代码的目录结构如下图所示：

步骤二:编写web.xml 配置文件，代码如下：

=================================web.xml========================

<?xml
version="1.0"encoding="UTF-8"?>
<web-app
version="2.5"
xmlns="http://java.sun.com/xml/ns/javaee"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://java.sun.com/xml/ns/javaee
http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd"> 
<error-page>
<error-code>404</error-code>
<location>/Err404.html</location>
</error-page>
<error-page>
<error-code>500</error-code>
<location>/Err500.html</location>
</error-page>



<filter>
<filter-name>loginFilter</filter-name>
<filter-class>com.wx.filters.LoginFilter</filter-class>

<init-param>
<param-name>exclusions</param-name>
<param-value>AnnoGenericSMMvc/,.js,.gif,.jpg,.jpeg,.png,.css,.ico,
Login.jsp,Login.php,Register.jsp,register.php,CheckUser.php,
ShowOneUser.jsp,ShowResult.jsp,Trans.php,ShowOneUser.php,quit.php
</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>loginFilter</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>



<filter>
<filter-name>DruidWebStatFilter</filter-name>
<filter-class>com.alibaba.druid.support.http.WebStatFilter</filter-class>
<init-param>
<param-name>exclusions</param-name>
<param-value>*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>DruidWebStatFilter</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
<servlet>
<servlet-name>DruidStatView</servlet-name>
<servlet-class>com.alibaba.druid.support.http.StatViewServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>DruidStatView</servlet-name>
<url-pattern>/druid/*</url-pattern>
</servlet-mapping>



<filter>
<filter-name>encode</filter-name>
<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
<init-param>
<param-name>encoding</param-name>
<param-value>UTF-8</param-value>
</init-param>
<init-param>
<param-name>forceEncoding</param-name>
<param-value>true</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>encode</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>



<servlet>
<servlet-name>springmvc</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:configs/mvc/springmvc-dispatcher.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>

<servlet-mapping>
<servlet-name>springmvc</servlet-name>
<url-pattern>*.php</url-pattern>
</servlet-mapping>



<context-param>
<param-name>log4jConfigLocation</param-name>
<param-value>classpath:configs/log4j.properties</param-value>
</context-param>
<listener>
<listener-class>org.springframework.web.util.Log4jConfigListener</listener-class>
</listener>



<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:configs/applicationContext.xml</param-value>
</context-param>
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>


<welcome-file-list>
<welcome-file>Login.jsp</welcome-file>
</welcome-file-list>
</web-app>
================================================================

知识讲解：Spring需要启动容器才能为其他框架提供服务，由于Web应用程序的人口是被Web服务器控制的，所以，无法在main()方法中通过创建ClassPallXmIApplicationContext对象来启动Spring容器。Spring提供了一个监听器类org.springframework.web．context.ContextLoaderListener来解决这个问题。该监听器实现了ServletContextListener接口，可以在Web容器启动的时候初始化Spring容器。当然，前提是需要在web.xml中配置好这个监听器。具体请参见上面配置代码及相关的注释部分。

步骤三：建立mybatis核心配置文件,如下所示:
====================== mybatis-config.xml============================
<?xml
version="1.0"encoding="UTF-8"
?>
<!DOCTYPE
configuration
PUBLIC
"-//mybatis.org//DTDConfig 3.0//EN"
"mybatis-3-config.dtd">
<configuration>

<typeAliases>
<typeAlias
type="com.wx.entitys.UserEntity"
alias="userEntity"/>
<typeAlias
type="com.wx.entitys.PageEntity"
alias="conEntity"/>
<typeAlias
type="com.wx.entitys.StudentEntity"
alias="stuEntity"/>
<typeAlias
type="com.wx.entitys.DeptEntity"
alias="deptEntity"/>
<typeAlias
type="com.wx.entitys.PageEntity"
alias="pageEntity"/>

</typeAliases>

</configuration>
=====================================================================

步骤四：建立druid数据源的属性文件,如下所示:
========================= druidConfig.properties=====================
driverClassName=com.mysql.jdbc.Driver
url=jdbc\:mysql\://localhost\:3306/schooldb
username=root
password=123456
#配置监控统计拦截的filters，去掉后监控界面sql无法统计
filters=stat
#配置初始化大小
initialSize=6
#配置初始化最大连接数
maxActive=20
#配置最小空闲连接数
minIdle=3
#配置获取连接等待超时的时间,1分钟
maxWait=60000
#检测连接是否有效的SQL

validationQuery=SELECT
'x'
#申请连接的时候检测，如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效
testWhileIdle=true
#申请连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能
testOnBorrow=false
#归还连接时执行validationQuery检测连接是否有效，做了这个配置会降低性能
testOnReturn=false
#启用PSCache，必须配置大于0，当大于0时，poolPreparedStatements自动触发修改为true

maxPoolPreparedStatementPerConnectionSize=20
#对于长时间不使用的连接强制关闭
removeAbandoned=true
#超过30秒的空闲连接就可以被关闭了,单位是秒
removeAbandonedTimeout=30
#配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒
timeBetweenEvictionRunsMillis=10000
#配置一个连接在池中最小生存的时间，单位是毫秒
minEvictableIdleTimeMillis=30000
=====================================================================

步骤五：建立log4j的属性文件,如下所示:
========================= log4j.properties=====================
log4j.rootLogger=INFO,
Console

#Console
log4j.appender.Console=org.apache.log4j.ConsoleAppender
log4j.appender.Console.layout=org.apache.log4j.PatternLayout
log4j.appender.Console.layout.ConversionPattern=%d
[%t] %-5p
[%c] %m%n
=====================================================================

步骤六：建立spring的核心配置文件,如下所示:
========================= applicationContext.xml=====================
<?xml
version="1.0"encoding="UTF-8"?>
<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-3.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> 
<context:component-scan
base-package="com.wx.dao.*">
</context:component-scan>
<context:component-scan
base-package="com.wx.service">
</context:component-scan>

<bean
id="config"class="org.springframework.beans.factory.config.PreferencesPlaceholderConfigurer">
<property
name="location">
<value>classpath:configs/druidConfig.properties</value>
</property>
</bean>

<bean
id="druidDataSource"
class="com.alibaba.druid.pool.DruidDataSource"init-method="init"
destroy-method="close">
<property
name="driverClassName"value="${driverClassName}"
/>
<property
name="url"value="${url}"
/>
<property
name="username"value="${username}"
/>
<property
name="password"value="${password}"
/>
<property
name="filters"value="${filters}"
/>
<property
name="initialSize"value="${initialSize}"
/>
<property
name="maxActive"value="${maxActive}"
/>
<property
name="minIdle"value="${minIdle}"
/>
<property
name="maxWait"value="${maxWait}"
/>
<property
name="validationQuery"value="${validationQuery}"
/>
<property
name="testWhileIdle"value="${testWhileIdle}"
/>
<property
name="testOnBorrow"value="${testOnBorrow}"
/>
<property
name="testOnReturn"value="${testOnReturn}"
/>
<property
name="maxPoolPreparedStatementPerConnectionSize"value="${maxPoolPreparedStatementPerConnectionSize}"/>
<property
name="removeAbandoned"value="${removeAbandoned}"
/>
<property
name="removeAbandonedTimeout"value="${removeAbandonedTimeout}"
/>
<property
name="timeBetweenEvictionRunsMillis"value="${timeBetweenEvictionRunsMillis}"
/>
<property
name="minEvictableIdleTimeMillis"value="${minEvictableIdleTimeMillis}"
/>
</bean>

<bean
id="sessionFactory"
class="org.mybatis.spring.SqlSessionFactoryBean">
<property
name="dataSource"ref="druidDataSource"></property>
<property
name="configLocation">
<value>classpath:configs/mybatis-config.xml</value>
</property>
<property
name="mapperLocations">
<list>
<value>classpath:com/wx/entitys/*.xml</value>
</list>
</property>
</bean>

<bean
id="sqlSessionTemplate"
class="org.mybatis.spring.SqlSessionTemplate">
<constructor-arg
name="sqlSessionFactory"ref="sessionFactory"></constructor-arg>
</bean>


<bean
id="txManager"
class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property
name="dataSource"ref="druidDataSource"></property>
</bean>
<tx:advice
id="txAdvise"
transaction-manager="txManager">
<tx:attributes>
<tx:method
name="find*"read-only="true"/>
<tx:method
name="search*"read-only="true"/>
<tx:method
name="query*"read-only="true"/>
<tx:method
name="get*"read-only="true"/>
<tx:method
name="add*"propagation="REQUIRED"/>
<tx:method
name="save*"propagation="REQUIRED"/>
<tx:method
name="do*"propagation="REQUIRED"/>
<tx:method
name="update*"propagation="REQUIRED"/>
<tx:method
name="del*"
propagation="REQUIRED"/>
</tx:attributes>
</tx:advice>
<aop:config>
<aop:pointcut
expression="execution(*com.wx.service.*.*(..))"
id="myCut"/>
<aop:advisor
advice-ref="txAdvise"pointcut-ref="myCut"/>
</aop:config>

</beans>
=====================================================================

步骤七：编写spring mvc的核心配置文件springmvc-dispatcher.xml，如下所示:
==================== springmvc-dispatcher.xml==================
<?xml
version="1.0"encoding="UTF-8"?>

<beans
xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.0.xsd"> 
<context:component-scan
base-package="com.wx.controler.*"></context:component-scan>


<bean
id="irvResolver"

class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<property
name="prefix"
value="/"></property>
<property
name="suffix"
value=".jsp"></property>
</bean>

</beans>
=====================================================================
上面列出了所有的配置文件及相关注释，接下来我们对整个框架使用泛型部分进行说明。泛型部分的代码即公共代码，我们结合一个用户模块对其进行说明。如下面的UML类图所示：实线空闲箭头代表继承，虚线空心箭头代表实现，直线代表关联。IBaseDao接口里面的5个方法对所有的表都通用。

步骤八: 编写公共模块的代码如下

==================== IBaseDao.java==============================
package com.wx.dao;

import java.util.List;

/**
* 集合持久层的公用的增，删，改，查接口
* <T>表示传入实体类
* @author汪祥
* 2015-09-11
*/
public
interface IBaseDao<T> {
/**
* 查询多条记录
* @param t
实体类的对象
* @return对象列表
*/
public List<T> queryMany(T t);

/**
* 根据id删除记录
* @param id
对象编号
* @return被删除的记录条数
*/
public Integer deleteById(String id);

/**
* 修改数据
* @param t
实体类的对象
* @return被修改的记录条数
*/
public Integer modify(T t);

/**
* 根据id查询一条记录
* @param id
对象编号
* @return被修改的记录条数
*/
public T getById(String id);

/**
* 添加一条数据
* @param t
实体类的对象
* @return添加的记录条数
*/
public Integer add(T t);
}
=====================================================================

==================== BaseDaoImpl.java==============================
package com.wx.dao;

import java.lang.reflect.ParameterizedType;
import java.util.List;
import org.mybatis.spring.SqlSessionTemplate;
import org.springframework.beans.factory.annotation.Autowired;

/**
* 集合持久层的公用的增，删，改，查的父类
* <T>表示传入实体类
* @author汪祥
* 2015-09-11
*/
public
class BaseDaoImpl<T> implements IBaseDao<T> {

@Autowired
protected SqlSessionTemplate
sqlTemplate;

/**
* 获取传过来的泛型类名称
* @return String
泛型类名称的小写形式
*/
@SuppressWarnings("unchecked")
public String getClassName() {
// 在父类中得到子类声明的父类的泛型信息
ParameterizedType pt = (ParameterizedType) this.getClass()
.getGenericSuperclass();
Class<T> clazz = (Class) pt.getActualTypeArguments()[0];
// 这里是获取实体类的简单名称，再把类名转为小写
StringclassName=clazz.getSimpleName().toString().toLowerCase();
System.out.println("className:"+className);
return className;
}

/**
* 添加一条数据
* @param t
实体类的对象
* @return添加的记录条数
*/
public Integer add(T t) {
return
sqlTemplate.insert(this.getClassName() +
".add", t);
}

/**
* 根据id删除记录
* @param id
对象编号
* @return被删除的记录条数
*/
public Integer deleteById(String id) {
return
sqlTemplate.delete(this.getClassName() +
".deleteById", id);
}

/**
* 根据id查询一条记录
* @param id
对象编号
* @return被修改的记录条数
*/
@SuppressWarnings("unchecked")
public T getById(String id) {
return (T)sqlTemplate.selectOne(this.getClassName() +
".getById", id);
}

/**
* 修改数据
* @param t
实体类的对象
* @return被修改的记录条数
*/
public Integer modify(T t) {
return
sqlTemplate.update(this.getClassName() +
".update", t);
}

/**
* 查询多条记录
* @param t
实体类的对象
* @return对象列表
*/
public List<T> queryMany(T t) {
return
sqlTemplate.selectList(this.getClassName() +
".queryMany", t);
}
}
=====================================================================
==================== IUserDao.java==============================
package com.wx.dao.user;

import com.wx.dao.IBaseDao;
import com.wx.entitys.UserEntity;
public
interface IUserDao extends IBaseDao<UserEntity> {
//登录
boolean isLogin(UserEntity user);

//判断用户是否存在(true-存在,false-不存在)
boolean isUserExist(String userName);
}
=====================================================================
==================== UserDaoImpl.java==============================
package com.wx.dao.user;

import java.util.List;

import org.springframework.stereotype.Repository;

import com.wx.dao.BaseDaoImpl;
import com.wx.entitys.UserEntity;

@Repository("userDao")
public
class UserDaoImpl extends BaseDaoImpl<UserEntity>
implements IUserDao {

public
boolean isLogin(UserEntity paramUser) {
boolean flag=false;
UserEntity theUser=sqlTemplate.selectOne("userentity.selectForLogin", paramUser);
if(theUser!=null){
flag=true;
}
return flag;
}

public
boolean isUserExist(String userName) {
boolean flag=false;
List<UserEntity> userList=sqlTemplate.selectList("userentity.selectByName", userName);
if(userList!=null && userList.size()>=1){
flag=true;
}
return flag;
}
} =====================================================================
步骤九：编写控制器类，这里只列举其中一个类UserControl.java，如下所示:
====================UserControl.java================================
package com.wx.controler.user;

import java.io.IOException;
import java.io.PrintWriter;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.servlet.ModelAndView;

import com.wx.entitys.UserEntity;
import com.wx.service.UserService;

@Controller
public
class UserControl{
@Autowired
private UserService
userServ;

@RequestMapping(value="/Login.php")
public ModelAndView login(HttpServletRequestrequest,HttpServletResponse response){
HttpSession session=request.getSession();
session.setMaxInactiveInterval(5*60);
//5分钟后session失效
String userName=request.getParameter("userName");
String passWord=request.getParameter("pwd");
UserEntity user=new UserEntity(userName, passWord);
ModelAndView mov=null;
if(userServ.isLogin(user)){
session.setAttribute("userStr",userName);
mov=new ModelAndView("redirect:QueryStu.php");
}else{
session.setAttribute("msg",
"用户名或密码错误");
mov=new ModelAndView("redirect:Login.jsp");
}
return mov;
}
@RequestMapping(value="/Register.php",method=RequestMethod.POST)
public ModelAndView register(HttpServletRequest request,
HttpServletResponse response,UserEntity user){
ModelAndView mov=new ModelAndView("index");
userServ.save(user);
return mov;
}
@RequestMapping(value="/Quit.php")
public ModelAndView quit(HttpServletRequestrequest,HttpServletResponse response){
HttpSession session=request.getSession();
session.invalidate();
ModelAndView mov=new ModelAndView("redirect:Login.jsp");
return mov;
}
@RequestMapping(value="/ShowOneUser.php")
public ModelAndView showOne(HttpServletRequestrequest,HttpServletResponse response){
String userIdStr=request.getParameter("userId");
Integer userId=Integer.parseInt(userIdStr);
UserEntity user=userServ.getById(userId);
request.setAttribute("oneUser", user);
ModelAndView mov=new ModelAndView("ShowOneUser");
return mov;
}
@RequestMapping(value="/CheckUser.php")
public
void isUserExist(HttpServletRequest request,
HttpServletResponse response) throws IOException{
String userName=request.getParameter("userName");
PrintWriter out=response.getWriter();
String returnStr="err";
if(!userServ.isUserExist(userName)){
returnStr="ok";
}
out.println(returnStr);
out.flush();
out.close();
}
}
=====================================================================

说明：其它的java类和jsp代码不一一列出，因为实在太多了，有需要请联系我。

步骤十: 启动tomcat，发布项目，在地址栏分别输入 http://localhost:8080/ AnnoGenericSMMvc

进行测试。登录后的结果如图所示：

联系作者：

内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理

标签：

相关文章推荐

新的分享

章节导航