使用mybatis開發原始Dao層

来源:https://www.cnblogs.com/xyfer1018/archive/2018/12/13/10111817.html
-Advertisement-
Play Games

本文將介紹使用框架mybatis開發原始Dao層來對一個對資料庫進行增刪改查的案例。 本次使用的mybatis版本為mybatis-3.2.7，開發工具為eclipse，資料庫為mysql，jdk版本jdk1.8.0_151。 1、首先，使用eclipse新建一個java工程，在lib目錄下加入my ...


　　本文將介紹使用框架mybatis開發原始Dao層來對一個對資料庫進行增刪改查的案例。

　　Mapper動態代理開發Dao層請閱讀我的下一篇博客：MyBatis開發Dao層的兩種方式（Mapper動態代理方式）

　　本次使用的mybatis版本為mybatis-3.2.7，開發工具為eclipse，資料庫為mysql，jdk版本jdk1.8.0_151。

　　1、首先，使用eclipse新建一個java工程，在lib目錄下加入mybatis核心包、依賴包、數據驅動包，然後BuildPath一下。。

　　

　　2、添加日誌文件，在classpath下創建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

　　3、在classpath下創建config資源文件夾，併在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>
    <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://localhost:3306/mybatis?characterEncoding=utf-8" />
                <property name="username" value="root" />
                <property name="password" value="root" />
            </dataSource>
        </environment>
    </environments>
</configuration>

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

　　4、創建數據封裝使用的User類

package com.xyfer.po;

import java.util.Date;
/**
 * 
 * @author xyfer
 * 數據封裝使用的User類
 *
 */
public class User {
    
    private int       id;          //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;
    }

}

