java渐变橡皮擦_橡皮擦的动态SegmentFault思否

什么是MyBatisMyBatis 本是apache的一个开源项目iBatis, 2010年这个项目由apache software foundation 迁移到了google code&＃xff0c;并且改名为MyBatis。是一个基于Java的持久层框架

为什么我们要用Mybatis&＃xff1f;

无论是Mybatis、Hibernate都是ORM的一种实现框架&＃xff0c;都是对JDBC的一种封装&＃xff01;

到目前为止&＃xff0c;我们已经在持久层中学了几种技术了...Hibernate

jdbc

SpringDAO

那我们为啥还要学Mybatis呢&＃xff1f;&＃xff1f;&＃xff1f;现在Mybatis在业内大行其道&＃xff0c;那为啥他能那么火呢&＃xff1f;&＃xff1f;

Hibernate是一个比较老旧的框架&＃xff0c;用过他的同学都知道&＃xff0c;只要你会用&＃xff0c;用起来十分舒服...啥sql代码都不用写...但是呢&＃xff0c;它也是有的缺点&＃xff1a;&＃xff1a;处理复杂业务时&＃xff0c;灵活度差, 复杂的HQL难写难理解&＃xff0c;例如多表查询的HQL语句

而JDBC很容易理解&＃xff0c;就那么几个固定的步骤&＃xff0c;就是开发起来太麻烦了&＃xff0c;因为什么都要我们自己干..

而SpringDAO其实就是JDBC的一层封装&＃xff0c;就类似于dbutils一样&＃xff0c;没有特别出彩的地方....

我们可以认为&＃xff0c;Mybatis就是jdbc和Hibernate之间的一个平衡点...毕竟现在业界都是用这个框架&＃xff0c;我们也不能不学呀&＃xff01;

Mybatis快速入门

其实我们已经学过了Hibernate了&＃xff0c;对于Mybatis入门其实就非常类似的。因此就很简单就能掌握基本的开发了...

导入开发包

导入Mybatis开发包mybatis-3.1.1.jar

commons-logging-1.1.1.jar

log4j-1.2.16.jar

cglib-2.2.2.jar

asm-3.3.1.jar

导入mysql/oracle开发包mysql-connector-java-5.1.7-bin.jar

Oracle 11g 11.2.0.1.0 JDBC_ojdbc6.jar

准备测试工作

创建一张表create table students(

id int(5) primary key,

name varchar(10),

sal double(8,2)

);

创建实体&＃xff1a;/**

* Created by ozc on 2017/7/21.

*/

public class Student {

private Integer id;

private String name;

private Double sal;

public Student() {

}

public Integer getId() {

return id;

}

public void setId(Integer id) {

this.id &＃61; id;

}

public String getName() {

return name;

}

public void setName(String name) {

this.name &＃61; name;

}

public Double getSal() {

return sal;

}

public void setSal(Double sal) {

this.sal &＃61; sal;

}

}

创建mybatis配置文件

创建mybatis的配置文件&＃xff0c;配置数据库的信息....数据库我们可以配置多个&＃xff0c;但是默认的只能用一个...

/p>

"http://mybatis.org/dtd/mybatis-3-config.dtd">

编写工具类测试是否获取到连接

使用Mybatis的API来创建一个工具类&＃xff0c;通过mybatis配置文件与数据库的信息&＃xff0c;得到Connection对象package cn.itcast.javaee.mybatis.util;

import java.io.IOException;

import java.io.Reader;

import java.sql.Connection;

import org.apache.ibatis.io.Resources;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

/**

* 工具类

* &＃64;author AdminTC

*/

