[SPARK-8386] [SQL] add write.mode for insertIntoJDBC when the parm overwrite is false

huaxingao · rxin · commit 7e1308d37f6c · 2015-10-14T12:31:29.000-07:00
the fix is for jira https://issues.apache.org/jira/browse/SPARK-8386 Author: Huaxin Gao <huaxing@us.ibm.com> Closes #9042 from huaxingao/spark8386.
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala b/sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala
@@ -1674,7 +1674,7 @@ class DataFrame private[sql](
    */
   @deprecated("Use write.jdbc()", "1.4.0")
   def insertIntoJDBC(url: String, table: String, overwrite: Boolean): Unit = {
-    val w = if (overwrite) write.mode(SaveMode.Overwrite) else write
+    val w = if (overwrite) write.mode(SaveMode.Overwrite) else write.mode(SaveMode.Append)
     w.jdbc(url, table, new Properties)
   }
 

Original file line number	Diff line number	Diff line change
`@@ -1674,7 +1674,7 @@ class DataFrame private[sql](`
`1674`	`1674`	`*/`
`1675`	`1675`	`@deprecated("Use write.jdbc()", "1.4.0")`
`1676`	`1676`	`def insertIntoJDBC(url: String, table: String, overwrite: Boolean): Unit = {`
`1677`		`- val w = if (overwrite) write.mode(SaveMode.Overwrite) else write`
	`1677`	`+ val w = if (overwrite) write.mode(SaveMode.Overwrite) else write.mode(SaveMode.Append)`
`1678`	`1678`	`w.jdbc(url, table, new Properties)`
`1679`	`1679`	`}`
`1680`	`1680`