龙空技术网

如何使用 Mybatis 实现数据库 CURD 操作?

CSDN 570

前言:

现在各位老铁们对“session 数据库”大致比较注意,咱们都想要分析一些“session 数据库”的相关文章。那么小编在网络上搜集了一些有关“session 数据库””的相关资讯,希望兄弟们能喜欢,姐妹们快快来了解一下吧!

作者 | 阿文,责编 | 郭芮

头图 | CSDN 下载自东方IC

出品 | CSDN(ID:CSDNnews)

MyBatis 是一款优秀的持久层框架,它支持自定义 SQL、存储过程以及高级映射。MyBatis 免除了几乎所有的 JDBC 代码以及设置参数和获取结果集的工作。MyBatis 可以通过简单的 XML 或注解来配置和映射原始类型、接口和 Java POJO(Plain Old Java Objects,普通老式 Java 对象)为数据库中的记录。

在传统的JDBC 实现中,我们需要把查询过程写在java 类中,这样非常不便于后期维护,而使用Mybatis 则可以将查询语句配置在配置文件中,只需要维护好映射关系即可, 下面我们就来一起看雪如何去使用Mybatis吧。

准备工作

首先,你需要准备以下软件:

ideamavenmysql

创建数据库并插入数据

首先,我们创建一个mybatis_db 的数据库,然后创建一个表 t_user,在这个表中我们插入几条数据,如下所示:

mysql> create database mybatis_db;Query OK, 1 row affected (0.01 sec)mysql> use mybatis_db;Database changedmysql> create table t_user(-> id int(32) primary key auto_increment,-> username varchar(50),-> jobs varchar(50),-> phone varchar(16));Query OK, 0 rows affected, 1 warning (0.01 sec)mysql> insert into t_user values(1,"zhangsan","teacher","13142767333");Query OK, 1 row affected (0.01 sec)mysql> insert into t_user values(2,"lisi","engineer","13142767334");Query OK, 1 row affected (0.01 sec)mysql> insert into t_user values(3,"wangwu","pilot","12342767334");Query OK, 1 row affected (0.00 sec)mysql>

配置pom.xml 下载jar包

我们创建一个maven工程,并配置pom.xml 下载mybatis 和mysql-connect-java 的jar包,目前mybatis 的最新版本是3.5.4。

<dependency><groupId>org.mybatis</groupId><artifactId>mybatis</artifactId><version>3.5.4</version></dependency><dependency><groupId>mysql</groupId><artifactId>mysql-connector-java</artifactId><version>8.0.19</version></dependency>

整个工程的目录如下:

配置mybatis-config

接下来,我们在 idea 的resource 中创建一个mybatis-config.xml 的配置文件(如果没有你需要在src\main目录点击右键创建一个目录,创建的时候选择resource即可),内容如下,具体不需要过多解释,该配置文件主要是定义JDBC相关的参数包括使用的驱动、mysql 访问地址、用户名和密码以及通过mappers 定义一个mybatis 的映射文件。

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN"""><configuration><environments default="mysql"><environment id="mysql"><transactionManager type="JDBC" /><dataSource type="POOLED"><property name="driver" value="com.mysql.jdbc.Driver" /><property name="url" value="jdbc:mysql://192.168.10.128:3306/mybatis_db" /><property name="username" value="root" /><property name="password" value="123456" /></dataSource></environment></environments><mappers><mapper resource="UserMapper.xml" /></mappers></configuration>

创建user类

接下里我们创建对于的User类,并生成get和set以及toString 方法,在idea 中,我们在IDE中右键选择Generate 然后选择Getter 和Setter 以及toString 全选即可快速生成对应的get和set方法。

最终结果如下:

package com.mybatis;public class User {private Integer id;private String username;private String jobs;private String phone;public Integer getId {return id;}public String getUsername {return username;}public String getJobs {return jobs;}public String getPhone {return phone;}public void setId(Integer id) {this.id = id;}public void setUsername(String username) {this.username = username;}public void setJobs(String jobs) {this.jobs = jobs;}public void setPhone(String phone) {this.phone = phone;}@Overridepublic String toString {return "User{" +"id=" + id +", username='" + username + '\'' +", jobs='" + jobs + '\'' +", phone='" + phone + '\'' +'}';}}

创建测试类

配置UserMapper.xml

接下里,我们创建映射文件UserMapper.xml 然后需要制定一个namespace就是 UserMapper,接着写一个select 语句,定义id和参数类型以及resultType,resultMap是指描述如何从数据库结果集中加载对象,是最复杂也是最强大的元素。

<?xml version="1.0" encoding="UTF-8"?><!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"""><mapper namespace="UserMapper"><!--根据用户编号获取用户信息 --><select id="findUserById" parameterType="Integer" resultType="com.mybatis.User">select * from t_user where id=#{id}</select></mapper>

