MyBatis基础练习
作者：互联网
项目目录结构：
依赖包：
<dependencies>
<!--单测-->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
<scope>test</scope>
</dependency>
<!--数据库-->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>8.0.11</version>
</dependency>
<!--MyBatis-->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>3.4.4</version>
</dependency>
<!--到slf4j与log4j的关联jar包，通过这个东西，将对slf4j接口的调用转换为对log4j的调用，不同的日志实现框架，这个转换工具不同-->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>1.7.25</version>
<scope>test</scope>
</dependency>
<!--alibaba 数据源 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>druid</artifactId>
<version>1.1.10</version>
</dependency>
</dependencies>
<build>
<resources>
<resource>
<directory>src/main/java</directory>
<includes>
<include>**/*.properties</include>
<include>**/*.xml</include>
</includes>
<filtering>false</filtering>
</resource>
<resource>
<directory>src/main/resources</directory>
<includes>
<include>**/*.properties</include>
<include>**/*.xml</include>
</includes>
<filtering>false</filtering>
</resource>
</resources>
</build>
实体类：
public class Department {
private int departmentId;
private String departmentName;
public int getDepartmentId() {
return departmentId;
}
public void setDepartmentId(int departmentId) {
this.departmentId = departmentId;
}
public String getDepartmentName() {
return departmentName;
}
public void setDepartmentName(String departmentName) {
this.departmentName = departmentName;
}
public Department() {
}
public Department(int departmentId, String departmentName) {
this.departmentId = departmentId;
this.departmentName = departmentName;
}
@Override
public String toString() {
return "Department{" +
"departmentId=" + departmentId +
", departmentName='" + departmentName + '\'' +
'}';
}
}
mybatis-config.xml配置
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!--配置的属性都是可外部配置且可动态替换的-->
<properties resource="database.properties" />
<settings>
<setting name="logImpl" value="SLF4J"/>
</settings>
<!--定义别名,存在的意义仅在于用来减少类完全限定名的冗余。-->
<typeAliases>
<!--使用扫描包，扫描指定包下的所有类，扫描之后的别名就是类名（不区分大小写），建议使用的时候和类名一致。-->
<package name="cn.pojo"/>
</typeAliases>
<!--环境数据源-->
<environments default="development">
<environment id="development">
<transactionManager type="JDBC"></transactionManager>
<dataSource type="cn.util.DruidDataSourceFactory">
<property name="driverClassName" value="${jdbc.driver}"/>
<property name="url" value="${jdbc.url}"/>
<property name="username" value="${jdbc.username}"/>
<property name="password" value="${jdbc.password}"/>
</dataSource>
</environment>
</environments>
<!--告诉 MyBatis 到哪里查找sql映射语句-->
<mappers>
<mapper resource="mapper/PracticeMapper.xml" />
</mappers>
</configuration>
工具类：
MyBatisUtil
public class MyBatisUtil {
//创建SqlSessionFactory工厂
public static SqlSessionFactory factory;
static {
InputStream is = null;
try {
//读取mybatis-config.xml
is = Resources.getResourceAsStream("mybatis-config.xml");
factory = new SqlSessionFactoryBuilder().build(is);
} catch (IOException e) {
e.printStackTrace();
}
}
public static SqlSession createSqlSession(){
return factory.openSession(false);//关闭自动提交事物
}
public static void closeSqlSession(SqlSession sqlSession){
if(null!=sqlSession){
sqlSession.close();
}
}
}
阿里云Druid数据源类
public class DruidDataSourceFactory extends PooledDataSourceFactory {
public DruidDataSourceFactory(){
this.dataSource = new DruidDataSource();
}
}
database.properties
jdbc.driver:com.mysql.cj.jdbc.Driver jdbc.url:jdbc:mysql://localhost:3306/tests?characterEncoding=utf8&useSSL=false&serverTimezone=UTC jdbc.username:root jdbc.password:123456
log4j.properties
### set log levels ###
log4j.rootLogger = DEBUG,Console,File
### Output To Console ###
log4j.appender.Console=org.apache.log4j.ConsoleAppender
log4j.appender.Console.Target=System.out
log4j.appender.Console.layout=org.apache.log4j.PatternLayout
#log4j.appender.stdout.layout.ConversionPattern = [%-5p] %d{yyyy-MM-dd HH:mm:ss,SSS} method:%l%n%m%n
#log4j.appender.Console.layout.ConversionPattern= [%p] %d{yyyy-MM-dd HH\:mm\:ss,SSS} %c{1}:%L - %m%n
log4j.appender.Console.layout.ConversionPattern= %d{ABSOLUTE} %5p %c{1}:%L - %m%n
#log4j.appender.File.layout.ConversionPattern=[%p][%d{yyyy-MM-dd HH\:mm\:ss,SSS}][%c]%m%n
### Output To File ###
log4j.appender.File=org.apache.log4j.RollingFileAppender
log4j.appender.File.File=d:\\mylog.log
#log4j.appender.File.DatePattern=_yyyyMMdd'.log'
log4j.appender.File.MaxFileSize=10MB
#log4j.appender.File.Threshold=ALL
log4j.appender.File.layout=org.apache.log4j.PatternLayout
log4j.appender.File.layout.ConversionPattern=[%p][%d{yyyy-MM-dd HH\:mm\:ss,SSS}][%c]%m%n
dao
public interface PracticeMapper {
//查询所有部门
public List<Department> queryDepartmentList();
//根据部门ID，查询单个部门信息
public Department queryDepartmentByDepartmentId(@Param("departmentId")Integer departmentId);
/**
* 根据部门名称，模糊查询部门信息
* @param departmentName
* @return
*/
public List<Department> queryDepartmentListLikeByDepartmentName(@Param("departmentName")String departmentName);
//添加一个部门
public Integer insertDepartmentList(Department department);
//删除一个部门，根据部门ID
public Integer deleteDepartmentByDepartmentId(@Param("departmentId")Integer departmentId);
//修改一个部门，根据部门ID
public Integer updateDepartentByDepartmentId(@Param("departmentName")String departmentName,@Param("departmentId")Integer departmentId);
//如果输入了部门名称，就按部门名称来查询，否则查询所有部门
public List<Department> queryDepartmentIf(@Param("departmentName")String departmentName);
//where和if 如果有部门名称和部门ID，查询单个部门，否则查询所有部门
public List<Department> queryDepartmentIfAndTrim(Department department);
//if+set进行更新操作
public Integer updateDepartmentIfAndSet(Department department);
//foreach 根据部门ID查询多条信息
public List<Department> queryDepartmentByArrayDepartmentId(Integer[] departmentId);
//List类型的foreach迭代
public List<Department> queryDepartmentByListDepartmentId(List<Integer> departmentId);
}
PracticeMapper.xml
<?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="cn.dao.PracticeMapper">
<!--开启mybatis的二级缓存-->
<!--
配置创建了一个 FIFO 缓存，每隔 60 秒刷新，最多可以存储结果对象或列表的 512 个引用，
而且返回的对象被认为是只读的，因此对它们进行修改可能会在不同线程中的调用者产生冲突。
-->
<!--
二级缓存是事务性的。
这意味着，当 SqlSession 完成并提交时，或是完成并回滚，
但没有执行 flushCache=true 的 insert/delete/update 语句时，缓存会获得更新。
flushCache=true：将其设置为 true 后，只要语句被调用，都会导致本地缓存和二级缓存被清空，默认值：（对 insert、update 和 delete 语句）true。
-->
<cache
eviction="FIFO"
flushInterval="60000"
size="512"
readOnly="true"/>
<!--
id：唯一标识，随便写，在同一个命名空间下保持唯一，使用动态代理之后要求和方法名保持一致
parameterType：参数的类型，使用动态代理之后和方法的参数类型一致
-->
<!--基本查询-->
<!--查询所有部门-->
<select id="queryDepartmentList" parameterType="Department" resultType="Department">
SELECT
<include refid="DepartmentInfo"/>
from tests.department
</select>
<!--根据部门ID，查询单个部门信息-->
<select id="queryDepartmentByDepartmentId" parameterType="Department" resultType="Department">
SELECT <include refid="DepartmentInfo"></include> from tests.department where departmentId = #{departmentId}
</select>
<!--根据部门名称，模糊查询部门信息-->
<select id="queryDepartmentListLikeByDepartmentName" parameterType="String" resultType="Department">
SELECT <include refid="DepartmentInfo"></include> FROM tests.department WHERE departmentName LIKE
CONCAT('%',#{departmentName},'%')
</select>
<!--添加一个部门-->
<insert id="insertDepartmentList" parameterType="Department">
INSERT INTO department (departmentName) VALUES (#{departmentName});
</insert>
<!--删除一个部门-->
<delete id="deleteDepartmentByDepartmentId" parameterType="Integer">
delete from department where departmentId = #{departmentId}
</delete>
<!--修改一个部门，根据部门ID-->
<update id="updateDepartentByDepartmentId" parameterType="Department">
update department set departmentName= #{departmentName} where departmentId = #{departmentId}
</update>
<!--SQL代码片段-->
<sql id="DepartmentInfo">
departmentId,departmentName
</sql>
<!--动态sql查询-->
<!--if 如果输入了部门名称，就按部门名称来查询，否则查询所有部门-->
<select id="queryDepartmentIf" parameterType="String" resultType="Department">
SELECT
<include refid="DepartmentInfo"/>
from tests.department
WHERE 1=1
<if test="''!=departmentName and null != departmentName">
AND departmentName LIKE CONCAT('%',#{departmentName},'%')
</if>
</select>
<!--if和trim 如果有部门名称和部门ID，查询单个部门，否则查询所有部门-->
<!--trim 会自动删除and和or，并且会自动识别标签是否有返回值，有则加上前缀(prefix)和后缀(suffix)-->
<select id="queryDepartmentIfAndTrim" parameterType="Department" resultType="Department">
SELECT
<include refid="DepartmentInfo"/>
from tests.department
<trim prefix="where" prefixOverrides="and |or">
<if test="''!=departmentName and null != departmentName">
AND departmentName = #{departmentName}
</if>
<if test="''!=departmentId and null != departmentId">
AND departmentId = #{departmentId}
</if>
</trim>
</select>
<!--if+set 进行更新操作-->
<update id="updateDepartmentIfAndSet" parameterType="Department">
update department
<set>
<if test="''!=departmentName and null != departmentName">departmentName=#{departmentName},</if>
<if test="''!=departmentId and null != departmentId">departmentId=#{departmentId}</if>
</set>
where departmentId = #{departmentId}
</update>
<!--foreach 根据部门ID查询多条信息-->
<!--
item：集合中每个元素进行迭代的别名
open：以什么开始
close：以什么结束
separator:以什么分隔
collection：若入参为单参数，且参数类型是一个List的时候，collection属性值为list
若入参为单参数，且参数类型是一个数组的时候，collection属性值为array
若入参为多参数，就需要将他们封装为一个Map进行处理
-->
<select id="queryDepartmentByArrayDepartmentId" parameterType="Department" resultType="Department">
SELECT <include refid="DepartmentInfo"></include> from tests.department where departmentId in
<foreach collection="array" item="departmentId" open="(" close=")" separator=",">
${departmentId}
</foreach>
</select>
<!--List类型的foreach迭代-->
<select id="queryDepartmentByListDepartmentId" parameterType="Department" resultType="Department">
SELECT <include refid="DepartmentInfo"></include> from tests.department where departmentId in
<foreach collection="list" item="departmentId" open="(" close=")" separator=",">
${departmentId}
</foreach>
</select>
</mapper>
单测
public class PracticeMapperTest {
private static final Logger logger = LoggerFactory.getLogger(PracticeMapperTest.class);
SqlSession sqlSession = MyBatisUtil.createSqlSession();
/**
* 查询所有部门
*
* @throws IOException
*/
@Test
public void queryDepartmentList() throws IOException {
//获取mapper接口的对象
List<Department> departments = sqlSession.getMapper(PracticeMapper.class).queryDepartmentList();
for (Department department : departments) {
System.out.println(department.toString());
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
/**
* 根据部门ID，查询单个部门信息
*/
@Test
public void queryDepartmentByDepartmentId(){
Department department = sqlSession.getMapper(PracticeMapper.class).queryDepartmentByDepartmentId(5);
System.out.println(department);
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
/**
* 根据部门名称，模糊查询部门信息
*/
@Test
public void queryDepartmentListLikeByDepartmentName(){
List<Department> list = sqlSession.getMapper(PracticeMapper.class).queryDepartmentListLikeByDepartmentName("气");
for(Department item:list){
System.out.println(item);
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
/**
* 添加一个部门
*/
@Test
public void insertDepartmentList(){
Department department = new Department();
department.setDepartmentName("卡牌部门");
Integer integer = sqlSession.getMapper(PracticeMapper.class).insertDepartmentList(department);
if(integer > 0){
sqlSession.commit();//自动提交
}else{
sqlSession.rollback();//回滚
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
/**
* 删除一个部门
*/
@Test
public void deleteDepartmentByDepartmentId(){
Integer integer = sqlSession.getMapper(PracticeMapper.class).deleteDepartmentByDepartmentId(11);
if(integer > 0){
sqlSession.commit();//自动提交
}else{
sqlSession.rollback();//回滚
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
/**
* 修改一个部门，根据部门ID
*/
@Test
public void updateDepartentByDepartmentId(){
Integer integer = sqlSession.getMapper(PracticeMapper.class).updateDepartentByDepartmentId( "灵气部门",4);
if(integer > 0){
sqlSession.commit();//自动提交
}else{
sqlSession.rollback();//回滚
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
/**
* 如果输入了部门名称，就按部门名称来查询，否则查询所有部门
*/
@Test
public void queryDepartmentIf(){
List<Department> list = sqlSession.getMapper(PracticeMapper.class).queryDepartmentIf("魔");
for(Department item : list){
System.out.println(item);
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
//where和if 如果有部门名称和部门ID，查询单个部门，否则查询所有部门
@Test
public void queryDepartmentIfAndTrim(){
Department department = new Department();
department.setDepartmentName("灵气部门");
List<Department> list = sqlSession.getMapper(PracticeMapper.class).queryDepartmentIfAndTrim(department);
for(Department item : list){
System.out.println(item);
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
//if+set进行更新操作
@Test
public void updateDepartmentIfAndSet(){
Department department = new Department();
department.setDepartmentId(4);
department.setDepartmentName("仙气大陆");
Integer integer = sqlSession.getMapper(PracticeMapper.class).updateDepartmentIfAndSet(department);
if(integer > 0){
sqlSession.commit();//自动提交
}else{
sqlSession.rollback();//回滚
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
//foreach 根据部门ID查询多条信息
@Test
public void queryDepartmentByArrayDepartmentId(){
Integer[] integers = {3,5,8};
List<Department> departments = sqlSession.getMapper(PracticeMapper.class).queryDepartmentByArrayDepartmentId(integers);
for(Department items: departments){
System.out.println(items);
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
//List类型的foreach迭代
@Test
public void queryDepartmentByListDepartmentId(){
List<Integer> list = new ArrayList<Integer>();
list.add(3);
list.add(9);
List<Department> departments = sqlSession.getMapper(PracticeMapper.class).queryDepartmentByListDepartmentId(list);
for(Department items: departments){
System.out.println(items);
}
MyBatisUtil.closeSqlSession(sqlSession);//关闭资源
}
}
标签：departmentName,练习,基础,department,sqlSession,departmentId,Department,MyBatis,publi 来源： https://www.cnblogs.com/mumu555/p/12826852.html