MybatisPlus基本使用(一)之增刪改查

第一步:配置依賴

<dependencies>
    <!--mybatis-plues插件依賴-->
    <dependency>
        <groupId>com.baomidou</groupId>
        <artifactId>mybatis-plus</artifactId>
        <version>3.3.1</version>
    </dependency>

    <!--Mysql-->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.47</version>
    </dependency>

    <!--連接池-->
    <dependency>
        <groupId>com.alibaba</groupId>
        <artifactId>druid</artifactId>
        <version>1.1.0</version>
    </dependency>

    <!--簡化bean代碼的工具包-->
    <dependency>
        <groupId>org.projectlombok</groupId>
        <artifactId>lombok</artifactId>
        <version>1.18.2</version>
    </dependency>
    <dependency>
        <groupId>junit</groupId>
        <artifactId>junit</artifactId>
        <version>4.12</version>
        <scope>test</scope>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-log4j12</artifactId>
        <version>1.6.4</version>
    </dependency>
</dependencies>

<build>
    <plugins>
        <plugin>
            <groupId>org.apache.maven.plugins</groupId>
            <artifactId>maven-compiler-plugin</artifactId>
            <configuration>
                <source>1.8</source>
                <target>1.8</target>
            </configuration>
        </plugin>
    </plugins>
</build>

二:MybatisPlus的用法

第一中用法Mybatis+MP 
首先創建子Module

log4j.properties：

log4j.rootLogger=DEBUG,A1
log4j.appender.A1=org.apache.log4j.ConsoleAppender
log4j.appender.A1.layout=org.apache.log4j.PatternLayout
log4j.appender.A1.layout.ConversionPattern=[%t] [%c]-[%p] %m%n

Mybatis實現查詢User

第一步，編寫mybatis-confifig.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>

<environments default="development">

<environment id="development">

<transactionManager type="JDBC"/>

<dataSource type="POOLED">

<property name="driver" value="com.mysql.jdbc.Driver"/>

<property name="url" value="jdbc:mysql://127.0.0.1:3306/mp?

useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQuerie

s=true&useSSL=false"/>

<property name="username" value="root"/>

<property name="password" value="root"/>

</dataSource>

</environment>

</environments>

<mappers>

<mapper resource="UserMapper.xml"/>

</mappers>

</configuration>

第二步，編寫User實體對象：（這里使用lombok進行了進化bean操作）

@Data

@NoArgsConstructor

@AllArgsConstructor

public class User {

　　private Long id;

　　private String userName;

　　private String password;

　　private String name;

　　private Integer age;

　　private String email;

}

第三步，編寫UserMapper接口：

public interface UserMapper {

　　List<User> findAll();

}

第四步，編寫UserMapper.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.itcast.mp.simple.mapper.UserMapper">

<select id="findAll" resultType="cn.itcast.mp.simple.pojo.User">

select * from tb_user

</select>

</mapper>

第五步，編寫TestMybatis測試用例：

public class TestMybatis {

@Test

public void testUserList() throws Exception{

　　String resource = "mybatis-config.xml";

　　InputStream inputStream = Resources.getResourceAsStream(resource);

　　SqlSessionFactory sqlSessionFactory = new

　　SqlSessionFactoryBuilder().build(inputStream);

　　SqlSession sqlSession = sqlSessionFactory.openSession();

　　UserMapper userMapper = sqlSession.getMapper(UserMapper.class);

　　List<User> list = userMapper.findAll();

　　for (User user : list) {

　　System.out.println(user);

　　　　}

　　}

}

測試結果:

 Mybatis+MP實現查詢User

第一步，將UserMapper繼承BaseMapper，將擁有了BaseMapper中的所有方法：

public interface UserMapper extends BaseMapper<User> {

List<User> findAll();

}

第二步，使用MP中的MybatisSqlSessionFactoryBuilder進程構建：

