Mybatis框架 使用接口Mapper實現數據庫的crud操作

Mybatis的Mapper接口方式實現簡單crud操作：

　　1.創建實體類 與數據庫對應

　　　　　　我的實體類是《Student》  

　　　　　　　　　　

package com.hxzy.mybatis.pojo;

import lombok.Data;

@Data
public class Student {
    private Integer s_id;
    private String s_name;
    private  String s_address;

    /**
     * 有參構造方法
     * @param s_id
     * @param s_name
     * @param s_address
     */
    public Student(Integer s_id, String s_name, String s_address) {
        this.s_id = s_id;
        this.s_name = s_name;
        this.s_address = s_address;
    }

    /**
     * 無參構造
     */
    public Student() {

    }

    @Override
    public String toString() {
        return "Student{" +
                "s_id=" + s_id +
                ", s_name='" + s_name + '\'' +
                ", s_address='" + s_address + '\'' +
                '}';
    }
}

 

　　　　　　2.我的數據庫表是student  《注意表字段要和實體類對應！！》

　　　　　　

 

　　　　　　3.創建配置文件 (一般放在接口包中 ，名字為 接口名+Mapper.xml)

 　　　　　　　　　　　　　　　　　　　　我的名字是 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">
<!--
        配置namespace 這個路徑就是接口所在的路徑
    -->
<mapper namespace="com.hxzy.mybatis.pojo.Student_Mapper">

        <select id="select_student" parameterType="int" resultType="com.hxzy.mybatis.pojo.Student">
              select  * from  student where s_id = #{id}
        </select>

        <select id="select_all_student" resultType="com.hxzy.mybatis.pojo.Student" >
            select  * from  student;
        </select>

        <select id="du_student" resultType="com.hxzy.mybatis.pojo.Student" parameterType="String">
            select  * from student where  student.s_name like  "${value}%"
        </select>

        <select id="insert_student" parameterType="com.hxzy.mybatis.pojo.Student">
            insert  into  student values(#{s_id},#{s_name},#{s_address})
        </select>

    <delete id="delete_student" parameterType="String">
        delete from student where  student.s_name = #{name}
    </delete>

    <update id="update_student" parameterType="com.hxzy.mybatis.pojo.Student">
        update student set student.s_name = #{s_name} where student.s_id = #{s_id}
    </update>

</mapper>

　　　　　　　　4.創建核心配置文件 （這個時候mybatis的配置文件  一般都叫 Mybatis_cfg.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="test1">

            <!--配置數據庫的信息-->
            <environment id="test1">
                <!--開啟JDBC的事務-->
                <transactionManager type="JDBC"></transactionManager>
                <!--配置一些必要的信息-->
                <dataSource type="POOLED">
                        <property name="driver" value="com.mysql.jdbc.Driver"></property>
                        <property name="url" value="jdbc:mysql://127.0.0.1:3306/stu"></property>
                        <property name="username" value="root" ></property>
                        <property name="password" value="gubin"></property>
                </dataSource>
            </environment>
        </environments>
    <!--p配置核心配置文件-->
        <mappers>
            <mapper resource="student_Mapper.xml"></mapper>
        </mappers>
</configuration>

 

　　　　　　　　　　5. 創建接口 （接口里面的方法名  就是Student_Mapper.xml的id）

 

package com.hxzy.mybatis.pojo;

import java.util.List;

public interface Student_Mapper {
    /**
     * 查詢單個學生
     * @param i
     * @return
     */
     Student select_student(int i);
    /**
     * 查詢全部的學生
     */
    List<Student> select_all_student();
    /**
     * 查詢姓杜的學生
     */
     List<Student> du_student(String str);
    /**
     * 添加學生
     */
   void insert_student(Student student);
    /**
     * 刪除學生
     */
    void delete_student(String str);
    /**
     * 修改學生
     */
    void update_student(Student student);
}

　　　　編寫測試類：

　　　　　　　　　

package com.hxzy.mybatis.test;

import com.hxzy.mybatis.entity.SqlSession_entity;
import com.hxzy.mybatis.pojo.Student;
import com.hxzy.mybatis.pojo.Student_Mapper;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;

import java.util.List;

public class Test_mybatis {
    /**
     * 查詢單個學生
     */
    @Test
    public  void  select_student(){
        //得到SqlSession 對象
        SqlSession session = SqlSession_entity.getSession();
        //此處省略了Statement語句的編寫
       Student_Mapper student_mapper  =  session.getMapper(Student_Mapper.class);
       //加載interface中的方法
       Student student =  student_mapper.select_student(1);
       session.close();
        System.out.println(student);
    }
    /**
     * 查詢多個學生
     */
    @Test
    public  void  select_all_student(){
        //獲得Session對象
        SqlSession session =  SqlSession_entity.getSession();
        //反射技術 將接口加載到內存
        Student_Mapper student_mapper =  session.getMapper(Student_Mapper.class);
        //將返回結果存入集合中
         List<Student> list =  student_mapper.select_all_student();
         //增強for遍歷
        for (Student student : list) {
            System.out.println(student);
        }
        session.close();
    }
    /**
     * 查詢所有姓杜的學生
     */
    @Test
    public void  test_du(){
        //獲得Session
        SqlSession session = SqlSession_entity.getSession();
        Student_Mapper student_mapper = session.getMapper(Student_Mapper.class);
        List<Student> list = student_mapper.du_student("杜");
        System.out.println(list);
        session.close();
    }
    /**
     * 添加學生
     */
    @Test
    public  void  tst_add(){
        //獲得Session
        SqlSession session = SqlSession_entity.getSession();
        Student_Mapper student_mapper = session.getMapper(Student_Mapper.class);
        //添加值
        student_mapper.insert_student(new Student(5,"黃小斌","石家庄"));
        //提交
        session.commit();
        //關閉
        session.close();
    }
    /**
     * 刪除學生
     */
    @Test
    public void delete_student()
    {
        SqlSession session = SqlSession_entity.getSession();
        Student_Mapper student_mapper =  session.getMapper(Student_Mapper.class);
        student_mapper.delete_student("劉啊文");
        session.commit();
        session.close();
    }
    /**
     * 修改學生
     */
    @Test
    public void update_student()
    {
        SqlSession session = SqlSession_entity.getSession();
        System.out.println();
        Student_Mapper student_mapper =  session.getMapper(Student_Mapper.class);
        student_mapper.update_student(new Student(4,"小阿六","避暑山庄"));

        session.commit();
        session.close();
    }

}