public class MybatisUtil {

private static ThreadLocal threadLocal &＃61; new ThreadLocal();

private static SqlSessionFactory sqlSessionFactory;

/**

* 加载位于src/mybatis.xml配置文件

*/

static{

try {

Reader reader &＃61; Resources.getResourceAsReader("mybatis.xml");

sqlSessionFactory &＃61; new SqlSessionFactoryBuilder().build(reader);

} catch (IOException e) {

e.printStackTrace();

throw new RuntimeException(e);

}

}

/**

* 禁止外界通过new方法创建

*/

private MybatisUtil(){}

/**

* 获取SqlSession

*/

public static SqlSession getSqlSession(){

//从当前线程中获取SqlSession对象

SqlSession sqlSession &＃61; threadLocal.get();

//如果SqlSession对象为空

if(sqlSession &＃61;&＃61; null){

//在SqlSessionFactory非空的情况下&＃xff0c;获取SqlSession对象

sqlSession &＃61; sqlSessionFactory.openSession();

//将SqlSession对象与当前线程绑定在一起

threadLocal.set(sqlSession);

}

//返回SqlSession对象

return sqlSession;

}

/**

* 关闭SqlSession与当前线程分开

*/

public static void closeSqlSession(){

//从当前线程中获取SqlSession对象

SqlSession sqlSession &＃61; threadLocal.get();

//如果SqlSession对象非空

if(sqlSession !&＃61; null){

//关闭SqlSession对象

sqlSession.close();

//分开当前线程与SqlSession对象的关系&＃xff0c;目的是让GC尽早回收

threadLocal.remove();

}

}

/**

* 测试

*/

public static void main(String[] args) {

Connection conn &＃61; MybatisUtil.getSqlSession().getConnection();

System.out.println(conn!&＃61;null?"连接成功":"连接失败");

}

}

创建实体与映射关系文件

配置实体与表的映射关系

/p>

"http://mybatis.org/dtd/mybatis-3-mapper.dtd">

现在我们已经有了Mybatis的配置文件和表与实体之前的映射文件了&＃xff0c;因此我们要将配置文件和映射文件关联起来

在测试类上&＃xff0c;我们是可以获取得到连接的

编写DAOpublic class StudentDao {

public void add(Student student) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

sqlSession.insert();

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

Student student &＃61; new Student(1, "zhongfucheng", 10000D);

studentDao.add(student);

}

}

到现在为止&＃xff0c;我们实体与表的映射文件仅仅映射了实体属性与表的字段的关系...

我们在Hibernate中如果想要插入数据什么的&＃xff0c;只要调用save()方法就行了。Hibernate是自动化屏蔽掉了数据库的差异&＃xff0c;而我们Mybatis是需要自己手动编写SQL代码的...

那么SQL代码是写在哪里的呢&＃xff1f;&＃xff1f;&＃xff1f;明显地&＃xff0c;我们作为一个框架&＃xff0c;不可能在程序中写SQL&＃xff0c;我们是在实体与表的映射文件中写的&＃xff01;

Mybatis实体与表的映射文件中提供了insert标签【SQL代码片段】供我们使用//在JDBC中我们通常使用?号作为占位符&＃xff0c;而在Mybatis中&＃xff0c;我们是使用#{}作为占位符

//parameterType我们指定了传入参数的类型

//#{}实际上就是调用了Student属性的get方法

INSERT INTO ZHONGFUCHENG.STUDENTS (ID, NAME, SAL) VALUES (#{id},#{name},#{sal});

在程序中调用映射文件的SQL代码片段public void add(Student student) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

sqlSession.insert("StudentID.add", student);

sqlSession.commit();

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

值得注意的是&＃xff1a;Mybatis中的事务是默认开启的&＃xff0c;因此我们在完成操作以后&＃xff0c;需要我们手动去提交事务&＃xff01;

Mybatis工作流程通过Reader对象读取Mybatis配置文件

通过SqlSessionFactoryBuilder对象创建SqlSessionFactory对象

获取当前线程的SQLSession

事务默认开启

通过SQLSession读取映射文件中的操作编号&＃xff0c;从而读取SQL语句

提交事务

关闭资源

完成CRUD操作

我们在上面中已经简单知道了Mybatis是怎么使用的以及工作流程了&＃xff0c;这次我们使用Mybatis来完成CRUD的操作&＃xff0c;再次巩固Mybatis的开发步骤以及一些细节

包与类之间的结构

增加学生

配置文件

/p>

"http://mybatis.org/dtd/mybatis-3-config.dtd">

映射文件

INSERT INTO ZHONGFUCHENG.STUDENTS (ID, NAME, SAL) VALUES (#{id},#{name},#{sal});

插入数据public class StudentDao {

public void add(Student student) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

sqlSession.insert("StudentID.add", student);

sqlSession.commit();

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

Student student &＃61; new Student(3, "zhong3", 10000D);

studentDao.add(student);

}

}

根据ID查询数据

增加select标签

SELECT * FROM STUDENTS WHERE id &＃61; #{id};

查询出来的结果是一个Student对象&＃xff0c;我们调用SelectOne方法public Student findById(int id) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

return sqlSession.selectOne("StudentID.findById",id);

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

Student student &＃61; studentDao.findById(1);

System.out.println(student.getName());

}

