MyBatis增删查改实战

迷南。 2021-07-24 17:22 632阅读 0赞

一 配置文件

1 db.properties

  1. driver=com.mysql.jdbc.Driver
  2. url=jdbc:mysql://127.0.0.1:3306/mybatis
  3. username=root
  4. password=123456

2 mybatis-config.xml

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE configuration
  3.   PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
  4.   "http://mybatis.org/dtd/mybatis-3-config.dtd">
  5.   <!--  XML 配置文件包含对 MyBatis 系统的核心设置 -->
  6. <configuration>
  7.      <!-- 引入properties资源文件 -->
  8.      <properties resource="db.properties"/>
  9.      <!-- 指定 MyBatis 所用日志的具体实现 -->
  10.      <settings>
  11.            <setting name="logImpl" value="LOG4J"/>
  12.      </settings>
  13.      <!-- 设置别名 -->
  14.      <typeAliases>
  15.            <typeAlias  alias="user"  type="org.fkit.domain.User"/>
  16.      </typeAliases>
  17.      <!-- 环境配置，即连接的数据库。 -->
  18.      <environments default="mysql">
  19.     <environment id="mysql">
  20.     <!--  指定事务管理类型，type="JDBC"指直接简单使用了JDBC的提交和回滚设置 -->
  21.       <transactionManager type="JDBC"/>
  22.       <!--  dataSource指数据源配置，POOLED是JDBC连接对象的数据源连接池的实现。 -->
  23.       <dataSource type="POOLED">
  24.         <property name="driver" value="${driver}"/>
  25.         <property name="url" value="${url}"/>
  26.         <property name="username" value="${username}"/>
  27.         <property name="password" value="${password}"/>
  28.       </dataSource>
  29.     </environment>
  30.   </environments>
  31.   <!-- mappers告诉了MyBatis去哪里找持久化类的映射文件 -->
  32.   <mappers>
  33.       <mapper resource="org/fkit/mapper/UserMapper.xml"/>
  34.   </mappers>
  35. </configuration>

3 log4j.xml

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE log4j:configuration SYSTEM "log4j.dtd">  
  3. <log4j:configuration  xmlns:log4j="http://jakarta.apache.org/log4j/">  
  4.     <appender name="STDOUT"  class="org.apache.log4j.ConsoleAppender">  
  5.         <layout class="org.apache.log4j.PatternLayout">  
  6.             <param name="ConversionPattern" value="%5p [%t] %m%n"  />  
  7.         </layout>  
  8.     </appender>   
  9.      <logger name="org.fkit.mapper.UserMapper">  
  10.         <level value="DEBUG" />  
  11.     </logger>
  12.     <root>  
  13.         <level value="ERROR" />  
  14.         <appender-ref ref="STDOUT" />  
  15.     </root>  
  16. </log4j:configuration>

二 领域模型

  1. package org.fkit.domain;
  2. import java.io.Serializable;
  3. /**
  4. *
  5. * CREATE TABLE `tb_user` (
  6.   `id` INT(11) NOT NULL AUTO_INCREMENT,
  7.   `name` VARCHAR(18) DEFAULT NULL,
  8.   `sex` CHAR(2) DEFAULT NULL,
  9.   `age` INT(11) DEFAULT NULL,
  10.   PRIMARY KEY  (`id`)
  11. )
  12. */
  13. public class User implements Serializable{
  15.      private static final long serialVersionUID = 1L;
  17.      private Integer id;
  18.      private String name;
  19.      private String sex;
  20.      private Integer age;
  22.      public User() {
  23.            super();
  24.            // TODO Auto-generated constructor stub
  25.      }
  27.      public User( String name, String sex, Integer age) {
  28.            super();
  29.            this.name = name;
  30.            this.sex = sex;
  31.            this.age = age;
  32.      }
  33.      public Integer getId() {
  34.            return id;
  35.      }
  36.      public void setId(Integer id) {
  37.            this.id = id;
  38.      }
  39.      public String getName() {
  40.            return name;
  41.      }
  42.      public void setName(String name) {
  43.            this.name = name;
  44.      }
  45.      public String getSex() {
  46.            return sex;
  47.      }
  48.      public void setSex(String sex) {
  49.            this.sex = sex;
  50.      }
  51.      public Integer getAge() {
  52.            return age;
  53.      }
  54.      public void setAge(Integer age) {
  55.            this.age = age;
  56.      }
  57.      @Override
  58.      public String toString() {
  59.            return "User [id=" + id + ", name=" + name + ", sex="  + sex + ", age="
  60.                      + age + "]";
  61.      }
  64. }

