Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

[SPARK-50792][SQL] Format binary data as a binary literal in JDBC. #49452

Open
wants to merge 11 commits into
base: master
Choose a base branch
from
+95 −1
Open

[SPARK-50792][SQL] Format binary data as a binary literal in JDBC. #49452

Changes from 1 commit
Commits
Show all changes
11 commits
Select commit Hold shift + click to select a range
ca63d5a
Format binary data as a binary literal in JDBC.
sunxiaoguang Jan 11, 2025
7fbb786
Support binary literal for Oracle
sunxiaoguang Jan 11, 2025
ce6bc59
Support binary literal for Oracle and add a test
sunxiaoguang Jan 11, 2025
13bc3ab
Format binary literal for PostgreSQL
sunxiaoguang Jan 11, 2025
2d86ab9
Use Spark SQL in JDBCV2Suite
sunxiaoguang Jan 11, 2025
d3bb055
Refactor test code
sunxiaoguang Jan 11, 2025
09022ab
Fix Oracle and DB2 binary literal
sunxiaoguang Jan 11, 2025
8ddfcc2
Do not support binary literal on Oracle
sunxiaoguang Jan 11, 2025
84ea312
Implement binary literal for OracleDialect
sunxiaoguang Jan 12, 2025
86a1cda
Support all binary comparison for BLOBs on Oracle
sunxiaoguang Jan 13, 2025
b8c9708
Verify returned result
sunxiaoguang Jan 13, 2025
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Support binary literal for Oracle 
Signed-off-by: Xiaoguang Sun <[email protected]>
  • Loading branch information
@sunxiaoguang
sunxiaoguang committed Jan 11, 2025
commit 7fbb7860da2a2378411973384c57ef2a458d11f2
1 change: 1 addition & 0 deletions sql/core/src/main/scala/org/apache/spark/sql/jdbc/OracleDialect.scala
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -138,6 +138,7 @@ private case class OracleDialect() extends JdbcDialect with SQLConfHelper with N
case timestampValue: Timestamp => "{ts '" + timestampValue + "'}"
case dateValue: Date => "{d '" + dateValue + "'}"
case arrayValue: Array[Any] => arrayValue.map(compileValue).mkString(", ")
case binaryValue: Array[Byte] => binaryValue.map("%02X".format(_)).mkString("X'", "", "'")
case _ => value
}

Expand Down
Loading