查询所有数据

SELECT * FROM STUDENTS;

我们查询出来的结果不单单只有一个对象了&＃xff0c;因此我们使用的是SelectList这个方法public List findAll() throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

return sqlSession.selectList("StudentID.findAll");

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

List students &＃61; studentDao.findAll();

System.out.println(students.size());

}

根据id删除

DELETE FROM STUDENTS WHERE id&＃61;#{id};

调用delete方法删除public void delete(int id ) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

sqlSession.delete("StudentID.delete", id);

sqlSession.commit();

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

studentDao.delete(1);

}

修改

update students set name&＃61;#{name},sal&＃61;#{sal} where id&＃61;#{id};

查询出对应的对象&＃xff0c;对其进行修改public void update(Student student ) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

sqlSession.update("StudentID.update", student);

sqlSession.commit();

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

Student student &＃61; studentDao.findById(2);

student.setName("fucheng");

student.setSal(2000D);

studentDao.update(student);

}

小细节

Mybatis分页

分页是一个非常实用的技术点&＃xff0c;我们也来学习一下使用Mybatis是怎么分页的...

我们的分页是需要多个参数的&＃xff0c;并不是像我们之前的例子中只有一个参数。当需要接收多个参数的时候&＃xff0c;我们使用Map集合来装载&＃xff01;public List pagination(int start ,int limit) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

/**

* 由于我们的参数超过了两个&＃xff0c;而方法中只有一个Object参数收集

* 因此我们使用Map集合来装载我们的参数

*/

Map map &＃61; new HashMap();

map.put("start", start);

map.put("limit", limit);

return sqlSession.selectList("StudentID.pagination", map);

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

List students &＃61; studentDao.pagination(0, 3);

for (Student student : students) {

System.out.println(student.getId());

}

}

那么在实体与表映射文件中&＃xff0c;我们接收的参数就是map集合

/*根据key自动找到对应Map集合的value*/

select * from students limit #{start},#{limit};

动态SQL

何为动态SQL&＃xff1f;&＃xff1f;回顾一下我们之前写的SSH项目中&＃xff0c;有多条件查询的情况&＃xff0c;如下图

我们当时刚开始做的时候&＃xff0c;是需要在Controller中判断SQL是否已经有条件了&＃xff0c;因为SQL语句需要拼接起来....这样干的话&＃xff0c;就非常容易出错的。

如下的代码&＃xff0c;如果有多个条件的话&＃xff0c;那么拼接起来很容易出错&＃xff01;public String listUI() {

//查询语句

String hql &＃61; "FROM Info i ";

List objectList &＃61; new ArrayList<>();

//根据info是否为null来判断是否是条件查询。如果info为空&＃xff0c;那么是查询所有。

if (info !&＃61; null) {

if (StringUtils.isNotBlank(info.getTitle())) {

hql &＃43;&＃61; "where i.title like ?";

objectList.add("%" &＃43; info.getTitle() &＃43; "%");

}

}

infoList &＃61; infoServiceImpl.findObjects(hql,objectList);

ActionContext.getContext().getContextMap().put("infoTypeMap", Info.INFO_TYPE_MAP);

return "listUI";

}

