一、MyBatis SQL語(yǔ)句構(gòu)建器
有時(shí)候我們需要在Java代碼中創(chuàng)建SQL語(yǔ)句,這時(shí)候我們就不得不面對(duì)加號(hào)、引號(hào)、換行、格式化問(wèn)題、嵌入條件的逗號(hào)管理及 AND 連接等問(wèn)題。對(duì)此,MyBatis 3 提供了方便的工具類來(lái)幫助解決此問(wèn)題。借助 SQL 類,我們只需要簡(jiǎn)單地創(chuàng)建一個(gè)實(shí)例,并調(diào)用它的方法即可生成 SQL 語(yǔ)句。
SQLProvider.java
package com.qfedu.test;
import com.qfedu.pojo.User;
import org.apache.ibatis.jdbc.SQL;
import org.junit.Test;
public class SQLProvider {
public String getAllUser(){
return new SQL()
.SELECT("uid")
.SELECT("username", "password")
.SELECT("age", "addr")
.FROM("user")
// .WHERE("uid = 1")
// .OR()
// .WHERE("username = 'zhangsan'")
.toString();
}
/**
* VALUES(column, values)方法,第一個(gè)參數(shù)為數(shù)據(jù)庫(kù)的表里的列名,第二個(gè)參數(shù)為要填充的數(shù)據(jù)
* 特別注意,要給每個(gè)value添加單引號(hào),否則生成的sql語(yǔ)句中的值會(huì)被認(rèn)為是sql表中的字段
* @return
*/
public String saveUser(){
return new SQL()
.INSERT_INTO("user")
.VALUES("username", "'shixiaopeng'")
.VALUES("password", "'999999'")
.VALUES("age", "'20'")
.VALUES("addr", "'北京'")
.toString();
}
/**
* VALUES(column, values)方法,第一個(gè)參數(shù)為數(shù)據(jù)庫(kù)的表里的列名,第二個(gè)參數(shù)為要填充的數(shù)據(jù)
* 特別注意:給每個(gè)value填充變量值的時(shí)候,可以使用#{value }的方式,
* 其中value可以是對(duì)象的屬性名,也可以是map中的key
* @param u
* @return
*/
public String saveUsers(User u){
return new SQL()
.INSERT_INTO("user")
.VALUES("username", "#{username}")
.VALUES("password", "#{password}")
.VALUES("age", "#{age}")
.VALUES("addr", "#{addr}")
.toString();
}
}
這個(gè)類的主要作用是用來(lái)生成SQL語(yǔ)句。需要特別注意的是插入的時(shí)候如果直接填充字符串常量 ,字符串常量外面還要包括一對(duì)單引號(hào),因?yàn)榻馕龅臅r(shí)候會(huì)把外面的雙引號(hào)去掉。而如果采用#{}就沒(méi)有這個(gè)問(wèn)題。
IUserDaoProvider.java
package com.qfedu.test;
import com.qfedu.pojo.User;
import org.apache.ibatis.annotations.InsertProvider;
import org.apache.ibatis.annotations.Options;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.SelectProvider;
import org.apache.ibatis.jdbc.SQL;
import java.util.List;
public interface IUserDaoProvider {
/**
* type:類型為SQLProvider的構(gòu)建器的類對(duì)象
* method:方法執(zhí)行該類對(duì)象中的具體方法
* @return
*/
@SelectProvider(type = SQLProvider.class, method = "getAllUser")
List<User> getAllUsers();
/**
* type:類型為SQLProvider的構(gòu)建器的類對(duì)象
* method:方法執(zhí)行該類對(duì)象中的具體方法
* @return
*/
@InsertProvider(type = SQLProvider.class, method = "saveUser")
int saveUser();
/**
* type:類型為SQLProvider的構(gòu)建器的類對(duì)象
* method:方法執(zhí)行該類對(duì)象中的具體方法
* Options選項(xiàng)可以設(shè)置額外的參數(shù):
* keyProperty主鍵屬性,useGeneratedKeys是否使用生成策略
* @return
*/
@InsertProvider(type = SQLProvider.class, method = "saveUsers")
@Options(useGeneratedKeys = true, keyProperty = "uid")
int saveUsers(User u);
}
這個(gè)接口使用注解的方式實(shí)現(xiàn)MyBatis。最后一個(gè)保存用戶的方法,添加了@Options注解,使用生成的鍵,并且指定主鍵是uid。
TestSQLProvider.java
package com.qfedu.test;
import com.qfedu.pojo.User;
import com.qfedu.util.SessionUtils;
import org.apache.ibatis.session.SqlSession;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.util.List;
public class TestSQLProvider {
private SqlSession session = null;
@Before
public void setUp() {
session = SessionUtils.getSession();
}
@After
public void tearDown() {
SessionUtils.closeSession(session);
}
@Test
public void testGetAllUsers() {
IUserDaoProvider mapper = session.getMapper(IUserDaoProvider.class);
List<User> list = mapper.getAllUsers();
for (User u : list) {
System.out.println(u);
}
}
@Test
public void testSaveUser(){
IUserDaoProvider mapper = session.getMapper(IUserDaoProvider.class);
int result = mapper.saveUser();
System.out.println(result);
}
@Test
public void testSaveUsers(){
IUserDaoProvider mapper = session.getMapper(IUserDaoProvider.class);
User u = new User();
u.setUsername("litao");
u.setPassword("000000");
u.setAge(20);
u.setAddr("wuhan");
System.out.println(mapper.saveUsers(u));;
}
@Test
public void testSQL(){
SQLProvider sp = new SQLProvider();
System.out.println(sp.getAllUser());
}
}
二、SSM整合
SSM指的是Spring、Spring MVC與MyBatis,之前學(xué)習(xí)的都是各個(gè)部分單獨(dú)怎么使用,現(xiàn)在要把這三個(gè)組件整合在一起。
1. pom.xml
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.qianfeng</groupId>
<artifactId>day70SSM</artifactId>
<version>1.0-SNAPSHOT</version>
<packaging>war</packaging>
<properties>
<!--統(tǒng)一管理spring相關(guān)產(chǎn)品的版本-->
<spring-version>5.2.2.RELEASE</spring-version>
</properties>
<build>
<plugins>
<!-- define the project compile level -->
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>3.6.1</version>
<configuration>
<source>1.8</source>
<target>1.8</target>
</configuration>
</plugin>
<!-- 添加tomcat插件 -->
<plugin>
<groupId>org.apache.tomcat.maven</groupId>
<artifactId>tomcat7-maven-plugin</artifactId>
<version>2.2</version>
<configuration>
<path>/</path>
<port>8080</port>
</configuration>
</plugin>
</plugins>
</build>
<dependencies>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>javax.servlet.jsp</groupId>
<artifactId>jsp-api</artifactId>
<version>2.2</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.15</version>
</dependency>
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>1.2.17</version>
</dependency>
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.10</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.6</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring-version}</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>com.springsource.org.aspectj.weaver</artifactId>
<version>1.6.8.RELEASE</version>
</dependency>
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.3.2</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.2.62</version>
</dependency>
<!-- <dependency>-->
<!-- <groupId>com.fasterxml.jackson.core</groupId>-->
<!-- <artifactId>jackson-databind</artifactId>-->
<!-- <version>2.10.2</version>-->
<!-- </dependency>-->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring-version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring-version}</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.10</version>
</dependency>
</dependencies>
</project>
之前添加的依賴在整合的時(shí)候基本上都要添加,當(dāng)然,如果不需要實(shí)現(xiàn)某項(xiàng)功能就不需要。唯一和之前不同的是這次對(duì)spring框架中的依賴進(jìn)行了版本統(tǒng)一管理。另外,由于我使用jackson-databind會(huì)出現(xiàn)異常信息,所以就把這段依賴注釋了,轉(zhuǎn)而使用fastjson。使用fastjson需要在spring-mvc.xml中多配置一些東西,等會(huì)兒再說(shuō)。
2. web.xml
<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
version="4.0">
<servlet>
<servlet-name>springDispatcherServlet</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath:spring-mvc.xml</param-value>
</init-param>
</servlet>
<servlet-mapping>
<servlet-name>springDispatcherServlet</servlet-name>
<url-pattern>/</url-pattern>
</servlet-mapping>
<!-- spring寫(xiě)好的中文過(guò)濾器-->
<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>
</filter>
<filter-mapping>
<filter-name>encode</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
</web-app>
web.xml中配置了兩個(gè)東西,一個(gè)是轉(zhuǎn)發(fā)控制器,另一個(gè)是spring的中文過(guò)濾器。
3. spring-mvc.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"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context https://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/mvc https://www.springframework.org/schema/mvc/spring-mvc.xsd">
<bean class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<property name="suffix" value=".jsp"/>
</bean>
<context:component-scan base-package="com.qianfeng.controller"/>
<context:component-scan base-package="com.qianfeng.service"/>
<mvc:annotation-driven>
<!-- 使用fastjson來(lái)替代默認(rèn)的HttpMessageConverter以提高執(zhí)行效率-->
<mvc:message-converters>
<bean class="com.alibaba.fastjson.support.spring.FastJsonHttpMessageConverter">
<property name="supportedMediaTypes">
<!-- 設(shè)置UTF-8編碼防止亂碼-->
<list>
<value>application/json;charset=UTF-8</value>
</list>
</property>
</bean>
</mvc:message-converters>
</mvc:annotation-driven>
<mvc:default-servlet-handler/>
<import resource="classpath:spring-mybatis.xml"/>
</beans>
這個(gè)是springmvc的配置文件,配置了視圖解析器,組件掃描,注解驅(qū)動(dòng),默認(rèn)的servlet處理器,引入了資源文件。在注解驅(qū)動(dòng)中我對(duì)fastjson進(jìn)行了一些配置,主要用來(lái)防止中文亂碼。這里配置的包掃描包括兩個(gè)包:一個(gè)時(shí)controller,一個(gè)是service。
4. spring-mybatis.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"
xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd">
<!-- 引入數(shù)據(jù)庫(kù)配置信息文件 -->
<context:property-placeholder location="classpath:db.properties" />
<!-- 配置druid數(shù)據(jù)源 -->
<bean id="ds" class="com.alibaba.druid.pool.DruidDataSource">
<!--<property name="url" value="jdbc:mysql://localhost:3306/hello2"></property>-->
<!--<property name="driverClassName" value="com.mysql.jdbc.Driver" />-->
<!--<property name="username" value="root" />-->
<!--<property name="password" value="123456" />-->
<property name="url" value="${url}"></property>
<property name="driverClassName" value="${driver}" />
<property name="username" value="${user}" />
<property name="password" value="${pass}" />
</bean>
<!-- 配置SqlSessionFactoryBean對(duì)象,用來(lái)獲取SqlSession -->
<!--
我們知道在Mybatis的所有操作都是基于一個(gè)SqlSession的,而SqlSession是由SqlSessionFactory來(lái)產(chǎn)生的,
SqlSessionFactory又是由SqlSessionFactoryBuilder來(lái)生成的。但是Mybatis-Spring是基于SqlSessionFactoryBean的。
在使用Mybatis-Spring的時(shí)候,我們也需要SqlSession,而且這個(gè)SqlSession是內(nèi)嵌在程序中的,一般不需要我們直接訪問(wèn)。
SqlSession也是由SqlSessionFactory來(lái)產(chǎn)生的,但是Mybatis-Spring給我們封裝了一個(gè)SqlSessionFactoryBean,
在這個(gè)bean里面還是通過(guò)SqlSessionFactoryBuilder來(lái)建立對(duì)應(yīng)的SqlSessionFactory,進(jìn)而獲取到對(duì)應(yīng)的SqlSession。
通過(guò)SqlSessionFactoryBean我們可以通過(guò)對(duì)其指定一些屬性來(lái)提供Mybatis的一些配置信息。?
-->
<bean id="sf" class="org.mybatis.spring.SqlSessionFactoryBean">
<property name="typeAliasesPackage" value="com.qfedu.pojo" />
<property name="mapperLocations" value="classpath:com/qfedu/dao/mapper/*Mapper.xml" />
<property name="dataSource" ref="ds"></property>
<property name="configLocation" value="classpath:mybatis-config.xml" />
</bean>
<!-- 配置映射掃描器,分別設(shè)置dao包的掃描和SqlSessionFactory的指定 -->
<!--
Mybatis-Spring為我們提供了一個(gè)叫做MapperScannerConfigurer的類,
通過(guò)這個(gè)類Mybatis-Spring會(huì)自動(dòng)為我們注冊(cè)Mapper對(duì)應(yīng)的MapperFactoryBean對(duì)象。
?如果我們需要使用MapperScannerConfigurer來(lái)幫我們自動(dòng)掃描和注冊(cè)Mapper接口的話我們需要在Spring的applicationContext配置文件中
定義一個(gè)MapperScannerConfigurer對(duì)應(yīng)的bean。對(duì)于MapperScannerConfigurer而言有一個(gè)屬性是我們必須指定的,
那就是basePackage。basePackage是用來(lái)指定Mapper接口文件所在的基包的,在這個(gè)基包或其所有子包下面的Mapper接口都將被搜索到。
多個(gè)基包之間可以使用逗號(hào)或者分號(hào)進(jìn)行分隔。最簡(jiǎn)單的MapperScannerConfigurer定義就是只指定一個(gè)basePackage屬性。
-->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.qfedu.dao" />
<property name="sqlSessionFactoryBeanName" value="sf" />
</bean>
<!-- 配置事務(wù)管理器 -->
<bean id="dtx" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="ds"></property>
</bean>
<tx:advice id="tx" transaction-manager="dtx">
<!-- 聲明屬性,聲明事務(wù)的規(guī)則 -->
<tx:attributes>
<tx:method name="save*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="Exception" />
<tx:method name="insert*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="Exception" />
<tx:method name="update*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="Exception" />
<tx:method name="delete*" propagation="REQUIRED" isolation="DEFAULT" rollback-for="Exception" />
</tx:attributes>
</tx:advice>
<!-- 定義切面 -->
<aop:config>
<aop:pointcut id="mpt" expression="execution(* com.qfedu.service.*.*(..))" />
<aop:advisor advice-ref="tx" pointcut-ref="mpt" />
</aop:config>
</beans>
這個(gè)配置文件導(dǎo)入了db.properties文件,配置了DruidDataSource、SqlSessionFactoryBean、MapperScannerConfigurer、DataSourceTransactionManager、tx:advice、定義了切面
5. mybatis-config.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!--
給當(dāng)前mybatis項(xiàng)目添加日志功能,該STDOUT_LOGGING值的好處是不用添加第三方j(luò)ar包就可以有日志的輸出
-->
<settings>
<setting name="logImpl" value="LOG4J"/>
</settings>
</configuration>
盡管在上一個(gè)文件中幾乎把所有的MyBatis配置都配置了,我們?nèi)匀挥斜匾獎(jiǎng)?chuàng)建這個(gè)文件對(duì)mybatis進(jìn)行一些私有化的配置。
6. log4j.properties
# 全局日志配置
log4j.rootLogger=ERROR, stdout, F
# MyBatis 日志配置
log4j.logger.com.qianfeng.dao.IUserDao=TRACE
# 控制臺(tái)輸出
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n
# 文件輸出
log4j.appender.F = org.apache.log4j.DailyRollingFileAppender
log4j.appender.F.File =myproj.log
log4j.appender.F.Append = true
log4j.appender.F.Threshold = DEBUG
log4j.appender.F.layout=org.apache.log4j.PatternLayout
log4j.appender.F.layout.ConversionPattern=%-d{yyyy-MM-dd HH\:mm\:ss}-[%p %F\:%L] %m%n
這是log4j的配置文件
7. db.properties
driver=com.mysql.cj.jdbc.Driver
url=jdbc:mysql://localhost:3306/mydb
user=root
pass=123456
這是連接數(shù)據(jù)庫(kù)時(shí)需要的配置信息,盡量不要使用user和password作為key。
8. IUserDao.java
package com.qianfeng.dao;
import com.qianfeng.pojo.User;
import org.apache.ibatis.annotations.Param;
import java.util.List;
public interface IUserDao {
List<User> getAllUsers();
int deleteUser(@Param("uid") int uid);
User getUserById(@Param("uid") int uid);
int updateUser(User user);
int saveUser(User user);
}
我們使用了MyBatis配置的第二種方式:即使用接口+xml文件方式
9. IUserService與UserServiceImpl
package com.qianfeng.service;
import com.qianfeng.pojo.User;
import java.util.List;
public interface IUserService {
List<User> getAllUsers();
boolean deleteUser(int uid);
User getUserById(int uid);
boolean updateUser(User user);
boolean saveUser(User user);
}
package com.qianfeng.service.impl;
import com.qianfeng.dao.IUserDao;
import com.qianfeng.pojo.User;
import com.qianfeng.service.IUserService;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
@Service
public class UserServiceImpl implements IUserService {
@Resource
private IUserDao userDao;
@Override
public List<User> getAllUsers() {
return userDao.getAllUsers();
}
@Override
public boolean deleteUser(int uid) {
return userDao.deleteUser(uid)>0;
}
@Override
public User getUserById(int uid) {
return userDao.getUserById(uid);
}
@Override
public boolean updateUser(User user) {
return userDao.updateUser(user)>0;
}
@Override
public boolean saveUser(User user) {
return userDao.saveUser(user)>0;
}
}
使用service注解來(lái)配合組件掃描,使用Resouce注解不用使用new關(guān)鍵字來(lái)創(chuàng)建對(duì)象。
10. UserController.java
package com.qianfeng.controller;
import com.qianfeng.pojo.User;
import com.qianfeng.service.IUserService;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.servlet.ModelAndView;
import javax.annotation.Resource;
import java.util.List;
@Controller
public class UserController {
@Resource
private IUserService userService;
@GetMapping("/users")
public ModelAndView getAllUsers(){
return new ModelAndView("/users","users",userService.getAllUsers());
}
@GetMapping("/deleteUser/{uid}")
public String deleteUser(@PathVariable int uid){
boolean flag = userService.deleteUser(uid);
return "redirect:/users";
}
@GetMapping("/updateUser/{uid}")
public ModelAndView updateUserPage(@PathVariable int uid){
return new ModelAndView("/update","user",userService.getUserById(uid));
}
@PostMapping("/updateUser")
public String updateUser(User user){
boolean flag = userService.updateUser(user);
return "redirect:/users";
}
@PostMapping("/saveUser")
public String saveUser(User user){
boolean flag = userService.saveUser(user);
return "redirect:/users";
}
}
這是一個(gè)controller,使用Controller注解來(lái)配合組件掃描