github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-03 03:59:07 +08:00
Code Issues Packages Projects Releases Wiki Activity

修改了提到的上述问题

Browse Source
This commit is contained in:
sanChouIsACat 2021-12-23 13:38:37 +08:00
parent 738c11e0e3
commit bd43216cf8
2 changed files with 6 additions and 16 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java
View File

@ -17,14 +17,13 @@ import org.slf4j.LoggerFactory;
public class ReaderJob extends CommonRdbmsReader.Job { public class ReaderJob extends CommonRdbmsReader.Job {
private Logger LOG=LoggerFactory.getLogger(OceanBaseReader.Task.class);
public ReaderJob() { public ReaderJob() {
super(ObReaderUtils.DATABASE_TYPE); super(ObReaderUtils.DATABASE_TYPE);
} }
public void init(Configuration originalConfig,DataBaseType databaseType){ public void init(Configuration originalConfig,DataBaseType databaseType){
//将config中的column和table中的关键字进行转义 //将config中的column和table中的关键字进行转义
final Logger LOG = LoggerFactory.getLogger(OceanBaseReader.Task.class);
try { try {
DatabaseKeywordTransformer.setDatabaseType(databaseType); DatabaseKeywordTransformer.setDatabaseType(databaseType);
}catch (Exception e){ }catch (Exception e){

19
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/DatabaseKeywordTransformer.java
View File

File diff suppressed because one or more lines are too long