1. 程式人生 > >Mybatis入門(1)

Mybatis入門(1)

mybatis入門

MyBatis簡介
  • MyBatis 本是apache的一個開源項目iBatis, 2010年這個項目由apache software foundation 遷移到了google code,並且改名為MyBatis 。2013年11月遷移到Github。
  • MyBatis是一個優秀的持久層框架,它對jdbc的操作數據庫的過程進行封裝,使開發者只需要關註 SQL 本身,而不需要花費精力去處理例如註冊驅動、創建connection、創建statement、手動設置參數、結果集檢索等jdbc繁雜的過程代碼。
  • Mybatis通過xml或註解的方式將要執行的各種statement(statement、preparedStatemnt、CallableStatement)配置起來,並通過java對象和statement中的sql進行映射生成最終執行的sql語句,最後由mybatis框架執行sql並將結果映射成java對象並返回。

傳統 使用jdbc編程問題總結

jdbc編程步驟:
1、 加載數據庫驅動
2、 創建並獲取數據庫鏈接
3、 創建jdbc statement對象
4、 設置sql語句
5、 設置sql語句中的參數(使用preparedStatement)
6、 通過statement執行sql並獲取結果
7、 對sql執行結果進行解析處理
8、 釋放資源(resultSet、preparedstatement、connection)


創建表

mysql> desc user;
+----------+--------------+------+-----+---------+----------------+
| Field    | Type         | Null | Key | Default | Extra          |
+----------+--------------+------+-----+---------+----------------+
| id       | int(11)      | NO   | PRI | NULL    | auto_increment |
| username | varchar(32)  | NO   |     | NULL    |                |
| birthday | date         | YES  |     | NULL    |                |
| sex      | char(1)      | YES  |     | NULL    |                |
| address  | varchar(256) | YES  |     | NULL    |                |
+----------+--------------+------+-----+---------+----------------+

mysql> select * from user;
+----+---------------+------------+------+----------+
| id | username      | birthday   | sex  | address  |
+----+---------------+------------+------+----------+
|  1 | wangwu        | NULL       | 2    | NULL     |
| 10 | zhangsan      | 2014-07-10 | 1    | 北京市   |
| 16 | zhangxiaoming | NULL       | 1    | 河南鄭州 |
| 22 | chenxiaoming  | NULL       | 1    | 河南鄭州 |
| 24 | zhangsanfeng  | NULL       | 1    | 河南鄭州 |
| 25 | chenxiaoming  | NULL       | 1    | 河南鄭州 |
| 26 | wangwu        | NULL       | NULL | NULL     |
| 28 | wudi          | NULL       | 0    | USA      |
| 30 | wudi1         | NULL       | 0    | USA      |
+----+---------------+------------+------+----------+
9 rows in set (0.00 sec)

JDBC程序

package com.mybatis.jdbc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
/**
 * @author CHUAN
 * 原始JDBC連接代碼
 */
