您现在的位置是：首页 > 个人日记个人日记

mybatis-02-CRUD简单操作

2019-02-02 13:58:15【个人日记】262人已围观

简介这是mybatis简单的CRUD操作,可以参考下里面的sql语句

CRUD配置

对商品数据的增删改查

项目结构

配置pom.xml文件

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns="http://maven.apache.org/POM/4.0.0"
  3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <modelVersion>4.0.0</modelVersion>
  6.     <groupId>test</groupId>
  7.     <artifactId>mybatis</artifactId>
  8.     <version>1.0-SNAPSHOT</version>
  10.     <dependencies>
  11.         <!--log记录-->
  12.         <dependency>
  13.             <groupId>log4j</groupId>
  14.             <version>1.2.17</version>
  15.         </dependency>
  16.         <!--MySQL驱动-->
  17.         <dependency>
  18.             <groupId>mysql</groupId>
  19.             <version>5.1.6</version>
  20.         </dependency>
  21.         <!-- ibatis.jar -->
  22.         <dependency>
  23.             <version>3.4.6</version>
  24.         </dependency>
  25.         <!-- junit.jar -->
  26.         <dependency>
  27.             <groupId>junit</groupId>
  28.             <version>4.12</version>
  29.             <scope>test</scope>
  30.         </dependency>
  31.     </dependencies>

mybatis-config.xml与Product.java文件并未变化

Mapper文件映射

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE mapper
  3.         PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
  4.         "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
  5. <mapper namespace="category">
  6.     <!--查询所有-->
  7.     <select id="fingAll" resultType="com.huangxin.model.ProductCategory">
  8.         SELECT * FROM product
  9.     </select>
  10.     <!--查询一个-->
  11.     <select id="getById" parameterType="java.lang.Long" resultType="com.huangxin.model.ProductCategory">
  12.         SELECT * FROM product WHERE id = #{id}
  13.     </select>
  14.     <!--${只能放value}-->
  15.     <!--使用${}可能会有sql注入-->
  16.     <!--使用"%"#{*}"#"也可以-->
  17.     <select id="findByCategoryName" parameterType="java.lang.String" resultType="com.huangxin.model.ProductCategory">
  18.         SELECT * FROM product WHERE supplier  LIKE  '%${value}%'
  19.     </select>
  20.     <!--插入新数据-->
  21.     <insert id="insert" parameterType="com.huangxin.model.ProductCategory">
  22.         INSERT INTO product(productName,salePrice,supplier,brand,costPrice)
  23.         VALUES(#{productName},#{salePrice},#{supplier},#{brand},#{costPrice})
  24.    </insert>
  25.     <!--修改数据-->
  26.     <update id="update" parameterType="com.huangxin.model.ProductCategory">
  27.         UPDATE product SET supplier=#{supplier} WHERE id=#{id}
  28.     </update>
  29.     <!--删除指定数据-->
  30.     <delete id="deleteById" parameterType="java.lang.Long">
  31.         DELETE  FROM product WHERE id = #{id}
  32.     </delete>
  33. </mapper>

加入log4j测试

将其放入resources目录
配置log4j.xml文件

  1. #全局配置
  2. log4j.rootLogger=DEBUG,console
  3. #debug调试
  4. #控制台日志输出
  5. log4j.appender.console=org.apache.log4j.ConsoleAppender
  6. log4j.appender.console.layout=org.apache.log4j.PatternLayout
  7. log4j.appender.console.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} [%p] %m %n

Junit测试

配置DAO.java文件

  1. package com.huangxin.dao;
  2. import com.huangxin.model.ProductCategory;
  3. import java.util.List;
  4. public interface ProductDAO {
  5.     /**
  6.      * 根据id删除信息
  7.      *
  8.      * @param id
  9.      */
  10.     void deleteById(Long id);
  11.     /**
  12.      * 通过ProductCategory对象插入信息
  13.      *
  14.      * @param productCategory
  15.      */
  16.     void insert(ProductCategory productCategory);
  17.     /**
  18.      * 更改商品信息
  19.      *
  20.      * @param productCategory
  21.      */
  22.     void update(ProductCategory productCategory);
  23.     /**
  24.      * 查询所有商品信息
  25.      *
  26.      * @return
  27.      */
  28.     List<ProductCategory> getAll();
  29.     /**
  30.      * 根据id查询信息
  31.      *
  32.      * @param id
  33.      */
  34.     ProductCategory getById(Long id);
  35.     /**
  36.      * 模糊查询
  37.      *
  38.      * @param categoryName
  39.      * @return
  40.      */
  41.     List<ProductCategory> findByCategoryName(String categoryName);
  42. }

实现接口

