欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

初识Mybatis

程序员文章站 2022-07-12 20:16:56
...

先来回顾一下jdbc的编程步骤:

  1. 加载数据库驱动
  2. 创建并获取数据库连接
  3. 创建jdbc statement 对象
  4. 设置sql语句
  5. 设置sql语句中的参数
  6. 通过statement执行sql并获取结果
  7. 对sql执行结果进行解析处理
  8. 释放资源(result,preparedstatement,connection)

    MyBatis是一个优秀的持久层框架,对jdbc的操作数据库过程进行封装,使开发者只需要关注sql本身,而不需要花费精力去处理例如注册驱动,创建connection,创建statement,手动设置参数,结果集检索等jdbc繁杂的过程代码.
    Mybatis是通过xml或者注解的方式将要执行的各种statement配置起来,并且通过java对象和statement中的sql进行映射生成最后执行的sql语句,最后由mybatis框架执行sql并将结果映射称java对象并返回.


初识Mybatis


Mybatis入门程序

需要实现以下功能

  • 根据用户id查询一个用户信息
  • 根据用户名称模糊查询用户信息列表
  • 添加用户
  • 更新用户
  • 删除用户
  • Mybits sqlmapconfig 全局配置文件:建立数据库连接 然后要进行编写sql语句 Mapper.xml 编写sql语句
    然后在算起来mapconfig加载映射文件,建立联系 Sqlsessionfactory 会话工厂 创建session会话用来执行sql语句
    Mapperstatement:包含一个statementId:标识 parameterType:输入参数类型
    resultType:输出结果类型

    第一步:创建java工程

    第二步:加入jar包
    初识Mybatis
    第三步:log4j.properties
    在classpath下创建log4j.properties
    这里说一句:mybatis默认使用log4j作为输出日志信息

# Global logging configuration
log4j.rootLogger=DEBUG, stdout
# Console output...
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%5p [%t] - %m%n

第四步:SqlMapConfig.xml
在classpath下创建SqlMapConfig.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!-- 和spring整合后 environments配置将废除-->
<environments default="development">
<environment id="development">
<!-- 使用jdbc事务管理-->
<transactionManager type="JDBC" />
<!-- 数据库连接池-->
<dataSource type="POOLED">
<property name="driver"
value="com.mysql.jdbc.Driver" />
<property name="url"
value="jdbc:mysql://localhost:3306/mybatis?characterEncoding=u
tf-8" />
<property name="username" value="root" />
<property name="password" value="mysql" />
</dataSource>
</environment>
</environments>
</configuration>

SqlMapConfig.xml是mybatis核心配置文件

第五步:po类

一、PO:persistant object 持久对象,可以看成是与数据库中的表相映射的java对象。最简单的PO就是对应数据库中某个表中的一条记录,多个记录可以用PO的集合。PO中应该不包含任何对数据库的操作。
二、VO:value
object值对象。通常用于业务层之间的数据传递,和PO一样也是仅仅包含数据而已。但应是抽象出的业务对象,可以和表对应,也可以不,这根据业务的需要.个人觉得同DTO(数据传输对象),在web上传递。

三、DAO:data access object
数据访问对象,此对象用于访问数据库。通常和PO结合使用,DAO中包含了各种数据库的操作方法。通过它的方法,结合PO对数据库进行相关的操作。

四、BO:business object 业务对象,封装业务逻辑的java对象,通过调用DAO方法,结合PO,VO进行业务操作。

五、POJO:plain ordinary java object
简单无规则java对象,我个人觉得它和其他不是一个层面上的东西,VO和PO应该都属于它。
O/R Mapping 是 Object Relational
Mapping(对象关系映射)的缩写。通俗点讲,就是将对象与关系数据库绑定,用对象来表示关系数据。在O/R
Mapping的世界里,有两个基本的也是重要的东东需要了解,即VO,PO。   VO,值对象(Value
Object),PO,持久对象(Persisent
Object),它们是由一组属性和属性的get和set方法组成。从结构上看,它们并没有什么不同的地方。但从其意义和本质上来看是完全不同的。
1.VO是用new关键字创建,由GC回收的。
  PO则是向数据库中添加新数据时创建,删除数据库中数据时削除的。并且它只能存活在一个数据库连接中,断开连接即被销毁。
2.VO是值对象,精确点讲它是业务对象,是存活在业务层的,是业务逻辑使用的,它存活的目的就是为数据提供一个生存的地方。
  PO则是有状态的,每个属性代表其当前的状态。它是物理数据的对象表示。使用它,可以使我们的程序与物理数据解耦,并且可以简化对象数据与物理数据之间的转换。
3.VO的属性是根据当前业务的不同而不同的,也就是说,它的每一个属性都一一对应当前业务逻辑所需要的数据的名称。
  PO的属性是跟数据库表的字段一一对应的。

PO对象需要实现序列化接口。

package com.hpe.mybatis.po;

import java.util.Date;

public class User {
    private int id;//编号
    private String username;//姓名
    private Date birthday;//生日
    private String sex;//性别
    private String address;//地址
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getUsername() {
        return username;
    }
    public void setUsername(String username) {
        this.username = username;
    }
    public Date getBirthday() {
        return birthday;
    }
    public void setBirthday(Date birthday) {
        this.birthday = birthday;
    }
    public String getSex() {
        return sex;
    }
    public void setSex(String sex) {
        this.sex = sex;
    }
    public String getAddress() {
        return address;
    }
    public void setAddress(String address) {
        this.address = address;
    }
    @Override
    public String toString() {
        return "User [id=" + id + ", username=" + username + ", birthday=" + birthday + ", sex=" + sex + ", address="
                + address + "]";
    }

}

