最近学习了Oracle数据库,那么如何使用Spring Boot和MyBatis Plus对接Oracle数据库呢?
这就有了这篇随记,具体流程如下
创建一个空的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,不然连接老会失败。
在配置文件中填写数据库连接的参数
spring:
datasource:
username: pp
password: 123456
url: jdbc:oracle:thin:@localhost:1521:XE
driver-class-name: oracle.jdbc.OracleDriver
参数说明:
为了演示本次对接Oracle数据库,我们需要一张测试数据表
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编程来批量生成测试数据,真香!!
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!准备工作完成,接下来就可以进行对接了。
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;
}
/** * @author ss_419 */ @Mapper public interface UserRepository extends BaseMapper{ // 这里可以自定义一些数据库操作方法 }
/**
* @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);
}
}
@SpringBootApplication
// Mapper包扫描
@MapperScan("org.example.mapper")
public class OracleDBApplication {
public static void main(String[] args) {
SpringApplication.run(OracleDBApplication.class,args);
}
}
万事俱备,只欠东风,对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);
}
}