Mybatis环境搭建和进行简单的CRUD增删改查操作

心已赠人 2022-09-26 03:50 135阅读 0赞

1：首先引入所需要的jar包。包括mybatis-3.2.8.jar、mysql-connector-java-3.1.12-bin.jar、junit4.4.jar、log4j-1.2.17.jar。其中后面2个不是必须需要的。只需要mybatis的和mysql驱动包就行了，上面几个jar一定要添加至构建路径。

2：建立mybatis-config.xml文件。里面存放mybatis的一些配置信息。如下：

上面注释掉的配置信息是相同的效果。因为配置一些属性的时候有多种方法。

3：建立model类：Student.java

<span style="font-size:18px;">package com.levi.model;
    
    public class Student {
    	private Integer id;
    	private String name;
    	private Integer age;
    	public Student() {
    		super();
    		// TODO Auto-generated constructor stub
    	}
    	public Student(String name, Integer age) {
    		super();
    		this.name = name;
    		this.age = age;
    	}
    	public Student(Integer id,String name, Integer age) {
    		this.age=age;
    		this.name=name;
    		this.id=id;
    	}
    	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 Integer getAge() {
    		return age;
    	}
    	public void setAge(Integer age) {
    		this.age = age;
    	}
    	@Override
    	public String toString() {
    		return "Student [id=" + id + ", name=" + name + ", age=" + age + "]";
    	}
    }
    </span>

4：建立一个接口类:StudentMapper.java,如下：

package com.levi.mappers;
    
    import java.util.List;
    
    import com.levi.model.Student;
    
    public interface StudentMapper {
    
    	public int add(Student student);
    	public int delete(int id);
    	public int update(Student student);
    	public Student getOne(int id);
    	public List<Student> getAll();
    }

5：建立StudentMapper.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.levi.mappers.StudentMapper">
    	<resultMap type="Student" id="StudentResult">
    		<id property="id" column="id"/>
    		<result property="name" column="name"/>
    		<result property="age" column="age"/>
    	</resultMap>
    	<insert id="add" parameterType="Student"  >
    		insert into t_student values(null,#{name},#{age})
    	</insert>
    	<delete id="delete"	parameterType="int">
    		delete from t_student where id=#{id}
    	</delete>
    	<update id="update" parameterType="Student" >
    		update t_student set name = #{name} , age = #{age} where id = #{id}
    	</update>
    	<select id="getOne" parameterType="int" resultType="Student">
    		select *from t_student where id = #{id}
    	</select>
    	
    	<select id="getAll" resultMap="StudentResult">
    		select * from t_student  
    	</select>
    </mapper>

6：建立一个获取 SqlSession的工具类SqlSessionFactoryUtil.java

package com.levi.util;
    
    import java.io.InputStream;
    
    import org.apache.ibatis.io.Resources;
    import org.apache.ibatis.session.SqlSession;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.apache.ibatis.session.SqlSessionFactoryBuilder;
    
    public class SqlSessionFactoryUtil {
    
    	private static SqlSessionFactory sqlSessionFactory;
    	
    	public static SqlSessionFactory getSqlSessionFactory(){
    		if(sqlSessionFactory==null){
    			InputStream inputStream=null;
    			try{
    				inputStream=Resources.getResourceAsStream("mybatis-config.xml");
    				sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);
    			}catch(Exception e){
    				e.printStackTrace();
    			}
    		}
    		return sqlSessionFactory;
    	}
    	
    	public static SqlSession openSession(){
    		return getSqlSessionFactory().openSession();
    	}
    }

7：配置下log4j的log4j.properties和jdbcproperties文件jdbc.properties。

log4j.properties文件：

log4j.rootLogger=info,appender1,appender2
    
    log4j.appender.appender1=org.apache.log4j.ConsoleAppender 
    
    log4j.appender.appender2=org.apache.log4j.FileAppender 
    log4j.appender.appender2.File=logFile.txt
     
    log4j.appender.appender1.layout=org.apache.log4j.TTCCLayout
    log4j.appender.appender2.layout=org.apache.log4j.TTCCLayout

jdbc.properties文件

jdbc.driverClassName=com.mysql.jdbc.Driver
    jdbc.url=jdbc:mysql://localhost:3306/db_mybatis?characterEncoding=UTF-8
    jdbc.username=root
    jdbc.password=root

8：最后写个junit测试类ServiceTest.java

package com.levi.service;
    
    
    import java.util.List;
    
    import org.apache.ibatis.session.SqlSession;
    import org.apache.log4j.Logger;
    import org.junit.After;
    import org.junit.Before;
    import org.junit.Test;
    
    import com.levi.mappers.StudentMapper;
    import com.levi.model.Student;
    import com.levi.util.SqlSessionFactoryUtil;
    
    public class ServiceTest {
    
    	private static Logger logger = Logger.getLogger(ServiceTest.class);
    	private SqlSession sqlSession = null;
    
    	@Before
    	public void setUp() throws Exception {
    		sqlSession = SqlSessionFactoryUtil.getSqlSessionFactory().openSession();
    	}
    
    	@After
    	public void tearDown() throws Exception {
    	}
    
    	@Test
    	public void add() {
    		StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);
    		int add = mapper.add(new Student("飞飞飞", 99));
    		sqlSession.commit();
    		if (add > 0) {
    			logger.info("添加成功");
    		}
    	}
    
    	@Test
    	public void delete() {
    		StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);
    		int delete = mapper.delete(14);
    		sqlSession.commit();
    		if (delete > 0) {
    			logger.info("删除成功");
    		}
    	}
    
    	@Test
    	public void update() {
    		StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);
    		int update = mapper.update(new Student(16, "飞飞飞2", 100));
    		sqlSession.commit();
    		if (update > 0) {
    			logger.info("更新成功");
    		}
    	}
    	@Test
    	public void getOne()
    	{
    		StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);
    		Student one = mapper.getOne(16);
    		if (one!=null) {
    			logger.info("查询一个成功");
    		}
    		sqlSession.commit();
    		System.out.println(one.toString());
    	}
    	@Test
    	public void getAll()
    	{
    		StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);
    		List<Student> all = mapper.getAll();
    		sqlSession.commit();
    		for (Student student : all) {
    			System.out.println(student.toString());
    		}
    	}
    }

上面就搭建了一个mybatis的环境和进行了简单的增删改查。