Skip to content
Closed
Changes from 1 commit
Commits
Show all changes
29 commits
Select commit Hold shift + click to select a range
7d78be3
core
andrej-db Oct 23, 2024
7839e1d
revert MsSqlServerDialect build method
andrej-db Oct 23, 2024
0172c49
remove visitCaseWhen, more intuitive predicate wrapping
andrej-db Oct 23, 2024
7ae7397
imports
andrej-db Oct 23, 2024
49d742e
fix
andrej-db Oct 23, 2024
c2001d9
MsSqlServerDialect: comment
andrej-db Oct 24, 2024
8b1b2da
JdbcDialects: move aux here
andrej-db Oct 25, 2024
1f01b77
V2ExpressionBuilder: refactor
andrej-db Oct 25, 2024
7e36029
nit
andrej-db Oct 29, 2024
ab79afe
nit
andrej-db Nov 18, 2024
de38a8c
Update JdbcDialects.scala
cloud-fan Nov 19, 2024
56cea3c
Update MsSqlServerDialect.scala
cloud-fan Nov 19, 2024
21ec622
Update sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcDialects…
cloud-fan Nov 19, 2024
468eb89
Update JdbcDialects.scala
cloud-fan Nov 19, 2024
1bc39ee
Update sql/core/src/main/scala/org/apache/spark/sql/jdbc/MsSqlServerD…
cloud-fan Nov 19, 2024
6a221c6
Update JdbcDialects.scala
cloud-fan Nov 19, 2024
ef1bcc8
Update MsSqlServerDialect.scala
cloud-fan Nov 19, 2024
5d94fa1
Update JdbcDialects.scala
andrej-db Nov 19, 2024
f94f8e5
Update MsSqlServerDialect.scala
andrej-db Nov 19, 2024
55084a3
Update MsSqlServerIntegrationSuite.scala
andrej-db Nov 19, 2024
7fb6b29
Update MsSqlServerDialect.scala
andrej-db Nov 19, 2024
ca0545a
Update MsSqlServerIntegrationSuite.scala
andrej-db Nov 19, 2024
df2fe41
Apply suggestions from code review
cloud-fan Nov 20, 2024
53a4220
Update connector/docker-integration-tests/src/test/scala/org/apache/s…
cloud-fan Nov 20, 2024
cbef9a5
Update MsSqlServerIntegrationSuite.scala
cloud-fan Nov 20, 2024
c990ec6
Update JdbcDialects.scala
cloud-fan Nov 20, 2024
ee4d4fb
Update sql/core/src/main/scala/org/apache/spark/sql/jdbc/MsSqlServerD…
cloud-fan Nov 20, 2024
6cff9f5
Update MsSqlServerIntegrationSuite.scala
andrej-db Nov 21, 2024
bca7ce8
Merge branch 'apache:master' into SPARK-50087-CaseWhen
andrej-db Nov 21, 2024
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
Update sql/core/src/main/scala/org/apache/spark/sql/jdbc/JdbcDialects…
….scala
  • Loading branch information
cloud-fan authored Nov 19, 2024
commit 21ec6224573d192f2d7ee30cbcf27fd1f55ba936
Original file line number Diff line number Diff line change
Expand Up @@ -380,7 +380,7 @@ abstract class JdbcDialect extends Serializable with Logging {
private[jdbc] class JDBCSQLBuilder extends V2ExpressionSQLBuilder {
// Some dialects do not support boolean type and this convenient util function is
// provided to generate a SQL statement to convert predicate to integer.
protected def predicateToIntSQL(input: Expression): String =
protected def predicateToIntSQL(input: Predicate): String =
"CASE WHEN " + inputToSQL(input) + " THEN 1 ELSE 0 END"

override def visitLiteral(literal: Literal[_]): String = {
Expand Down