ToB企服应用市场:ToB评测及商务社交产业平台

标题: quarkus数据库篇之一：比官方demo更简单的基础操作 [打印本页]
作者: 曹旭辉    时间: 2023-8-28 12:07
标题: quarkus数据库篇之一：比官方demo更简单的基础操作
欢迎访问我的GitHub

这里分类和汇总了欣宸的全部原创(含配套源码)：https://github.com/zq2599/blog_demos
关于《数据库篇》

本篇概览



环境和版本信息

源码下载

名称链接备注项目主页https://github.com/zq2599/blog_demos该项目在GitHub上的主页git仓库地址(https)https://github.com/zq2599/blog_demos.git该项目源码的仓库地址，https协议git仓库地址(ssh)git@github.com:zq2599/blog_demos.git该项目源码的仓库地址，ssh协议
确认数据库已就绪

  1. docker run \
  2. --name quarkus_test \
  3. -e POSTGRES_USER=quarkus \
  4. -e POSTGRES_PASSWORD=123456 \
  5. -e POSTGRES_DB=quarkus_test \
  6. -p 5432:5432 \
  7. -v /xxx:/var/lib/postgresql/data \
  8. postgres:13.3
复制代码

新建maven子工程basic-db

  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.     <parent>
  6.         <artifactId>quarkus-tutorials</artifactId>
  7.         <groupId>com.bolingcavalry</groupId>
  8.         <version>1.0-SNAPSHOT</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  11.     <artifactId>basic-db</artifactId>
  12.     <dependencies>
  13.         <dependency>
  14.             <groupId>io.quarkus</groupId>
  15.             <artifactId>quarkus-arc</artifactId>
  16.         </dependency>
  17.         
  18.         <dependency>
  19.             <groupId>io.quarkus</groupId>
  20.             <artifactId>quarkus-agroal</artifactId>
  21.         </dependency>
  22.         
  23.         <dependency>
  24.             <groupId>io.quarkus</groupId>
  25.             <artifactId>quarkus-hibernate-orm</artifactId>
  26.         </dependency>
  27.         
  28.         <dependency>
  29.             <groupId>io.quarkus</groupId>
  30.             <artifactId>quarkus-jdbc-postgresql</artifactId>
  31.         </dependency>
  32.         
  33.         <dependency>
  34.             <groupId>io.quarkus</groupId>
  35.             <artifactId>quarkus-junit5</artifactId>
  36.             <scope>test</scope>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>io.rest-assured</groupId>
  40.             <artifactId>rest-assured</artifactId>
  41.             <scope>test</scope>
  42.         </dependency>
  43.     </dependencies>
  45.     <build>
  46.         <plugins>
  47.             <plugin>
  48.                 <groupId>${quarkus.platform.group-id}</groupId>
  49.                 <artifactId>quarkus-maven-plugin</artifactId>
  50.                 <extensions>true</extensions>
  51.                 <executions>
  52.                     <execution>
  53.                         <goals>
  54.                             <goal>build</goal>
  55.                             <goal>generate-code</goal>
  56.                             <goal>generate-code-tests</goal>
  57.                         </goals>
  58.                     </execution>
  59.                 </executions>
  60.             </plugin>
  61.             <plugin>
  62.                 <artifactId>maven-compiler-plugin</artifactId>
  63.                 <configuration>
  64.                     <compilerArgs>
  65.                         <arg>-parameters</arg>
  66.                     </compilerArgs>
  67.                 </configuration>
  68.             </plugin>
  69.             <plugin>
  70.                 <artifactId>maven-surefire-plugin</artifactId>
  71.                 <configuration>
  72.                     <systemPropertyVariables>
  73.                         <java.util.logging.manager>org.jboss.logmanager.LogManager</java.util.logging.manager>
  74.                         <maven.home>${maven.home}</maven.home>
  75.                     </systemPropertyVariables>
  76.                 </configuration>
  77.             </plugin>
  78.         </plugins>
  79.     </build>
  80. </project>
