diff options
| author | Huaxin Gao <huaxing@us.ibm.com> | 2015-10-14 12:31:29 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@databricks.com> | 2015-10-14 12:31:29 -0700 |
| commit | 7e1308d37f6ca35f063e67e4b87a77e932ad89a5 (patch) | |
| tree | c9ce11102521f2fe40a4021ac3f3202f4af16a5e /sql/core | |
| parent | 31f315981709251d5d26c508a3dc62cf0e6f87e1 (diff) | |
| download | spark-7e1308d37f6ca35f063e67e4b87a77e932ad89a5.tar.gz spark-7e1308d37f6ca35f063e67e4b87a77e932ad89a5.tar.bz2 spark-7e1308d37f6ca35f063e67e4b87a77e932ad89a5.zip | |
[SPARK-8386] [SQL] add write.mode for insertIntoJDBC when the parm overwrite is false
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.
Diffstat (limited to 'sql/core')
| -rw-r--r-- | sql/core/src/main/scala/org/apache/spark/sql/DataFrame.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 index bfe8d3c8ef..174bc6f42a 100644 --- 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) } |