Mybatis之增刪改查操做

準備工做

創建總體項目目錄

新建一個java工程，建立以下工程目錄

其中com.kang.pojo中存放pojo類，com.kang.test中存放測試類。

源碼目錄config中存放Mybatis的相關配置文件，map包下存放映射xml文件。

1、創建POJO類和對應的數據表

一、POJO類User.java

package com.kang.pojo;

 

 

import java.util.Date;

 

 

public class User {

private int id;

private String username;// 用戶姓名

private String sex;// 性別

private Date birthday;// 生日

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 String getSex() {

return sex;

}

public void setSex(String sex) {

this.sex = sex;

}

public Date getBirthday() {

return birthday;

}

public void setBirthday(Date birthday) {

this.birthday = birthday;

}

public String getAddress() {

return address;

}

public void setAddress(String address) {

this.address = address;

}

@Override

public String toString() {

return "User [id=" + id + ", username=" + username + ", sex=" + sex + ", birthday=" + birthday + ", address="

+ address + "]";

}

}

二、數據表user

CREATE TABLE `user` (

  `id` int(11) NOT NULL AUTO_INCREMENT,

  `username` varchar(32) NOT NULL COMMENT '用戶名稱',

  `birthday` date DEFAULT NULL COMMENT '生日',

  `sex` char(1) DEFAULT NULL COMMENT '性別',

  `address` varchar(256) DEFAULT NULL COMMENT '地址',

  PRIMARY KEY (`id`)

) ENGINE=InnoDB AUTO_INCREMENT=29 DEFAULT CHARSET=utf8

以後向其中添加一些記錄，這裏略過這一步。結果如圖：

2、設置Mybatis的配置文件

首先新建一個源碼目錄（source folder）config，專門來存放配置文件。在該目錄下新建一個包：map，用來存放相應的映射xml文件。

一、建立一個名爲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做爲輸出日誌信息，注意在開發環境下，須要把log4j.rootLogger設爲DEBUG。

二、建立一個db.properties的屬性文件，用來配置jdbc鏈接mysql的信息。

jdbc.driver=com.mysql.jdbc.Driver

jdbc.url=jdbc:mysql://192.168.1.148:3306/mybatis?characterEncoding=utf-8

jdbc.username=root

jdbc.password=root

三、建立一個SqlMapConfig.xml，用來配置Mybatis的基本信息。

<?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>

 

 

<!-- 加載屬性文件 -->

<properties resource="db.properties">

<!--properties中還能夠配置一些屬性名和屬性值 -->

<!-- <property name="jdbc.driver" value=""/> -->

</properties>

 

 

<!-- 全局配置參數，須要時再設置 -->

<!-- <settings> </settings> -->

 

 

<!-- 別名定義 -->

<typeAliases>

<!-- 針對單個別名定義 type：類型的路徑 alias：別名 -->

<!-- <typeAlias type="cn.itcast.mybatis.po.User" alias="user"/> -->

<!-- 批量別名定義 指定包名，mybatis自動掃描包中的po類，自動定義別名，別名就是類名（首字母大寫或小寫均可以） -->

<package name="com.kang.pojo" />

</typeAliases>

 

 

<!-- 和spring整合後 environments配置能夠廢除 -->

<environments default="development">

<environment id="development">

<!-- 使用jdbc事務管理，事務控制由mybatis -->

<transactionManager type="JDBC" />

<!-- 數據庫鏈接池，由mybatis管理 -->

<dataSource type="POOLED">

<property name="driver" value="${jdbc.driver}" />

<property name="url" value="${jdbc.url}" />

<property name="username" value="${jdbc.username}" />

<property name="password" value="${jdbc.password}" />

</dataSource>

</environment>

</environments>

 

 

<!-- 加載 映射文件 -->

<mappers>

<mapper resource="map/UserMapper.xml" />

</mappers>

<!--經過resource方法一次加載一個映射文件 -->

<!-- <mapper resource="map/UserMapper.xml"/> -->

 

 

<!-- 經過mapper接口加載單個 映射文件 遵循一些規範：須要將mapper接口類名和mapper.xml映射文件名稱保持一致，且在一個目錄 

中 上邊規範的前提是：使用的是mapper代理方法 -->

<!-- <mapper class="com.kang.mapper.UserMapper"/> -->

 

 

