MyBatis入门

2018-04-25  本文已影响0人  GAWEGOR

MyBatis HelloWorld

目录结构

directory.png

准备数据库

DROP TABLE IF EXISTS `blog`;
CREATE TABLE `blog`(
  `id` INT NOT NULL AUTO_INCREMENT,
  `name` VARCHAR(50),
  PRIMARY KEY(`id`)
) ENGINE=InnoDB AUTO_INCREMENT=100 DEFAULT CHARSET=utf8;

INSERT INTO `blog` VALUES (101,'Gawegor');

jar包

使用Maven添加依赖:

    </dependencies>
        <!-- mybatis包 -->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.4.6</version>
        </dependency>
        <!-- mysql JDBC包 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>6.0.6</version>
        </dependency>
    </dependencies>

MyBatis配置文件

MyBatis核心全局配置文件,一般命名为:mybatis-config.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>
    
    <environments default="development">
        <environment id="development">
            <!-- 事务管理设置 -->
            <transactionManager type="JDBC"/>
            <!-- 数据库连接设置 -->
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql://localhost:3306/test"/>
                <property name="username" value="root"/>
                <property name="password" value="123"/>
            </dataSource>
        </environment>
    </environments>
    <!-- 映射文件设置 -->
    <mappers>
        <mapper resource="mybatis/hello/BlogMapper.xml"/>
    </mappers>
</configuration>

POJO

对应数据库表的POJO。

package mybatis.hello;

import java.io.Serializable;

public class Blog implements Serializable {
    private Integer id;
    private String name;
    public Integer getId() {
        return id;
    }
    public void setId(Integer id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    @Override
    public String toString() {
        return "Id: " + getId() + ", Name: " + getName();
    }
}

Mapper接口

它定义了我们需要的CURD操作的方法。等价于DAO接口,但不需要实现,由Mybatis生成。

BlogMapper.class

package mybatis.hello;

public interface BlogMapper {
    Blog selectBlog(Integer id);
}

映射文件

BlogMapper.xml,对应BlogMapper.class接口

<?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="mybatis.hello.BlogMapper">
    <!-- 一个select对应BlogMapper.class接口的一个方法 -->
    <select id="selectBlog" resultType="mybatis.hello.Blog">
        select * from Blog where id = #{id} <!-- id对应方法参数名 -->
    </select>
</mapper>

因为我们的BlogMapper.xml放在了mybatis.hello,所以需要设置pom.xml,让Maven构建时将BlogMapper.xml放到资源目录。pom.xml

<build>
    <resources>
        <resource>
            <directory>src/main/java</directory>
            <includes>
               <include>**/*.xml</include>
            </includes>
        </resource>
    </resources>
</build>

使用MyBatis

上面完成了基础配置,现在可以写用MaBatis获取获取数据库记录的代码了。

package mybatis.hello;

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

public class Main {
    public static void main(String[] args) throws IOException {
        //创建SqlSessionFactory
        String resource = "mybatis-config.xml";
        InputStream inputStream = Resources.getResourceAsStream(resource);
        SqlSessionFactory sqlSessionFactory = new 
            SqlSessionFactoryBuilder().build(inputStream);
        
        //获取SqlSession对象
        SqlSession sqlSession = sqlSessionFactory.openSession();
        try {
           //获取BlogMapper接口的实现代理和用它的方法来获取数据库记录
           BlogMapper mapper = sqlSession.getMapper(BlogMapper.class);
           Blog blog = mapper.selectBlog(101);
           System.out.println(blog);  
        } finally {
            sqlSession.close();
        }
    }
}

其中这里有几个重要的点:

  1. SqlSessionFactory,全局对象,应用生命周期中只创建一次。里面保存了全局配置文件的预设信息。也需要通过它来获取SqlSession。
  2. SqlSession,对应JDBC的Connection。它是非线程安全的,每次使用完都需要用close()关闭。
  3. Mapper接口实现,通过SqlSession.getMapper(Class)可以获取Mapper接口的一个实现(MyBatis已经帮你实现好了)。

总结

上一篇 下一篇

猜你喜欢

热点阅读