---
title: "SpringBatch 连接 OceanBase 数据库 - OceanBase 数据库 V4.2.1 | OceanBase 文档中心"
description: SpringBatch 连接 OceanBase 数据库 本文介绍 SpringBatch 连接示例。 环境配置 JDK1.8。 OceanBase 3.x（MySQL 模式/Oracle 模式）。 基于 spring-boot 集成 spring-batch。 配置依赖 <dependency> <groupId>…
---
切换语言
- 中文站 - 简体中文
- International - English
- 日本站 - 日本語
文档反馈 OceanBase 数据库分布式版 - V 4.2.1 LTS
# SpringBatch 连接 OceanBase 数据库
更新时间：2026-04-16 00:11:35
[编辑](https://github.com/oceanbase/oceanbase-doc/edit/V4.2.1/zh-CN/300.develop/100.application-development-of-mysql-mode/200.sample-program-of-mysql-mode/100.java-of-mysql-mode/900.connect-to-the-oceanbase-database-through-spring-batch-of-mysql-mode.md)
本文介绍 SpringBatch 连接示例。
## 环境配置
- JDK1.8。
- OceanBase 3.x（MySQL 模式/Oracle 模式）。
- 基于 spring-boot 集成 spring-batch。
## 配置依赖
```xml
org.springframework.boot
spring-boot-starter-batch
mysql
mysql-connector-java
8.0.25
com.alibaba
druid
1.1.22
org.springframework.boot
spring-boot-starter-data-jpa
```
## 配置文件
```java
#yml文件：
spring:
datasource:
url: jdbc:mysql://10.100.xxx.xxx:18815/test
driver-class-name: com.mysql.cj.jdbc.Driver
# username: admin@mysql
username: admin@oracle
password: ******
jpa:
hibernate:
ddl-auto: update
```
## 示例代码
通过调用数据库写入类方法写入数据，具体步骤如下：
1. 创建需要的类。
实体类 : `People` 和 `PeopleDESC`。
```java
//基本people类
@Entity
@Table(name = "PEOPLE")
public class People {
@Id
@GeneratedValue
private int id;
private String lastName;
private String firstName;
//。。。。。。略
}
```
```java
//加工后的peopledesc类(增加desc属性)
@Entity
@Table(name = "OK_PEOPLE")
public class PeopleDESC {
@Id
@GeneratedValue //strategy = AUTO / IDENTITY / SEQUENCE 三种主键生成策略均不支持
private int id;
private String lastName;
private String firstName;
private String desc1;
//。。。。。。略
}
```
批处理类：`AddPeopleDescProcessor` 和 `AddDescPeopleWriter`。
```java
//用于给people添加desc属性返回一个peopledesc类的处理器
public class AddPeopleDescProcessor implements ItemProcessor {
public PeopleDESC process(People item) throws Exception {
return new PeopleDESC(item.getId() ,
item.getLastName(),
item.getFirstName(),
Thread.currentThread().getName());
}
}
```
2. 将 peopledesc 写入数据库的类。
```java
//将peopledesc写入数据库的类
public class AddDescPeopleWriter implements ItemWriter {
private JdbcTemplate jdbcTemplate;
public void setDataSource(DataSource dataSource) {
this.jdbcTemplate = new JdbcTemplate(dataSource);
}
public JdbcTemplate getJdbcTemplate() {
return jdbcTemplate;
}
public void write(List items) throws Exception {
for (PeopleDESC peopleDESC : items) {
this.jdbcTemplate
.update("insert into ok_people (id,first_name,last_name,desc1) values (?, ?, ?, ?)",
peopleDESC.getId(), peopleDESC.getFirstName(),
peopleDESC.getLastName(), peopleDESC.getDesc());
}
}
}
```
3. 启动工程 `spring-data-jpa` 会根据实体类 `People` 及 `PeopleDESC` 自动建表，示例结果如下。
4. 批量添加测试数据至 `people`。
```java
public void addData(){
jdbcTemplate = new JdbcTemplate(dataSource);
StringBuilder stringBuilder = new StringBuilder("");
for (int i = 1 ; i<=100 ; i++){
stringBuilder.append("insert into people values ("+i+",'first_test"+i+"','last_test"+i+"');");
jdbcTemplate.execute(stringBuilder.toString());
stringBuilder.delete(0, stringBuilder.length());
}
}
```
测试下结果，显示如下：
5. 执行批处理方法。
```java
public void writerTest() throws Exception {
//获得people表的结果集
String sql = "select * from people;";
preparedStatement = dataSource.getConnection().prepareStatement(sql);
ResultSet resultSet = preparedStatement.executeQuery();
List list = new ArrayList();
//基于添加desc属性的处理器对结果集进行加工，并封装成一个List
while (resultSet.next()){
People people = peopleRowMapper.mapRow(resultSet, resultSet.getRow());
PeopleDESC desc = addPeopleDescProcessor.process(people);
list.add(desc);
}
//调用数据库写入类方法写入数据
addDescPeopleWriter.setDataSource(dataSource);
addDescPeopleWriter.write(list);
}
```
上一篇 下一篇 [AI](https://www.oceanbase.com/obi) 咨询热线