码迷，mamicode.com
首页 > 其他好文 > 详细

mybatis实现的对数据的增删查改

时间：2016-07-25 13:11:44      阅读：227      评论：0      收藏：0      [点我收藏+]

标签：

mybatis实现的对数据的增删查改

前期准备

新建java工程或java wweb工程，
需要导入以下的包，
技术分享

基本工作已经完成，接下来开始进入正题。

新建实体类

新建与数据库表对应的实体类
package com.edu.hpu.domain;

/**
 * @author Administrator
 *user表所对应的实体类
 */
public class User {
      //实体类的属性和表的字段名称一一对应
	  private int id;
	  private String name;
	  private int age;
     //对属性进行封装	  
	public int getId() {
		return id;
	}
	public void setId(int 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;
	}
	  //添加toString方法
	  @Override
	public String toString() {
		return "User [id=" + id + ",name=" + name + ",age=" + age + "]";
	}
}

添加Mybatis工具类

添加用到的工具类，如下所示，
package com.edu.hpu.util;

import java.io.InputStream;

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

public class MyBatisUtil {

    /**
     * 获取SqlSessionFactory
     * @return SqlSessionFactory
     */
    public static SqlSessionFactory getSqlSessionFactory() {
        String resource = "conf.xml";//调取配置文件
        InputStream is = MyBatisUtil.class.getClassLoader().getResourceAsStream(resource);
        SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);
        return factory;
    }
    
    /**
     * 获取SqlSession
     * @return SqlSession
     */
    public static SqlSession getSqlSession() {
        return getSqlSessionFactory().openSession();
    }
    
    /**
     * 获取SqlSession
     * @param isAutoCommit 
     *         true 表示创建的SqlSession对象在执行完SQL之后会自动提交事务
     *         false 表示创建的SqlSession对象在执行完SQL之后不会自动提交事务，这时就需要我们手动调用sqlSession.commit()提交事务
     * @return SqlSession
     */
    public static SqlSession getSqlSession(boolean isAutoCommit) {
        return getSqlSessionFactory().openSession(isAutoCommit);
    }
}

使用mybatis对数据进行增删查改操作有两种方法，分别为配置文件操作和注解操作。

通过配置文件进行操作

数据库配置文件如下所示，对数据库信息进行配置，
<?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">
            <transactionManager type="JDBC" />
            <!-- 配置数据库连接信息 -->
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.jdbc.Driver" />
                <property name="url" value="jdbc:mysql://localhost:3306/test?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull" />
                <property name="username" value="root" />
                <property name="password" value="admin" />
            </dataSource>
        </environment>
    </environments>
      <mappers>
        <!-- 注册userMapper.xml文件， 
         userMapper.xml位于com.edu.hpu.mapping这个包下，所以resource写成com/edu/hpu/mapping/userMapper.xml-->
          <mapper resource="com/edu/hpu/mapping/userMapper.xml"/> 
         <!-- <mapper class="com.edu.hpu.mapping.UserMapper_11"/> -->
     </mappers>
</configuration>

配置操作数据库语句文件，如下所示，
<?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.edu.hpu.mapping.userMapper">
    <!-- 在select标签中编写查询的SQL语句， 设置select标签的id属性为getUser，id属性值必须是唯一的，不能够重复
    使用parameterType属性指明查询时使用的参数类型，resultType属性指明查询返回的结果集类型
    resultType="com.edu.hpu.domain.User"就表示将查询结果封装成一个User类的对象返回
    User类就是users表所对应的实体类
    -->
    <!-- 
        根据id查询得到一个user对象
     -->
    <select id="getUser" parameterType="int" 
        resultType="com.edu.hpu.domain.User">
        select * from users where id=#{id}
    </select>
