MyBatis增删改查

增删改查简称为CURD，即Create Update Retrieve Delete 操作。

首先创建一个Maven项目，pom.xml配置如下：

<?xml version="1.0" encoding="UTF-8"?>

<project xmlns="[http://maven.apache.org/POM/4.0.0](http://maven.apache.org/POM/4.0.0)"

         xmlns:xsi="[http://www.w3.org/2001/XMLSchema-instance](http://www.w3.org/2001/XMLSchema-instance)"

         xsi:schemaLocation="[http://maven.apache.org/POM/4.0.0](http://maven.apache.org/POM/4.0.0)[http://maven.apache.org/xsd/maven-4.0.0.xsd](http://maven.apache.org/xsd/maven-4.0.0.xsd)">

    <modelVersion>4.0.0</modelVersion>

    <groupId>com.bianla.wql</groupId>

    <artifactId>TestMybatisCRUD</artifactId>

    <version>1.0-SNAPSHOT</version>

    <dependencies>

        <!-- [https://mvnrepository.com/artifact/mysql/mysql-connector-java](https://mvnrepository.com/artifact/mysql/mysql-connector-java)-->

        <dependency>

            <groupId>mysql</groupId>

            <artifactId>mysql-connector-java</artifactId>

            <version>8.0.13</version>

        </dependency>

        <!-- [https://mvnrepository.com/artifact/org.mybatis/mybatis](https://mvnrepository.com/artifact/org.mybatis/mybatis)-->

        <dependency>

            <groupId>org.mybatis</groupId>

            <artifactId>mybatis</artifactId>

            <version>3.4.6</version>

        </dependency>

    </dependencies>

</project>

然后创建数据库，表名为Student，字段为student_id, student_name, student_score, student_age.

文件目录：

屏幕快照 2019-01-15 下午6.30.11.png

然后在java目录下创建一个包，包中创建四个文件夹，分别为dao、entity、test、util文件夹。

在dao文件夹中创建一个StudentDao文件：

package com.bianla.demo.dao;

import com.bianla.demo.entity.StudentEntity;

import java.util.List;

import java.util.Map;

public interface StudentDao{

    //查询学生 如果不传入map，则查询全部学生

    List<StudentEntity> selectAllStudents(Map map);

    //插入学生

    void insertStudent(StudentEntity entity);

    //更新学生

    void updateStudent (StudentEntity entity);

    //删除学生

    void deleteStudent (int id);

}

然后在entity文件夹中创建StudentEntity文件：

package com.bianla.demo.entity;

public class StudentEntity {

    private int studentId;

    private String studentName;

    private int studentAge;

    private String studentScore;

    public StudentEntity(){}

    public StudentEntity(int id, String name, int age, String score){

        this.studentId = id;

        this.studentName = name;

        this.studentAge = age;

        this.studentScore = score;

    }

    @Override

    //重写了toString方法

    public String toString(){

        return "{StudentEntity: id="+studentId+" name="+studentName+" age="+studentAge+" score="+studentScore+"}";

    }

    //省略了get、set方法

}

然后在util文件夹下创建MyBatisUtil文件：

package com.bianla.demo.util;

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 MyBatisUtil {

    //sqlSessionFactory对象

    private static SqlSessionFactory sqlSessionFactory = null;

    //类线程锁

    private  static final Class CLASS_LOCK = MyBatisUtil.class;

    //私有化构造参数

    private MyBatisUtil(){}

    //构建sessionFactory 单例模式

    public static SqlSessionFactory initSessionFactory(){

        //文件路径以resources为根路径

        String source = "mybatis-config.xml";

        InputStream stream = null;

        try {

           stream = Resources.getResourceAsStream(source);

        }catch (IOException e){

            e.printStackTrace();

        }

        //下面括号中不能写this，因为initSessionFactory是静态方法

        synchronized (CLASS_LOCK){

            if (sqlSessionFactory == null){

                sqlSessionFactory = new SqlSessionFactoryBuilder().build(stream);

            }

        }

        return sqlSessionFactory;

    }

    //打开sqlSession

    public static SqlSession openSqlSession(){

        if (sqlSessionFactory == null){

            initSessionFactory();

        }

        return sqlSessionFactory.openSession();

    }

}

然后在resources目录下创建mysql.properties文件：

jdbc.driver=com.mysql.jdbc.Driver

jdbc.url=jdbc:mysql://localhost:3306/wl_test_database?useSSL=false&allowPublicKeyRetrieval=true

jdbc.username=root

jdbc.password=Aa123456

然后在resources目录下创建mybatis-config.xml文件：

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE configuration

        PUBLIC "-//[mybatis.org//DTD](http://mybatis.org//DTD)Config 3.0//EN"

        "[http://mybatis.org/dtd/mybatis-3-config.dtd](http://mybatis.org/dtd/mybatis-3-config.dtd)">

<configuration>

    <properties resource="mysql.properties"/>

    <environments default="wqlTestDevelopment">

        <environment id="wqlTestDevelopment">

            <transactionManager type="JDBC"></transactionManager>

            <dataSource type="POOLED">

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

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

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

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

            </dataSource>

        </environment>

    </environments>

    <mappers>

        <mapper resource="mapper/StudentMapper.xml"/>

    </mappers>

</configuration>

然后在resources目录下创建mapper文件夹，在mapper文件夹中创建StudentMapper.xml文件：

<?xml version="1.0" encoding="UTF-8"?>

<!DOCTYPEmapper

        PUBLIC"-//[mybatis.org//DTD](http://mybatis.org//DTD)mapper 3.0//EN"

        "[http://mybatis.org/dtd/mybatis-3-mapper.dtd](http://mybatis.org/dtd/mybatis-3-mapper.dtd)">

<!--映射文件中的namespace是用于绑定Dao接口的，即面向接口编程-->

<!--当我们的namespace绑定接口后，你就可以不用写接口实现类，mybatis会通过该绑定自动帮我们找到要执行的SQL语句-->

<!--不过需要注意：namespace对应文件的接口要与映射文件中的SQL语句的ID一一对应，即StudentDao的接口名，与StudentMapper的sql语句的id一致-->

<mapper namespace="com.bianla.demo.dao.StudentDao">

    <!--配置实体与表的映射-->

    <resultMap id="studentMap" type="com.bianla.demo.entity.StudentEntity">

        <id column="student_id" property="studentId"/>

        <result column="student_name" property="studentName"/>

        <result column="student_age" property="studentAge"/>

        <result column="student_score" property="studentScore"/>

    </resultMap>

    <!--一般findAll查询所有，不需要条件。这里是为说明可以设置这样的条件-->

    <select id="selectAllStudents" parameterType="map" resultMap="studentMap">

        select * from student

        <!--where开始设置条件-->

        <where>

            <!--如果传进来的id不为null，就设置条件表字段的id=传进来的id，这里可以动态设置条件也就是mybatis强大的动态sql。-->

            <if test="id!=null">

                and student_id=#{id}

            </if>

        </where>

    </select>

    <!--增加一位学生

        id：要与StudentDao中的接口名一致

        parameterType：传入的参数类型为studentEntity

    -->

    <insert id="insertStudent" parameterType="com.bianla.demo.entity.StudentEntity">

        <!--selectKey用来将主键回写

            keyProperty：查询出来的主键对应StudentEntity的哪个属性

            keyColumn：查询出来的主键在Student表中的字段

            order：查询主键语句在插入语句的前面还是后面执行

            resultType：查询出来的主键的类型-->

        <selectKey keyProperty="studentId" keyColumn="student_id" order="AFTER" resultType="int">

            select LAST_INSERT_ID()

        </selectKey>

        insert into `Student` values (#{studentId},#{studentName},#{studentAge},#{studentScore})

    </insert>

    <!--更新学生数据-->

    <update id="updateStudent" parameterType="com.bianla.demo.entity.StudentEntity">

        update `Student` set student_name = #{studentName}, student_age = #{studentAge}, student_score = #{studentScore} where student_id = #{studentId}

    </update>

    <!--根据ID删除学生-->

    <delete id="deleteStudent" parameterType="int">

        delete from student where student_id = #{id}

    </delete>

</mapper>

最后再在test文件夹下创建StudentTest文件：

增删改查的内容为核心代码。

package com.bianla.demo.test;

import com.bianla.demo.dao.StudentDao;

import com.bianla.demo.entity.StudentEntity;

import com.bianla.demo.util.MyBatisUtil;

import org.apache.ibatis.session.SqlSession;

import java.util.ArrayList;

import java.util.HashMap;

import java.util.List;

import java.util.Map;

public class StudentTest {

    public static void  main (String[] args){

        SqlSession sqlSession = null;

        try {

            sqlSession = MyBatisUtil.openSqlSession();

            // 通过SqlSession对象得到Mapper接口的一个代理对象

            // 需要传递的参数是Mapper接口的类型

            StudentDao dao = sqlSession.getMapper(StudentDao.class);

            //增加

            StudentEntity entity = new StudentEntity();

            //entity.setStudentId(6);

            entity.setStudentAge(123);

            entity.setStudentName("唐昊");

            entity.setStudentScore("92");

            dao.insertStudent(entity);

            //更改

            StudentEntity updateEntity = new StudentEntity();

            updateEntity.setStudentName("小舞");

            updateEntity.setStudentScore("921");

            updateEntity.setStudentAge(16);

            updateEntity.setStudentId(2);

            dao.updateStudent(updateEntity);

            //删除

            dao.deleteStudent(5);

            //查询

            List<StudentEntity> list = new ArrayList<StudentEntity>();

            Map<String,Object> map = new HashMap<String, Object>();

            map.put("id",1);

            list = dao.selectAllStudents(map);

            System.out.println(list);

[sqlSession.commit();](http://sqlsession.commit();/)

        }catch (Exception e){

            e.printStackTrace();

            System.err.println(e.getMessage());

            sqlSession.rollback();

        }finally {

            if (sqlSession != null){

                sqlSession.close();

            }

        }

    }

}

我们分别试验一下：

查询全部(核心代码仅使用以下内容)：

...

//查询
List<StudentEntity> list = new ArrayList<StudentEntity>();

list = dao.selectAllStudents(null);

System.out.println(list);

...

此时的效果：

屏幕快照 2019-01-15 下午6.15.57.png

核对一下数据库：

屏幕快照 2019-01-15 下午6.16.36.png

没问题。

查询id为1的对象（核心代码）：

...

//查询

List<StudentEntity> list = new ArrayList<StudentEntity>();

Map<String,Object> map = new HashMap<String, Object>();

map.put("id",1);

list = dao.selectAllStudents(map);

System.out.println(list);

...

效果：

屏幕快照 2019-01-15 下午6.18.40.png

新增一位学生，并查询（核心代码）：

...

//增加

StudentEntity entity = new StudentEntity();

entity.setStudentId(6);

entity.setStudentAge(123);

entity.setStudentName("唐昊");

entity.setStudentScore("92");

dao.insertStudent(entity);

//查询

List<StudentEntity> list = new ArrayList<StudentEntity>();

list = dao.selectAllStudents(null);

System.out.println(list);

...

效果：

屏幕快照 2019-01-15 下午6.21.21.png

核对一下数据：

屏幕快照 2019-01-15 下午6.22.05.png

删除一位学生，并查询全部的学生（核心代码）：

...

dao.deleteStudent(5);

//查询

List<StudentEntity> list = new ArrayList<StudentEntity>();

list = dao.selectAllStudents(null);

System.out.println(list);

...

效果：

屏幕快照 2019-01-15 下午6.24.14.png

核对一下数据库：

屏幕快照 2019-01-15 下午6.25.57.png

修改id为2的数据（核心代码）,并查询：

...

//更改

StudentEntity updateEntity = new StudentEntity();

updateEntity.setStudentName("小舞");

updateEntity.setStudentScore("921");

updateEntity.setStudentAge(16);

updateEntity.setStudentId(2);

dao.updateStudent(updateEntity);

//查询

List<StudentEntity> list = new ArrayList<StudentEntity>();

list = dao.selectAllStudents(null);

System.out.println(list);

...

效果：

屏幕快照 2019-01-15 下午6.29.06.png

核对数据库：

屏幕快照 2019-01-15 下午6.29.20.png

完美～

加油～

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 211,948评论 6赞 492
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 90,371评论 3赞 385
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 157,490评论 0赞 348
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 56,521评论 1赞 284
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 65,627评论 6赞 386
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 49,842评论 1赞 290
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 38,997评论 3赞 408
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 37,741评论 0赞 268
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 44,203评论 1赞 303
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 36,534评论 2赞 327
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 38,673评论 1赞 341
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 34,339评论 4赞 330
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 39,955评论 3赞 313
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 30,770评论 0赞 21
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 32,000评论 1赞 266
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 46,394评论 2赞 360
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 43,562评论 2赞 349

MyBatis增删改查

推荐阅读更多精彩内容