码迷,mamicode.com
首页 > 微信 > 详细

mybatis入门篇1 --- 编写入门小程序

时间:2020-01-30 19:22:13      阅读:157      评论:0      收藏:0      [点我收藏+]

标签:连接池   声明   都差不多   技术   username   getting   文件   catch   一点   

首先简单说一下为什么使用mybatis,我们上一个项目使用的JDBC,所有的sql语句都是写在java程序中,这样的就会使sql语句与java程序高度耦合,不符合我们的高内聚,低耦合情况,我们只希望你给我一个接口并且返回指定类型的程序,具体如何实现我不管,这样才会更好的进行操作,Hibernate跟mybatis都属于这种情况,hibernate属于全自动框架,mybatis属于半自动框架,什么意思?hibernate对于简单的数据库操作很方便,但是一旦涉及到复杂的数据库操作或者想要对sql语句优化就会很乏力,无法处理,因为sql是内部产生的,mybatis解决了这个问题。我们常听说的sql语句优化,就是这种情景。Mybatis是一款半自动化的持久性框架,他支持定制化sql,存储过程以及高级映射的优秀的持久性框架。

mybatis的入门程序也可以看:https://mybatis.org/mybatis-3/getting-started.html

首先第一步下载我们所需的jar包,直接去github:https://github.com/mybatis/mybatis-3/releases/tag/mybatis-3.5.3,下载最新版的,我这个不知道为啥下载失败,因此使用的是网上中的3.4.6,但都差不多。

如果后续不想要写javabean的get,set方法,可以下载lombok包,同时把junit包加进去,我没有起项目,直接就是一般的java程序,下面截图是主要的代码

技术图片

 

 

 首先看一下我们引用的第三方包,者mybatis基础上增加了一个mysql连接包,junit测试包,以及lombok包

技术图片

 

 

 首先我们看一下配置文件,SqlMappingConfig.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整合之后,会使用spring的连接池-->
    <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=utf-8"/>
                <property name="username" value="root"/>
                <property name="password" value="mysql"/>
            </dataSource>
        </environment>
    </environments>
    <!--指定映射文件,一般这个文件跟我们的映射类放在同一级目录下-->
    <mappers>
        <mapper resource="com/yang/domain/Customer.xml"/>
    </mappers>
</configuration>

接下来我们需要定义一个javabean与数据库对应,Customer

package com.yang.domain;

import lombok.Getter;
import lombok.Setter;

// 引用lombok中的get,set方法,自动为我们生成getattr,setattr方法,这个就是数据库的映射表,字段要与数据库一致
//@Getter @Setter
// 我这里还是搞上set get方法
public class Customer {
    private Integer id;
    private String username;
    private String job;
    private String phone;
    private String email;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getUsername() {
        return username;
    }

    public void setUsername(String username) {
        this.username = username;
    }

    public String getJob() {
        return job;
    }

    public void setJob(String job) {
        this.job = job;
    }

    public String getPhone() {
        return phone;
    }

    public void setPhone(String phone) {
        this.phone = phone;
    }

    public String getEmail() {
        return email;
    }

    public void setEmail(String email) {
        this.email = email;
    }

    @Override
    public String toString() {
        return "Customer{" +
                "id=" + id +
                ", username=‘" + username + ‘\‘‘ +
                ", job=‘" + job + ‘\‘‘ +
                ", phone=‘" + phone + ‘\‘‘ +
                ", email=‘" + email + ‘\‘‘ +
                ‘}‘;
    }
}

我们在同级目录下定义我们这个customer的映射表,注意resultType不要写成resultMap,我一开始就写错了,mybatis报错也没有定位,有一点错误就会报出来,找了半天错误。。。。。