配置DAOImlp.java文件

  1. package com.huangxin.dao.impl;
  2. import com.huangxin.dao.ProductDAO;
  3. import com.huangxin.model.ProductCategory;
  4. import org.apache.ibatis.session.SqlSession;
  5. import org.apache.ibatis.session.SqlSessionFactory;
  6. import java.util.List;
  7. public class ProductDAOImpl implements ProductDAO {
  8.     private SqlSessionFactory factory;
  9.     /**
  10.      * 带参数的构造函数
  11.      *
  12.      * @param factory
  13.      */
  14.     public ProductDAOImpl(SqlSessionFactory factory) {
  15.         this.factory = factory;
  16.     }
  17.     public void deleteById(Long id) {
  18.         SqlSession sqlSession = factory.openSession(true);
  19.         sqlSession.delete("category.deleteById", id);
  20.         sqlSession.close();
  21.     }
  22.     public void insert(ProductCategory productCategory) {
  23.         // 获取一个sqlSession
  24.         SqlSession sqlSession = factory.openSession(true);//设置事务是否自动提交
  25.         sqlSession.insert("category.insert", productCategory);
  26.         //sqlSession.commit();如果不自动提交事务,最后在这里提交
  27.         sqlSession.close();
  28.     }
  29.     public void update(ProductCategory productCategory) {
  30.         // 获取一个sqlSession
  31.         SqlSession sqlSession = factory.openSession(true);//设置事务是否自动提交
  32.         sqlSession.update("category.update", productCategory);
  33.         sqlSession.close();
  35.     }
  36.     public List<ProductCategory> getAll() {
  37.         // 获取一个sqlSession
  38.         SqlSession sqlSession = factory.openSession();
  39.         //赋值给list
  40.         List<ProductCategory> list = sqlSession.selectList("category.fingAll");
  41.         //关闭sqlSession
  42.         sqlSession.close();
  43.         return list;
  44.     }
  45.     public ProductCategory getById(Long id) {
  46.         //获取SqlSession会话
  47.         SqlSession sqlSession = factory.openSession();
  48.         ProductCategory category = sqlSession.selectOne("category.getById", id);
  49.         sqlSession.close();
  50.         return category;
  51.     }
  52.     public List<ProductCategory> findByCategoryName(String categoryName) {
  53.         SqlSession sqlSession = factory.openSession();
  54.         List<ProductCategory> list = sqlSession.selectList("category.findByCategoryName", categoryName);
  55.         sqlSession.close();
  56.         return list;
  57.     }
  58. }

junit测试

  1. package com.huangxin.dao.impl;
  3. import com.huangxin.dao.ProductDAO;
  4. import com.huangxin.model.ProductCategory;
  5. import org.apache.ibatis.io.Resources;
  6. import org.apache.ibatis.session.SqlSessionFactory;
  7. import org.apache.ibatis.session.SqlSessionFactoryBuilder;
  8. import org.junit.Before;
  9. import org.junit.Test;
  10. import java.io.InputStream;
  11. import java.math.BigDecimal;
  12. import java.util.List;
  13. public class ProductDAOImplTest {
  14.     private SqlSessionFactory factory;
  15.     private ProductDAO dao;
  16.     @Before
  17.     public void setUp() throws Exception {
  18.         //将全局配置文件读取
  19.         InputStream in = Resources.getResourceAsStream("mybatis-config.xml");
  20.         factory = new SqlSessionFactoryBuilder().build(in);
  21.         dao = new ProductDAOImpl(factory);
  22.     }
  23.     @Test
  24.     public void deleteById() {
  25.         dao.deleteById(22L);
  26.     }
  27.     @Test
  28.     public void insert() {
  29.         ProductCategory productCategory = new ProductCategory();
  30.         productCategory.setProductName("测试");
  31.         productCategory.setBrand("未知");
  32.         productCategory.setCostPrice(new BigDecimal("50"));
  33.         productCategory.setSupplier("未知");
  34.         productCategory.setSalePrice(new BigDecimal("100"));
  35.         dao.insert(productCategory);
  36.     }
  37.     @Test
  38.     public void update() {
  39.         ProductCategory productCategory = dao.getById(22L);
  40.         productCategory.setSupplier("新数据");
  41.         dao.update(productCategory);
  42.     }
  43.     @Test
  44.     public void getAll() {
  45.         List<ProductCategory> lists = dao.getAll();
  46.         for (ProductCategory list : lists) {
  47.             System.out.println(list);
  48.         }
  49.     }
  50.     @Test
  51.     public void getById() {
  52.         ProductCategory productCategory = dao.getById(6l);
  53.         System.out.println(productCategory);
  54.         System.out.println(productCategory.getProductName());
  55.     }
  56.     @Test
  57.     public void findByCategoryName1() {
  58.         for (ProductCategory productCategory : dao.findByCategoryName("未知")) {
  59.          System.out.println(productCategory);
  60.         }
  61.     }
  62. }

控制台输出结果

Tags： JavaWeb  

上一篇： spring-03-构造方法注入和set方法注入

下一篇： spring-05-复杂数据类型注入

相关文章

随机图文

评论区

    2024-12-21 21:58:50

    站长

    没有登录功能是为了方便大家留言,但留言接口现在被恶意攻击,将关闭留言接口,如有疑问,请联系我的QQ 1538933906/同微信


文章评论



给自个选个头像吧!






站长推荐

spring-03-构造方法注入和set方法注入

标签

猜你喜欢

站点信息

  • 建站时间:   2019-01-31
  • 网站程序:   Tomcat+nginx
  • 文章统计:   44篇文章
  • 标签管理:   标签云
  • 微信公众号：  扫描二维码，联系我