소스 검색

fixed issue #227 , fixed Mysql5.1.73 throw NullPointerException

alexwang 8 년 전
부모
커밋
bc7927fe75
1개의 변경된 파일3개의 추가작업 그리고 2개의 파일을 삭제
  1. 3 2
      parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java

+ 3 - 2
parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlConnection.java

@@ -279,8 +279,9 @@ public class MysqlConnection implements ErosaConnection {
         }
 
         List<String> columnValues = rs.getFieldValues();
-        if(columnValues.get(0).toUpperCase().equals("CRC32")){
-        	binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_CRC32;
+        if (columnValues.size() > 0 && columnValues.get(0) != null
+                && columnValues.get(0).toUpperCase().equals("CRC32")) {
+                binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_CRC32;
         }else{
         	binlogChecksum = LogEvent.BINLOG_CHECKSUM_ALG_OFF;
         }