Mybatis之增刪改查操作

準(zhǔn)備工作

建立整體項(xiàng)目目錄

新建一個(gè)java工程，創(chuàng)建如下工程目錄

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

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

一、建立POJO類和對應(yīng)的數(shù)據(jù)表

1、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 + "]";

}

}

2、數(shù)據(jù)表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

之后向其中添加一些記錄，這里略過這一步。結(jié)果如圖：

二、設(shè)置Mybatis的配置文件

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

1、創(chuàng)建一個(gè)名為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默認(rèn)使用log4j作為輸出日志信息，注意在開發(fā)環(huán)境下，需要把log4j.rootLogger設(shè)為DEBUG。

2、創(chuàng)建一個(gè)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

3、創(chuàng)建一個(gè)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>

?

?

<!-- 全局配置參數(shù)，需要時(shí)再設(shè)置 -->

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

?

?

<!-- 別名定義 -->

<typeAliases>

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

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

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

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

</typeAliases>

?

?

<!-- 和spring整合后 environments配置可以廢除 -->

<environments default="development">

<environment id="development">

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

<transactionManager type="JDBC" />

<!-- 數(shù)據(jù)庫連接池，由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方法一次加載一個(gè)映射文件 -->

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

?

?

<!-- 通過mapper接口加載單個(gè) 映射文件 遵循一些規(guī)范：需要將mapper接口類名和mapper.xml映射文件名稱保持一致，且在一個(gè)目錄?

中 上邊規(guī)范的前提是：使用的是mapper代理方法 -->

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

?

?

<!-- 批量加載mapper 指定mapper接口的包名，mybatis自動(dòng)掃描包下邊所有mapper接口進(jìn)行加載 遵循一些規(guī)范：需要將mapper接口類名和mapper.xml映射文件名稱保持一致，且在一個(gè)目錄?

中 上邊規(guī)范的前提是：使用的是mapper代理方法 -->

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

</configuration>

4、創(chuàng)建pojo類對應(yīng)的映射文件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進(jìn)行分類化管理，理解sql隔離 注意：使用mapper代理方法開發(fā)，namespace有特殊重要的作用 -->

<mapper namespace="UserMapper">

<!-- 在 映射文件中可以配置很多sql語句 -->

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

<!-- 通過 select標(biāo)簽執(zhí)行數(shù)據(jù)庫查詢?

id：標(biāo)識映射文件中的 sql語句， 將sql語句封裝到mappedStatement對象中，所以將id稱為statement的id。

parameterType：指定輸入 參數(shù)的類型，這里指定int型 。#{}表示一個(gè)占位符號 #{id}：其中的id表示接收輸入的參數(shù)，參數(shù)類型就是int型，名稱為id。

如果輸入 參數(shù)是簡單類型，#{}中的參數(shù)名可以任意，可以value或其它名稱。

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

這里取值為user，是因?yàn)樵谂渲梦募袉?dòng)了自動(dòng)別名方式。也可以使用指定全類名的方式。?

-->

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

select * from user where id = #{id}

</select>

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

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

${}:表示拼接sql串，將接收到參數(shù)的內(nèi)容不加任何修飾拼接在sql中。使用${}拼接sql，引起 sql注入

${value}：接收輸入?yún)?shù)的內(nèi)容，如果傳入類型是簡單類型，${}中只能使用value這個(gè)名字。

-->

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

resultType="user">

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

</select>

<!-- 添加用戶?

parameterType：指定輸入?yún)?shù)類型是pojo（包括 用戶信息）

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

-->

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

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

select LAST_INSERT_ID()

</selectKey>

<!--?

將插入數(shù)據(jù)的主鍵返回，返回到user對象中。

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

keyProperty：將查詢到主鍵值設(shè)置到parameterType指定的對象的哪個(gè)屬性。

order：SELECT LAST_INSERT_ID()執(zhí)行順序，相對于insert語句來說它的執(zhí)行順序。

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

