root
/
DataX
mirror of https://github.com/alibaba/DataX.git
1
0
Fork 0
Code Issues Actions Packages Projects Releases Wiki Activity

Update ObReaderUtils.java 

OceanBase oracle模式下需要使用position排序获取正确的联合主键顺序
This commit is contained in:
lvfuyou 2024-03-18 18:25:54 +08:00 committed by GitHub
parent 072b24f673
commit 89682833a8
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java
View File

@ -154,12 +154,14 @@ public class ObReaderUtils {
} else {
schema = "(select sys_context('USERENV','current_schema') from dual)";
}
//OceanBase oracle模式下需要使用position排序获取正确的联合主键顺序
sql = String.format(
"SELECT cols.column_name Column_name " +
"FROM all_constraints cons, all_cons_columns cols " +
"WHERE cols.table_name = '%s' AND cons.constraint_type = 'P' " +
"AND cons.constraint_name = cols.constraint_name " +
"AND cons.owner = cols.owner and cons.OWNER = %s",
"AND cons.owner = cols.owner and cons.OWNER = %s " +
"order by cols.position " ,
tableName, schema);
}
LOG.info("get primary key by sql: " + sql);