From 104dc599e885dcd27c55ac8d214a729b381018a9 Mon Sep 17 00:00:00 2001
From: Robin Bygrave <robin.bygrave@gmail.com>
Date: Tue, 26 Apr 2016 10:12:37 +1200
Subject: [PATCH] #662 - Postgres Timestamp with time zone testing

---
 .../avaje/tests/timezone/TimezoneTests.java   | 125 ++++++++++++++++++
 1 file changed, 125 insertions(+)
 create mode 100644 src/test/java/com/avaje/tests/timezone/TimezoneTests.java

diff --git a/src/test/java/com/avaje/tests/timezone/TimezoneTests.java b/src/test/java/com/avaje/tests/timezone/TimezoneTests.java
new file mode 100644
index 000000000..e61b33c4b
--- /dev/null
+++ b/src/test/java/com/avaje/tests/timezone/TimezoneTests.java
@@ -0,0 +1,125 @@
+package com.avaje.tests.timezone;
+
+import com.avaje.ebean.Ebean;
+import com.avaje.ebean.Transaction;
+import org.junit.Test;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Timestamp;
+import java.util.Calendar;
+import java.util.TimeZone;
+
+public class TimezoneTests {
+
+  static {
+    System.setProperty("oracle.jdbc.J2EE13Compliant", "true") ;
+  }
+
+  private final long now = 1460000000000L;
+
+  private final Timestamp nowTs = new Timestamp(now);
+
+  private final Calendar utcCalendar;
+
+  public TimezoneTests() {
+    utcCalendar = Calendar.getInstance();
+    utcCalendar.setTimeZone(TimeZone.getTimeZone("UTC"));
+  }
+
+  @Test
+  public void rawJdbc() throws SQLException {
+
+//    insert("Local");
+//    insert("UTC");
+//    insert("America/Los_Angeles");
+
+    System.out.println("Local");
+    fetch();
+
+    System.out.println("UTC");
+    setZone("UTC");
+    fetch();
+
+    System.out.println("LA");
+    setZone("America/Los_Angeles");
+    fetch();
+  }
+
+  private void fetch() throws SQLException {
+    Transaction transaction = Ebean.beginTransaction();
+    Connection connection = transaction.getConnection();
+    PreparedStatement statement = connection.prepareStatement("select * from tztest");
+    ResultSet resultSet = statement.executeQuery();
+    while (resultSet.next()) {
+      System.out.println(" zone:"+resultSet.getString("zone"));
+      System.out.println("   ts:"+tsof(resultSet.getTimestamp("ts")));
+      System.out.println(" tstz:"+tsof(resultSet.getTimestamp("tstz")));
+      System.out.println("  ts1:"+tsof(resultSet.getTimestamp("ts1", utcCal())));
+      System.out.println("tstz1:"+tsof(resultSet.getTimestamp("tstz1", utcCal())));
+    }
+    System.out.println("");
+    resultSet.close();
+    statement.close();
+    transaction.end();
+  }
+
+//  private void fetch() throws SQLException {
+//    Transaction transaction = Ebean.beginTransaction();
+//    Connection connection = transaction.getConnection();
+//    SqlQuery sqlQuery = Ebean.createSqlQuery("select * from tztest");
+//    List<SqlRow> rows = sqlQuery.findList();
+//    for (SqlRow row : rows) {
+//      System.out.println(" zone:"+row.getString("zone"));
+//      System.out.println("   ts:"+tsof(row.getTimestamp("ts")));
+//      System.out.println(" tstz:"+tsof(row.getTimestamp("tstz")));
+//      //System.out.println(" tstz:"+tsof(getOracleTimestamp(connection, row, "tstz")));
+//      System.out.println("  ts1:"+tsof(row.getTimestamp("ts1")));
+//      System.out.println("tstz1:"+tsof(row.getTimestamp("tstz1")));
+//      //System.out.println("tstz1:"+tsof(getOracleTimestamp(connection, row, "tstz1")));
+//    }
+//    System.out.println("");
+//    transaction.end();
+//  }
+//
+//  private Timestamp getOracleTimestamp(Connection connection, SqlRow row, String name) throws SQLException {
+//    TIMESTAMPTZ ts = (TIMESTAMPTZ)row.get(name);
+//    Connection unwrap = connection.unwrap(Connection.class);
+//    return ts.timestampValue(unwrap);
+//  }
+
+  private String tsof(Timestamp timestamp) {
+    return ""+timestamp.getTime()+","+timestamp.toString();
+  }
+
+  private void setZone(String zone) {
+    TimeZone.setDefault(TimeZone.getTimeZone(zone));
+  }
+
+  private void insert(String zone) throws SQLException {
+
+    String insert = "insert into tztest (zone, ts, tstz, ts1, tstz1) values (?,?,?,?,?)";
+
+    if (!zone.equalsIgnoreCase("local")) {
+      setZone(zone);
+    }
+
+    Transaction transaction = Ebean.beginTransaction();
+    Connection connection = transaction.getConnection();
+    PreparedStatement statement = connection.prepareStatement(insert);
+    statement.setString(1, zone);
+    statement.setTimestamp(2, nowTs);
+    statement.setTimestamp(3, nowTs);
+    statement.setTimestamp(4, nowTs, utcCal());
+    statement.setTimestamp(5, nowTs, utcCal());
+    statement.executeUpdate();
+
+    transaction.commit();
+  }
+
+  private Calendar utcCal() {
+    return (Calendar) utcCalendar.clone();
+  }
+}