<!-- 创建用户(Create) -->
    <insert id="addUser" parameterType="com.edu.hpu.domain.User">
        insert into users(name,age) values(#{name},#{age})
    </insert>
    
    <!-- 删除用户(Remove) -->
    <delete id="deleteUser" parameterType="int">
        delete from users where id=#{id}
    </delete>
    
    <!-- 修改用户(Update) -->
    <update id="updateUser" parameterType="com.edu.hpu.domain.User">
        update users set name=#{name},age=#{age} where id=#{id}
    </update>
    
    <!-- 查询全部用户-->
    <select id="getAllUsers" resultType="com.edu.hpu.domain.User">
        select * from users
    </select>
    
</mapper>
通过配置文件实现对数据库的增删查改基本上已经完成，接下来给出测试类，
可以进行测试，如下所示，
package com.edu.hpu.test;

import java.util.List;
import com.edu.hpu.domain.User;
import com.edu.hpu.util.MyBatisUtil;
import org.junit.Test;
import org.apache.ibatis.session.SqlSession;

public class Test2 {

    @Test
    public void testAdd(){
        //SqlSession sqlSession = MyBatisUtil.getSqlSession(false);
        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);
        /**
         * 映射sql的标识字符串，
         * com.edu.hpu.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，
         * addUser是insert标签的id属性值，通过insert标签的id属性值就可以找到要执行的SQL
         */
        String statement = "com.edu.hpu.mapping.userMapper.addUser";//映射sql的标识字符串
        User user = new User();
        user.setName("新增用户小黄");
        user.setAge(20);
        //执行插入操作
        int retResult = sqlSession.insert(statement,user);
        //手动提交事务
        //sqlSession.commit();
        //使用SqlSession执行完SQL之后需要关闭SqlSession
        sqlSession.close();
        System.out.println(retResult);
    }
    
    @Test
    public void testUpdate(){
        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);
        /**
         * 映射sql的标识字符串，
         * com.edu.hpu.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，
         * updateUser是update标签的id属性值，通过update标签的id属性值就可以找到要执行的SQL
         */
        String statement = "com.edu.hpu.mapping.userMapper.updateUser";//映射sql的标识字符串
        User user = new User();
        user.setId(3);
        user.setName("hello world");
        user.setAge(25);
        //执行修改操作
        int retResult = sqlSession.update(statement,user);
        //使用SqlSession执行完SQL之后需要关闭SqlSession
        sqlSession.close();
        System.out.println(retResult);
    }
    
    @Test
    public void testDelete(){
        SqlSession sqlSession = MyBatisUtil.getSqlSession(true);
        /**
         * 映射sql的标识字符串，
         * com.edu.hpu.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，
         * deleteUser是delete标签的id属性值，通过delete标签的id属性值就可以找到要执行的SQL
         */
        String statement = "com.edu.hpu.mapping.userMapper.deleteUser";//映射sql的标识字符串
        //执行删除操作
        int retResult = sqlSession.delete(statement,4);
        //使用SqlSession执行完SQL之后需要关闭SqlSession
        sqlSession.close();
        System.out.println(retResult);
    }
    
    @Test
    public void testGetAll(){
        SqlSession sqlSession = MyBatisUtil.getSqlSession();
        /**
         * 映射sql的标识字符串，
         * com.edu.hpu.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，
         * getAllUsers是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL
         */
        String statement = "com.edu.hpu.mapping.userMapper.getAllUsers";//映射sql的标识字符串
        //执行查询操作，将查询结果自动封装成List<User>返回
        List<User> lstUsers = sqlSession.selectList(statement);
        //使用SqlSession执行完SQL之后需要关闭SqlSession
        sqlSession.close();
        System.out.println(lstUsers);
    }
}

通过注解进行操作

通过注解进行操作需要写一个接口，但是不必实现，如下所示，
package com.edu.hpu.mapping;

import java.util.List;
import com.edu.hpu.domain.User;
import org.apache.ibatis.annotations.Delete;
import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Select;
import org.apache.ibatis.annotations.Update;
/**
 * @author gacl
 * 定义sql映射的接口，使用注解指明方法要执行的SQL
 */
public interface UserMapper_11 {
	//使用@Insert注解指明add方法要执行的SQL
	@Insert("insert into users(name, age) values(#{name}, #{age})")
	public int add(User user);
	
	//使用@Delete注解指明deleteById方法要执行的SQL
	@Delete("delete from users where id=#{id}")
	public int deleteById(int id);
	
