You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2014/09/28 03:04:16 UTC

svn commit: r1628037 - in /pig/trunk: CHANGES.txt contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java

Author: daijy
Date: Sun Sep 28 01:04:15 2014
New Revision: 1628037

URL: http://svn.apache.org/r1628037
Log:
PIG-4046: PiggyBank DBStorage DATETIME should use setTimestamp with java.sql.Timestamp

Modified:
    pig/trunk/CHANGES.txt
    pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java

Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1628037&r1=1628036&r2=1628037&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Sun Sep 28 01:04:15 2014
@@ -84,6 +84,8 @@ OPTIMIZATIONS
  
 BUG FIXES
 
+PIG-4046: PiggyBank DBStorage DATETIME should use setTimestamp with java.sql.Timestamp (sinchii via daijy)
+
 PIG-4050: HadoopShims.getTaskReports() can cause OOM with Hadoop 2 (rohini)
 
 PIG-4176: Fix tez e2e test Bloom_[1-3] (daijy)

Modified: pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java?rev=1628037&r1=1628036&r2=1628037&view=diff
==============================================================================
--- pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java (original)
+++ pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java Sun Sep 28 01:04:15 2014
@@ -19,10 +19,10 @@ package org.apache.pig.piggybank.storage
 
 import java.io.IOException;
 import java.sql.Connection;
-import java.sql.Date;
 import java.sql.DriverManager;
 import java.sql.PreparedStatement;
 import java.sql.SQLException;
+import java.sql.Timestamp;
 import java.util.Properties;
 
 import org.apache.commons.logging.Log;
@@ -136,7 +136,7 @@ public class DBStorage extends StoreFunc
             break;
 
           case DataType.DATETIME:
-            ps.setDate(sqlPos, new Date(((DateTime) field).getMillis()));
+            ps.setTimestamp(sqlPos, new Timestamp(((DateTime) field).getMillis()));
             sqlPos++;
             break;