-
大小: 38KB文件類型: .rar金幣: 2下載: 1 次發布日期: 2021-06-06
- 語言: 數據庫
- 標簽: 雙數據源??springboot??mysql+oracle??
資源簡介
主要是數據同步從oracle同步到mysql,數據量為好幾十萬,采用了流處理的方式同步進行處理,防止出現oom
代碼片段和文件信息
package?cn.witsky.quota;
import?org.springframework.boot.SpringApplication;
import?org.springframework.boot.autoconfigure.SpringBootApplication;
import?org.springframework.context.annotation.Bean;
import?org.springframework.context.annotation.Configuration;
import?org.springframework.http.client.SimpleClientHttpRequestFactory;
import?org.springframework.http.converter.HttpMessageConverter;
import?org.springframework.http.converter.StringHttpMessageConverter;
import?org.springframework.retry.backoff.ExponentialBackOffPolicy;
import?org.springframework.retry.policy.SimpleRetryPolicy;
import?org.springframework.retry.support.RetryTemplate;
import?org.springframework.scheduling.annotation.EnableAsync;
import?org.springframework.scheduling.annotation.EnableScheduling;
import?org.springframework.web.client.RestTemplate;
import?java.nio.charset.Charset;
@SpringBootApplication
@EnableAsync
@Configuration
@EnableScheduling
public?class?Application?{
????public?static?void?main(String[]?args)?{
????????SpringApplication.run(Application.class?args);
????}
????@Bean(name?=?“restTemplate“)
????public?RestTemplate?restTemplate()?{
????????SimpleClientHttpRequestFactory?factory?=?new?SimpleClientHttpRequestFactory();
????????factory.setReadTimeout(20000);
????????factory.setConnectTimeout(3000);
????????RestTemplate?restTemplate?=?new?RestTemplate(factory);
????????//?找出并修改默認的StringHttpMessageConverter
????????//?關閉Accept-Charset的輸出(防止輸出超長的編碼列表)
????????//?設置默認編碼為UTF-8
????????boolean?stringConverterFound?=?false;
????????for?(HttpMessageConverter?httpMessageConverter?:?restTemplate.getMessageConverters())?{
????????????if?(httpMessageConverter?instanceof?StringHttpMessageConverter)?{
????????????????StringHttpMessageConverter?stringHttpMessageConverter?=?(StringHttpMessageConverter)httpMessageConverter;
????????????????stringHttpMessageConverter.setWriteAcceptCharset(false);
????????????????stringHttpMessageConverter.setDefaultCharset(Charset.forName(“UTF-8“));
????????????????stringConverterFound?=?true;
????????????????break;
????????????}
????????}
????????if?(!stringConverterFound)?{
????????????//?如果不存在StringHttpMessageC?onverter,則創建一個
????????????StringHttpMessageConverter?stringHttpMessageConverter?=?new?StringHttpMessageConverter(Charset.forName(“UTF-8“));
????????????stringHttpMessageConverter.setWriteAcceptCharset(false);
????????????restTemplate.getMessageConverters().add(stringHttpMessageConverter);
????????}
????????return?restTemplate;
????}
????//?創建用于重試的retryTemplate
????@Bean
????public?RetryTemplate?retryTemplate()?{
????????RetryTemplate?retryTemplate?=?new?RetryTemplate();
????????retryTemplate.setBackOffPolicy(new?ExponentialBackOffPolicy());
????????SimpleRetryPolicy?retryPolicy?=?new?SimpleRetryPolicy();
????????retryPolicy.setMaxAttempts(3);
????????retryTemplate.setRetryPolicy(retryPolicy);
????????return?retryTemplate;
????}
}
?屬性????????????大小?????日期????時間???名稱
-----------?---------??----------?-----??----
?????文件???????4219??2020-07-27?19:59??rcs-tqybsj\pom.xm
?????文件???????3008??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\Application.java
?????文件??????17795??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件???????6303??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件???????5701??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件????????655??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件???????1191??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件???????4148??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件??????13151??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件???????2381??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件??????16223??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????文件????????451??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\Config.java
?????文件???????1872??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\dao\dataob
?????文件????????572??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\dao\dataob
?????文件????????469??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\dao\dataob
?????文件???????1515??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\dao\mysqldao\RcsTqybSubMapper.java
?????文件????????755??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\dao\oracledao\UserMobileDzMapper.java
?????文件???????3025??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\DataSourceMysqlConfig.java
?????文件???????2372??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\DataSourceOracleConfig.java
?????文件???????3121??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\DruidConfig.java
?????文件???????3083??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\DruidProperties.java
?????文件???????9575??2020-08-13?14:32??rcs-tqybsj\src\main\java\cn\witsky\quota\service\WorkService.java
?????文件???????4107??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\util\Constants.java
?????文件???????1727??2020-08-13?14:45??rcs-tqybsj\src\main\resources\application.properties
?????文件???????1008??2020-07-28?18:14??rcs-tqybsj\src\main\resources\logback-spring.xm
?????文件???????8546??2020-07-27?19:59??rcs-tqybsj\src\main\resources\mybatis\mapper\RcsTqybSubMapper.xm
?????文件????????622??2020-08-04?09:56??rcs-tqybsj\src\main\resources\mybatis\mapper\UserMobileDzMapper.xm
?????文件????????450??2020-07-27?19:59??rcs-tqybsj\src\main\resources\mybatis-config.xm
?????目錄??????????0??2020-07-27?19:59??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
?????目錄??????????0??2020-08-13?14:43??rcs-tqybsj\src\main\java\cn\witsky\quota\ba
............此處省略27個文件信息
- 上一篇:MySQL數據庫操作指令.pdf
- 下一篇:maven SSM 增刪改查
評論
共有 條評論