本文共 12188 字，大约阅读时间需要 40 分钟。

前面我们学会了Mybatis如何配置数据库以及创建SqlSession，那怎么写呢？crud怎么写？

代码直接放在Github仓库【 】

需要声明的是：此Mybatis学习笔记，是从原始的Mybatis开始的，而不是整合了其他框架（比如Spring）之后，个人认为，这样能对它的功能，它能帮我们做什么，有更好的理解，后面再慢慢叠加其他的功能。

项目的目录如下：

创建数据库：初始化数据，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包：

   
       
    
     4.0.0
        
    
     com.test
        
    
     test
        
    
     1.0-SNAPSHOT
        
            
             
                 
      
       org.mybatis
                  
      
       mybatis
                  
      
       3.3.0
              
             
             
                 
      
       mysql
                  
      
       mysql-connector-java
                  
      
       5.1.29
              
             
             
                 
      
       junit
                  
      
       junit
                  
      
       4.11
                  
      
       test
              
             
             
                 
      
       log4j
                  
      
       log4j
                  
      
       1.2.17
              
             
                 
      
       org.slf4j
                  
      
       slf4j-api
                  
      
       1.7.12
              
             
                 
      
       org.slf4j
                  
      
       slf4j-log4j12
                  
      
       1.7.12
              
         
    
   

与数据库中相对应的实体类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：

mybatis.xml文件里面抽取出来的数据库连接相关信息jdbc_mysql.properties文件:

jdbc.driver=com.mysql.jdbc.Driverjdbc.url=jdbc:mysql://localhost:3306/testjdbc.user=rootjdbc.password=123456

日志系统的配置文件 log4j.properties:

log4j.prpplog4j.rootLogger=DEBUG, stdoutlog4j.appender.stdout=org.apache.log4j.ConsoleAppenderlog4j.appender.stdout.layout=org.apache.log4j.PatternLayoutlog4j.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 = debuglog4j.logger.java.sql.PreparedStatement = debuglog4j.logger.java.sql.ResultSet =debug

在主配置文件mybatis.xml里我们配置了去扫描mapper文件，那我们要实现的是对Student的增删改查等功能，Mapper.xml:

   
       
        
    
     		insert into student(name,age,score) values(#{name},#{age},#{score})	
        
    
             insert into student(name,age,score) values(#{name},#{age},#{score})        
             
     
                  select @@identity        
         
        
        
    
             delete from student where id=#{id}        
         
        
    
     		update student set name=#{name},age=#{age},score=#{score} where id=#{id}	
        
        
        
            select id,name,age,score from student        
             
        
    		select * from student where id=#{xxx}	    
        
        
        
        
        
            
             
             select id,name,age,score from student where name like '%${value}%'    
   

有了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
   
     selectAllStudents();    // 返回所有学生的信息Map    public Map
    
      selectAllStudentsMap();    // 根据id查找学生    public Student selectStudentById(int id);    // 根据名字查找学生，模糊查询    public List
     
      selectStudentsByName(String name);}
     
    
   

接口的实现类如下：

• 如果是插入一条数据需要使用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
   
     selectAllStudents() {        List
    
      students ;        try {            sqlSession = MyBatisUtils.getSqlSession();            students = sqlSession.selectList("selectAllStudents");            //查询不用修改，所以不用提交事务        } finally {            if (sqlSession != null) {                sqlSession.close();            }        }        return students;    }    public Map
     
       selectAllStudentsMap() {        Map
      
        map=new HashMap
       
        ();        /**         * 可以写成Map
        
          map=new HashMap
         
          (); */ 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
          
            selectStudentsByName(String name) { List
           
            students=new ArrayList
            
             (); 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
   
     students=dao.selectAllStudents();        if(students.size()>0){            for(Student student:students){                System.out.println(student);            }        }    }    /*     * 查询列表装成map     *     */    @Test    public void testselectMap(){        Map
    
      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
     
      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。

【作者简介】：

此文章仅代表自己（本菜鸟）学习积累记录，或者学习笔记，如有侵权，请联系作者核实删除。人无完人，文章也一样，文笔稚嫩，在下不才，勿喷，如果有错误之处，还望指出，感激不尽~