<!-- 批量加載mapper 指定mapper接口的包名，mybatis自動掃描包下邊全部mapper接口進行加載 遵循一些規範：須要將mapper接口類名和mapper.xml映射文件名稱保持一致，且在一個目錄 

中 上邊規範的前提是：使用的是mapper代理方法 -->

<!-- <package name="com.kang.mapper" /> -->

</configuration>

四、建立pojo類對應的映射文件UserMapper.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進行分類化管理，理解sql隔離 注意：使用mapper代理方法開發，namespace有特殊重要的做用 -->

<mapper namespace="UserMapper">

<!-- 在 映射文件中能夠配置不少sql語句 -->

<!-- 經過id查詢用戶表的記錄 -->

<!-- 經過 select標籤執行數據庫查詢 

id：標識映射文件中的 sql語句， 將sql語句封裝到mappedStatement對象中，因此將id稱爲statement的id。

parameterType：指定輸入 參數的類型，這裏指定int型 。#{}表示一個佔位符號 #{id}：其中的id表示接收輸入的參數，參數類型就是int型，名稱爲id。

若是輸入 參數是簡單類型，#{}中的參數名能夠任意，能夠value或其它名稱。

resultType：指定sql輸出結果所映射的java對象類型，select指定的resultType表示將單條記錄映射成的java對象。

這裏取值爲user，是由於在配置文件中啓動了自動別名方式。也可使用指定全類名的方式。 

-->

<select id="findUserById" parameterType="int" resultType="user">

select * from user where id = #{id}

</select>

<!-- 根據用戶名稱模糊查詢用戶信息，可能返回多條記錄。

resultType：指定就是單條記錄所映射的java對象類型。

${}:表示拼接sql串，將接收到參數的內容不加任何修飾拼接在sql中。使用${}拼接sql，引發 sql注入

${value}：接收輸入參數的內容，若是傳入類型是簡單類型，${}中只能使用value這個名字。

-->

<select id="findUserByUsername" parameterType="java.lang.String"

resultType="user">

select * from user where username like '%${value}%'

</select>

<!-- 添加用戶 

parameterType：指定輸入參數類型是pojo（包括 用戶信息）

#{}中指定pojo的屬性名，接收到pojo對象的屬性值，mybatis經過OGNL獲取對象的屬性值。

-->

<insert id="insertUser" parameterType="user">

<selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">

select LAST_INSERT_ID()

</selectKey>

<!-- 

將插入數據的主鍵返回，返回到user對象中。

SELECT LAST_INSERT_ID()：獲得剛insert進去記錄的主鍵值，只適用與自增主鍵。

keyProperty：將查詢到主鍵值設置到parameterType指定的對象的哪一個屬性。

order：SELECT LAST_INSERT_ID()執行順序，相對於insert語句來講它的執行順序。

resultType：指定SELECT LAST_INSERT_ID()的結果類型

-->

insert into user(username,birthday,sex,address)