三 构造会话工厂

  1. package org.fkit.factory;
  3. import java.io.InputStream;
  5. import org.apache.ibatis.io.Resources;
  6. import org.apache.ibatis.session.SqlSession;
  7. import org.apache.ibatis.session.SqlSessionFactory;
  8. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
  10. public class FKSqlSessionFactory {
  12.     private static SqlSessionFactory sqlSessionFactory = null;
  14.     // 初始化创建SqlSessionFactory对象
  15.     static{
  16.         try (// 读取mybatis-config.xml文件
  17.                 InputStream is = Resources.getResourceAsStream("mybatis-config.xml");
  18.             ){
  19.             sqlSessionFactory = new SqlSessionFactoryBuilder()
  20.                     .build(is);
  21.         } catch (Exception e) {
  22.             e.printStackTrace();
  23.         }
  24.     }
  26.     // 获取SqlSession对象的静态方法
  27.     public static SqlSession getSqlSession(){
  28.         return sqlSessionFactory.openSession();
  29.     }
  31.     // 获取SqlSessionFactory的静态方法
  32.     public static SqlSessionFactory getSqlSessionFactory() {
  33.         return sqlSessionFactory;
  34.     }
  36. }

四 mapper文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  3. "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  4. <!-- namespace指用户自定义的命名空间。 -->
  5. <mapper namespace="org.fkit.mapper.UserMapper">
  6.      <!-- insert操，
  7.      parameterType="user"表示该插入语句需要一个user对象作为参数
  8.      useGeneratedKeys="true"表示使用自动增长的主键 -->
  9.   <insert id="saveUser" parameterType="user"
  10.   useGeneratedKeys="true" keyProperty="id">
  11.       INSERT INTO TB_USER(name,sex,age)
  12.       VALUES(#{name},#{sex},#{age})
  13.   </insert>
  15.   <!-- select操作
  16.   parameterType="int"表示该查询语句需要一个int类型的参数
  17.   resultType="user"表示返回的是一个user对象 -->
  18.   <select id="selectUser" parameterType="int" resultType="user">
  19.       SELECT * FROM TB_USER WHERE id = #{id}
  20.   </select>
  22.   <!-- update操作
  23.   parameterType="user"表示该更新语句需要一个user对象作为参数-->
  24.   <update id="modifyUser" parameterType="user">
  25.       UPDATE TB_USER
  26.       SET name = #{name},sex = #{sex},age = #{age}
  27.       WHERE id = #{id}
  28.   </update>
  30.   <!-- delete操作 parameterType="int"表示该查询语句需要一个int类型的参数-->
  31.   <delete id="removeUser" parameterType="int">
  32.       DELETE FROM TB_USER WHERE id = #{id}
  33.   </delete>
  35. </mapper>

五 测试

1 增

  1. package org.fkit.test;
  3. import org.apache.ibatis.session.SqlSession;
  4. import org.fkit.domain.User;
  5. import org.fkit.factory.FKSqlSessionFactory;
  7. public class InsertTest {
  9.     public static void main(String[] args)  {
  10.         // 定义SqlSession变量
  11.         SqlSession sqlSession = null;
  12.         try {
  13.             // 创建SqlSession实例
  14.             sqlSession = FKSqlSessionFactory.getSqlSession();
  15.             // 创建User对象
  16.             User user = new User("jack", "男", 22);
  17.             // 插入数据
  18.             sqlSession.insert("org.fkit.mapper.UserMapper.saveUser", user);
  19.             // 提交事务
  20.             sqlSession.commit();
  21.         } catch (Exception e) {
  22.             // 回滚事务
  23.             sqlSession.rollback();
  24.             e.printStackTrace();
  25.         }finally {
  26.             // 关闭SqlSession
  27.             if(sqlSession != null)
  28.                 sqlSession.close();
  29.         }
  31.     }
  33. }

2 查

  1. package org.fkit.test;
  3. import org.apache.ibatis.session.SqlSession;
  4. import org.fkit.domain.User;
  5. import org.fkit.factory.FKSqlSessionFactory;
  7. public class SelectTest {
  9.     public static void main(String[] args)  {
  10.         // 定义SqlSession变量
  11.         SqlSession sqlSession = null;
  12.         try {
  13.             // 创建SqlSession实例
  14.             sqlSession = FKSqlSessionFactory.getSqlSession();
  15.             // 根据id查询User对象
  16.             User user = sqlSession.selectOne("org.fkit.mapper.UserMapper.selectUser",1);
  17.             System.out.println(user);
  18.             // 提交事务
  19.             sqlSession.commit();
  20.         } catch (Exception e) {
  21.             // 回滚事务
  22.             sqlSession.rollback();
  23.             e.printStackTrace();
  24.         }finally {
  25.             // 关闭SqlSession
  26.             if(sqlSession != null)
  27.                 sqlSession.close();
  28.         }                
  29.     }
  31. }

3 改

  1. package org.fkit.test;
  3. import org.apache.ibatis.session.SqlSession;
  4. import org.fkit.domain.User;
  5. import org.fkit.factory.FKSqlSessionFactory;
  7. public class UpadeTest {
  9.     public static void main(String[] args)  {
  10.         // 定义SqlSession变量
  11.         SqlSession sqlSession = null;
  12.         try {
  13.             // 创建SqlSession实例
  14.             sqlSession = FKSqlSessionFactory.getSqlSession();
  15.             // 根据id查询User对象
  16.             User user = sqlSession.selectOne("org.fkit.mapper.UserMapper.selectUser",1);
  17.             // 修改User对象的属性值
  18.             user.setName("tom");
  19.             user.setAge(25);
  20.             // 修改User对象
  21.             sqlSession.update("org.fkit.mapper.UserMapper.modifyUser", user);
  22.             // 提交事务
  23.             sqlSession.commit();
  24.         } catch (Exception e) {
  25.             // 回滚事务
  26.             sqlSession.rollback();
  27.             e.printStackTrace();
  28.         }finally {
  29.             // 关闭SqlSession
  30.             if(sqlSession != null)
  31.                 sqlSession.close();
  32.         }        
  33.     }
  34. }

4 删

  1. package org.fkit.test;
  4. import org.apache.ibatis.session.SqlSession;
  5. import org.fkit.factory.FKSqlSessionFactory;
  7. public class DeleteTest {
  9.     public static void main(String[] args)  {
  10.         // 定义SqlSession变量
  11.         SqlSession sqlSession = null;
  12.         try {
  13.             // 创建SqlSession实例
  14.             sqlSession = FKSqlSessionFactory.getSqlSession();
  15.             // 删除id为1的User对象
  16.             sqlSession.delete("org.fkit.mapper.UserMapper.removeUser", 1);
  17.             // 提交事务
  18.             sqlSession.commit();
  19.         } catch (Exception e) {
  20.             // 回滚事务
  21.             sqlSession.rollback();
  22.             e.printStackTrace();
  23.         }finally {
  24.             // 关闭SqlSession
  25.             if(sqlSession != null)
  26.                 sqlSession.close();
  27.         }    
  28.     }
  30. }

六 测试

1 增

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70

2 查

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 1

3 改

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 2

4 删

watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2NoZW5ncWl1bWluZw_size_16_color_FFFFFF_t_70 3

发表评论

表情：
评论列表 （有 0 条评论，632人围观）

还没有评论，来说两句吧...

相关阅读

    相关 SQL增删改查——实战

            这次在机房重构中，配合SQLHelper，SQL语句中的增删改查都用到了。翻看第一次机房时候的代码，发现，当时用到的语句只有一个查询，增删改的功能就是用查询语句

    た 入场券た 入场券/ 0 赞/ 318 阅读