复制代码
配置文件

  1. quarkus.datasource.db-kind=postgresql
  2. quarkus.hibernate-orm.log.sql=true
  3. quarkus.datasource.jdbc.max-size=8
  4. quarkus.datasource.jdbc.min-size=2
复制代码
  1. quarkus.datasource.username=quarkus
  2. quarkus.datasource.password=123456
  3. quarkus.datasource.jdbc.url=jdbc:postgresql://192.168.50.43:15432/quarkus_test
  4. quarkus.hibernate-orm.database.generation=drop-and-create
  5. quarkus.hibernate-orm.sql-load-script=import.sql
复制代码
取值含义none啥也不做create第一次启动会建表，之后启动不会再改动drop-and-create每一次启动应用的时候都删表(数据也没了)，然后建表，再执行import.sql导入数据drop启动应用的时候删表，不删库update保留数据，升级表结构validate检查表结构与entity是否匹配


SQL文件

  1. INSERT INTO known_fruits(id, name) VALUES (1, 'Cherry');
  2. INSERT INTO known_fruits(id, name) VALUES (2, 'Apple');
  3. INSERT INTO known_fruits(id, name) VALUES (3, 'Banana');
复制代码
编码：实体类

  1. package com.bolingcavalry.db.entity;
  3. import javax.persistence.Cacheable;
  4. import javax.persistence.Column;
  5. import javax.persistence.Entity;
  6. import javax.persistence.GeneratedValue;
  7. import javax.persistence.Id;
  8. import javax.persistence.NamedQuery;
  9. import javax.persistence.QueryHint;
  10. import javax.persistence.SequenceGenerator;
  11. import javax.persistence.Table;
  13. @Entity
  14. @Table(name = "known_fruits")
  15. @NamedQuery(name = "Fruits.findAll", query = "SELECT f FROM Fruit f ORDER BY f.name", hints = @QueryHint(name = "org.hibernate.cacheable", value = "true"))
  16. @Cacheable
  17. public class Fruit {
  19.     @Id
  20.     @SequenceGenerator(name = "fruitsSequence", sequenceName = "known_fruits_id_seq", allocationSize = 1, initialValue = 10)
  21.     @GeneratedValue(generator = "fruitsSequence")
  22.     private Integer id;
  24.     @Column(length = 40, unique = true)
  25.     private String name;
  27.     public Fruit() {
  28.     }
  30.     public Fruit(String name) {
  31.         this.name = name;
  32.     }
  34.     public Integer getId() {
  35.         return id;
  36.     }
  38.     public void setId(Integer id) {
  39.         this.id = id;
  40.     }
  42.     public String getName() {
  43.         return name;
  44.     }
  46.     public void setName(String name) {
  47.         this.name = name;
  48.     }
  49. }
复制代码
service层

  1. package com.bolingcavalry.db.service;
  3. import com.bolingcavalry.db.entity.Fruit;
  4. import javax.enterprise.context.ApplicationScoped;
  5. import javax.inject.Inject;
  6. import javax.persistence.EntityManager;
  7. import javax.transaction.Transactional;
  8. import java.util.List;
  10. @ApplicationScoped
  11. public class FruitService {
  12.     @Inject
  13.     EntityManager entityManager;
  15.     public List<Fruit> get() {
  16.         return entityManager.createNamedQuery("Fruits.findAll", Fruit.class)
  17.                 .getResultList();
  18.     }
  20.     public Fruit getSingle(Integer id) {
  21.         return entityManager.find(Fruit.class, id);
  22.     }
  24.     @Transactional
  25.     public void create(Fruit fruit) {
  26.         entityManager.persist(fruit);
  27.     }
  29.     @Transactional
  30.     public void update(Integer id, Fruit fruit) {
  31.         Fruit entity = entityManager.find(Fruit.class, id);
  33.         if (null!=entity) {
  34.             entity.setName(fruit.getName());
  35.         }
  36.     }
  38.     @Transactional
  39.     public void delete(Integer id) {
  40.         Fruit entity = entityManager.getReference(Fruit.class, id);
  42.         if (null!=entity) {
  43.             entityManager.remove(entity);
  44.         }
  45.     }
  46. }
