Mybatis基于傳統dao層的開發（完整代碼演示）
- 專案結構
- 持久層 Dao 介面
- 持久層 Dao 實作類
- 持久層映射配置
- 測驗類
專案結構
持久層 Dao 介面
IUserDao：
package com.keafmd.dao;
import com.keafmd.domain.User;
import java.util.List;
/**
* Keafmd
*
* @ClassName: IUserDao
* @Description: 用戶的持久層介面
* @author: 牛哄哄的柯南
* @date: 2021-02-06 19:29
*/
public interface IUserDao {
/**
* 查詢所有操作
* @return
*/
List<User> findAll();
/**
* 保存用戶
* @param user
*/
void saveUser(User user);
/**
* 更新用戶
* @param user
*/
void updateUser(User user);
/**
* 根據id洗掉用戶
* @param id
*/
void deleteUser(Integer id);
/**
* 根據id查新用戶資訊
* @param id
* @return
*/
User findById(Integer id);
/**
* 根據名稱模糊查詢
* @param username
* @return
*/
List<User> findByName(String username);
/**
* 查詢總用戶數
* @return
*/
int findTotal();
}
持久層 Dao 實作類
UserDaoImpl：
package com.keafmd.dao.impl;
import com.keafmd.dao.IUserDao;
import com.keafmd.domain.User;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import java.util.List;
/**
* Keafmd
*
* @ClassName: UserDaoImpl
* @Description:
* @author: 牛哄哄的柯南
* @date: 2021-02-09 11:09
*/
public class UserDaoImpl implements IUserDao {
private SqlSessionFactory factory;
public UserDaoImpl(SqlSessionFactory factory){
this.factory=factory;
}
public List<User> findAll() {
//1.根據factory獲取SQLSession物件
SqlSession session = factory.openSession();
//2.呼叫SqlSession中的方法，實作查詢串列
List<User> users = session.selectList("com.keafmd.dao.IUserDao.findAll");//引數為能獲取配置資訊的key
//3.釋放資源
session.close();
return users;
}
public void saveUser(User user) {
//1.根據factory獲取SQLSession物件
SqlSession session = factory.openSession();
//2.呼叫SqlSession中的方法，實作保存
session.insert("com.keafmd.dao.IUserDao.saveUser",user);
//3.提交事務
session.commit();
//釋放資源
session.close();
}
public void updateUser(User user) {
//1.根據factory獲取SQLSession物件
SqlSession session = factory.openSession();
//2.呼叫SqlSession中的方法，實作更新
session.update("com.keafmd.dao.IUserDao.updateUser",user);
//3.提交事務
session.commit();
//釋放資源
session.close();
}
public void deleteUser(Integer id) {
//1.根據factory獲取SQLSession物件
SqlSession session = factory.openSession();
//2.呼叫SqlSession中的方法，實作更新
session.update("com.keafmd.dao.IUserDao.deleteUser",id);
//3.提交事務
session.commit();
//釋放資源
session.close();
}
public User findById(Integer id) {
//1.根據factory獲取SQLSession物件
SqlSession session = factory.openSession();
//2.呼叫SqlSession中的方法，實作查詢一個
User user = session.selectOne("com.keafmd.dao.IUserDao.findById",id);//引數為能獲取配置資訊的key
//3.釋放資源
session.close();
return user;
}
public List<User> findByName(String username) {
//1.根據factory獲取SQLSession物件
SqlSession session = factory.openSession();
//2.呼叫SqlSession中的方法，實作查詢串列
List<User> users = session.selectList("com.keafmd.dao.IUserDao.findByName",username);//引數為能獲取配置資訊的key
//3.釋放資源
session.close();
return users;
}
public int findTotal() {
//1.根據factory獲取SQLSession物件
SqlSession session = factory.openSession();
return session.selectOne("com.keafmd.dao.IUserDao.findTotal");
}
}
持久層映射配置
IUserDao.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">
<mapper namespace="com.keafmd.dao.IUserDao">
<!--配置查詢所有-->
<!--id為方法名稱-->
<select id="findAll" resultType="com.keafmd.domain.User">
select * from user
</select>
<!--保存用戶-->
<insert id="saveUser" parameterType="com.keafmd.domain.User">
<!--配置插入操作后，獲取插入的id-->
<selectKey keyProperty="id" keyColumn="id" resultType="int" order="AFTER">
select last_insert_id();
</selectKey>
insert into user(username,address,sex,birthday)values(#{username},#{address},#{sex},#{birthday});
</insert>
<!--更新用戶-->
<update id="updateUser" parameterType="com.keafmd.domain.User">
update user set username=#{username},address=#{address},sex=#{sex},birthday=#{birthday} where id=#{id}
</update>
<!--洗掉用戶-->
<!--#{id}這里面寫個占位符就行-->
<delete id="deleteUser" parameterType="Integer">
delete from user where id = #{uid}
</delete>
<!--根據id查詢用戶-->
<select id="findById" parameterType="Integer" resultType="com.keafmd.domain.User">
select * from user where id = #{id}
</select>
<!--根據名稱模糊查詢-->
<select id="findByName" parameterType="String" resultType="com.keafmd.domain.User">
<!--select * from user where username like #{name}-->
<!--value是固定的，原始碼寫固定了，這種了解即可，不推薦-->
select * from user where username like '%${value}%'
</select>
<!--查詢總用戶數-->
<select id="findTotal" resultType="int">
select count(id) from user;
</select>
</mapper>
測驗類
MybatisTest：
package com.keafmd.test;
import com.keafmd.dao.IUserDao;
import com.keafmd.dao.impl.UserDaoImpl;
import com.keafmd.domain.User;
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.After;
import org.junit.Before;
import org.junit.Test;
import java.io.InputStream;
import java.util.Date;
import java.util.List;
/**
* Keafmd
*
* @ClassName: MybatisTest
* @Description: 測驗類，測驗crud操作
* @author: 牛哄哄的柯南
* @date: 2021-02-08 15:24
*/
public class MybatisTest {
private InputStream in;
private IUserDao userDao;
@Before // 用于在測驗方法執行前執行
public void init()throws Exception{
//1.讀取組態檔,生成位元組輸入流
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創建SqlSessionFactory工廠
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
SqlSessionFactory factory = builder.build(in);
//3.使用工廠物件創建dao物件
userDao = new UserDaoImpl(factory);
}
@After // 用于在測驗方法執行后執行
public void destory() throws Exception{
//6.釋放資源
in.close();
}
/**
* 查詢所有
* @throws Exception
*/
@Test
public void testFindAll() throws Exception {
//5.使用代理物件執行方法
List<User> users = userDao.findAll();
for (User user : users) {
System.out.println(user);
}
}
/**
* 測驗保存操作
*/
@Test
public void testSave() throws Exception {
User user = new User();
user.setUsername("Keafmd DAO");
user.setSex("男");
user.setBirthday(new Date());
user.setAddress("XXXXXXX");
System.out.println("保存操作前："+user);
//5.執行保存方法
userDao.saveUser(user);
System.out.println("保存操作后："+user);
}
/**
* 測驗更新
* @throws Exception
*/
@Test
public void testUpdate() throws Exception {
User user = new User();
user.setId(51);
user.setUsername("update DAO");
user.setSex("男");
user.setBirthday(new Date());
user.setAddress("XXXXXXX");
//5.執行更新方法
userDao.updateUser(user);
}
/**
* 測驗洗掉
* @throws Exception
*/
@Test
public void testDelete() throws Exception {
//5.執行洗掉方法
userDao.deleteUser(46);
}
/**
* 查詢一個
* @throws Exception
*/
@Test
public void testFindOne() throws Exception {
//5.執行查詢一個方法
User user = userDao.findById(50);
System.out.println(user);
}
/**
* 根據username模糊查詢
* @throws Exception
*/
@Test
public void testFindByName() throws Exception {
//5.執行模糊查詢方法
List<User> users = userDao.findByName("%王%");
for (User user : users) {
System.out.println(user);
}
}
/**
* 查詢記錄總條數
* @throws Exception
*/
@Test
public void testFindTiotal() throws Exception {
//5.執行記錄總條數
int total = userDao.findTotal();
System.out.println(total);
}
}
以上就是Mybatis基于傳統dao層的開發（完整代碼演示）的全部內容，
看完如果對你有幫助，感謝點贊支持！
如果你是電腦端的話，看到右下角的 “一鍵三連” 了嗎，沒錯點它[哈哈]
加油！
共同努力！
Keafmd
轉載請註明出處，本文鏈接：https://www.uj5u.com/ruanti/258471.html
標籤：其他
上一篇：淺談結構體傳參時的傳值與傳址