Spring Boot对接Oracle数据库

Spring Boot对接Oracle数据库

最近学习了Oracle数据库，那么如何使用Spring Boot和MyBatis Plus对接Oracle数据库呢？

这就有了这篇随记，具体流程如下

1、创建Maven工程

创建一个空的Maven工程，导入如下依赖：

    4.0.0
    
        org.springframework.boot
        spring-boot-starter-parent
        2.3.7.RELEASE
        
    
    org.example
    oracle-init
    1.0-SNAPSHOT
    
        8
        8
        UTF-8
    
    
        
            org.springframework.boot
            spring-boot-starter
            2.3.7.RELEASE
        
        
            org.springframework.boot
            spring-boot-starter-test
            2.3.7.RELEASE
        
        
        
            com.oracle.database.jdbc
            ojdbc6
            11.2.0.4
        
        
            org.projectlombok
            lombok
            1.16.10
            provided
        





        
            com.baomidou
            mybatis-plus-boot-starter
            3.5.3.2
        
        
            org.junit.jupiter
            junit-jupiter
            RELEASE
            compile
        
    

tips：这里碰到一个坑，我本机适用的Oracle数据库版本是11g XE，所以要使用的驱动为ojdbc5/ojdbc6，不然连接老会失败。

2、application.yml

在配置文件中填写数据库连接的参数

spring:
  datasource:
      username: pp
      password: 123456
      url: jdbc:oracle:thin:@localhost:1521:XE
      driver-class-name: oracle.jdbc.OracleDriver

参数说明：

• username：数据库连接用户名
• password：数据库连接密码
• url：连接地址
• driver-class-name：数据库驱动

  3、创建实例数据表

  为了演示本次对接Oracle数据库，我们需要一张测试数据表

  3.1创建Users数据表，SQL如下:

  CREATE TABLE users (
    id INT PRIMARY KEY,
    username VARCHAR(50) NOT NULL,
    password VARCHAR(50) NOT NULL,
    email VARCHAR(100) NOT NULL,
    created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP
  );
  

  什么？没有测试数据！！！Orz…

  这里可以使用Oracle数据库的PL/SQL编程来批量生成测试数据，真香！！

  3.2PL/SQL批量生产测试数据

  sql如下:

  DECLARE
    TYPE user_type IS RECORD (
      id NUMBER,
      username VARCHAR2(50),
      email VARCHAR2(100),
      password VARCHAR2(100),
      created_at DATE
    );
    TYPE user_list IS TABLE OF user_type;
    l_users user_list := user_list();
  BEGIN
    FOR i IN 1..100 LOOP
      l_users.extend;
      l_users(i).id := i;
      l_users(i).username := 'user' || i;
      l_users(i).email := 'user' || i || '@example.com';
      l_users(i).password := 'password' || i;
      l_users(i).created_at := SYSDATE; -- 使用当前时间作为创建时间
    END LOOP;
    FORALL i IN 1..l_users.COUNT
      INSERT INTO users (id, username, email, password, created_at)
      VALUES (l_users(i).id, l_users(i).username, l_users(i).email, l_users(i).password, l_users(i).created_at);
    COMMIT;
    DBMS_OUTPUT.PUT_LINE('Data inserted successfully.');
  EXCEPTION
    WHEN OTHERS THEN
      DBMS_OUTPUT.PUT_LINE('Error: ' || SQLERRM);
      ROLLBACK;
  END;
  

  执行之后查看数据表中的数据：

  

  OK！准备工作完成，接下来就可以进行对接了。

  4、使用MP对Oracle进行CRUD

  4.1创建实体类

  User：

  /**
   * TODO User实体类
   * @version 1.0
   * @author ss_419
   * @date 2023/8/11 14:49
   */
  @Data
  @AllArgsConstructor
  @NoArgsConstructor
  // 指定Oracle数据库中的表名
  @TableName("users")
  public class User {
      private Long id;
      private String username;
      private String password;
      private String email;
      private Date created_at;
  }
  

  4.2、创建Mapper

  /**
   * @author ss_419
   */
  @Mapper
  public interface UserRepository extends BaseMapper {
      // 这里可以自定义一些数据库操作方法
  }
  

  4.3、创建Service

  /**
   * @author ss_419
   */
  @Service
  public class UserService
          extends ServiceImpl {
      // 这里可以编写一些业务逻辑方法
      private final UserRepository userRepository;
      @Autowired
      public UserService(UserRepository userRepository) {
          this.userRepository = userRepository;
      }
      public List getAllUsers() {
          List users = userRepository.selectList(null);
          return users;
      }
      public User getUserById(Long id) {
          return userRepository.selectById(id);
      }
      public void saveUser(User user) {
          userRepository.insert(user);
      }
      public void updateUser(User user) {
          userRepository.updateById(user);
      }
      public void deleteUser(Long id) {
          userRepository.deleteById(id);
      }
  }
  

  4.4、创建启动器

  @SpringBootApplication
  // Mapper包扫描
  @MapperScan("org.example.mapper")
  public class OracleDBApplication {
      public static void main(String[] args) {
          SpringApplication.run(OracleDBApplication.class,args);
      }
  }
  

  5、测试

  万事俱备，只欠东风，对CRUD进行测试。

  @SpringBootTest
  public class OraCTest {
      @Autowired
      private UserService service;
      /**
       * 获取所有用户信息
       */
      @Test
      public void testGetAllUsers() {
          List users = service.getAllUsers();
          users.forEach(System.out::println);
      }
      /**
       * 根据id获取用户
       */
      @Test
      public void testGetUserById() {
          User userById = service.getUserById(1L);
          System.out.println("userById = " + userById);
      }
      /**
       * 保存用户
       */
      @Test
      public void testSaveUser() {
          User user = new User();
          user.setId(1000L);
          user.setUsername("测试新增User");
          user.setPassword("00101010");
          user.setEmail("test@example.com");
          user.setCreated_at(new Date());
          service.saveUser(user);
      }
      /**
       * 更新用户
       */
      @Test
      public void testUpdateUser() {
          // 先查询
          User user = service.getUserById(1000L);
          System.out.println("userById = " + user);
          // 后更新
          user.setUsername("update_username");
          service.updateUser(user);
      }
      /**
       * 根据id删除用户
       */
      @Test
      public void testDeleteUser() {
          service.deleteUser(1000L);
      }
  }