天天看點
傳回

Mybatis【5】-- Mybatis多種增删改查那些你會了麼？

前面我們學會了

Mybatis

如何配置資料庫以及建立

SqlSession

 ，那怎麼寫呢？crud怎麼寫？

代碼直接放在Github倉庫【https://github.com/Damaer/Mybatis-Learning/tree/master/mybatis-05-CURD 】

需要聲明的是：此

Mybatis

 學習筆記，是從原始的

Mybatis

 開始的，而不是整合了其他架構（比如

Spring

 ）之後，個人認為，這樣能對它的功能，它能幫我們做什麼，有更好的了解，後面再慢慢疊加其他的功能。

項目的目錄如下：

Mybatis【5】-- Mybatis多種增删改查那些你會了麼？

建立資料庫：初始化資料，SQL語句如下（也就是

resource

下的

test.sql

）

#建立資料庫
CREATE DATABASE `test` DEFAULT CHARACTER SET utf8 COLLATE utf8_general_ci;
#建立資料表
CREATE TABLE `student` ( `id` INT NOT NULL AUTO_INCREMENT , `name` VARCHAR(20) NOT NULL ,
`age` INT NOT NULL , `score` DOUBLE NOT NULL , PRIMARY KEY (`id`)) ENGINE = MyISAM;

使用

maven

管理項目，

pom.xml

檔案管理依賴

jar

包：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>

    <groupId>com.test</groupId>
    <artifactId>test</artifactId>
    <version>1.0-SNAPSHOT</version>
    <dependencies>
        <!-- mybatis核心包 -->
        <dependency>
            <groupId>org.mybatis</groupId>
            <artifactId>mybatis</artifactId>
            <version>3.3.0</version>
        </dependency>
        <!-- mysql驅動包 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.29</version>
        </dependency>
        <!-- junit測試包 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.11</version>
            <scope>test</scope>
        </dependency>
        <!-- 日志檔案管理包 -->
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-api</artifactId>
            <version>1.7.12</version>
        </dependency>
        <dependency>
            <groupId>org.slf4j</groupId>
            <artifactId>slf4j-log4j12</artifactId>
            <version>1.7.12</version>
        </dependency>
    </dependencies>
</project>

與資料庫中相對應的實體類

Student

:

package bean;

public class Student {
	private Integer id;
	private String name;
	private int age;
	private double score;
	public Student(){

    }
	public Student(String name, int age, double score) {
		super();
		this.name = name;
		this.age = age;
		this.score = score;
	}
	public Integer getId() {
		return id;
	}
	public void setId(Integer id) {
		this.id = id;
	}
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public int getAge() {
		return age;
	}
	public void setAge(int age) {
		this.age = age;
	}
	public double getScore() {
		return score;
	}
	public void setScore(double score) {
		this.score = score;
	}
	@Override
	public String toString() {
		return "Student [id=" + id + ", name=" + name + ", age=" + age
				+ ", score=" + score + "]";
	}
	
}

mybatis

的重要一步是配置資料源，要不怎麼知道使用哪一個資料庫，有哪些mapper檔案,主配置檔案

mybatis.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>
    <!-- 配置資料庫檔案 -->
    <properties resource="jdbc_mysql.properties">

    </properties>
    <!-- 别名，對資料對象操作全名太長，需要使用别名 -->
    <typeAliases>
        <!--<typeAlias type="bean.Student" alias="Student"/>-->
        <!--直接使用類名即可，對于整個包的路徑配置（别名），簡單快捷 -->
        <package name="bean"/>
    </typeAliases>
    <!-- 配置運作環境 -->
    <!-- default 表示預設使用哪一個環境，可以配置多個，比如開發時的測試環境，上線後的正式環境等 -->
    <environments default="mysqlEM">
        <environment id="mysqlEM">
            <transactionManager type="JDBC">
            </transactionManager>
            <dataSource type="POOLED">
                <property name="driver" value="${jdbc.driver}"/>
                <property name="url" value="${jdbc.url}"/>
                <property name="username" value="${jdbc.user}"/>
                <property name="password" value="${jdbc.password}"/>
            </dataSource>
        </environment>
    </environments>
    <!-- 注冊映射檔案 -->
    <mappers>
        <mapper resource="mapper/mapper.xml"/>
    </mappers>
</configuration>

