mybatis进行CRUD操作(基于xml)

青旅半醒 2023-06-10 10:28 14阅读 0赞

### 文章目录 ###

*   *  1、mybatis的概述
     *  2、mybatis的入门
     *  3、使用mybatis进行基本的CRUD操作
     *  4、MyBatis与JDBC编程的比较

## 1、mybatis的概述 ##

mybatis是一个持久层框架，用java编写的
            它封装了jdbc操作的很多细节，使得开发者只需要关注sql语句本身，而无需关注注册驱动，创建连接等繁杂过程。
            它使用了orm思想实现类结果集封装。
    
    
    
            ORM：对象关系映射
                   就是把数据库表和实体类以及实体类的属性对应起来，让我们可以操作实体类就实现操作数据库。

## 2、mybatis的入门 ##

1、创建一个不使用骨架的maven工程,修改pom.xml，引入jar坐标

<dependencies>
            <dependency>
                <groupId>org.mybatis</groupId>
                <artifactId>mybatis</artifactId>
                <version>3.5.2</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>5.1.6</version>
            </dependency>
            <dependency>
                <groupId>log4j</groupId>
                <artifactId>log4j</artifactId>
                <version>1.2.12</version>
            </dependency>
            <dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.13-beta-3</version>
            </dependency>
        </dependencies>

2、创建数据库表以及编写实体类

DROP TABLE IF EXISTS `user`;
    
    CREATE TABLE `user` (
      `id` int(11) NOT NULL auto_increment,
      `username` varchar(32) NOT NULL COMMENT '用户名称',
      `birthday` datetime default NULL COMMENT '生日',
      `sex` char(1) default NULL COMMENT '性别',
      `address` varchar(256) default NULL COMMENT '地址',
      PRIMARY KEY  (`id`)
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8;
    
    
    
    insert  into `user`(`id`,`username`,`birthday`,`sex`,`address`) values (41,'老王','2018-02-27 17:47:08','男','北京'),(42,'小二王','2018-03-02 15:09:37','女','北京金燕龙'),(43,'小二王','2018-03-04 11:34:34','女','北京金燕龙'),(45,'传智播客','2018-03-04 12:04:06','男','北京金燕龙'),(46,'老王','2018-03-07 17:37:26','男','北京'),(48,'小马宝莉','2018-03-08 11:44:00','女','北京修正');

package com.oceanstar.domain;
    
    import java.io.Serializable;
    import java.util.Date;
    
    public class User implements Serializable {
        
        private Integer id;
        private String username;
        private Date birthday;
        private String sex;
        private String address;
    
        。。。。。
    }

3、编写实体层dao接口

package com.oceanstar.Dao;
    
    import com.oceanstar.domain.User;
    
    import java.util.List;
    
    /**
     * 用户的持久层接口
     * */
    public interface IUserDao {
        
        /*
        * 查询所有
        * @return
        * */
        List<User> findAll();
    }

4、创建mybatis的主配置文件：SqlMapConfig.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="mysql">
            
            <environment id="mysql">
                
                <transactionManager type="JDBC"></transactionManager>
                
                <dataSource type="POOLED">
                    
                    <property name="driver" value="com.mysql.jdbc.Driver"/>
                    <property name="url" value="jdbc:mysql://localhost:3306/test?characterEncoding=utf8"/>
                    <property name="username" value="root"/>
                    <property name="password" value="123456"/>
                </dataSource>
            </environment>
        </environments>
    
        
        <mappers>
            <mapper resource="com/oceanstar/dao/IUserDao.xml"></mapper>
        </mappers>
    </configuration>

5、创建映射配置文件：IUserDao.xml

>  *  mybatis的映射配置文件位置必须和dao接口的包结构目录相同
> 
>  *  映射配置文件的mapper标签namespace属性的取值必须是dao的全限制类名
>  *  映射配置文件的操作配置(select)，id的取值必须是dao接口的方法名

这样我们在开发中就无需在写dao的实现类

6、编写测试类

## 3、使用mybatis进行基本的CRUD操作 ##

1、引入测试类

<dependency>
                <groupId>junit</groupId>
                <artifactId>junit</artifactId>
                <version>4.10</version>
            </dependency>

2、修改IUserDao

package com.oceanstar.dao;
    
    import com.oceanstar.domain.User;
    
    import java.util.List;
    
    /**
     * 用户的持久层接口
     * */
    public interface IUserDao {
        
        /*
        * 查询所有
        * @return
        * */
        List<User> findAll();
    
        /*
         * 根据id查询
         * @return
         * */
        User findById(Integer id);
    
        /*
         * 根据名称模糊查询
         * @param userName
         * @return
         * */
        List<User> findByName(String userName);
    
        /*
         * 查询总记录条数
         * @return
         * */
        int findTotal();
    
    
        /*
         * 保存用户
         * @param user
         * @return 影响数据库记录的行数
         * */
        int SaveUser(User user);
    
        /*
         * 根据userId删除
         * @return 影响数据库记录的行数
         * */
        int DeleteById(Integer userId);
    
    
        /*
         * 更新
         * @param user
         * @return 影响数据库记录的行数
         * */
        int UpdateUser(User user);
    
    
    }

3、修改IUserDao.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.oceanstar.dao.IUserDao">
        
        <select id="findAll" resultType="com.oceanstar.domain.User">
            select * from user ;
        </select>
    
        
        <select id="findById" parameterType="java.lang.Integer" resultType="com.oceanstar.domain.User">
            select * from user where id = #{
        aaaa} ;
        </select>
    
        
        <insert id="SaveUser" parameterType="com.oceanstar.domain.User">
            
            <selectKey keyColumn="id" keyProperty="id" resultType="int">
                select last_insert_id();
            </selectKey>
            
            insert into user (username, birthday, sex, address) values (#{
        username}, #{
        birthday}, #{
        sex}, #{
        address}) ;
        </insert>
    
    
        
        <select id="findByName" parameterType="java.lang.String" resultType="com.oceanstar.domain.User">
            select * from user where username like #{
        username};
        </select>
    
        
        <select id="findTotal" resultType="int">
            select count(id) from user;
        </select>
    
    
        
        <delete id="DeleteById" parameterType="INT" >
            delete from user where id = #{
        bbbb} ;
        </delete>
    
        
        <update id="UpdateUser" parameterType="com.oceanstar.domain.User" >
            update user set username = #{
        username}, birthday = #{
        birthday}, sex = #{
        sex},
            address = #{
        address}  where id = #{
        id} ;
        </update>
    
    
    
    </mapper>