public class jdbcConn {
    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        try {
            // 加載數據庫驅動
            Class.forName("com.mysql.jdbc.Driver");
            // 通過驅動管理類獲取數據庫鏈接
            connection = DriverManager
                    .getConnection(
                            "jdbc:mysql://172.16.30.189:3306/mybatis?characterEncoding=utf-8",
                            "root", "123");
            // 定義sql語句 ?表示占位符
            String sql = "select * from user where username = ?";
            // 獲取預處理statement
            preparedStatement = connection.prepareStatement(sql);
            // 設置參數,第一個參數為sql語句中參數的序號(從1開始),第二個參數為設置的參數值
            preparedStatement.setString(1, "wangwu");
            // 向數據庫發出sql執行查詢,查詢出結果集
            resultSet = preparedStatement.executeQuery();
            // 遍歷查詢結果集
            while (resultSet.next()) {
                System.out.println(resultSet.getString("id") + "  "
                        + resultSet.getString("username"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 釋放資源
            if (resultSet != null) {
                try {
                    resultSet.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if (preparedStatement != null) {
                try {
                    preparedStatement.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
            if (connection != null) {
                try {
                    connection.close();
                } catch (SQLException e) {
                    // TODO Auto-generated catch block
                    e.printStackTrace();
                }
            }
        }
    }

}

測試結果:
1  wangwu
26  wangwu

jdbc問題總結如下:

1、 數據庫連接創建、釋放頻繁造成系統資源浪費,從而影響系統性能。如果使用數據庫連接池可解決此問題。
2、 Sql語句在代碼中硬編碼,造成代碼不易維護,實際應用中sql變化的可能較大,sql變動需要改變java代碼。
3、 使用preparedStatement向占有位符號傳參數存在硬編碼,因為sql語句的where條件不一定,可能多也可能少,修改sql還要修改代碼,系統不易維護。
4、 對結果集解析存在硬編碼(查詢列名),sql變化導致解析代碼變化,系統不易維護,如果能將數據庫記錄封裝成pojo對象解析比較方便。


Mybatis架構

技術分享圖片


  • 1、 mybatis配置
    SqlMapConfig.xml,此文件作為mybatis的全局配置文件,配置了mybatis的運行環境等信息。
    mapper.xml文件即sql映射文件,文件中配置了操作數據庫的sql語句。此文件需要在SqlMapConfig.xml中加載。
  • 2、 通過mybatis環境等配置信息構造SqlSessionFactory即會話工廠
  • 3、 由會話工廠創建sqlSession即會話,操作數據庫需要通過sqlSession進行。
  • 4、 mybatis底層自定義了Executor執行器接口操作數據庫,Executor接口有兩個實現,一個是基本執行器、一個是緩存執行器。
  • 5、 Mapped Statement也是mybatis一個底層封裝對象,它包裝了mybatis配置信息及sql映射信息等。mapper.xml文件中一個sql對應一個Mapped Statement對象,sql的id即是Mapped statement的id。
  • 6、 Mapped Statement對sql執行輸入參數進行定義,包括HashMap、基本類型、pojo,Executor通過Mapped Statement在執行sql前將輸入的java對象映射至sql中,輸入參數映射就是jdbc編程中對preparedStatement設置參數。
  • 7、 Mapped Statement對sql執行輸出結果進行定義,包括HashMap、基本類型、pojo,Executor通過Mapped Statement在執行sql後將輸出結果映射至java對象中,輸出結果映射過程相當於jdbc編程中對結果的解析處理過程。

Mybatis入門程序

mybatis下載

mybaits的代碼由github.com管理
下載地址:https://github.com/mybatis/mybatis-3/releases
課前資料提供的mybatis如下:

  • mybatis-3.2.7.jar mybatis的核心包
  • lib文件夾 mybatis的依賴包所在
  • mybatis-3.2.7.pdf mybatis使用手冊

業務需求

使用MyBatis實現以下功能:
根據用戶id查詢一個用戶
根據用戶名稱模糊查詢用戶列表
添加用戶
更新用戶
刪除用戶


環境搭建

  • 加入jar包
    加入mybatis核心包、依賴包、數據驅動包。
    mybatis核心包

技術分享圖片

mybatis依賴包
技術分享圖片

數據庫驅動包(已添加)
技術分享圖片
效果:
技術分享圖片


  • 加入配置文件

    • log4j.properties
      在config下創建log4j.properties如下:
      # 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

      mybatis默認使用log4j作為輸出日誌信息。

    • SqlMapConfig.xml
      在config下創建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://172.16.30.189:3306/mybatis?characterEncoding=utf-8" />
              <property name="username" value="root" />
              <property name="password" value="123" />
          </dataSource>
      </environment>
      </environments>
      </configuration>

      SqlMapConfig.xml是mybatis核心配置文件,配置文件內容為數據源、事務管理。

  • 創建pojo

pojo類作為mybatis進行sql映射使用,po類通常與數據庫表對應,

數據庫user表如下圖:
技術分享圖片

User.java如下:

Public class User {
    private int id;
    private String username;// 用戶姓名
    private String sex;// 性別
    private Date birthday;// 生日
    private String address;// 地址

get/set……
  • 第六步:sql映射文件

在config下的sqlmap目錄下創建sql映射文件User.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">
<!-- namespace:命名空間,用於隔離sql,還有一個很重要的作用,後面會講 -->
<mapper namespace="test">
</mapper>
  • 第七步:加載映射文件

mybatis框架需要加載Mapper.xml映射文件
將users.xml添加在SqlMapConfig.xml,如下:
技術分享圖片


以下按業務需求實現mybatis

  • 實現根據id查詢用戶
    使用的sql:
    SELECT * FROM `user` WHERE id = 1:
  • 映射文件:

在user.xml中添加select標簽,編寫sql:

<?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">
<!-- namespace:命名空間,用於隔離sql,還有一個很重要的作用,後面會講 -->
<mapper namespace="usertest">

    <!-- id:statement的id 或者叫做sql的id-->
    <!-- parameterType:聲明輸入參數的類型 -->
    <!-- resultType:聲明輸出結果的類型,應該填寫pojo的全路徑 -->
    <!-- #{}:輸入參數的占位符,相當於jdbc的? -->
    <!-- 通過ID查詢一個用戶   如果pojo和數據庫裏面的字段能一一對應上,就用resulttype自動映射-->
    <select id="findUserById" parameterType="Integer" resultType="com.mybatis.pojo.User">
        select * from user where id = #{v}
    </select>
</mapper>

測試程序
測試程序步驟:

  1. 創建SqlSessionFactoryBuilder對象
  2. 加載SqlMapConfig.xml配置文件
  3. 創建SqlSessionFactory對象
  4. 創建SqlSession對象
  5. 執行SqlSession對象執行查詢,獲取結果User
  6. 打印結果
  7. 釋放資源

myBatisDemo 程序如下:

package com.mybatis.juint;

import java.io.IOException;
import java.io.InputStream;
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.Test;
import com.mybatis.pojo.User;

public class myBatisDemo {
    @Test
    public void mybatisTest() throws IOException {
        // 加載核心配置文件
        String resource = "sqlMapConfig.xml";
        InputStream in = Resources.getResourceAsStream(resource);

        // 創建sqlsessionfactory
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder()
                .build(in);
        // 創建sqlsession
        SqlSession sqlSession = sqlSessionFactory.openSession();

        // 執行sql語句
        User user = sqlSession.selectOne("usertest.findUserById", 10);

        System.out.println(user.toString());
    }
}

測試結果:
技術分享圖片

  • 實現根據用戶名模糊查詢用戶

查詢sql:

SELECT * FROM `user` WHERE username LIKE ‘%wang%‘

有兩種方法:

映射文件

在User.xml配置文件中添加如下內容:

<!-- #{}表示占位符 裏面隨便用-->
    <!-- ${}字符創拼接 裏面必須是value-->
    <select id="findUserByUsername" parameterType="String" resultType="com.mybatis.pojo.User">
        <!-- select * from user where username like ‘%${value}%‘--> ------>方法1

        select * from user where username like "%"#{v}"%" ------>方法2
    </select>

測試程序

    @Test
    public void mybatisTest2() throws IOException {
        // 加載核心配置文件
        String resource = "sqlMapConfig.xml";
        InputStream in = Resources.getResourceAsStream(resource);

        // 創建sqlsessionfactory
        SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder()
                .build(in);
        // 創建sqlsession
        SqlSession sqlSession = sqlSessionFactory.openSession();

        // 執行sql語句
        List<User> user = sqlSession.selectList("usertest.findUserByUsername",
                "wu");

        System.out.println(user.toString());
    }

測試結果:
技術分享圖片

小結

{}和${}

  • #{}表示一個占位符號,通過#{}可以實現preparedStatement向占位符中設置值,自動進行java類型和jdbc類型轉換。#{}可以有效防止sql註入。 #{}可以接收簡單類型值或pojo屬性值。 如果parameterType傳輸單個簡單類型值,#{}括號中可以是value或其它名稱。

  • ${}表示拼接sql串,通過${}可以將parameterType 傳入的內容拼接在sql中且不進行jdbc類型轉換, ${}可以接收簡單類型值或pojo屬性值,如果parameterType傳輸單個簡單類型值,${}括號中只能是value。

parameterType和resultType

  • parameterType:指定輸入參數類型,mybatis通過ognl從輸入對象中獲取參數值拼接在sql中。
  • resultType:指定輸出結果類型,mybatis將sql查詢結果的一行記錄數據映射為resultType指定類型的對象。如果有多條數據,則分別進行映射,並把對象放到容器List中

selectOne和selectList

  • selectOne查詢一條記錄,如果使用selectOne查詢多條記錄則拋出異常:
    org.apache.ibatis.exceptions.TooManyResultsException: Expected one result (or null) to be returned by selectOne(), but found: 3
    at org.apache.ibatis.session.defaults.DefaultSqlSession.selectOne(DefaultSqlSession.java:70)
  • selectList可以查詢一條或多條記錄

  • 實現添加用戶

使用的sql:

INSERT INTO `user` (username,birthday,sex,address) VALUES 
(‘hz‘,‘2016-07-26‘,‘1‘,‘sg‘)

映射文件:
在User.xml配置文件中添加如下內容:

 <insert id="insertUser" parameterType="com.mybatis.pojo.User">
    <!-- mysql 先保存數據再生成id -->
        <selectKey keyProperty="id" resultType="Integer" order="AFTER">
            <!-- mysql提供的LAST_INSERT_ID()函數-->
            select LAST_INSERT_ID()
        </selectKey>
        insert into user (username,address,sex) values(#{username},#{address},#{sex})
    </insert>

測試程序:

Mybatis入門(1)