	//使用@Update注解指明update方法要执行的SQL
	@Update("update users set name=#{name},age=#{age} where id=#{id}")
	public int update(User user);
	
	//使用@Select注解指明getById方法要执行的SQL
	@Select("select * from users where id=#{id}")
	public User getById(int id);
	
	//使用@Select注解指明getAll方法要执行的SQL
	@Select("select * from users")
	public List<User> getAll();
}

同时，需要在数据库配置文件中添加所写的接口，在conf.xml中添加如下语句，
<mapper class="com.edu.hpu.mapping.UserMapper_11"/>，

OK，基本上已经完成，这里给出测试类可以进行测试，
package com.edu.hpu.test;

import java.util.List;
import com.edu.hpu.domain.User;
import com.edu.hpu.mapping.UserMapper_11;
import com.edu.hpu.util.MyBatisUtil;
import org.apache.ibatis.session.SqlSession;
import org.junit.Test;

/**
 * @author Administrator
 *对注解进行测试
 */
public class Test3 {
     
	@Test
	public void testAdd(){
		SqlSession sqlSession = MyBatisUtil.getSqlSession(true);
		//得到UserMapper接口的实现类对象，UserMapper接口的实现类对象由sqlSession.getMapper(UserMapper.class)动态构建出来
		UserMapper_11 mapper = sqlSession.getMapper(UserMapper_11.class);
		User user = new User();
		user.setName("大智若愚");
		user.setAge(20);
		int add = mapper.add(user);
		//使用SqlSession执行完SQL之后需要关闭SqlSession
		sqlSession.close();
		System.out.println(add);
	}
	
	@Test
	public void testUpdate(){
		SqlSession sqlSession = MyBatisUtil.getSqlSession(true);
		//得到UserMapper接口的实现类对象，UserMapper接口的实现类对象由sqlSession.getMapper(UserMapper.class)动态构建出来
		UserMapper_11 mapper = sqlSession.getMapper(UserMapper_11.class);
		User user = new User();
		user.setId(3);
		user.setName("大音希声");
		user.setAge(26);
		//执行修改操作
		int retResult = mapper.update(user);
		//使用SqlSession执行完SQL之后需要关闭SqlSession
		sqlSession.close();
		System.out.println(retResult);
	}
	
	@Test
	public void testDelete(){
		SqlSession sqlSession = MyBatisUtil.getSqlSession(true);
		//得到UserMapper接口的实现类对象，UserMapper接口的实现类对象由sqlSession.getMapper(UserMapper.class)动态构建出来
		UserMapper_11 mapper = sqlSession.getMapper(UserMapper_11.class);
		//执行删除操作
		int retResult = mapper.deleteById(7);
		//使用SqlSession执行完SQL之后需要关闭SqlSession
		sqlSession.close();
		System.out.println(retResult);
	}
	
	@Test
	public void testGetUser(){
		SqlSession sqlSession = MyBatisUtil.getSqlSession();
		//得到UserMapper接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapper.class)动态构建出来
		UserMapper_11 mapper = sqlSession.getMapper(UserMapper_11.class);
		//执行查询操作，将查询结果自动封装成User返回
		User user = mapper.getById(1);
		//使用SqlSession执行完SQL之后需要关闭SqlSession
		sqlSession.close();
		System.out.println(user);
	}
	
	@Test
	public void testGetAll(){
		SqlSession sqlSession = MyBatisUtil.getSqlSession();
		//得到UserMapper接口的实现类对象，UserMapper接口的实现类对象由sqlSession.getMapper(UserMapper.class)动态构建出来
		UserMapper_11 mapper = sqlSession.getMapper(UserMapper_11.class);
		//执行查询操作，将查询结果自动封装成List<User>返回
		List<User> lstUsers = mapper.getAll();
		//使用SqlSession执行完SQL之后需要关闭SqlSession
		sqlSession.close();
		System.out.println(lstUsers);
	}
}

本博客参考自：http://www.cnblogs.com/xdp-gacl/p/4262895.html


mybatis实现的对数据的增删查改

标签：

原文地址：http://blog.csdn.net/wojiaohuangyu/article/details/52022210
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！