values(#{username},#{birthday},#{sex},#{address})

<!-- 

使用mysql的uuid（）生成主鍵。

執行過程：

首先經過uuid()獲得主鍵，將主鍵設置到user對象的id屬性中。

其次在insert執行時，從user對象中取出id屬性值。

-->

<!--  

<selectKey keyProperty="id" order="BEFORE" resultType="java.lang.String">

SELECT uuid()

</selectKey>

insert into user(id,username,birthday,sex,address) value(#{id},#{username},#{birthday},#{sex},#{address}) -->

</insert>

    <!-- 刪除 用戶根據id刪除用戶，須要輸入 id-->

<delete id="deleteUserById" parameterType="int">

delete from user where id=#{id}

</delete>

<!-- 根據id更新用戶

須要傳入用戶的id。

須要傳入用戶的更新信息。

parameterType指定user對象，包括 id和更新信息，注意：id必須存在。

#{id}：從輸入 user對象中獲取id屬性值。

-->

<update id="updateUser" parameterType="user">

update user set

username=#{username},birthday=#{birthday},sex=#{sex},address=#{address}

where id=#{id}

</update>

 

 

</mapper>

五、編寫測試類

package com.kang.test;

 

 

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.kang.pojo.User;

 

 

public class MyTest {

// 會話工廠

private SqlSessionFactory sqlSessionFactory;

 

 

@Before

public void createSqlSessionFactory() throws IOException {

// 配置文件SqlMapConfig.xml在類路徑下

String resource = "SqlMapConfig.xml";

// 獲得配置文件流

InputStream inputStream = Resources.getResourceAsStream(resource);

 

 

// 建立會話工廠，傳入mybatis的配置文件信息

sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);

 

 

}

 

 

// 根據 id查詢用戶信息

@Test

public void testFindUserById() {

// 數據庫會話實例

SqlSession sqlSession = null;

try {

// 建立數據庫會話實例sqlSession

sqlSession = sqlSessionFactory.openSession();

// 經過SqlSession操做數據庫

// 第一個參數：映射文件中statement的id，等於=namespace+"."+statement的id。這裏的namesapce是UserMapper。

// 第二個參數：指定和映射文件中所匹配的parameterType類型的參數。

// sqlSession.selectOne的結果是與映射文件中所匹配的resultType類型的對象。

// 查詢單個記錄，根據用戶id查詢用戶信息

User user = sqlSession.selectOne("UserMapper.findUserById", 10);

// 輸出用戶信息，注意重寫了user的toString方法。

System.out.println(user);

} catch (Exception e) {

e.printStackTrace();

} finally {

if (sqlSession != null) {

sqlSession.close();// 釋放資源

}

}

System.out.println("-------執行完畢----------");

 

 

}

 

 

// 根據用戶名稱模糊查詢用戶信息

@Test

public void testFindUserByUsername() {

// 數據庫會話實例

SqlSession sqlSession = null;

try {

// 建立數據庫會話實例sqlSession

sqlSession = sqlSessionFactory.openSession();

// list中的user和映射文件中resultType所指定的類型一致。

List<User> list = sqlSession.selectList("UserMapper.findUserByUsername", "張");

System.out.println(list.size());

} catch (Exception e) {

e.printStackTrace();

} finally {

if (sqlSession != null) {

sqlSession.close();

}

}

System.out.println("-------執行完畢----------");

}

 

 

// 添加用戶信息

@Test

public void testInsert() {

// 數據庫會話實例

SqlSession sqlSession = null;

try {

// 建立數據庫會話實例sqlSession

sqlSession = sqlSessionFactory.openSession();

// 添加用戶信息

User user = new User();

user.setUsername("馬雲");

user.setAddress("浙江杭州");

user.setSex("1");

user.setBirthday(new Date());

sqlSession.insert("UserMapper.insertUser", user);

// 提交事務

sqlSession.commit();

} catch (Exception e) {

e.printStackTrace();

} finally {

if (sqlSession != null) {

sqlSession.close();

}

}

System.out.println("-------執行完畢----------");

}

 

 

// 根據id刪除用戶

@Test

public void testDelete() {

// 數據庫會話實例

SqlSession sqlSession = null;

try {

// 建立數據庫會話實例sqlSession

sqlSession = sqlSessionFactory.openSession();

// 刪除用戶，指定了用戶id

sqlSession.delete("UserMapper.deleteUserById", 29);

// 提交事務

sqlSession.commit();

System.out.println("--------------------------------");

} catch (Exception e) {

e.printStackTrace();

} finally {

if (sqlSession != null) {

sqlSession.close();

}

}

System.out.println("-------執行完畢----------");

}

 

 

// 更新用戶信息

@Test

public void testUpdate() {

// 數據庫會話實例

SqlSession sqlSession = null;

try {

// 建立數據庫會話實例sqlSession

sqlSession = sqlSessionFactory.openSession();

// 添加用戶信息

User user = new User();

user.setId(16);

user.setUsername("張×××");

user.setAddress("河南洛陽");

user.setSex("1");

user.setBirthday(new Date());

sqlSession.update("UserMapper.updateUser", user);

// 提交事務

sqlSession.commit();

 

 

} catch (Exception e) {

e.printStackTrace();

} finally {

if (sqlSession != null) {

sqlSession.close();

}

}

System.out.println("-------執行完畢----------");

}

 

 

}

六、單元測試

一、按照用戶id查詢

查詢用戶id爲10 的用戶信息

二、模糊查詢

查詢名字含有「張」的用戶信息

三、添加用戶信息

用戶表

四、根據用戶id從數據庫中刪除。

刪除id爲26的用戶

用戶表

五、更新用戶信息

將id爲16的用戶的地址改成北京。

用戶表