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

Merge pull request #1754 from alibaba/20230414_exception_trace

Browse Source 
add exception trace.
This commit is contained in:
dingxiaobo 2023-04-14 09:50:58 +08:00 committed by GitHub
commit 4e94ed586b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/RdbmsException.java
View File

@ -69,32 +69,32 @@ public class RdbmsException extends DataXException{
} }
public static DataXException asQueryException(DataBaseType dataBaseType, Exception e,String querySql,String table,String userName){ public static DataXException asQueryException(DataBaseType dataBaseType, Exception e,String querySql,String table,String userName){
if (dataBaseType.equals(DataBaseType.MySql)){ if (dataBaseType.equals(DataBaseType.MySql)) {
DBUtilErrorCode dbUtilErrorCode = mySqlQueryErrorAna(e.getMessage()); DBUtilErrorCode dbUtilErrorCode = mySqlQueryErrorAna(e.getMessage());
if (dbUtilErrorCode == DBUtilErrorCode.MYSQL_QUERY_TABLE_NAME_ERROR && table != null){ if (dbUtilErrorCode == DBUtilErrorCode.MYSQL_QUERY_TABLE_NAME_ERROR && table != null) {
return DataXException.asDataXException(dbUtilErrorCode,"表名为："+table+" 执行的SQL为:"+querySql+" 具体错误信息为："+e); return DataXException.asDataXException(dbUtilErrorCode, "表名为：" + table + " 执行的SQL为:" + querySql + " 具体错误信息为：" + e, e);
} }
if (dbUtilErrorCode == DBUtilErrorCode.MYSQL_QUERY_SELECT_PRI_ERROR && userName != null){ if (dbUtilErrorCode == DBUtilErrorCode.MYSQL_QUERY_SELECT_PRI_ERROR && userName != null) {
return DataXException.asDataXException(dbUtilErrorCode,"用户名为："+userName+" 具体错误信息为："+e); return DataXException.asDataXException(dbUtilErrorCode, "用户名为：" + userName + " 具体错误信息为：" + e, e);
} }
return DataXException.asDataXException(dbUtilErrorCode,"执行的SQL为: "+querySql+" 具体错误信息为："+e); return DataXException.asDataXException(dbUtilErrorCode, "执行的SQL为: " + querySql + " 具体错误信息为：" + e, e);
} }
if (dataBaseType.equals(DataBaseType.Oracle)){ if (dataBaseType.equals(DataBaseType.Oracle)) {
DBUtilErrorCode dbUtilErrorCode = oracleQueryErrorAna(e.getMessage()); DBUtilErrorCode dbUtilErrorCode = oracleQueryErrorAna(e.getMessage());
if (dbUtilErrorCode == DBUtilErrorCode.ORACLE_QUERY_TABLE_NAME_ERROR && table != null){ if (dbUtilErrorCode == DBUtilErrorCode.ORACLE_QUERY_TABLE_NAME_ERROR && table != null) {
return DataXException.asDataXException(dbUtilErrorCode,"表名为："+table+" 执行的SQL为:"+querySql+" 具体错误信息为："+e); return DataXException.asDataXException(dbUtilErrorCode, "表名为：" + table + " 执行的SQL为:" + querySql + " 具体错误信息为：" + e, e);
} }
if (dbUtilErrorCode == DBUtilErrorCode.ORACLE_QUERY_SELECT_PRI_ERROR){ if (dbUtilErrorCode == DBUtilErrorCode.ORACLE_QUERY_SELECT_PRI_ERROR) {
return DataXException.asDataXException(dbUtilErrorCode,"用户名为："+userName+" 具体错误信息为："+e); return DataXException.asDataXException(dbUtilErrorCode, "用户名为：" + userName + " 具体错误信息为：" + e, e);
} }
return DataXException.asDataXException(dbUtilErrorCode,"执行的SQL为: "+querySql+" 具体错误信息为："+e); return DataXException.asDataXException(dbUtilErrorCode, "执行的SQL为: " + querySql + " 具体错误信息为：" + e, e);
} }
return DataXException.asDataXException(DBUtilErrorCode.SQL_EXECUTE_FAIL, "执行的SQL为: "+querySql+" 具体错误信息为："+e); return DataXException.asDataXException(DBUtilErrorCode.SQL_EXECUTE_FAIL, "执行的SQL为: " + querySql + " 具体错误信息为：" + e, e);
} }
public static DBUtilErrorCode mySqlQueryErrorAna(String e){ public static DBUtilErrorCode mySqlQueryErrorAna(String e){