4、修改测试类

package com.oceanstar.test;
    
    import com.oceanstar.dao.IUserDao;
    import com.oceanstar.domain.User;
    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 org.junit.After;
    import org.junit.Before;
    import org.junit.Test;
    
    import java.io.InputStream;
    import java.util.Date;
    import java.util.List;
    
    /*
    * 测试Mybatis
    * */
    public class MyBatisTest {
        
        private InputStream in;
        private  SqlSession sqlSession;
        private IUserDao iUserDao;
        @Before
        public void init() throws Exception{
        
            //1、读取配置文件
            in =  Resources.getResourceAsStream("SqlMapConfig.xml");
            //2、创建SqlSessionFactory的构建者对象
            SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder();
            //3、使用构建者对象创建工厂对象SqlSessionFactory --- 创建连接
            SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder.build(in);
            //4、使用SqlSessionFactory产生一个SqlSession对象  -- 创建会话组件
            sqlSession = sqlSessionFactory.openSession();
            //5、使用SqlSession创建dao接口的代理对象:   --- 代理持久层, 执行sql语句
            iUserDao = sqlSession.getMapper(IUserDao.class);
        }
    
        @After
        public void destory() throws Exception{
        
            sqlSession.commit();
            sqlSession.close();
            in.close();
        }
    
        @Test
        public void testFindAll() {
        
            //6、使用代理对象执行方法
            List<User> users = iUserDao.findAll();
            for (User user : users){
        
                System.out.println(user);
            }
        }
    
    
        @Test
        public void testFindById() {
        
            //6、使用代理对象执行查询方法
            User user = iUserDao.findById(41);
            System.out.println(user);
        }
    
        @Test
        public void testFindbyUserName() {
        
            //6、使用代理对象执行方法
            List<User> users = iUserDao.findByName("%王%");
            for (User user : users){
        
                System.out.println(user);
            }
        }
    
        @Test
        public void testFindTotal() {
        
            //6、使用代理对象执行查询方法
            int count = iUserDao.findTotal();
            System.out.println(count);
        }
    
        @Test
        public void testDeleteId() {
        
            //6、使用代理对象执行删除方法
            int i = iUserDao.DeleteById(41);
            System.out.println("删除一条记录后，影响数据库的行数" + i); // 就算它自动回滚，没有执行成功(因为自动提交被关闭了)，也会打印出"删除一条记录后，影响数据库的行数1"，所以不能根据返回值判断是否成功提交。
        }
    
        @Test
        public void testSaveUser(){
        
            User user = new User();
            user.setUsername("SaveTest");
            user.setAddress("aaaa");
            user.setBirthday(new Date());
            user.setSex("女");
    
            int i = iUserDao.SaveUser(user);
            System.out.println("插入一条记录后，影响数据库的行数" + i);
        }
    
        @Test
        public void testUpdateUser(){
        
            User user = iUserDao.findById(42);
            if (user == null){
        
                throw  new  RuntimeException("没有找到对应的id");
            }
    
            System.out.println(user);
            user.setUsername("testUpdate");
            user.setAddress("西湖");
            user.setBirthday(new Date());
            user.setSex("男");
    
            int i = iUserDao.UpdateUser(user);
            System.out.println("更新操作之后："+ user + "影响行数" + i);
        }
    }

## 4、MyBatis与JDBC编程的比较 ##

1、数据库链接创建，释放频繁造成系统资源浪费从而影响系统性能，如果使用数据库连接池可以解决此问题。  
解决：在SqlMapConfig.xml中配置数据库连接池，使用连接池管理数据库链接

2、Sql语句写在代码中不易维护，实际应用sql变化的可能较大，失去了变动需要改变java代码。  
解决：将Sql语句配置在xxx.xml文件中与Java代码分离

3、向sql语句传参麻烦，因为sql语句的where条件不一定，可能多也可能少，占位符需要和参数对应。  
解决：MyBatis自动将Java对象映射至Sql语句，通过statement中的parameterType定义输入参数的类型。

4、对结果集解析麻烦，Sql变化导致解析代码变化，且解析前需要遍历，如果能将数据库记录封装成pojo对象解析比较方便。  
解决：MyBatis自动将Sql执行结构映射至Java对象，通过statement中的resultType定义输出结果的类型。