mybatis.xml

檔案裡面抽取出來的資料庫連接配接相關資訊

jdbc_mysql.properties

檔案:

jdbc.driver=com.mysql.jdbc.Driver
jdbc.url=jdbc:mysql://localhost:3306/test
jdbc.user=root
jdbc.password=123456

日志系統的配置檔案

log4j.properties

 
log4j.prpp
log4j.rootLogger=DEBUG, stdout

log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=[service] %d - %c -%-4r [%t] %-5p %c %x - %m%n

#log4j.appender.R=org.apache.log4j.DailyRollingFileAppender    
#log4j.appender.R.File=../logs/service.log    
#log4j.appender.R.layout=org.apache.log4j.PatternLayout    
#log4j.appender.R.layout.ConversionPattern=[service] %d - %c -%-4r [%t] %-5p %c %x - %m%n    

#log4j.logger.com.ibatis = debug    
#log4j.logger.com.ibatis.common.jdbc.SimpleDataSource = debug    
#log4j.logger.com.ibatis.common.jdbc.ScriptRunner = debug    
#log4j.logger.com.ibatis.sqlmap.engine.impl.SqlMapClientDelegate = debug    
#log4j.logger.java.sql.Connection = debug    
log4j.logger.java.sql.Statement = debug
log4j.logger.java.sql.PreparedStatement = debug
log4j.logger.java.sql.ResultSet =debug

在主配置檔案

mybatis.xml

裡我們配置了去掃描

mapper

檔案，那我們要實作的是對

Student

的增删改查等功能，