第六步:程序编写

初识Mybatis

在classpath 下的sqlmap 目录下创建sql 映射文件Users.xml:

<?xml version="1.0" encoding="UTF-8"?>
<!DOCTYPE mapper
PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="test">
    <!--namespace就是一个命名空间,用来隔离sql语句,相当于一个容器,可以有多个 -->

    <!-- 功能: 通过用户id查询用户信息 属性: id就是标识映射文件的sql 将sql语句封装到mappedStatement对象中,所以id成为statement的id 
        parameterType:输入映射参数类型 resultType:输出结果所映射的java对象的类型(指定sql输入结果映射的对象类型,就是返回类型是user) -->
    <select id="findUserById" parameterType="int"
        resultType="com.hpe.mybatis.po.User">
        SELECT * FROM `user` WHERE id = #{id}
    </select>
    <!--根据用户名模糊查询用户信息 -->
    <!--${}表示拼接sql语句,如果传入的数据参数类型是简单类型,那么参数必须为value ${value} -->
    <select id="findUserByName" parameterType="java.lang.String"
        resultType="com.hpe.mybatis.po.User">
        SELECT * FROM `user` WHERE username LIKE '%${value}%'
    </select>

    <!--新增用户 -->
    <insert id="insertUser" parameterType="com.hpe.mybatis.po.User">
        <!-- 返回主键值 -->
        <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
            select LAST_INSERT_ID()
        </selectKey>
        INSERT INTO user(id,username,birthday,sex,address)
        VALUES(#{id},#{username},#{birthday},#{sex},#{address})
    </insert>
    <!-- 删除用户 -->
    <delete id="deleteUser" parameterType="int">
        DELETE FROM user WHERE id = #{id}
    </delete>

    <!--更新用户 -->
    <update id="updateUser">
        UPDATE user SET username=#{username},birthday=#{birthday},
        sex=#{sex},address=#{address} where id = #{id}
    </update>
</mapper>
package com.hpe.mybatis.first;

import java.io.IOException;
import java.io.InputStream;
import java.util.Date;
import java.util.List;

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.Before;
import org.junit.Test;

import com.hpe.mybatis.po.User;

public class MybatisDemo {
    //会话工厂
    private SqlSessionFactory sqlSessionFactory;

    @Before
    public void setUp() throws IOException {
        // mybatis配置文件
        String resource = "SqlMapConfig.xml";

        // 读取配置文件
        InputStream inputStream = Resources.getResourceAsStream(resource);

        // 创建会话工厂,传入参数是MyBatis配置文件
        sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

    }

    // 根据用户id查询一个用户信息
    @Test
    public void findUserByIdTest() throws IOException {
        // System.out.println("这是一个测试方法");

        // 创建会话,用来操作数据库(增删改查)
        SqlSession sqlSession = sqlSessionFactory.openSession();

        // statement:namespace.statementID 即test.findUserById
        // parameter:输入映射参数 指定和映射文件中所匹配的parameterType类型的参数
        User user = sqlSession.selectOne("test.findUserById", 1);
        System.out.println(user);

        // 关闭会话
        sqlSession.close();
    }

    // 根据用户名称模糊查询用户信息列表(可能返回多条结果-->用list集合存储结果)
    @Test
    public void findUserByNameTest() throws IOException {
        // 创建会话,用来操作数据库
        SqlSession sqlSession = sqlSessionFactory.openSession();

        List<User> list = sqlSession.selectList("test.findUserByName", "三丰");

        System.out.println(list);

        sqlSession.close();
    }

    //添加用户信息
    @Test
    public void insertUserTest() throws IOException{
        SqlSession sqlSession = sqlSessionFactory.openSession();
        User user = new User();
        user.setUsername("鹿晗");
        user.setBirthday(new Date());
        user.setSex("1");
        user.setAddress("山东济宁");
        sqlSession.insert("test.insertUser", user);
        //提交事务(默认autocommit==false 我们要将其改成手动提交)
        sqlSession.commit();
        System.out.println(user.getId());//输出新添加的id号
        //关闭会话
        sqlSession.close();
    }

    //删除用户信息
    @Test
    public void deleteUserTest() throws IOException{
        SqlSession sqlSession = sqlSessionFactory.openSession();
        sqlSession.delete("test.deleteUser", 28);
        //提交事务(默认autocommit==false 我们要将其改成手动提交)
        sqlSession.commit();
        //关闭会话
        sqlSession.close();
    }

    @Test
    public void updateUserTest() throws IOException{
        SqlSession sqlSession = sqlSessionFactory.openSession();
        User user = new User();
        user.setUsername("鹿晗");
        user.setBirthday(new Date());
        user.setSex("1");
        user.setAddress("山东济南");
        user.setId(27);
        sqlSession.update("test.updateUser", user);
        //提交事务(默认autocommit==false 我们要将其改成手动提交)
        sqlSession.commit();
        //关闭会话
        sqlSession.close();
    }
}