发布于2021-05-29 19:02 阅读(617) 评论(0) 点赞(11) 收藏(2)
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.6</version>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<!--具体版本看自己的mysql数据库版本-->
<version>8.0.25</version>
</dependency>
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="userMapper">
<!--resultType设置返回的类型-->
<select id="finAll" resultType="com.xzh.doman.User">
select *
from user
</select>
</mapper>
<?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>
<!--配置数据源环境-->
<environments default="developement">
<environment id="developement">
<!--事务管理器-->
<transactionManager type="JDBC"></transactionManager>
<dataSource type="POOLED">
<!--这里因为用的是8.0以上的mysql所以这样配置-->
<property name="driver" value="com.mysql.cj.jdbc.Driver"/>
<property name="url" value="jdbc:mysql:///mybatis"/>
<property name="password" value="000000"/>
<property name="username" value="root"/>
</dataSource>
</environment>
</environments>
<!--加载映射文件-->
<mappers>
<mapper resource="com/xzh/mapper/UserMapper.xml"/>
</mappers>
</configuration>
package com.xzh.test.Mybatis;
import com.xzh.domain.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.jupiter.api.Test;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
/**
* @Author XuZhuHong
* @CreateTime 2021/5/27 21:25
*/
public class MyBatisTest {
@Test
public void testSelect() throws IOException {
//调用方法获取sqlSession
SqlSession sqlSession = getSqlSession();
//执行操作 参数就是UserMapper.xml配置里面 的
// <mapper namespace="userMapper">和 <select id="finAll"
//的namespace 和id的值
List< User > userList = sqlSession.selectList("userMapper.finAll");
//打印输出
for (User user : userList) {
System.out.println(user);
}
//释放资源
sqlSession.close();
}
public static SqlSession getSqlSession() throws IOException {
//获取核心配置文件
InputStream resourceAsStream = Resources.getResourceAsStream("sqlMapConfig.xml");
//获得session工厂对象
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(resourceAsStream);
//获得session会话对象:
SqlSession sqlSession = sqlSessionFactory.openSession();
return sqlSession;
}
}
基于之前配置的环境,只需要在com/xzh/mapper/UserMapper.xml里面添加配置
<!--插入操作-->
<!--parameterType是设置传入的数据类型-->
<insert id="save" parameterType="com.xzh.domain.User">
insert into user
values (#{id}, #{username}, #{password})
</insert>
<!-- #{id} #{}这里面填的是User对应的属性-->
@Test
public void testInsert() throws IOException {
User user = new User();
//这里有点奇怪 如果把id改成Integer类型的数据 不set就会报异常 但是int就不会
user.setUsername("陆六");
user.setPassword("123");
//调用方法获取sqlSession
SqlSession sqlSession = getSqlSession();
//执行操作 参数就是UserMapper.xml配置里面 的
// <mapper namespace="userMapper">和 <select id="save"
//的namespace 和id的值 这个后面的参数是传递一个对象进去 对象是要对应映射里的对象
sqlSession.insert("userMapper.save",user);
//提交事务 这个Mybatis是不会自动提交的需要手动提交
sqlSession.commit();
//释放资源
sqlSession.close();
}
注意点:
基于之前配置的环境,只需要在com/xzh/mapper/UserMapper.xml里面添加配置
<!--更新操作-->
<!--parameterType是设置传入的数据类型-->
<update id="update" parameterType="com.xzh.domain.User">
update user
set username=#{username},
password=#{password}
where id = #{id}
</update>
<!-- #{id} #{}这里面填的是User对应的属性-->
测试类:
@Test
public void testUpdate() throws IOException {
User user = new User();
user.setId(11);
user.setUsername("陆六1");
user.setPassword("1231");
//调用方法获取sqlSession
SqlSession sqlSession = getSqlSession();
sqlSession.update("userMapper.update",user);
//提交事务 这个Mybatis是不会自动提交的需要手动提交
sqlSession.commit();
//释放资源
sqlSession.close();
}
基于之前配置的环境,只需要在com/xzh/mapper/UserMapper.xml里面添加配置
<!--删除操作-->
<delete id="delete" parameterType="java.lang.Integer">
delete
from user
where id = #{id}
</delete>
<!--#{id}这里里面因为只需要一个数据 所以怎么写都ok-->
@Test
public void testDelete() throws IOException {
//调用方法获取sqlSession
SqlSession sqlSession = getSqlSession();
sqlSession.delete("userMapper.delete",13);
sqlSession.commit();
sqlSession.close();
}
其中,事务管理器(transactionManager)类型有两种:
JDBC:这个配置就是直接使用了JDBC 的提交和回滚设置,它依赖于从数据源得到的连接来管理事务作用域。(一般是这个)
MANAGED:这个配置几乎没做什么。它从来不提交或回滚一个连接,而是让容器来管理事务的整个生命周期(比如 JEE 应用服务器的上下文)。 默认情况下它会关闭连接,然而一些容器并不希望这样,因此需要将 closeConnection 属性设置为 false 来阻止它默认的关闭行为。
其中,数据源(dataSource)类型有三种:
UNPOOLED:这个数据源的实现只是每次被请求时打开和关闭连接。
POOLED:这种数据源的实现利用“池”的概念将 JDBC 连接对象组织起来。(一般是这个)
JNDI:这个数据源的实现是为了能在如 EJB 或应用服务器这类容器中使用,容器可以集中或在外部配置数据源,然后放置一个 JNDI 上下文的引用。
该标签的作用是加载映射的,加载方式有如下几种:
使用相对于类路径的资源引用,例如:
使用完全限定资源定位符(URL),例如:
使用映射器接口实现类的完全限定类名,例如:
将包内的映射器接口实现全部注册为映射器,例如:
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--这个文件里面主要描述的说是sql语句-->
<mapper namespace="com.xzh.dao.UserMapper">
<!--删除操作-->
<delete id="delete" parameterType="java.lang.Integer">
delete
from user
where id = #{id}
</delete>
<!--#{id}这里里面因为只需要一个数据 所以怎么写都ok-->
<!--更新操作-->
<!--parameterType是设置传入的数据类型 这里是设置了别名 所以只写的user-->
<update id="update" parameterType="user">
update user
set username=#{username},
password=#{password}
where id = #{id}
</update>
<!-- #{id} #{}这里面填的是User对应的属性-->
<!--插入操作-->
<!--parameterType是设置传入的数据类型 这里是设置了别名 所以只写的user-->
<insert id="save" parameterType="user">
insert into user
values (#{id}, #{username}, #{password})
</insert>
<!-- #{id} #{}这里面填的是User对应的属性-->
<!--查询操作-->
<!--resultType设置结果集合返回的类型 这里是设置了别名 所以只写的user-->
<select id="findAll" resultType="user">
select *
from user
</select>
<select id="findById" resultType="user" parameterType="int">
select * from user where id=#{id}
</select>
</mapper>
package com.xzh.dao;
import com.xzh.domain.User;
import java.io.IOException;
import java.util.List;
/**
* @Author XuZhuHong
* @CreateTime 2021/5/28 9:14
*/
public interface UserMapper {
List< User > findAll() throws IOException;
void save(User user);
void update(User user);
void delete(int id);
User findById(int id);
}
### 对应测试类:
package com.xzh.service;
import com.xzh.dao.UserMapper;
import com.xzh.domain.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.Test;
import javax.crypto.Mac;
import java.io.IOException;
import java.io.InputStream;
import java.util.List;
/**
* @Author XuZhuHong
* @CreateTime 2021/5/28 9:20
*/
public class ServiceDemo {
@Test
public void testUpdate() throws IOException {
//调用函数得到sqlSession
SqlSession sqlSession = getSqlSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
userMapper.update(new User(6, "琪琪", "123"));
}
@Test
public void testFindById() throws IOException {
//调用函数得到sqlSession
SqlSession sqlSession = getSqlSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
User byId = userMapper.findById(6);
System.out.println(byId);
}
@Test
public void testFindAll() throws IOException {
//调用函数得到sqlSession
SqlSession sqlSession = getSqlSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
List< User > all = userMapper.findAll();
for (User user : all) {
System.out.println(user);
}
}
//得到sqlSession函数
public static SqlSession getSqlSession() throws IOException {
InputStream resourceAsStream = Resources.getResourceAsStream("sqlMapConfig.xml");
SqlSessionFactory build = new SqlSessionFactoryBuilder().build(resourceAsStream);
SqlSession sqlSession = build.openSession(true);
return sqlSession;
}
<select id="findByCondition" parameterType="user" resultType="user">
select *
from user
<where>
<if test="id!=0">and id = #{id}</if>
<if test="username!=null">and username = #{username}</if>
<if test="password!=null">and password = #{password}</if>
</where>
</select>
对应测试类:
@Test
public void testFindByCondition() throws IOException {
User user = new User();
// user.setPassword("123");
user.setUsername("张三");
//调用函数得到sqlSession
SqlSession sqlSession = getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
List< User > userList = mapper.findByCondition(user);
for (User user1 : userList) {
System.out.println(user1);
}
}
collection表示参数
open表示开始
close表示结束
separator表示分隔符
item就和foreach中的item一样
<!--根据提供的多个条件查询 foreach语句-->
<select id="findByIds" parameterType="list" resultType="user">
select * from user
<where>
<foreach collection="list" open="id in(" close=")" item="id" separator=",">
#{id}
</foreach>
</where>
</select>
测试类:
@Test
public void testFindByIds() throws IOException {
//调用函数得到sqlSession
SqlSession sqlSession = getSqlSession();
UserMapper mapper = sqlSession.getMapper(UserMapper.class);
List< Integer > list = new ArrayList<>();
list.add(1);
list.add(2);
list.add(3);
List< User > userList = mapper.findByIds(list);
for (User user1 : userList) {
System.out.println(user1);
}
<!--sql语句抽取-->
<sql id="selectUser">
select * from user
</sql>
<!--通过include标签填写对应的id 进行引入-->
<select id="findAll" resultType="user">
<include refid="selectUser"></include>
</select>
开发步骤:
编写需要转换的数据类的配置:
package com.xzh.handler;
import org.apache.ibatis.type.BaseTypeHandler;
import org.apache.ibatis.type.JdbcType;
import java.sql.CallableStatement;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Date;
/**
* @Author XuZhuHong
* @CreateTime 2021/5/28 13:11
*/
//定义的类型必须要继承BaseTypeHandler方法 并重写他的函数 泛型参数就是要转换的参数
public class DateTypeHandler extends BaseTypeHandler< Date > {
//将java转换为数据库需要的类型 这里就是将java数据格式化为sql需要的数据
@Override
public void setNonNullParameter(PreparedStatement preparedStatement, int i, Date date, JdbcType jdbcType) throws SQLException {
long time = date.getTime();
preparedStatement.setLong(i,time);
}
//将数据库中的数据转换为java类型
//String参数是要转换的名称
//ResultSet查询的结果集合
@Override
public Date getNullableResult(ResultSet resultSet, String s) throws SQLException {
long aLong = resultSet.getLong(s);
Date date=new Date(aLong);
return date;
}
@Override
public Date getNullableResult(ResultSet resultSet, int i) throws SQLException {
long aLong = resultSet.getLong(i);
Date date=new Date(aLong);
return date;
}
@Override
public Date getNullableResult(CallableStatement callableStatement, int i) throws SQLException {
long aLong = callableStatement.getLong(i);
Date date=new Date(aLong);
return date;
}
}
然后在sqlMapConfig中添加 自定义类型转换器
<!--自定义类型转换器 里面的handler必须要是转换器的全类名-->
<typeHandlers>
<typeHandler handler="com.xzh.handler.DateTypeHandler"/>
</typeHandlers>
在pom.xml中导入坐标:
<!--分页插件-->
<dependency>
<groupId>com.github.pagehelper</groupId>
<artifactId>pagehelper</artifactId>
<version>3.7.5</version>
</dependency>
<dependency>
<groupId>com.github.jsqlparser</groupId>
<artifactId>jsqlparser</artifactId>
<version>0.9.1</version>
</dependency>
在sqlMapConfig.xml中添加这个插件
<!--配置分页助手插件-->
<plugins>
<plugin interceptor="com.github.pagehelper.PageHelper">
<property name="dialect" value="mysql"/>
</plugin>
</plugins>
测试类:
@Test
public void testFindAllPage() throws IOException {
//调用函数得到sqlSession
SqlSession sqlSession = getSqlSession();
UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
//配置分页参数 startPage(页码,每页显示条数)
PageHelper.startPage(1,3);
List< User > userList = userMapper.findAll();
for (User user : userList) {
System.out.println(user);
}
//获取分页相关的参数 泛型是 查询的数据类型 那个最后的参数是查询到的数据集合
PageInfo<User> pageInfo= new PageInfo<>(userList);
System.out.println("当前页"+pageInfo.getPageNum());
System.out.println("每页显示条数"+pageInfo.getPageSize());
System.out.println("总条数"+pageInfo.getTotal());
System.out.println("总页数"+pageInfo.getPages());
System.out.println("上一页"+pageInfo.getPrePage());
System.out.println("下一页"+pageInfo.getNextPage());
System.out.println("是否是首页"+pageInfo.getFirstPage());
System.out.println("是否是尾页"+pageInfo.getLastPage());
}
原文链接:https://blog.csdn.net/qq_42923605/article/details/117338752
作者:我睡觉爱打呼噜
链接:http://www.javaheidong.com/blog/article/207091/fdb2e9dc5594c4678f1e/
来源:java黑洞网
任何形式的转载都请注明出处,如有侵权 一经发现 必将追究其法律责任
昵称:
评论内容:(最多支持255个字符)
---无人问津也好,技不如人也罢,你都要试着安静下来,去做自己该做的事,而不是让内心的烦躁、焦虑,坏掉你本来就不多的热情和定力
Copyright © 2018-2021 java黑洞网 All Rights Reserved 版权所有,并保留所有权利。京ICP备18063182号-2
投诉与举报,广告合作请联系vgs_info@163.com或QQ3083709327
免责声明:网站文章均由用户上传,仅供读者学习交流使用,禁止用做商业用途。若文章涉及色情,反动,侵权等违法信息,请向我们举报,一经核实我们会立即删除!