#7 Support timestamptz

lib/connection.dart

@@ -530,9 +530,15 @@ class _Connection implements Connection {
       case _PG_DATE:
         return DateTime.parse(UTF8.decode(data));
 
+      case _PG_TIMESTAMPZ:
+        var str = UTF8.decode(data),
+          cc = str[str.length - 3];
+        if (cc == '+' || cc == '-')
+          str += ":00"; //convert to ISO 8601 (2012-02-27 13:27:00.123+02:00)
+        return DateTime.parse(str).toLocal();
+
       // Not implemented yet - return a string.
       case _PG_MONEY:
-      case _PG_TIMESTAMPZ:
       case _PG_TIMETZ:
       case _PG_TIME:
       case _PG_INTERVAL:

lib/format_value.dart

@@ -80,6 +80,9 @@ _formatDateTime(DateTime datetime, String type) {
     throw new Exception('Unexpected type: $type.'); //TODO exception type
   }
 
+  if (t == 'timestamptz')
+    datetime = datetime.toUtc();
+
   pad(i) {
     var s = i.toString();
     return s.length == 1 ? '0$s' : s;
@@ -111,10 +114,8 @@ _formatDateTime(DateTime datetime, String type) {
     }
   }
 
-  if (t == 'timestamptz') {
-    // Add timezone offset.
-    throw new Exception('Not implemented'); //TODO
-  }
+  if (t == 'timestamptz')
+    sb.write("Z");
 
   return "'${sb.toString()}'";
 }

test/postgresql_test.dart

@@ -289,6 +289,18 @@ main() {
       );
     });
 
+    test('Select timestamptz with milliseconds', () {
+      final DateTime time = new DateTime(1979, 12, 20, 9, 0, 12);
+      conn.execute('create temporary table dart_unit_test (a timestamptz)');
+      conn.execute("insert into dart_unit_test values (@time)", {"time": time});
+
+      conn.query('select a from dart_unit_test').toList().then(
+        expectAsync1((rows) {
+          expect(rows[0][0], equals(time));
+        })
+      );
+    });
+
     test('Select DateTime', () {
 
       conn.execute('create temporary table dart_unit_test (a date)');