Kafka JDBC Connect执行Oracle查询触发ORA-00933错误排查

这种问题我之前也碰到过，核心原因通常是Kafka Connect JDBC对SQL语句的解析逻辑和SQL Developer不一样，尤其是针对WHERE子句的处理。结合你的情况，给你几个具体的排查和解决方向：

1. 去掉SQL末尾的分号 #

SQL Developer允许语句以分号结尾，但Oracle JDBC驱动（包括ojdbc7）在执行单条SQL时，会把末尾的分号当成SQL的一部分，直接导致ORA-00933错误。

比如你在properties里可能写了：

query=SELECT * FROM your_table WHERE update_time > SYSDATE - 1;

把分号去掉就好：

query=SELECT * FROM your_table WHERE update_time > SYSDATE - 1

2. 检查SQL的换行和转义处理 #

如果你的SQL在properties文件里是多行编写的，要注意properties的续行规则：

• 续行符\后面不能有任何空格或制表符，否则会被解析成SQL的一部分
• 避免在WHERE子句的条件里出现不必要的换行，或者确保换行后的语法依然正确

比如正确的多行写法：

query=SELECT id, name, update_time \
FROM your_table \
WHERE update_time > SYSDATE - 1 \
AND status = 'ACTIVE'

3. 排查WHERE子句中的特殊字符 #

如果你的WHERE子句里包含单引号、特殊符号，要确保在properties里正确转义：

• Oracle里的单引号需要用两个单引号转义，比如WHERE name = 'O''Neil'
• 避免使用Oracle特有的、JDBC驱动解析有歧义的语法（比如某些复杂的子查询、自定义函数调用，建议先简化WHERE条件测试）

4. 查看Kafka Connect实际执行的SQL #

开启Kafka Connect的DEBUG日志，找到实际发送给Oracle的SQL语句，这样能直接定位到语法错误的位置。日志里通常会打印类似Executing SQL query: [你的SQL内容]的信息，对比你写的SQL，就能发现是否有拼接错误或截断问题。

5. 排除Kafka Connect的自动拼接冲突 #

如果你同时配置了增量同步模式（比如mode=incrementing或mode=timestamp），但又使用了自定义query参数，要注意：Kafka Connect不会自动给自定义query添加增量条件，但如果你的SQL里已经包含了类似的条件，要确保逻辑正确。不过根据你的描述，去掉WHERE子句就正常，这条可能不是主要原因，但可以作为排查项。

先从最常见的“去掉分号”开始测试，大概率能解决问题。如果还是不行，再逐步排查其他方向。

内容的提问来源于stack exchange，提问作者Alex