时间:2021-05-19
简介
该篇文章主要是介绍如何使用MyBatis对Mysql数据库进行单表操作(对于mybatis的下载以及配置文件的作用和具体信息,我在上一篇文章中也已经提到了),使用的环境如下:
配置文件
首先需要有两个配置文件,一个是configuration.xml文件,配置的是连接数据库的环境以及对于mapper.xml文件的映射,还有另一个文件就是mapper.xml,这个文件主要是用来写sql语句的
configuration.xml文件
mapper.xml文件
具体操作
具体操作看如下代码,我对代码都进行了一定的注释,并结合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<Map<String, Object>> 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"); SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is); SqlSession sqlSession = factory.openSession(true); return sqlSession.selectOne("getTotalCount"); } //查询:获取表格的所有记录 //sql语句:SELECT *FROM atm; //resultType类型:domain.User (如果是自己写的实体类,需要类名的具体路径,除非做了配置) public List<User> 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<User> 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<String, Object> 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属性,获取返回值类型,通过反射创建对象,遍历结果集,将结果集包装成返回值类型的对象
基本的流程大概就是这样,本篇文章主要是对单表操作进行介绍,下一篇文章会介绍如果是多表,该如何进行操作
到此这篇关于使用Mybatis对数据库进行单表操作的实现示例的文章就介绍到这了,更多相关Mybatis 数据库单表操作内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持!
声明:本页内容来源网络,仅供用户参考;我单位不保证亦不表示资料全面及准确无误,也不保证亦不表示这些资料为最新信息,如因任何原因,本网内容或者用户因倚赖本网内容造成任何损失或损害,我单位将不会负任何法律责任。如涉及版权问题,请提交至online#300.cn邮箱联系删除。
本文实例讲述了Yii框架实现对数据库的CURD操作。分享给大家供大家参考,具体如下:首先要对数据库进行操作,需要创建一个和数据库表名相同的model,放在mod
Coonamd对象定义了将对数据源执行的命令,可以用于查询数据库表并返回一个记录集,也可以用于对数据库表进行添加、更改和删除操作。一、使用Command对象的步
WEB数据库加密。对WEB数据库加密是指对数据库中的数据进行加密处理。目前对WEB数据库加密主要是对数据库中的表、数据、属性和记录日志进行加密处理。通过数据库加
在Excel中如何使用SQL语句进行数据筛选?我们在使用VBA对数据库进行访问时,利用SQL语句能够方便地实现对数据库的查询。本文使用SQL语句实现多条件查询,
对数据加密分两种,一种是对数据库本身进行加密,另一种是对数据表中的数据进行加密,如果SQLite数据库加密,我这里使用的一个管理工具叫SQLiteDevelop