使用Mybatis对数据库进行单表操作的实现示例

网友投稿 289 2022-11-28


使用Mybatis对数据库进行单表操作的实现示例

简介

该篇文章主要是介绍如何使用MyBatis对mysql数据库进行单表操作(对于mybatis的下载以及配置文件的作用和具体信息,我在上一篇文章中也已经提到了),使用的环境如下:

JDK版本:1.8

编译器:IDEA2019

JDBC版本:8.0.18

mybatis版本:3.5.3

配置文件

首先需要有两个配置文件,一个是configuration.xml文件,配置的是连接数据库的环境以及对于mapper.xml文件的映射,还有另一个文件就是mapper.xml,这个文件主要是用来写sql语句的

configuration.xml文件

PUBLIC "-//mybatis.org//DTD Config 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-config.dtd">

http://

mapper.xml文件

PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"

"http://mybatis.org/dtd/mybatis-3-mapper.dtd">

INSERT ATM VALUES(#{account}, #{password}, #{balance})

update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account};

DELETE FROM ATM WHERE account=#{account};

SELECT *FROM atm;

SELECT COUNT(*) FROM atm;

select count(*),max(balance) from atm;

SELECT *FROM atm order by ${flag} ${order};

具体操作

具体操作看如下代码,我对代码都进行了一定的注释,并结合mapper.xml文件一起看

public class UserDao {

//增加一条记录,user对象是我创建的实体类

//mapper.xml文件的sql语句如下:

//update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account};

//#{key}中的key要和实体类user的属性名一致

//如果传递的是基本数据类型或者String,且#{key}只有一个,那么名字可以不一致

//如果传入的是map集合,#{key}中的key要和map集合里的key一致

public void insert(User user){

//MYBATIS操作流程

//获取工厂Builder对象

SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();

//获取configuration.xml配置文件的输入流

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");

//builder根据is获取SqlSessionFactory工厂对象

SqlSessionFactory factory = builder.build(is);

//获取SqlSession对象

SqlSession sqlSession = factory.openSession();

//执行sql语句操作

//insert是在mapper.xml下,insert标签的id名

//user是我要插入的数据(动态操作),替换掉sql语句的#{}

sqlSession.insert("insert", user);

sqlSession.commit();

}

//改:修改记录,user是要修改的数据

//mapper.xml文件的sql语句如下:

//update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account};

public void update(User user){

//MYBATIS操作流程

//获取工厂Builder对象

SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();

//获取configuration.xml配置文件的输入流

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");

//builder根据is获取SqlSessionFactory工厂对象

SqlSessionFactory factory = builder.build(is);

//获取SqlSession对象

SqlSession sqlSession = factory.openSession(true);

//执行sql语句操作

sqlSession.update("update",user);

}

//删除:根据account删除

//mapper.xml的sql语句如下:

// DELETE FROM ATM WHERE account=#{account};

public void delete(String account){

//MYBATIS操作流程

//获取工厂Builder对象

SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();

//获取configuration.xml配置文件的输入流

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");

//builder根据is获取SqlSessionFactory工厂对象

SqlSessionFactory factory = builder.build(is);

//获取SqlSession对象

SqlSession sqlSession = factory.openSession(true);

//执行sql语句操作

sqlSession.update("delete",account);

}

//===============================查询====================================

//查询:查找记录总条数以及balance的最大值

//sql语句如下:select count(*),max(balance) from atm;

//select标签上的resultType表示的是返回值,指的是一条记录的类型,最后包裹成list集合

//我这里用的hashMap

public List> gettotal(){

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");

SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);

SqlSession sqlSession = factory.openSession(true);

return sqlSession.selectList("gettotal");

}

//查询:获取总记录数

//sql语句: SELECT COUNT(*) FROM atm;

//resultType类型:integer

public Integer getTotalCount(){

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");

SqlqFGZUSessionFactory factory = new SqlSessionFactoryBuilder().build(is);

SqlSession sqlSession = factory.openSession(true);

return sqlSession.selectOne("getTotalCount");

}http://

//查询:获取表格的所有记录

//sql语句:SELECT *FROM atm;

//resultType类型:domain.User (如果是自己写的实体类,需要类名的具体路径,除非做了配置)

public List selectAll(){

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");

SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);

SqlSession sqlSession = factory.openSession(true);

return sqlSession.selectList("selectAll");

}

//查询:查询所有该表所有记录,并根据flag列进行order排序

//flag不确定,order可能是升序也可能是降序(由调用这个方法的用户决定)

//sql语句: SELECT *FROM atm order by ${flag} ${order};

//这里用的是${}而不是#{}

//#{}和${}的区别:

//#{}:当我们的动态参数是用作条件的时候我们用这个,比如说account=#{key}

//${}:当我们的动态参数表示的是一个普通字符串,比如说表名、列名或者关键字我们用这个

//resultType:domain.User(domain包下的User类)

public List selectAllByAcc(String flag, String order){

InputStream is = Thread.currentThread().getContextClassLoader().getResourceAsStream("configuration.xml");

SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);

SqlSession sqlSession = factory.openSession(true);

Map map = new HashMap<>();

map.put("flag", flag);

map.put("order", order);

return sqlSession.selectList("selectAllByAcc", map);

}

}

关于单表操作的底层原理

这里我简单提一下关于增删改查操作的底层原理,以查询操作为例,查询操作和增删改操作的主要区别在于sql语句的不同以及查询操作有返回值,所以底层还需要处理返回值

例如:sqlSession.selectOne(sql,obj)

1)首先,底层需要根据configuration.xml,找到mysql的驱动类driver,加载驱动

2)根据configuration.xml文件,找到连接MySQL数据库的url,user,password,获取连接Connection

3)参考configuration.xml配置文件,找到mapper.xml文件,从而找到sql语句,创建状态参数PreparedStatement

4)解析sql语句,把#{key}或者${key}转换成?的形式,并记录key的名字,根据传递过来的obj匹配key,如果传递过来的是domain实体对象,通过反射获取domain实体中的所有属性,根据属性名字去匹配key,然后调用状态参数的setObject方法对?进行复制(其他类型的对象也基本如此)

5)执行SQL操作,获取结果集

6)分析ResultType属性,获取返回值类型,通过反射创建对象,遍历结果集,将结果集包装成返回值类型的对象

基本的流程大概就是这样,本篇文章主要是对单表操作进行介绍,下一篇文章会介绍如果是多表,该如何进行操作


版权声明:本文内容由网络用户投稿,版权归原作者所有,本站不拥有其著作权,亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容,请联系我们jiasou666@gmail.com 处理,核实后本网站将在24小时内删除侵权内容。

上一篇:快速解决idea打开某个项目卡住的问题
下一篇:如何在IDEA中对 hashCode()和 equals() 利用快捷键快速进行方法重写
相关文章

 发表评论

暂时没有评论,来抢沙发吧~