复制代码
单元测试类

  1. package com.bolingcavalry;
  3. import com.bolingcavalry.db.entity.Fruit;
  4. import com.bolingcavalry.db.service.FruitService;
  5. import io.quarkus.test.junit.QuarkusTest;
  6. import org.junit.jupiter.api.*;
  8. import javax.inject.Inject;
  9. import java.util.List;
  11. @QuarkusTest
  12. @TestMethodOrder(MethodOrderer.OrderAnnotation.class)
  13. public class FruitServiceTest {
  15.     /**
  16.      * import.sql中导入的记录数量，这些是应用启动是导入的
  17.      */
  18.     private static final int EXIST_RECORDS_SIZE = 3;
  20.     /**
  21.      * import.sql中，第一条记录的id
  22.      */
  23.     private static final int EXIST_FIRST_ID = 1;
  25.     /**
  26.      * 在Fruit.java中，id字段的SequenceGenerator指定了initialValue等于10，
  27.      * 表示自增ID从10开始
  28.      */
  29.     private static final int ID_SEQUENCE_INIT_VALUE = 10;
  31.     @Inject
  32.     FruitService fruitService;
  34.     @Test
  35.     @DisplayName("list")
  36.     @Order(1)
  37.     public void testGet() {
  38.         List<Fruit> list = fruitService.get();
  39.         // 判定非空
  40.         Assertions.assertNotNull(list);
  41.         // import.sql中新增3条记录
  42.         Assertions.assertEquals(EXIST_RECORDS_SIZE, list.size());
  43.     }
  45.     @Test
  46.     @DisplayName("getSingle")
  47.     @Order(2)
  48.     public void testGetSingle() {
  49.         Fruit fruit = fruitService.getSingle(EXIST_FIRST_ID);
  50.         // 判定非空
  51.         Assertions.assertNotNull(fruit);
  52.         // import.sql中的第一条记录
  53.         Assertions.assertEquals("Cherry", fruit.getName());
  54.     }
  56.     @Test
  57.     @DisplayName("update")
  58.     @Order(3)
  59.     public void testUpdate() {
  60.         String newName = "ShanDongBigCherry";
  62.         fruitService.update(EXIST_FIRST_ID, new Fruit(newName));
  64.         Fruit fruit = fruitService.getSingle(EXIST_FIRST_ID);
  65.         // 从数据库取出的对象，其名称应该等于修改的名称
  66.         Assertions.assertEquals(newName, fruit.getName());
  67.     }
  69.     @Test
  70.     @DisplayName("create")
  71.     @Order(4)
  72.     public void testCreate() {
  73.         Fruit fruit = new Fruit("Orange");
  74.         fruitService.create(fruit);
  75.         // 由于是第一次新增，所以ID应该等于自增ID的起始值
  76.         Assertions.assertEquals(ID_SEQUENCE_INIT_VALUE, fruit.getId());
  77.         // 记录总数应该等于已有记录数+1
  78.         Assertions.assertEquals(EXIST_RECORDS_SIZE+1, fruitService.get().size());
  79.     }
  81.     @Test
  82.     @DisplayName("delete")
  83.     @Order(5)
  84.     public void testDelete() {
  85.         // 先记删除前的总数
  86.         int numBeforeDelete = fruitService.get().size();
  88.         // 删除第一条记录
  89.         fruitService.delete(EXIST_FIRST_ID);
  91.         // 记录数应该应该等于删除前的数量减一
  92.         Assertions.assertEquals(numBeforeDelete-1, fruitService.get().size());
  93.     }
  94. }
复制代码

IDEA的小坑




运行单元测试



欢迎关注博客园：程序员欣宸

学习路上，你不孤单，欣宸原创一路相伴...

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！



欢迎光临 ToB企服应用市场:ToB评测及商务社交产业平台 (https://dis.qidao123.com/) Powered by Discuz! X3.4