欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页

mybatis之基础的增删改查

程序员文章站 2024-02-21 10:20:10
...

今天,花了点时间在原来入门项目的基础上增加了增删改查操作,废话不多说,直接上代码

User.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="test">
    <!--查询用户信息-->
    <select id="findById" parameterType="int" resultType="com.xzf.pojo.User">
        SELECT * FROM USER WHERE id=#{id}
    </select>
    <!--修改用户信息-->
    <update id="updateById" parameterType="com.xzf.pojo.User">
        UPDATE USER SET NAME=#{name} WHERE id=#{id}
    </update>
    <!--添加用户信息-->
    <insert id="insertUser" parameterType="com.xzf.pojo.User">
          INSERT INTO USER(NAME,age) VALUES(#{name},#{age})
    </insert>
    <!--删除用户信息-->
    <delete id="deleteUser" parameterType="int">
          DELETE FROM USER WHERE id=#{id}
    </delete>
    <!--模糊查询-->
    <select id="findByName" parameterType="java.lang.String" resultType="com.xzf.pojo.User">
          SELECT * FROM USER WHERE NAME LIKE '%${value}%'
    </select>
</mapper>

UserTest新增代码如下

    @Test
    public void updateById()throws Exception{
        //读取配置文件
        String resource="mybaits-config.xml";
        InputStream inputStream= Resources.getResourceAsStream(resource);

        //创建SqlSesstionFactory
        SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);

        //创建SqlSession
        SqlSession sqlSession=sqlSessionFactory.openSession();

        User user=new User();
        user.setId(1);
        user.setName("夏洛克");
        //这里设置年龄为100,但User.xml文件里只设置更新名字,修改后的结果中年龄应未变
        user.setAge(100);
        //调用sqlSession的方法,第一个参数为statement即所调用的配置文件的具体方法,第二个为传入参数
        int result=sqlSession.update("test.updateById",user);
        //result为1代表成功,为0代表不成功
        System.out.println(result);

        //提交事务
        sqlSession.commit();
        //关闭资源
        sqlSession.close();
    }

    @Test
    public void insertUser()throws Exception{
        //读取配置文件
        String resource="mybaits-config.xml";
        InputStream inputStream= Resources.getResourceAsStream(resource);

        //创建SqlSesstionFactory
        SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);

        //创建SqlSession
        SqlSession sqlSession=sqlSessionFactory.openSession();

        User user=new User();
        user.setName("fa");
        user.setAge(1);
        //调用sqlSession的方法,第一个参数为statement即所调用的配置文件的具体方法,第二个为传入参数
        int result=sqlSession.insert("test.insertUser",user);
        //result为1代表成功,为0代表不成功
        System.out.println(result);

        //提交事务
        sqlSession.commit();
        //关闭资源
        sqlSession.close();
    }

    @Test
    public void deleteUser()throws Exception{
        //读取配置文件
        String resource="mybaits-config.xml";
        InputStream inputStream= Resources.getResourceAsStream(resource);

        //创建SqlSesstionFactory
        SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);

        //创建SqlSession
        SqlSession sqlSession=sqlSessionFactory.openSession();

        User user=new User();
        user.setId(5);
        //调用sqlSession的方法,第一个参数为statement即所调用的配置文件的具体方法,第二个为传入参数
//        int result=sqlSession.delete("test.deleteUser",2);
        int result=sqlSession.insert("test.deleteUser",user);
        //result为1代表成功,为0代表不成功
        System.out.println(result);

        //提交事务
        sqlSession.commit();
        //关闭资源
        sqlSession.close();
    }
    
    @Test
    public void findByName()throws Exception{
        //读取配置文件
        String resource="mybaits-config.xml";
        InputStream inputStream= Resources.getResourceAsStream(resource);

        //创建SqlSesstionFactory
        SqlSessionFactory sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);

        //创建SqlSession
        SqlSession sqlSession=sqlSessionFactory.openSession();

        //调用sqlSession的方法,第一个参数为statement即所调用的配置文件的具体方法,第二个为传入参数
        List<User> resultUser=sqlSession.selectList("test.findByName","c");
        System.out.println("resultUser:"+resultUser);

        //提交事务
        sqlSession.commit();
        //关闭资源
        sqlSession.close();
    }

在最后的模糊查询中,特地利用selectOne()与selectList()分别进行查询,当查询的结果超过一条时,selectOne()方法会报错,具体信息如下at org.apache.ibatis.session.defaults.DefaultSqlSession.selectOne

DefaultSqlSession.class中selectOne源码如下

public <T> T selectOne(String statement, Object parameter) {
        List<T> list = this.selectList(statement, parameter);
        if (list.size() == 1) {
            return list.get(0);
        } else if (list.size() > 1) {
            throw new TooManyResultsException("Expected one result (or null) to be returned by selectOne(), but found: " + list.size());
        } else {
            return null;
        }
    }