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 */@Mapperpublic interface UserRepository extends BaseMapper {    // 这里可以自定义一些数据库操作方法}

  4.3、创建Service

  /** * @author ss_419 */@Servicepublic 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进行测试。

  @SpringBootTestpublic 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);    }}