　　5、在classpath下的資源文件夾sqlmapper目錄下創建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">
<mapper namespace="test">
    <!-- 根據id查詢用戶 -->
    <select id="findUserById" parameterType="int" resultType="com.xyfer.po.User">
        select * from user where id = #{id}
    </select>
    <!-- 添加用戶 -->
    <insert id="insertUser" parameterType="com.xyfer.po.User">
    <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
        select LAST_INSERT_ID() 
    </selectKey>
      insert into user(username,birthday,sex,address) 
      values(#{username},#{birthday},#{sex},#{address})
    </insert>
    <!-- 修改用戶 -->
    <update id="updateUser" parameterType="com.xyfer.po.User">
        update user set username=#{username},birthday=#{birthday},sex=#{sex},address=#{address}
        where id=#{id}
    </update>
    <!-- 刪除用戶 -->
    <delete id="deleteUserById" parameterType="int">
        delete from user where id=#{id}
    </delete>
    
</mapper>

　　6、mybatis框架需要載入映射文件，將Users.xml添加在SqlMapConfig.xml，如下：

<mappers>
        <mapper resource="User.xml"/>
</mappers>

　　7、dao層介面

package com.xyfer.dao;

import com.xyfer.po.User;

public interface UserDao {

    public User getUserById(int id);   //根據id值查詢一個用戶
    public void insertUser(User user); //新增一個用戶
    public void updateUser(User user); //修改一個用戶
    public void deleteUser(int id);    //刪除一個用戶
    
}

　　dao層介面實現類

package com.xyfer.dao.impl;

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;

import com.xyfer.dao.UserDao;
import com.xyfer.po.User;

public class UserDaoImpl implements UserDao {
    //註入SqlSessionFactory
    public UserDaoImpl(SqlSessionFactory sqlSessionFactory){
            this.setSqlSessionFactory(sqlSessionFactory);
        }
            
    private SqlSessionFactory sqlSessionFactory;
        
    public SqlSessionFactory getSqlSessionFactory() {
        return sqlSessionFactory;
    }

    public void setSqlSessionFactory(SqlSessionFactory sqlSessionFactory) {
        this.sqlSessionFactory = sqlSessionFactory;
    }

    @Override
    public User getUserById(int id) {
        SqlSession session = sqlSessionFactory.openSession();
        User user = null;
        try {
            //通過sqlsession調用selectOne方法獲取一條結果集
            //參數1：指定定義的statement的id,參數2：指定向statement中傳遞的參數
            user = session.selectOne("test.findUserById", 1);
            System.out.println(user);
                        
        } finally{
            session.close();
        }
        return user;
    }

    @Override
    public void insertUser(User user) {
        SqlSession sqlSession = sqlSessionFactory.openSession();
        try {
            sqlSession.insert("test.insertUser", user);
            sqlSession.commit();
        } finally{
            sqlSession.close();
        }
    }

    @Override
    public void updateUser(User user) {
        SqlSession sqlSession = sqlSessionFactory.openSession();
        try {
            sqlSession.update("test.updateUser", user);
            sqlSession.commit();
        } finally{
            sqlSession.close();
        }
    }

    @Override
    public void deleteUser(int id) {
        SqlSession sqlSession = sqlSessionFactory.openSession();
        try {
            sqlSession.update("test.deleteUserById", id);
            sqlSession.commit();
        } finally{
            sqlSession.close();
        }
    }

}

　　8、創建一個JUnit的測試類，對UserDao進行測試。

package com.xyfer.dao.impl;

import static org.junit.Assert.*;

import java.io.InputStream;
import java.util.Date;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import org.junit.Before;
import org.junit.Test;

import com.xyfer.dao.UserDao;
import com.xyfer.po.User;

public class UserDaoImplTest {

    private SqlSessionFactory sqlSessionFactory;
    
    @Before
    public void init() throws Exception {
        SqlSessionFactoryBuilder sessionFactoryBuilder = new SqlSessionFactoryBuilder();
        InputStream inputStream = Resources.getResourceAsStream("SqlMapConfig.xml");
        sqlSessionFactory = sessionFactoryBuilder.build(inputStream);
    }

    @Test
    public void testGetUserById() {
        UserDao userDao = new UserDaoImpl(sqlSessionFactory);
        User user = userDao.getUserById(22);
        System.out.println(user);
    }

    @Test
    public void testInsertUser() {
        User user = new User();
        user.setUsername("小李");
        user.setSex("男");
        user.setBirthday(new Date());
        user.setAddress("杭州市");
        UserDao userDao = new UserDaoImpl(sqlSessionFactory);
        userDao.insertUser(user);
    }

    @Test
    public void testUpdateUser() {
        User user = new User();
        user.setId(10);
        user.setUsername("小威");
        user.setSex("男");
        user.setBirthday(new Date());
        user.setAddress("杭州市");
        UserDao userDao = new UserDaoImpl(sqlSessionFactory);
        userDao.updateUser(user);
    }

    @Test
    public void testDeleteUser() {
        UserDao userDao = new UserDaoImpl(sqlSessionFactory);
        userDao.deleteUser(10);
    }

}

　　以上步驟，完成使用mybatis框架開發原始dao層，並對資料庫進行增刪改查操作。

　　需要註意的是，上文提到的config文件夾和sqlmapper文件夾均為資源文件夾（source folder），預設會載入該路徑下的文件。

　　

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 如何學好面向對象？
    如何學好面向對象？ 面向對象雖然只有三個特性，封裝、繼承、多態，但是真正面向對象卻是說的容易做起來困難。但是，還是有一定的規則可尋的， 要學好面向對象，必須掌握設計模式 。 什麼是設計模式？ 設計模式（Design pattern）：是一套被反覆使用、多數人知曉的、經過分類編目的、代碼設計經驗的總結 ...
  • Java中的數據驗證
    本文介紹了Java驗證的幾種機制，包括JPA驗證，Bean驗證，實體監聽器和事務監聽器。通過介紹希望可以在Java項目整體的驗證方面提供一些參考。 ...
  • 解釋器模式 Interpreter 行為型 設計模式（十九）
    解釋器模式是一種不很常用的模式，但是比如正則表達式就是一種解釋器模式的思維，所以儘管實際編碼中不常用，理解解釋器模式的含義很重要，本文對解釋器模式進行了簡單的介紹，並且給出了Java代碼示例，介紹瞭解釋器模式的意圖結構。 ...
  • 領域驅動設計理解&總結
    領域驅動設計理解&總結 這篇文章主要是通讀《實現領域驅動設計》之後自己的理解和總結（同時也參照一些博文的分析來加深自己的理解）； 有些疑問是自定義內容，雖然有自己的理解，但依然感覺較為抽象，後續會通過實踐來理解其中的精妙之處。 ...
  • 雜談篇之我是怎麼讀源碼的，授之以漁
    前言 開心一刻 今天上課不小心睡著了，結果被老師叫起來回答問題，這是背景。無奈之下看向同桌尋求幫助，同桌小聲說到選C，結果周圍的人都說選C，向同桌投去一個感激的眼神後大聲說道選C。剛說完教室就笑開了，老師一臉恨鐵不成鋼的表情說選你個頭，我叫你翻譯文言文你選C！你出去，你給我出去。看著同桌擠眉弄眼的表 ...
  • scrapy入門
    什麼是scrapy？ scrapy是一個為了爬去網站數據，提取結構性數據而編寫的應用框架，我們只需要實現少量的代碼，就能夠快速的抓取 scrapy使用了 Twisted 非同步網路框架，可以加快我們的下載速度 非同步和非阻塞的區別 非同步：調用在發佈之後，這個調用就直接返回，不管有無結果 非阻塞：關註的是 ...
  • 過濾器模式（Filter Pattern）
    過濾器模式 一、什麼是過濾器模式   過濾器模式（Filter Pattern），這種模式允許開發人員使用不同的標準來過濾一組對象，通過邏輯運算以解耦的方式把它們連接起來。這種類型的設計模式屬於結構型模式，它結合多個標準來獲得單一標準。 二、具體實現 1、主要角色 過濾對象：需要 ...
  • matplotlib簡單示例
    一、簡介 以下引用自百度百科 Matplotlib 是一個 Python 的 2D繪圖庫，它以各種硬拷貝格式和跨平臺的互動式環境生成出版質量級別的圖形 。 通過 Matplotlib，開發者可以僅需要幾行代碼，便可以生成繪圖，直方圖，功率譜，條形圖，錯誤圖，散點圖等。 二、流程 1. 明確要研究的問 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類