public class TestMybatisPlus {

@Test

public void testUserList() throws Exception{

　　String resource = "mybatis-config.xml";

　　InputStream inputStream = Resources.getResourceAsStream(resource);

　　//這里使用的是MP中的MybatisSqlSessionFactoryBuilder

　　SqlSessionFactory sqlSessionFactory = new

　　MybatisSqlSessionFactoryBuilder().build(inputStream);

　　SqlSession sqlSession = sqlSessionFactory.openSession();

　　UserMapper userMapper = sqlSession.getMapper(UserMapper.class);

　　// 可以調用BaseMapper中定義的方法

　　List<User> list = userMapper.selectList(null);

　　for (User user : list) {

　　System.out.println(user);

　　}

}

運行報錯：

解決：在User對象中添加@TableName，指定數據庫表名

由於使用了MybatisSqlSessionFactoryBuilder進行了構建，繼承的BaseMapper中的方法就載入到了

SqlSession中，所以就可以直接使用相關的方法；

 

第二種方法

Spring+Mybatis+MP

第一步創建子模塊

導入依賴

<!--定義Spring版本號-->
<properties>
    <spring.version>5.1.6.RELEASE</spring.version>
</properties>

<!--引入Spring相關依賴-->
<dependencies>
    <dependency>
        <groupId>org.springframework</groupId>
        <artifactId>spring-webmvc</artifactId>
        <version>${spring.version}</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>
</dependencies>

實現查詢User

　　第一步，編寫jdbc.properties

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3307/mp? useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQuerie s=true&useSSL=false
jdbc.username=root
jdbc.password=root

第二步，編寫applicationContext.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" 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.xsd">

<context:property-placeholder location="classpath:*.properties"/>

<!-- 定義數據源 -->

　　　　<bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close">

　　　　<property name="driver" value="${jdbc.driver}"/>
　　　　<property name="url" value="${jdbc.url}"/>
　　　　<property name="username" value="${jdbc.username}"/>
　　　　<property name="password" value="${jdbc.password}"/>

　　　　　　<property name="maxActive" value="10"/>

　　　　　　<property name="minIdle" value="5"/>

　　　　</bean>

　　<!--這里使用MP提供的sqlSessionFactory，完成了Spring與MP的整合-->

　　<bean id="sqlSessionFactory" class="com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean">

　　　　<property name="dataSource" ref="dataSource"/>

　　</bean>

　　<!--掃描mapper接口，使用的依然是Mybatis原生的掃描器-->

　　<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">

　　　　<property name="basePackage" value="cn.itcast.mp.simple.mapper"/>

　　</bean>

</beans>

第三步，編寫User對象以及UserMapper接口：

@Data

@NoArgsConstructor

@AllArgsConstructor

@TableName("tb_user")

public class User {

　　private Long id;

　　private String userName;

　　private String password;

　　private String name;

　　private Integer age;

　　private String email;

}

第四步，編寫測試用例：

@RunWith(SpringJUnit4ClassRunner.class)

@ContextConfiguration(locations = "classpath:applicationContext.xml")

public class TestSpringMP {

　　　　@Autowired

　　　　private UserMapper userMapper;

　　　　　　@Test

　　　　　public void testSelectList(){

　　　　　　　　List<User> users = this.userMapper.selectList(null);

　　　　　　　　　　for (User user : users) {

　　　　　　　　　　System.out.println(user);

　　　　　　}

　　}

}

第三種SpringBoot+Mybatis+MP

使用SpringBoot將進一步的簡化MP的整合，需要注意的是，由於使用SpringBoot需要繼承parent，所以需要重新創

建工程，並不是創建子Module。

<!--SpringBoot版本-->

<parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.3.12.RELEASE</version>
</parent>

<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter</artifactId>
<exclusions>
<exclusion>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-logging</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-test</artifactId>
    <scope>test</scope>
</dependency>
<!--簡化代碼的工具包-->
<dependency>
    <groupId>org.projectlombok</groupId>
    <artifactId>lombok</artifactId>
    <optional>true</optional>
</dependency>
<!--mybatis-plus的springboot支持-->
<dependency>
<groupId>com.baomidou</groupId>
<artifactId>mybatis-plus-boot-starter</artifactId>
<version>3.1.1</version>
</dependency>
    <!--mysql驅動-->
    <dependency>
        <groupId>mysql</groupId>
        <artifactId>mysql-connector-java</artifactId>
        <version>5.1.47</version>
    </dependency>
    <dependency>
        <groupId>org.slf4j</groupId>
        <artifactId>slf4j-log4j12</artifactId>
    </dependency>
</dependencies>
<build>
    <plugins>
        <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
        </plugin>
    </plugins>
</build>

log4j.properties：

log4j.rootLogger=DEBUG,A1

log4j.appender.A1=org.apache.log4j.ConsoleAppender

log4j.appender.A1.layout=org.apache.log4j.PatternLayout

log4j.appender.A1.layout.ConversionPattern=[%t] [%c]-[%p] %m%n

編寫application.properties

spring.application.name = itcast-mp-springboot

spring.datasource.driver-class-name=com.mysql.jdbc.Driver

spring.datasource.url=jdbc:mysql://127.0.0.1:3306/mp?useUnicode=true&characterEncoding=utf8&autoReconnect=true&allowMultiQueries=true&useSSL=false

spring.datasource.username=root

spring.datasource.password=root

編寫pojo

　　@Data

　　@NoArgsConstructor

　　@AllArgsConstructor

　　@TableName("tb_user")

public class User {

　　　　private Long id;

　　　　private String userName;

　　　　private String password;

　　　　private String name;

　　　　private Integer age;

　　　　private String email;

}

編寫mapper

public interface UserMapper extends BaseMapper<User> {

}

編寫啟動類

@MapperScan("cn.itcast.mp.mapper") //設置mapper接口的掃描包

@SpringBootApplication

public class MyApplication {

　　public static void main(String[] args) {

　　　　SpringApplication.run(MyApplication.class, args);

　　}

}

編寫測試用例

　　//@RunWith(SpringRunner.class)