后来&＃xff0c;我们觉得这样不好&＃xff0c;于是就专门写了一个查询助手类&＃xff1a;package zhongfucheng.core.utils;

import java.util.ArrayList;

import java.util.List;

/**

* Created by ozc on 2017/6/7.

*/

public class QueryHelper {

private String fromClause &＃61; "";

private String whereClause &＃61; "";

private String orderbyClause &＃61; "";

private List objectList;

public static String ORDER_BY_ASC &＃61; "asc";

public static String ORDER_BY_DESC &＃61; "desc";

//FROM子句只出现一次

/**

* 构建FROM字句&＃xff0c;并设置查询哪张表

* &＃64;param aClass 用户想要操作的类型

* &＃64;param alias 别名

*/

public QueryHelper(Class aClass, String alias) {

fromClause &＃61; " FROM " &＃43; aClass.getSimpleName() &＃43; " " &＃43; alias;

}

//WHERE字句可以添加多个条件&＃xff0c;但WHERE关键字只出现一次

/**

* 构建WHERE字句

* &＃64;param condition

* &＃64;param objects

* &＃64;return

*/

public QueryHelper addCondition(String condition, Object... objects) {

//如果已经有字符了&＃xff0c;那么就说明已经有WHERE关键字了

if (whereClause.length() > 0) {

whereClause &＃43;&＃61; " AND " &＃43; condition;

} else {

whereClause &＃43;&＃61; " WHERE" &＃43; condition;

}

//在添加查询条件的时候&＃xff0c;?对应的查询条件值

if (objects &＃61;&＃61; null) {

objectList &＃61; new ArrayList<>();

}

for (Object object : objects) {

objectList.add(object);

}

return this;

}

/**

*

* &＃64;param property 要排序的属性

* &＃64;param order 是升序还是降序

* &＃64;return

*/

public QueryHelper orderBy(String property, String order) {

//如果已经有字符了&＃xff0c;那么就说明已经有ORDER关键字了

if (orderbyClause.length() > 0) {

orderbyClause &＃43;&＃61; " , " &＃43; property &＃43;" " &＃43; order;

} else {

orderbyClause &＃43;&＃61; " ORDER BY " &＃43; property&＃43;" " &＃43; order;

}

return this;

}

/**

* 返回HQL语句

*/

public String returnHQL() {

return fromClause &＃43; whereClause &＃43; orderbyClause;

}

/**

* 得到参数列表

* &＃64;return

*/

public List getObjectList() {

return objectList;

}

}

这样一来的话&＃xff0c;我们就不用自己手动拼接了&＃xff0c;给我们的查询助手类去拼接就好了。

而如果我们使用Mybatis的话&＃xff0c;就可以免去查询助手类了。因为Mybatis内部就有动态SQL的功能【动态SQL就是自动拼接SQL语句】&＃xff01;

动态查询

select * from students

and name&＃61;#{name}

and sal <#{sal}

查询出来小于9000块的人public List findByCondition(String name,Double sal) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

/**

* 由于我们的参数超过了两个&＃xff0c;而方法中只有一个Object参数收集

* 因此我们使用Map集合来装载我们的参数

*/

Map map &＃61; new HashMap();

map.put("name", name);

map.put("sal", sal);

return sqlSession.selectList("StudentID.findByCondition", map);

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

List students &＃61; studentDao.findByCondition(null,9000D);

for (Student student : students) {

System.out.println(student.getId() &＃43; "---" &＃43; student.getName() &＃43; "----" &＃43; student.getSal());

}

}

动态更新

update students

name &＃61; #{name},

sal &＃61; #{sal},

where id &＃61; #{id}

给出三个更新的字段public void updateByConditions(int id,String name,Double sal) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

/**

* 由于我们的参数超过了两个&＃xff0c;而方法中只有一个Object参数收集

* 因此我们使用Map集合来装载我们的参数

*/

Map map &＃61; new HashMap();

map.put("id", id);

map.put("name", name);

