这篇文章主要给大家介绍了关于Mybatis新手教程之简单入门的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面来一起学习学习吧
1、Mybatis概述
MyBatis 是支持普通 SQL 查询（相比较于Hibernate的封装，Mybatis是半自动化的JDBC封装，一个特点就是Mybatis执行的SQL查询语句需要自己在配置文件中写），存储过程和高级映射的优秀持久层框架。MyBatis 消除了几乎所有的 JDBC 代码和参数的手工设置以及对结果集的检索。MyBatis 可以使用简单的XML 或注解用于配置和原始映射，将接口和 Java 的 POJO（Plain Old Java Objects，普通的Java 对象）映射成数据库中的记录。
2、Mybatis原理解析
下面以Mybatis简单的执行流程
1、加载mybatis全局配置文件（数据源、mapper映射文件等），解析配置文件，MyBatis基于XML配置文件生成Configuration，和一个个MappedStatement（包括了参数映射配置、动态SQL语句、结果映射配置），其对应着<select | update | delete | insert>标签项。
2、SqlSessionFactoryBuilder通过Configuration对象生成SqlSessionFactory，用来开启SqlSession。
3、SqlSession对象完成和数据库的交互：
a、用户程序调用mybatis接口层api（即Mapper接口中的方法）
b、SqlSession通过调用api的Statement ID找到对应的MappedStatement对象
c、通过Executor（负责动态SQL的生成和查询缓存的维护）将MappedStatement对象进行解析，sql参数转化、动态sql拼接，生成jdbc Statement对象
d、JDBC执行sql。
e、借助MappedStatement中的结果映射关系，将返回结果转化成HashMap、JavaBean等存储结构并返回。
下面是Mybatis的框架原理图
3、Mybatis简单实例
（1）导入相关jar包以及Mybatis运行环境核心jar包和连接数据库的包
（2）创建一张简单的数据表
（3）创建Java对象（PO类型）
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 | package cn.mybatis.po;
public class User {
private int id;
private String username;
private String password;
private String address;
private String sex;
public int getId() {
return id;
}
public String getUsername() {
return username;
}
public String getPassword() {
return password;
}
public String getAddress() {
return address;
}
public String getSex() {
return sex;
}
public void setId(int id) {
this.id = id;
}
public void setUsername(String username) {
this.username = username;
}
public void setPassword(String password) {
this.password = password;
}
public void setAddress(String address) {
this.address = address;
}
public void setSex(String sex) {
this.sex = sex;
}
@Override
public String toString() {
return "User{" +
"id=" + id +
", username='" + username + '\'' +
", password='" + password + '\'' +
", address='" + address + '\'' +
", sex='" + sex + '\'' +
'}';
}
}
User实体类
|
（4）创建Mybatis核心配置文件（SqlMapConfig.xml）
在核心配置文件配置连接数据库的相关信息，（如果是和Spring整合，则可以放在Spring配置文件中进行对数据库的配置）
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 | <?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis//DTD Config 3.0//EN"
"http://mybatis/dtd/mybatis-3-config.dtd">
<configuration>
<!--加载资源文件-->
<!-- <properties resource="jdbc.properties"></properties>
<!–settings配置LOG4J输出日志 –>
<settings>
<setting name="logImpl" value="LOG4J"/>
</settings>-->
<!--typeAliases配置包的别名-->
<!--environments配置了数据库连接，配置了driver、url、username、password属性-->
<environments default="development">
<environment id="development">
<transactionManager type="JDBC">
<!--<property name="" value="" />-->
</transactionManager>
<dataSource type="POOLED">
<property name="driver" value="com.mysql.jdbc.Driver" />
<property name="url" value="jdbc:mysql:///mybatis01" />
<property name="username" value="root" />
<property name="password" value="123" />
</dataSource>
</environment>
</environments>
<!--配置一个SQL语句和映射的配置文件-->
<mappers>
<mapper resource="UserMapper.xml" />
</mappers>
</configuration>
Mybatis核心配置文件
|
（5）创建一个Mapper.xml文件，对应编写所需要的Sql查询操作
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | <?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis//DTD Mapper 3.0//EN"
"http://mybatis/dtd/mybatis-3-mapper.dtd">
<!--mapper为根元素，namespace指定了命名空间-->
<mapper namespace="test">
<!--定义一个SELECT查询-->
<!--parameterType:指定输入参数的类型-->
<!--#{}表示占位符-->
<!--#{id}：其中的id表示的就是接受的输入参数，
参数名称就是id，
这里指出：如果输入参数是简单类型，#{}中的参数名可以任意设置（value或者其他名称）-->
<!--resultType：指定输出类型(即指定输出结果所映射的Java对象类型)-->
<select id="findUserById" parameterType="int" resultType="cn.mybatis.po.User">
SELECT * FROM t_user WHERE id = #{id}
</select>
</mapper>
UserMapper配置文件
|
（7）创建测试程序，对刚刚编写的select查询进行测试
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 | package cn.mybatis.first;
import cn.mybatis.po.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import java.io.IOException;
import java.io.InputStream;
public class Test {
public User findUserById() throws IOException {
//得到mybatis配置文件
String resource = "SqlMapConfig.xml";
//得到配置文件的文件流信息
InputStream inputStream = Resources.getResourceAsStream(resource);
//创建会话工厂 传入mybatis的配置文件信息
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
//通过会话工厂得到SqlSession
SqlSession sqlSession = sqlSessionFactory.openSession();
//通过sqlSession来操作数据库
//第一个参数就是映射文件中statment的id：namespace +statment的id
//第二个参数就是制定映射文件中的parameterType类型的参数
User user = sqlSession.selectOne("test.findUserById",1);
//System.out.println(user);
//释放会话资源
try {
sqlSession.close();
} catch (Exception e) {
e.printStackTrace();
}
return user;
}
public static void main(String[] args) {
// TODO Auto-generated method stub
Test test = new Test();
try {
System.out.println(test.findUserById());
} catch (IOException e) {
e.printStackTrace();
}
}
}
Test测试程序
|
（8）加入Log4j日志文件
| 1 2 3 4 5 6 7 8 9 | ### direct log messages to stdout ###
log4j.rootLogger=DEBUG, stdout
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.properties
|
（9）测试结果
4.其他CRUD操作
（1）insert操作
在Mapper文件中添加响应的SQL配置，以及使用MySQL中的LAST_INSERT_ID()函数得到增加的数据的主键值
| 1 2 3 4 5 6 7 8 9 10 11 12 13 | <insert id="addUser" parameterType="cn.mybatis.po.User">
<!--
现在需要得到刚刚插入的记录中的主键值,只适用于自增主键的情况
LAST_INSERT_ID()
keyProperty：将查询到的主键值设置到parameterType指定对象中的那个属性
order：指定相对于insert的顺序
resultType：指定映射结果的结果类型
-->
<selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
SELECT LAST_INSERT_ID()
</selectKey>
INSERT INTO t_user(id,username,password,address,sex) VALUES(#{id},#{username},#{password},#{address}, #{sex});
</insert>
|
插入数据的日志信息，没有使用sqlSessionmit();之前的日志情况
从上面的图中可以看出，没有添加commit的时候，事务进行了回滚，所以要想添加数据，需要自己手动提交（在没有整合Spring之前）
附上insertUser的函数
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 | public void inserUser() throws IOException {
//得到配置文件的文件流信息
InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml");
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
SqlSession sqlSession = sqlSessionFactory.openSession();
User user = new User("World","1234","武汉市","男");
sqlSession.insert("test.addUser",user);
System.out.println(user.getId());
sqlSessionmit();
//释放会话资源
try {
sqlSession.close();
} catch (Exception e) {
e.printStackTrace();
}
}
inserUser函数
|
（2）模糊查询
首先配置Mapper文件，${}和#{}的简单区别如下：
| 1 2 3 4 5 6 7 8 9 10 | <!--
模糊查询可能会查询多条记录
resultType:指定的就是查询结果对应的单条记录类型
${}:表示将输入的参数不加任何的修饰，直接作为字符串拼接在SQL中
但是这样直接拼接，容易导致SQL注入的隐患
${value}中的value表示接受的输入参数，注意如果输入参数是简单类型，其中的形参只能用value
-->
<select id="findUserByUsername" parameterType="java.lang.String" resultType="cn.mybatis.po.User">
SELECT * FROM t_user WHERE username LIKE '%${value}%'
</select>
|
使用查询的时候碰到一个小错误，由于之前测试的insert方法，其中在User实体类中添加了有参构造函数，所以出现了下面的错误，分析原因就是：使用Mybatis查询的时候需要在实体类中加入无参构造方法（当然如果实体类本身没有构造函数，就会是默认的无参构造函数）
附上findByUsername的函数实现
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | public void findUserByUsername() throws IOException {
//得到配置文件的文件流信息
InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml");
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
SqlSession sqlSession = sqlSessionFactory.openSession();
List<User> userList = sqlSession.selectList("test.findUserByUsername","u");
System.out.println(userList);
//释放会话资源
try {
sqlSession.close();
} catch (Exception e) {
e.printStackTrace();
}
}
findByUsername函数实现
|
（3）删除操作
首先在Mapper中配置删除的操作
| 1 2 3 | <delete id="deleteUser" parameterType="java.lang.Integer">
DELETE FROM t_user WHERE id = #{value}
</delete>
|
运行测试程序，同insert中一样，需要手动提交事务，如下面所示
最终结果：
数据表中删除了编号为10的数据记录
5.细节整理
（1）关于示例程序中一些相关类的理解
a）SqlSessionFactoryBuilder
用来创建SqlSessionFactory。因为SqlSessionFactory使用了单例模式，所以不需要使用单例模式来管理SqlSessionFactoryBuilder，只需要在创建SqlSessionFactory时 候使用一次就可以
b）SqlSessionFactory
会话工厂，用来创建SqlSession。可以使用单例模式来管理SqlSessionFactory这个会话工厂，工厂创建之后，就一直使用一个实例。
c）SqlSession
面向程序员的接口，提供了操作数据库的方法。SqlSession是线程不安全的（原因：在SqlSession实现类中除了接口中的操作数据库的方法之外，还有数据域的属性，比如说一些提交的数据等等，所以在多线程并发请求的时候，会导致线程不安全），所以我们可以将SqlSession使用在方法体里面，这样每个线程都有自己的方法，就不会冲突
（2）Mybatis中mapper映射文件
如同解释Mybatis执行原理的时候一样，Mapper映射文件中配置的Sql语句，实际上在执行的时候都被封装称为一个个MapperStatment对象，即Mapper映射文件是按照statment来管理不同的Sql。在编写程序的时候，我们在使用SqlSession其中的操作数据库的方法（selectOne，selectList等等）的时候，传入的参数除了实参（id，模糊查询的字符串等等）之外，还需要传入的就是相应的Sql位置，而Sql是被Statment管理，所以就是传入namespace+statmentId
（3）占位符
#{id}：其中的id表示的就是接受的输入参数，参数名称就是id，这里指出：如果输入参数是简单类型，#{}中的参数名可以任意设置（value或者其他名称）
${value}：表示将输入的参数不加任何的修饰，直接作为字符串拼接在SQL中但是这样直接拼接，容易导致SQL注入的隐患${value}中的value表示接受的输入参数，注意如果输入参数是简单类型，其中的形参只能用value
（4）别名定义
①单个别名的定义
| 1 2 3 4 | <typeAliases>
<!--针对单个别名的定义-->
<typeAlias type="cn.mybatis.po.User" alias="user"></typeAlias>
</typeAliases>
|
定义别名后的使用
| 1 2 3 | <select id="findUserByIdTest" parameterType="int" resultType="user">
SELECT * FROM t_user WHERE id = #{id}
</select>
|
②批量别名的定义
| 1 2 3 4 | <typeAliases>
<!--批量别名定义：Mybatis在定义别名的时候会自动扫描包中的po类，自动的将别名定义为类名（首字母大写或者小写都可以）-->
<package name="cn.mybatis.po"></package>
</typeAliases>
|
（5）在SqlMapConfig.xml中加载Mapper映射文件的时候，除了通过resource的方式，还可以使用mapper接口加载的方式来实现
①首先先注意一点：
在配置mybatis-config.xml时，其中的节点是有顺序的，配置顺序依次为：
properties/settings/typeAliases/typeHandlers/objectFactory/objectWrapperFactory/plugins/environments/databaseIdProvider/mappers
②使用mapper加载的方式，要将mapper接口和mapper配置文件放在同一目录下面，并且文件名称一致，而且要遵循mapper代理的方式进行开发
| 1 2 3 | <mappers>
<mapper class="cn.mybatis.mapper.UserMapper"></mapper>
</mappers>
|
6.Mybatis开发dao方法简介
（1）使用dao接口+实现类的方式
a）首先编写接口，如同一般编写模式方式进行编写
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 | package cn.mybatis.dao;
import cn.mybatis.po.User;
/**
* 原始Dao方式开发：dao接口+dao实现类的方式
*/
public interface UserDao {
//根据id查询信息
public User findUserById(int id) throws Exception;
//添加信息
public void insertUser(User user) throws Exception;
//删除信息
public void deleteUser(int id) throws Exception;
}
dao接口
|
b）然后编写接口实现
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 | package cn.mybatis.dao.daoImpl;
import cn.mybatis.dao.UserDao;
import cn.mybatis.po.User;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.junit.Test;
public class UserDaoImpl implements UserDao {
//使用构造方法注入SqlSessionFactory
private SqlSessionFactory sqlSessionFactory;
public UserDaoImpl(SqlSessionFactory sqlSessionFactory) {
this.sqlSessionFactory = sqlSessionFactory;
}
@Override
@Test
public User findUserById(int id) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
User user = sqlSession.selectOne("test.findUserById",id);
sqlSession.close();
return user;
}
@Override
public void insertUser(User user) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
// User user1 = new User("test1","123","洪山区","男");
sqlSession.insert("test.findUserById",user);
sqlSessionmit();
sqlSession.close();
}
@Override
public void deleteUser(int id) throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
sqlSession.delete("test.findUserById",id);
sqlSessionmit();
sqlSession.close();
}
}
dao接口实现类
|
c）Mapper配置文件和SqlConfig配置文件不变
d）使用Junit进行测试
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 | package cn.mybatis.testdao;
import cn.mybatis.dao.UserDao;
import cn.mybatis.dao.daoImpl.UserDaoImpl;
import cn.mybatis.po.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.InputStream;
public class UserDaoImplTest {
private SqlSessionFactory sqlSessionFactory;
@Before
public void setUp() throws Exception {
InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml");
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
}
@Test
public void testFindUserById() throws Exception{
//创建UserDao的对象
UserDao userDao = new UserDaoImpl(sqlSessionFactory);
//调用UserDao的方法
User user = userDao.findUserById(1);
System.out.println(user );
}
}
Junit测试
|
e）测试结果
f）原始dao方法的问题
①dao接口实现中存在大量的模板方法（即很多重复性的代码 ）
②调用SqlSession方法的时候将statmentid硬编码了
③条用SqlSession方法的时候传入的参数，由于使用泛型，所以在编译阶段不会报错（即使传入参数错误）
（2）使用Mapper代理的方法（即只需要Mapper接口）
（a）使用mapper方式的规范
①在使用mapper代理的方式中，namespace的值应该是mapper接口的路径
②在mapper.java接口文件中的接口方法名称和mapper.xml中的statment的id一致
③在mapper.java接口文件中的接口方法的输入参数和mapper.xml中的statment的parameterType一致
④在mapper.java接口文件中的接口方法的返回值类型和mapper.xml中的statment的resultType一致
（b）查询、删除操作实例
①编写mapper.xml配置文件，其中包含select和delete的sql配置
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | <?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper
PUBLIC "-//mybatis//DTD Mapper 3.0//EN"
"http://mybatis/dtd/mybatis-3-mapper.dtd">
<!--mapper为根元素，namespace指定了命名空间-->
<!--在使用mapper代理的方式中，namespace的值应该是mapper接口的路径-->
<mapper namespace="cn.mybatis.mapper.UserMapper">
<select id="findUserById" parameterType="int" resultType="cn.mybatis.po.User">
SELECT * FROM t_user WHERE id = #{id}
</select>
<delete id="deleteUser" parameterType="java.lang.Integer">
DELETE FROM t_user WHERE id = #{value}
</delete>
</mapper>
mapper.xml配置文件
|
②编写mapper接口，按照mapper代理的方式开发规范来编写mapper的接口
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 | package cn.mybatis.testmapper;
import cn.mybatis.mapper.UserMapper;
import cn.mybatis.po.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.InputStream;
public class UserMapperTest {
private SqlSessionFactory sqlSessionFactory;
@Before
public void setUp() throws Exception {
InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml");
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
}
@Test
public void testFindUserById() throws Exception{
SqlSession sqlSession = sqlSessionFactory.openSession();
//得到UserMapper的代理对象
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
User user = userMapper.findUserById(9);
System.out.println(user);
}
@Test
public void testDeleteUser() throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
userMapper.deleteUser(9);
sqlSessionmit();
}
@After
public void tearDown() throws Exception {
}
}
mapper接口
|
③Junit测试
| 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 | package cn.mybatis.testmapper;
import cn.mybatis.mapper.UserMapper;
import cn.mybatis.po.User;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import java.io.InputStream;
public class UserMapperTest {
private SqlSessionFactory sqlSessionFactory;
@Before
public void setUp() throws Exception {
InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml");
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
}
@Test
public void testFindUserById() throws Exception{
SqlSession sqlSession = sqlSessionFactory.openSession();
//得到UserMapper的代理对象
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
User user = userMapper.findUserById(8);
System.out.println(user);
}
@Test
public void testDeleteUser() throws Exception {
SqlSession sqlSession = sqlSessionFactory.openSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
userMapper.deleteUser(8);
}
@After
public void tearDown() throws Exception {
}
}
Junit测试
|
④查询结果展示
⑤删除结果展示
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作具有一定的参考学习价值，如果有疑问大家可以留言交流，谢谢大家对脚本之家的支持。
发布评论