基于springboot,一个数据库读取另外一个数据库五分钟同步一次数据表里字段都一样,后端的代码应该怎样写
时间: 2024-05-29 22:12:49 浏览: 223
SpringBoot定时任务实现Oracle和mysql数据同步
5星 · 资源好评率100%
你可以将两个数据库连接起来,使用定时任务每隔五分钟同步数据。首先,你需要在Spring Boot项目中添加两个数据库的配置信息,例如application.properties文件中分别添加如下内容:
spring.datasource.db1.url=jdbc:mysql://localhost:3306/db1
spring.datasource.db1.username=user1
spring.datasource.db1.password=pass1
spring.datasource.db2.url=jdbc:mysql://localhost:3306/db2
spring.datasource.db2.username=user2
spring.datasource.db2.password=pass2
然后,你需要创建两个数据源和两个JdbcTemplate实例,分别用于连接两个数据库:
@Configuration
public class DatabaseConfig {
@Bean
@Primary
@ConfigurationProperties(prefix = "spring.datasource.db1")
public DataSource db1DataSource() {
return DataSourceBuilder.create().build();
}
@Bean
@ConfigurationProperties(prefix = "spring.datasource.db2")
public DataSource db2DataSource() {
return DataSourceBuilder.create().build();
}
@Bean(name = "db1JdbcTemplate")
public JdbcTemplate db1JdbcTemplate(@Qualifier("db1DataSource") DataSource dataSource) {
return new JdbcTemplate(dataSource);
}
@Bean(name = "db2JdbcTemplate")
public JdbcTemplate db2JdbcTemplate(@Qualifier("db2DataSource") DataSource dataSource) {
return new JdbcTemplate(dataSource);
}
}
接下来,你可以编写一个定时任务,使用JdbcTemplate从一个数据库读取数据,然后插入到另一个数据库中。例如,你可以创建一个名为DataSyncTask的定时任务,每隔五分钟同步一次数据,代码如下:
@Component
public class DataSyncTask {
@Autowired
@Qualifier("db1JdbcTemplate")
private JdbcTemplate db1JdbcTemplate;
@Autowired
@Qualifier("db2JdbcTemplate")
private JdbcTemplate db2JdbcTemplate;
@Scheduled(fixedRate = 300000)
public void syncData() {
List<Map<String, Object>> dataList = db1JdbcTemplate.queryForList("SELECT * FROM table_name");
for (Map<String, Object> data : dataList) {
db2JdbcTemplate.update("INSERT INTO table_name VALUES (?, ?, ?)", data.get("field1"), data.get("field2"), data.get("field3"));
}
}
}
这样,代码就可以每隔五分钟从一个数据库读取数据并同步到另一个数据库中。
阅读全文