-->

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

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

<!--?

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

執(zhí)行過程：

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

其次在insert執(zhí)行時(shí)，從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>

? ? <!-- 刪除 用戶根據(jù)id刪除用戶，需要輸入 id-->

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

delete from user where id=#{id}

</delete>

<!-- 根據(jù)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>

5、編寫測試類

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 {

// 會(huì)話工廠

private SqlSessionFactory sqlSessionFactory;

?

?

@Before

public void createSqlSessionFactory() throws IOException {

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

String resource = "SqlMapConfig.xml";

// 得到配置文件流

InputStream inputStream = Resources.getResourceAsStream(resource);

?

?

// 創(chuàng)建會(huì)話工廠，傳入mybatis的配置文件信息

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

?

?

}

?

?

// 根據(jù) id查詢用戶信息

@Test

public void testFindUserById() {

// 數(shù)據(jù)庫會(huì)話實(shí)例

SqlSession sqlSession = null;

try {

// 創(chuàng)建數(shù)據(jù)庫會(huì)話實(shí)例sqlSession

sqlSession = sqlSessionFactory.openSession();

// 通過SqlSession操作數(shù)據(jù)庫

// 第一個(gè)參數(shù)：映射文件中statement的id，等于=namespace+"."+statement的id。這里的namesapce是UserMapper。

// 第二個(gè)參數(shù)：指定和映射文件中所匹配的parameterType類型的參數(shù)。

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

// 查詢單個(gè)記錄，根據(jù)用戶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("-------執(zhí)行完畢----------");

?

?

}

?

?

// 根據(jù)用戶名稱模糊查詢用戶信息

@Test

public void testFindUserByUsername() {

// 數(shù)據(jù)庫會(huì)話實(shí)例

SqlSession sqlSession = null;

try {

// 創(chuàng)建數(shù)據(jù)庫會(huì)話實(shí)例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("-------執(zhí)行完畢----------");

}

?

?

// 添加用戶信息

@Test

public void testInsert() {

// 數(shù)據(jù)庫會(huì)話實(shí)例

SqlSession sqlSession = null;

try {

// 創(chuàng)建數(shù)據(jù)庫會(huì)話實(shí)例sqlSession

sqlSession = sqlSessionFactory.openSession();

// 添加用戶信息

User user = new User();

user.setUsername("馬云");

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

user.setSex("1");

user.setBirthday(new Date());

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

// 提交事務(wù)

sqlSession.commit();

} catch (Exception e) {

e.printStackTrace();

} finally {

if (sqlSession != null) {

sqlSession.close();

}

}

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

}

?

?

// 根據(jù)id刪除用戶

@Test

public void testDelete() {

// 數(shù)據(jù)庫會(huì)話實(shí)例

SqlSession sqlSession = null;

try {

// 創(chuàng)建數(shù)據(jù)庫會(huì)話實(shí)例sqlSession

sqlSession = sqlSessionFactory.openSession();

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

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

// 提交事務(wù)

sqlSession.commit();

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

} catch (Exception e) {

e.printStackTrace();

} finally {

if (sqlSession != null) {

sqlSession.close();

}

}

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

}

?

?

// 更新用戶信息

@Test

public void testUpdate() {

// 數(shù)據(jù)庫會(huì)話實(shí)例

SqlSession sqlSession = null;

try {

// 創(chuàng)建數(shù)據(jù)庫會(huì)話實(shí)例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);

// 提交事務(wù)

sqlSession.commit();

?

?

} catch (Exception e) {

e.printStackTrace();

} finally {

if (sqlSession != null) {

sqlSession.close();

}

}

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

}

?

?

}

6、單元測試

1、按照用戶id查詢

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

2、模糊查詢

查詢名字含有“張”的用戶信息

3、添加用戶信息

用戶表

4、根據(jù)用戶id從數(shù)據(jù)庫中刪除。

刪除id為26的用戶

用戶表

5、更新用戶信息

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

用戶表