溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
準備工作
建立整體項目目錄
新建一個java工程，創建如下工程目錄
其中com.kang.pojo中存放pojo類，com.kang.test中存放測試類。
源碼目錄config中存放Mybatis的相關配置文件，map包下存放映射xml文件。
一、建立POJO類和對應的數據表
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、數據表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
之后向其中添加一些記錄，這里略過這一步。結果如圖：
二、設置Mybatis的配置文件
首先新建一個源碼目錄（source folder）config，專門來存放配置文件。在該目錄下新建一個包：map，用來存放相應的映射xml文件。
1、創建一個名為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。
2、創建一個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、創建一個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>
4、創建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>
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 {
// 會話工廠
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("-------執行完畢----------");
}
?
?
}
6、單元測試
1、按照用戶id查詢
查詢用戶id為10 的用戶信息
2、模糊查詢
查詢名字含有“張”的用戶信息
3、添加用戶信息
用戶表
4、根據用戶id從數據庫中刪除。
刪除id為26的用戶
用戶表
5、更新用戶信息
將id為16的用戶的地址改為北京。
用戶表
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