  @RunWith(SpringJUnit4ClassRunner.class)
　@SpringBootTest

public class UserMapperTest {

　　　　@Autowired

　　private UserMapper userMapper;

　　@Test

　　　　public void testSelect() {

　　　　　　List<User> userList = userMapper.selectList(null);

　　　　　　　　for (User user : userList) {

　　　　　　　　　　System.out.println(user);

　　　　　　　　}

　　　　}

}

 

增加方法:

方法定義是Mybatisplus定義好的

測試用例

@RunWith(SpringRunner.class)

@SpringBootTest

public class UserMapperTest {

　　　　@Autowired

　　　　private UserMapper userMapper;

　　　　@Test

　　　public void testInsert(){

　　　　　　User user = new User();

　　　　　　user.setAge(20);

　　　　　　user.setEmail("[e-mail]");

　　　　　　user.setName("曹操");

　　　　　　user.setUserName("caocao");

　　　　　　user.setPassword("123456");

　　　　　　int result = this.userMapper.insert(user); //返回的result是受影響的行數，並不是自增后的id

　　　　　　System.out.println("result = " + result);

　　　　　　System.out.println(user.getId()); //自增后的id會回填到對象中

　　}

}

可以看到，數據已經寫入到了數據庫，但是，id的值不正確，我們期望的是數據庫自增長，實際是MP生成了id的值

寫入到了數據庫。

如何設置id的生成策略呢？

/**

* 生成ID類型枚舉類

*

* @author hubin

* @since 2015-11-10

*/

@Getter

public enum IdType {

/**

* 數據庫ID自增

*/

AUTO(0),

/**

* 該類型為未設置主鍵類型

*/

NONE(1),

/**

* 用戶輸入ID

* <p>該類型可以通過自己注冊自動填充插件進行填充</p>

*/

INPUT(2),

/* 以下3種類型、只有當插入對象ID 為空，才自動填充。 */

/**

* 全局唯一ID (idWorker)

*/

ID_WORKER(3),

/**

* 全局唯一ID (UUID)

*/

UUID(4),

MP支持的id策略：

/**

* 字符串全局唯一ID (idWorker 的字符串表示)

*/

ID_WORKER_STR(5);

private final int key;

IdType(int key) {

this.key = key;

　　}

}

修改User對象：

@TableId(type = IdType.AUTO) //指定id類型為自增長

private Long id;

@TableField

在MP中通過@TableField注解可以指定字段的一些屬性，常常解決的問題有2個：

1、對象中的屬性名和字段名不一致的問題（非駝峰）

2、對象中的屬性字段在表中不存在的問題

@TableField(select = false)

@TableField(value = "email")//指定數據庫表中的字段名

 

 

根據id更新

@RunWith(SpringRunner.class)

@SpringBootTest

public class UserMapperTest {

　　@Autowired

　　private UserMapper userMapper;

　　　　@Test

public void testUpdateById() {

　　　　　　User user = new User();

　　　　　　user.setId(6L); //主鍵

　　　　　　user.setAge(21); //更新的字段

　　　　//根據id更新，更新不為null的字段

　　　　this.userMapper.updateById(user);

　　}

}

根據條件更新

@Test
    public void testUpdate(){
        User user = new User();
        user.setAge(20);
        user.setPassword("88888");
        QueryWrapper<User> wrapper = new QueryWrapper<>();
        wrapper.eq("user_name","zhangsan");
        int result = this.userMapper.update(user,wrapper);//匹配user_name=zhangsan的用戶數據
        System.out.println("result =>"+result);
    }