然后我们创建一个测试类,根据id来查询用户:

package com.mybatis;import java.io.InputStream;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;/*** @Auth: xxxx* @E-mail: xxx* @title: MybatisTest* @projectName: mybatis* @description: TODO 描述信息* @Date 2020/4/7 9:15 下午**/public class MybatisTest {@Testpublic void findUserByIdTest throws Exception {String resource = "mybatis-config.xml";InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;User user = sqlSession.selectOne("findUserById", 1);System.out.println(user.toString);sqlSession.close;}}

如果我们希望进行模糊查询,则在UserMapper.xml 中定义:

<select id="findUserByName" parameterType="String" resultType="com.mybatisdemo.User">select * from t_user where username like concat('%','${value}','%')</select>

使用like concat('%','${value}','%') 是为了防止sql 注入带来的安全隐患。

然后在测试类中新建一个方法进行测试:

@Testpublic void findUserByNameTest throws Exception {String resource = "mybatis-config.xml";InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;List<User> users = sqlSession.selectList("findUserByName","g");for (User user:users){System.out.println(user.toString);}sqlSession.close;}

如图所示:

接下来我们测试下添加新用户,首先我们在UserMapper.xml 中定义一个insert元素:

<insert id="addUser" parameterType="com.mybatisdemo.User" >insert into t_user(username,jobs,phone) value (#{username},#{jobs},#{phone})</insert>

然后来写测试接口:

@Testpublic void addUser throws Exception {String resource = "mybatis-config.xml";InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;User user = new User;user.setUsername("beiluo");user.setJobs("DevOps");user.setPhone("1314566666");int rows = sqlSession.insert("addUser",user);if (rows >0){System.out.println("Success add "+ rows +"data!");}else{System.out.println("add data fail!");}sqlSession.commit;sqlSession.close;}

如下所示:

接下来测试更新:

<update id="updateUserInfo" parameterType="com.mybatisdemo.User">update t_user set username=#{username},jobs=#{jobs},phone=#{phone} where id =#{id}</update>

然后写个测试类:

@Testpublic void updateUserinfo throws Exception {String resource = "mybatis-config.xml";InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;User user = new User;user.setId(1);user.setUsername("jike");user.setJobs("qa");user.setPhone("13142764432");int rows = sqlSession.update("updateUserInfo",user);if (rows >0){System.out.println("Success update "+ rows +" data!");}else{System.out.println("update data fail!");}sqlSession.commit;sqlSession.close;}

执行后如下所示:

最后,我们测试下删除功能:

<delete id="deleteUser" parameterType="com.mybatisdemo.User" >delete from t_user where id=#{id}</delete>

测试类如下:

@Testpublic void deleteUser throws Exception {String resource = "mybatis-config.xml";InputStream inputStream = Resources.getResourceAsStream(resource);SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder.build(inputStream);SqlSession sqlSession = sqlSessionFactory.openSession;int rows = sqlSession.delete("deleteUser",1);if (rows >0){System.out.println("Success delete "+ rows +" data!");}else{System.out.println("delete data fail!");}sqlSession.commit;sqlSession.close;}

执行结果如下:

☞拿下 Gartner 容器产品第一,阿里云打赢云原生关键一战!

☞腾讯面试官这样问我二叉树,我刚好都会 | 原力计划

☞斩获GitHub 2000+ Star,阿里云开源的 Alink 机器学习平台如何跑赢双11数据“博弈”?| AI 技术生态论

☞微软为一人收购一公司?破解索尼程序、写黑客小说,看他彪悍的程序人生!

☞机器学习项目模板:ML项目的6个基本步骤

☞IBM、微软、苹果、谷歌、三星……这些区块链中的科技巨头原来已经做了这么多事!

☞资深程序员总结:分析Linux进程的6个方法,我全都告诉你今日福利:评论区留言入选,可获得价值299元的「2020 AI开发者万人大会」在线

标签: #session 数据库 #ibatismysqlinsert #idea如何配置mysql数据库 #idea怎么添加数据库驱动 #idea如何配置数据库