Spring Boot对接Oracle数据库具体流程

2023-11-09 11:21:37 作者：七七r

这篇文章主要给大家介绍了关于Spring Boot对接Oracle数据库的具体流程,本文将介绍如何在Spring Boot中连接Oracle数据库的基本配置,包括添加依赖、配置数据源、配置JPA等,需要的朋友可以参考下

Spring Boot对接Oracle数据库

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

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

1、创建Maven工程

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

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0"
         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>2.3.7.RELEASE</version>
        <relativePath/>
    </parent>
    <groupId>org.example</groupId>
    <artifactId>oracle-init</artifactId>
    <version>1.0-SNAPSHOT</version>

    <properties>
        <maven.compiler.source>8</maven.compiler.source>
        <maven.compiler.target>8</maven.compiler.target>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    </properties>
    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter</artifactId>
            <version>2.3.7.RELEASE</version>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <version>2.3.7.RELEASE</version>
        </dependency>
        <!--    Oracel11g与ojdbc5/ojdbc6版本匹配    -->
        <dependency>
            <groupId>com.oracle.database.jdbc</groupId>
            <artifactId>ojdbc6</artifactId>
            <version>11.2.0.4</version>
        </dependency>
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.16.10</version>
            <scope>provided</scope>
        </dependency>

<!--        <dependency>-->
<!--            <groupId>com.oracle.database.jdbc</groupId>-->
<!--            <artifactId>ojdbc8</artifactId>-->
<!--            <version>19.8.0.0</version>-->
<!--        </dependency>-->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.5.3.2</version>
        </dependency>
        <dependency>
            <groupId>org.junit.jupiter</groupId>
            <artifactId>junit-jupiter</artifactId>
            <version>RELEASE</version>
            <scope>compile</scope>
        </dependency>
    </dependencies>
</project>

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<User> {
    // 这里可以自定义一些数据库操作方法
}

4.3、创建Service

/**
 * @author ss_419
 */
@Service
public class UserService
        extends ServiceImpl<UserRepository, User> {
    // 这里可以编写一些业务逻辑方法
    private final UserRepository userRepository;

    @Autowired
    public UserService(UserRepository userRepository) {
        this.userRepository = userRepository;
    }
    public List<User> getAllUsers() {
        List<User> 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<User> 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);
    }
}

补充知识：Oracle主键自增问题

在MySQL中，id可以直接设置自增长，而在Oracle中需要设置序列

① 以navicat为例进行演示：

② 编写配置类

@Configuration
public class KeyGeneratorConfig {
 
    @Bean
    public IKeyGenerator keyGenerator(){
        return new OracleKeyGenerator();
    }
}

③ 实体类配置

总结

到此这篇关于Spring Boot对接Oracle数据库具体流程的文章就介绍到这了,更多相关SpringBoot对接Oracle内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

Spring Boot对接Oracle数据库具体流程