使用Mybatis对数据库进行单表操作的方法

发布时间:2020-08-10 10:32:15 作者:小新
来源:亿速云 阅读:180

小编给大家分享一下使用Mybatis对数据库进行单表操作的方法,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!

使用的环境如下:

配置文件

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

configuration.xml文件

<&#63;xml version="1.0" encoding="UTF-8" &#63;>
<!DOCTYPE configuration
    PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
  <environments default="e1">
    <environment id="e1">
      <transactionManager type="JDBC"></transactionManager>
      <dataSource type="POOLED">
        <property name="driver" value="com.mysql.cj.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/bank&#63;serverTimezone=CST"/>
        <property name="username" value="root"/>
        <property name="password" value="123456"/>
      </dataSource>
    </environment>
    <environment id="e2">
      <transactionManager type=""></transactionManager>
      <dataSource type=""></dataSource>
    </environment>
  </environments>
  <mappers>
    <mapper resource="mapper/UserMapper.xml"></mapper>
  </mappers>
</configuration>

mapper.xml文件

<&#63;xml version="1.0" encoding="UTF-8" &#63;>
<!DOCTYPE mapper
    PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
    "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="dao.UserDao">
  <insert id="insert">
    INSERT ATM VALUES(#{account}, #{password}, #{balance})
  </insert>
  <update id="update">
    update atm set account=#{account},password=#{password},balance=#{balance} where account=#{account};
  </update>
  <delete id="delete">
    DELETE FROM ATM WHERE account=#{account};
  </delete>

  <select id="selectAll" resultType="domain.User">
    SELECT *FROM atm;
  </select>

  <select id="getTotalCount" resultType="integer">
    SELECT COUNT(*) FROM atm;
  </select>
  <select id="gettotal" resultType="hashmap">
    select count(*),max(balance) from atm;
  </select>


  <select id="selectAllByAcc" resultType="domain.User">
    SELECT *FROM atm order by ${flag} ${order};
  </select>
</mapper>

具体操作

具体操作看如下代码,我对代码都进行了一定的注释,并结合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}转换成&#63;的形式,并记录key的名字,根据传递过来的obj匹配key,如果传递过来的是domain实体对象,通过反射获取domain实体中的所有属性,根据属性名字去匹配key,然后调用状态参数的setObject方法对&#63;进行复制(其他类型的对象也基本如此)
5)执行SQL操作,获取结果集
6)分析ResultType属性,获取返回值类型,通过反射创建对象,遍历结果集,将结果集包装成返回值类型的对象
基本的流程大概就是这样,本篇文章主要是对单表操作进行介绍,下一篇文章会介绍如果是多表,该如何进行操作

以上是使用Mybatis对数据库进行单表操作的方法的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注亿速云行业资讯频道!

推荐阅读:
  1. 4、django操作单表进行增删改
  2. django 单表操作实例详解

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

mybatis 数据库 单表

上一篇:如何记录iis php中的错误日志

下一篇:php采集乱码怎么办

相关阅读

您好,登录后才能下订单哦!

密码登录
登录注册
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》