map.put("sal", sal);

sqlSession.update("StudentID.updateByConditions", map);

sqlSession.commit();

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

studentDao.updateByConditions(2,"haha",500D);

}

动态删除

以前我们使用JDBC也好&＃xff0c;Hibernate也好&＃xff0c;想要批量删除的时候&＃xff0c;总是使用的是循环删除。而我们现在使用的是Mybatis&＃xff0c;SQL语句是自己写的。所以我们可以写下如下的SQL来进行删除delete from students where id in (?,?,?,?);

而我们的Mybatis又支持动态SQL,所以删除起来就非常方便了&＃xff01;

delete from students where id in

#{ids}

删除编号为2&＃xff0c;3&＃xff0c;4的记录public void deleteByConditions(int... ids) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

/**

* 由于我们的参数超过了两个&＃xff0c;而方法中只有一个Object参数收集

* 因此我们使用Map集合来装载我们的参数

*/

sqlSession.delete("StudentID.deleteByConditions", ids);

sqlSession.commit();

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

studentDao.deleteByConditions(2,3,4);

}

动态插入

我们要想动态插入的话&＃xff0c;就比其他的DML语句稍微复杂一点&＃xff0c;因为它有两部分是不确定的&＃xff0c;平常的SQL语句是这样的&＃xff1a;insert into student(id,name,sal) values(?,?,?)

SQL代码块是不能像之前那样帮我们自动去除多余的逗号的&＃xff0c;因此我们需要使用trim标签来自己手动去除...

编写insertSQL语句的时候&＃xff0c;不要忘了写()括号。

id,

name,

sal,

#{id},

#{name},

#{sal},

insert into students () values

()

测试三个不同内容的数据public void insertByConditions(Student student) throws Exception {

//得到连接对象

SqlSession sqlSession &＃61; MybatisUtil.getSqlSession();

try{

//映射文件的命名空间.SQL片段的ID&＃xff0c;就可以调用对应的映射文件中的SQL

sqlSession.insert("StudentID.insertByConditions", student);

sqlSession.commit();

}catch(Exception e){

e.printStackTrace();

sqlSession.rollback();

throw e;

}finally{

MybatisUtil.closeSqlSession();

}

}

public static void main(String[] args) throws Exception {

StudentDao studentDao &＃61; new StudentDao();

studentDao.insertByConditions(new Student(55, null, null));//name和sal为空

studentDao.insertByConditions(new Student(66, "haxi", null));//sal为空

studentDao.insertByConditions(new Student(77, null, 3999d));//name为空

}

总结Mybatis的准备工作与Hibernate差不多&＃xff0c;都需要一个总配置文件、一个映射文件。

Mybatis的SQLSession工具类使用ThreadLocal来对线程中的Session来进行管理。

Mybatis的事务默认是开启的&＃xff0c;需要我们手动去提交事务。

Mybatis的SQL语句是需要手写的&＃xff0c;在程序中通过映射文件的命名空间.sql语句的id来进行调用!

在Mybatis中&＃xff0c;增删改查都是需要我们自己写SQL语句的&＃xff0c;然后在程序中调用即可了。SQL由于是我们自己写的&＃xff0c;于是就相对Hibernate灵活一些。

如果需要传入多个参数的话&＃xff0c;那么我们一般在映射文件中用Map来接收。

由于我们在开发中会经常用到条件查询&＃xff0c;在之前&＃xff0c;我们是使用查询助手来帮我们完成对SQL的拼接的。而Mybatis的话&＃xff0c;我们是自己手写SQL代码的。

Mybatis也支持一些判断标签&＃xff0c;于是我们就可以通过这些标签来完成动态CRUD的操作了。

值得注意的是&＃xff0c;我们的sql片段代码是需要我们自己手动去分割&＃xff0c;号的。如果文章有错的地方欢迎指正&＃xff0c;大家互相交流。习惯在微信看技术文章&＃xff0c;想要获取更多的Java资源的同学&＃xff0c;可以关注微信公众号:Java3y查看原文