<?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="myCustomer">
    <!--根据id查询-->
    <select id="queryCustomerById" parameterType="java.lang.Integer" resultType="com.yang.domain.Customer">
        SELECT * FROM `customer` WHERE id = #{id}
    </select>
    <!--查询所有-->
    <select id="queryAllCustomer" resultType="com.yang.domain.Customer">
        SELECT * FROM `customer`
    </select>
    <!--添加-->
    <insert id="insertCustomer" parameterType="com.yang.domain.Customer">
        /*这个获取返回id,并且赋值给我们返回的对象,如果没有这个那么返回的customer对象中id就会为空*/
        <selectKey keyColumn="id" keyProperty="id" resultType="Integer" order="AFTER">
            select last_insert_id()
        </selectKey>
        insert into `customer`(username, job, phone, email) values (#{username}, #{job}, #{phone}, #{email})
    </insert>
    <!--更新-->
    <update id="updateCustomer" parameterType="com.yang.domain.Customer">
        update `customer` set username=#{username} where id=#{id}
    </update>
    <!--删除-->
    <delete id="deleteCustomer" parameterType="com.yang.domain.Customer">
        delete from `customer` where id=#{id}
    </delete>

</mapper>

因为我们这个有增删改查,因此在获取操作数据库的session会话做了一个工具类的封装,MyBatisUtil

package com.yang.util;

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 java.io.InputStream;

// 为了方便测试,我们封装一个获取连接对象的工具类
public class MyBatisUtil {

    // 声明session工厂
    public static final SqlSessionFactory sessionFactory;

    static {
        // 加载配置文件
        SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
        InputStream inputStream = null;
        try {
            // 读取配置文件
            inputStream = Resources.getResourceAsStream("SqlMappingConfig.xml");
        } catch (Exception e) {
            e.printStackTrace();
        }
        // 获取session工厂
        sessionFactory = sqlSessionFactoryBuilder.build(inputStream);
    }

    // 获取连接对象
    public static SqlSession openSession() {
        return sessionFactory.openSession();
    }
}

最终看一下我们的测试文件

package com.yang.test;

import com.yang.domain.Customer;
import com.yang.util.MyBatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;

import java.util.List;

public class TestCustomer {


    // 查询单个用户
    @Test
    public void test() {
        // 获取session连接对象(会话)
        SqlSession sqlSession = MyBatisUtil.openSession();
        // 执行sql语句,查询查询一条数据使用selectOne
        Customer customer = sqlSession.selectOne("queryCustomerById", 1);
        System.out.println(customer);  // Customer{id=1, username=‘yang‘, job=‘射手‘, phone=‘13499887733‘, email=‘12341241@qq.com‘}
        // 完毕之后需要关闭会话
        sqlSession.close();
    }

    // 查询所有用户
    @Test
    public void testList() {
        SqlSession sqlSession = MyBatisUtil.openSession();
        List<Customer> customers = sqlSession.selectList("queryAllCustomer");
        for (Customer customer : customers) {
            System.out.println(customer); // Customer{id=1, username=‘yang‘, job=‘射手‘, phone=‘13499887733‘, email=‘12341241@qq.com‘}  ....
        }
        sqlSession.close();
    }

    // 插入操作
    @Test
    public void insert() {
        SqlSession sqlSession = MyBatisUtil.openSession();
        Customer customer = new Customer();
        customer.setUsername("yang");
        customer.setPhone("18122222222");
        Integer id = sqlSession.insert("insertCustomer", customer);
        // 当改变数据库时,我们需要手动提交
        sqlSession.commit();
        System.out.println(customer);  // Customer{id=12, username=‘yang‘, job=‘null‘, phone=‘18122222222‘, email=‘null‘}
        System.out.println(id);  // 1 这个是影响的行数,想要id直接去返回的结果集中去拿
        sqlSession.close();
    }

    // 更新操作
    @Test
    public void update() {
        SqlSession sqlSession = MyBatisUtil.openSession();
        Customer customer = sqlSession.selectOne("queryCustomerById", 1);
        customer.setUsername("yang");
        System.out.println(customer);  // Customer{id=1, username=‘yang‘, job=‘射手‘, phone=‘13499887733‘, email=‘12341241@qq.com‘}
        sqlSession.update("updateCustomer", customer);
        System.out.println(customer);  // Customer{id=1, username=‘yang‘, job=‘射手‘, phone=‘13499887733‘, email=‘12341241@qq.com‘}
        sqlSession.commit();
        sqlSession.close();
    }

    // 删除
    @Test
    public void delete() {
        SqlSession sqlSession = MyBatisUtil.openSession();
        Customer customer = sqlSession.selectOne("queryCustomerById", 3);
        System.out.println(customer);
        sqlSession.delete("deleteCustomer", customer);
        sqlSession.commit();
        sqlSession.close();
    }
}

通过编写代码,已经对mybatis有了基本的认识,我们具体看一下mybatis的执行流程图,可以采用debug模式一步一步看:

技术图片

 

mybatis入门篇1 --- 编写入门小程序

标签:连接池   声明   都差不多   技术   username   getting   文件   catch   一点   

原文地址:https://www.cnblogs.com/yangshixiong/p/12243372.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!