    @Test
    public void testUpdate2(){
        UpdateWrapper<User> wrapper = new UpdateWrapper<>();
        wrapper.set("age",21).set("password","99999")//更新的字段
        .eq("user_name","zhangsan");
        //根據條件做更新
        int result = this.userMapper.update(null, wrapper);
        System.out.println("result =>"+result);
    }

根據id刪除數據

@Test
public void testDeleteById(){
        //根據id刪除數據
    int result = this.userMapper.deleteById(1L);
    System.out.println("result =>"+result);
}

刪除操作

deleteById

測試用例：

@Test

public void testDeleteById() {

　　　　//執行刪除操作

　　　　int result = this.userMapper.deleteById(6L);

　　　　System.out.println("result = " + result);

}

deleteByMap

@Test
public void testDeleteByMap(){
    //根據id刪除數據
    HashMap<String, Object> map = new HashMap<>();
    map.put("user_name","lisi");
    map.put("password","123456");
    //根據map刪除數據，多條件之間是and關系
    int result = this.userMapper.deleteByMap(map);
    System.out.println("result =>"+result);
}

delete刪除方法

public void testDeleteByMap() {

　　User user = new User();

　　user.setAge(20);

　　user.setName("張三");

　　//將實體對象進行包裝，包裝為操作條件

　　QueryWrapper<User> wrapper = new QueryWrapper<>(user);

　　int result = this.userMapper.delete(wrapper);

　　System.out.println("result = " + result);

}

deleteBatchIds

@Test

public void testDeleteByMap() {

　　//根據id集合批量刪除

　　int result = this.userMapper.deleteBatchIds(Arrays.asList(1L,10L,20L));

　　System.out.println("result = " + result);

}

 

批量查詢方法

@Test

public void testSelectBatchIds() {

　　//根據id集合批量查詢

　　List<User> users = this.userMapper.selectBatchIds(Arrays.asList(2L, 3L, 10L));

　　for (User user : users) {

　　System.out.println(user);

　　}

}

 

selectOne

@Test

public void testSelectOne() {

　　　　QueryWrapper<User> wrapper = new QueryWrapper<User>();

　　　　wrapper.eq("name", "李四");

　　　　//根據條件查詢一條數據，如果結果超過一條會報錯

　　　　User user = this.userMapper.selectOne(wrapper);

　　　　System.out.println(user);

}

 

selectCount

@Test

public void testSelectCount() {

　　QueryWrapper<User> wrapper = new QueryWrapper<User>();

　　wrapper.gt("age", 23); //年齡大於23歲

　　//根據條件查詢數據條數

　　Integer count = this.userMapper.selectCount(wrapper);

　　System.out.println("count = " + count);

}

 

selectList

@Test

public void testSelectList() {

　　　　QueryWrapper<User> wrapper = new QueryWrapper<User>();

　　　　wrapper.gt("age", 23); //年齡大於23歲

　　　　//根據條件查詢數據

　　　　List<User> users = this.userMapper.selectList(wrapper);

　　　for (User user : users) {

　　　　System.out.println("user = " + user);

　　}

}

 

selectPage

/**

* 分頁插件

*/

@Configuration

@MapperScan("cn.itcast.mp.mapper") //設置mapper接口的掃描包

public class MybatisPlusConfig {

@Bean

public PaginationInterceptor paginationInterceptor() {

return new PaginationInterceptor();

　　}

}

測試用例：

@Test

public void testSelectPage() {

　　QueryWrapper<User> wrapper = new QueryWrapper<User>();

　　wrapper.gt("age", 20); //年齡大於20歲

　　Page<User> page = new Page<>(1,1);

　　//根據條件查詢數據

　　IPage<User> iPage = this.userMapper.selectPage(page, wrapper);

　　System.out.println("數據總條數：" + iPage.getTotal());

　　System.out.println("總頁數：" + iPage.getPages());

　　List<User> users = iPage.getRecords();

　　for (User user : users) {

　　System.out.println("user = " + user);

　　}

}

 

 

基本配置