We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent becf9d1 commit 57b42ddCopy full SHA for 57b42dd
kyuubi-server/src/main/scala/org/apache/kyuubi/server/metadata/jdbc/JdbcDatabaseDialect.scala
@@ -54,9 +54,9 @@ class MySQLDatabaseDialect extends GenericDatabaseDialect {
54
Some(
55
s"""
56
|INSERT INTO $table (${colsToInsert.mkString(",")})
57
- |VALUES (${colsToInsert.map(_ => "?").mkString(",")})
+ |VALUES (${colsToInsert.map(_ => "?").mkString(",")}) AS new
58
|ON DUPLICATE KEY UPDATE
59
- |${colsToReplace.map(c => s"$c = VALUES($c)").mkString(",")}
+ |${colsToReplace.map(c => s"$c = new.$c").mkString(",")}
60
|""".stripMargin)
61
}
62
0 commit comments