Mapper.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="abc">
    <!-- parameterType可以省略不寫 -->
    <insert id="insertStudent" parameterType="Student">
		insert into student(name,age,score) values(#{name},#{age},#{score})
	</insert>

    <insert id="insertStudentCacheId" parameterType="Student">
        insert into student(name,age,score) values(#{name},#{age},#{score})
        <!-- 指定結果類型resultType，keyProperty是屬性，自動傳回到屬性id中，order是次序，after是指擷取id是在于插入後 -->
        <selectKey resultType="int" keyProperty="id" order="AFTER">
            select @@identity
        </selectKey>
    </insert>

    <!-- 删除 -->
    <delete id="deleteStudentById" >
        delete from student where id=#{id}
        <!-- 這裡的id放什麼都可以，隻是一個占位符，不表示什麼 -->
    </delete>

    <update id="updateStudent">
		update student set name=#{name},age=#{age},score=#{score} where id=#{id}
	</update>

    <!-- 查詢清單 -->
    <!-- 系統不知道傳回封裝為什麼類型，是以要注明傳回類型 -->
    <select id="selectAllStudents" resultType="Student">
        select id,name,age,score from student
        <!-- 如果資料庫為tid，tname，tage，那麼我們可以使用别名
        select tid id,tname name,tage age,tscore score from student -->
    </select>
    <!-- 通過id來查詢學生 -->
    <select id="selectStudentById" resultType="Student">
		select * from student where id=#{xxx}

	</select>
    <!-- 模糊查詢-->
    <!-- 不能寫成'%#{name}%' -->
    <!-- 可以寫成這樣，也就是使函數拼接 select id,name,age,score from student where name like concat('%',#{xxx},'%') -->
    <!-- 也可以寫成這樣，‘’引起來的是寫死的，而變量是不可以引起來的select id,name,age,score from student where name like '%' #{xxx} '%' -->
    <!-- '%' #{xxx} '%'中間必須有空格，要不就無效了 -->
    <select id="selectStudentsByName" resultType="Student">
        <!--最常用的（動态參數） select id,name,age,score from student where name like '%' #{name} '%' -->
        <!-- 下面的是字元串拼接 ，隻能寫value，了解即可，容易sql注入，執行效率低，不建議使用-->
        select id,name,age,score from student where name like '%${value}%'
    </select>
</mapper>

有了

mapper.xml

檔案還不夠，我們需要定義接口與

sql

語句一一對應,

IStudentDao.class

 
package dao;
import bean.Student;
import java.util.List;
import java.util.Map;
public interface IStudentDao {
    // 增加學生
    public void insertStudent(Student student);
    // 增加新學生并傳回id
    public void insertStudentCacheId(Student student);

    // 根據id删除學生
    public void deleteStudentById(int id);
    // 更新學生的資訊
    public void updateStudent(Student student);

    // 傳回所有學生的資訊List
    public List<Student> selectAllStudents();
    // 傳回所有學生的資訊Map
    public Map<String, Object> selectAllStudentsMap();

    // 根據id查找學生
    public Student selectStudentById(int id);
    // 根據名字查找學生，模糊查詢
    public List<Student>selectStudentsByName(String name);
}

接口的實作類如下：

sqlSession

有很多方法:

  • 如果是插入一條資料需要使用

    insert()

     ;
  • 删除一條資料使用

    delete()
  • 更新一條資料使用

    update()
  • 如果查詢傳回資料的

    List

    SelectList()

     方法；
  • 如果傳回查詢多條資料的

    Map

    selectMap()
  • 如果查詢一條資料，那麼隻需要使用

    selectOne()

     即可。 
package dao;

import bean.Student;
import org.apache.ibatis.session.SqlSession;
import utils.MyBatisUtils;

import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class StudentDaoImpl implements IStudentDao {
    private SqlSession sqlSession;
    public void insertStudent(Student student) {
        //加載主配置檔案
        try {
            sqlSession = MyBatisUtils.getSqlSession();
            sqlSession.insert("insertStudent", student);
            sqlSession.commit();
        } finally {
            if (sqlSession != null) {
                sqlSession.close();
            }
        }
    }

    public void insertStudentCacheId(Student student) {
        try {
            sqlSession = MyBatisUtils.getSqlSession();
            sqlSession.insert("insertStudentCacheId", student);
            sqlSession.commit();
        } finally {
            if (sqlSession != null) {
                sqlSession.close();
            }
        }
    }

    public void deleteStudentById(int id) {
        try {
            sqlSession = MyBatisUtils.getSqlSession();
            sqlSession.delete("deleteStudentById", id);
            sqlSession.commit();
        } finally {
            if (sqlSession != null) {
                sqlSession.close();
            }
        }
    }

    public void updateStudent(Student student) {
        try {
            sqlSession = MyBatisUtils.getSqlSession();
            sqlSession.update("updateStudent", student);
            sqlSession.commit();
        } finally {
            if (sqlSession != null) {
                sqlSession.close();
            }
        }
    }

    public List<Student> selectAllStudents() {
        List<Student> students ;
        try {
            sqlSession = MyBatisUtils.getSqlSession();
            students = sqlSession.selectList("selectAllStudents");
            //查詢不用修改，是以不用送出事務
        } finally {
            if (sqlSession != null) {
                sqlSession.close();
            }
        }
        return students;
    }

    public Map<String, Object> selectAllStudentsMap() {
        Map<String ,Object> map=new HashMap<String, Object>();
        /**
         * 可以寫成Map<String ,Student> map=new HashMap<String, Student>();
         */
        try {
            sqlSession=MyBatisUtils.getSqlSession();
            map=sqlSession.selectMap("selectAllStudents", "name");
            //查詢不用修改，是以不用送出事務
        } finally{
            if(sqlSession!=null){
                sqlSession.close();
            }
        }
        return map;
    }

    public Student selectStudentById(int id) {
        Student student=null;
        try {
            sqlSession=MyBatisUtils.getSqlSession();
            student=sqlSession.selectOne("selectStudentById",id);
            sqlSession.commit();
        } finally{
            if(sqlSession!=null){
                sqlSession.close();
            }
        }
        return student;
    }

    public List<Student> selectStudentsByName(String name) {
        List<Student>students=new ArrayList<Student>();
        try {
            sqlSession=MyBatisUtils.getSqlSession();
            students=sqlSession.selectList("selectStudentsByName",name);
            //查詢不用修改，是以不用送出事務
        } finally{
            if(sqlSession!=null){
                sqlSession.close();
            }
        }
        return students;
    }
}

我們使用了一個自己定義的工具類，用來擷取

Sqlsession

的執行個體：

package utils;

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 java.io.IOException;
import java.io.InputStream;

public class MyBatisUtils {
    static private SqlSessionFactory sqlSessionFactory;

    static public SqlSession getSqlSession() {
        InputStream is;
        try {
            is = Resources.getResourceAsStream("mybatis.xml");
            if (sqlSessionFactory == null) {
                sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);
            }
            return sqlSessionFactory.openSession();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        return null;
    }
}

測試代碼

MyTest.class

 
import bean.Student;
import dao.IStudentDao;
import dao.StudentDaoImpl;
import org.junit.Before;
import org.junit.Test;
import java.util.List;
import java.util.Map;

public class MyTest {
	private IStudentDao dao;
	@Before
	public void Before(){
		dao=new StudentDaoImpl();
	}
    /**
     * 插入測試
     */
    @Test
    public void testInsert(){
        /**
         * 要是沒有select id，這樣是不會自動擷取id的，id會一直為空
         */
        Student student=new Student("hello",14,94.6);
        System.out.println("插入前：student="+student);
        dao.insertStudent(student);
        System.out.println("插入後：student="+student);
    }
    /**
     * 測試插入後擷取id
     */
    @Test
    public void testinsertStudentCacheId(){
        Student student=new Student("helloworld",17,85);
        System.out.println("插入前：student="+student);
        dao.insertStudentCacheId(student);
        System.out.println("插入後：student="+student);
    }
    /*
     * 測試删除
     *
     */
    @Test
    public void testdeleteStudentById(){
        dao.deleteStudentById(18);

    }
    /*
     * 測試修改，一般我們業務裡面不這樣寫，一般是查詢出來student再修改
     *
     */
    @Test
    public void testUpdate(){
        Student student=new Student("lallalalla",14,94.6);
        student.setId(21);
        dao.updateStudent(student);

    }
    /*
     * 查詢清單
     *
     */
    @Test
    public void testselectList(){
        List<Student> students=dao.selectAllStudents();
        if(students.size()>0){
            for(Student student:students){
                System.out.println(student);
            }
        }
    }
    /*
     * 查詢清單裝成map
     *
     */
    @Test
    public void testselectMap(){
        Map<String,Object> students=dao.selectAllStudentsMap();
        // 有相同的名字的會直接替換掉之前查出來的，因為是同一個key
        System.out.println(students.get("helloworld"));
        System.out.println(students.get("1ADAS"));
    }
    /*
     * 通過id來查詢student
     *
     */
    @Test
    public void testselectStudentById(){
        Student student=dao.selectStudentById(19);
        System.out.println(student);
    }
    /*
     * 通過模糊查詢student的名字
     *
     */
    @Test
    public void testselectStudentByName(){
        List<Student>students=dao.selectStudentsByName("abc");
        if(students.size()>0){
            for(Student student:students)
                System.out.println(student);
        }

    }
}

至此這個demo就完成了，運作test的時候建議多跑幾次插入再測其他功能。

從上面的代碼我們可以看出Mybatis總體運作的邏輯：

  • 1.通過加載

    mybatis.xml

     檔案，然後解析檔案，擷取資料庫連接配接資訊，存起來。
  • 2.掃描

    mybatis.xml

     裡面配置的

    mapper.xml

     檔案。
  • 3.掃描

    mapper.xml

     檔案的時候，，将

    sql

     按照

    namespace

     和

    id

     存起來。
  • 4.通過剛剛存起來的資料庫連接配接資訊，build出一個

    sqlSessionFactory

     工廠,

    sqlSessionFactory

     又可以擷取到

    openSession

     ，相當于擷取到資料庫會話。
  • 5.通過

    SqlSession

     的

    insert()

     ，

    update()

     ,

    delete()

     等方法，裡面傳入

    id

     和參數，就可以查找到剛剛掃描

    mapper.xml

     檔案時存起來的sql，去執行sql。
Mybatis【5】-- Mybatis多種增删改查那些你會了麼？

【作者簡介】：

秦懷，公衆号【秦懷雜貨店】作者，技術之路不在一時，山高水長，縱使緩慢，馳而不息。這個世界希望一切都很快，更快，但是我希望自己能走好每一步，寫好每一篇文章，期待和你們一起交流。

此文章僅代表自己（本菜鳥）學習積累記錄，或者學習筆記，如有侵權，請聯系作者核實删除。人無完人，文章也一樣，文筆稚嫩，在下不才，勿噴，如果有錯誤之處，還望指出，感激不盡~

Mybatis【5】-- Mybatis多種增删改查那些你會了麼？
mybatis
上一篇: ts 函數的類型
下一篇: JDBC【1】-- 入門之增删改查

繼續閱讀