30
30
static jmethodID s_Timestamp_getTime;
31
31
static jmethodID s_Timestamp_setNanos;
33
static Type s_Timestamp;
34
33
static TypeClass s_TimestampClass;
36
static Type s_Timestamptz;
37
34
static TypeClass s_TimestamptzClass;
39
36
static bool _Timestamp_canReplaceType(Type self, Type other)
41
return other->m_class == s_TimestampClass || other->m_class == s_TimestamptzClass;
38
TypeClass cls = Type_getClass(other);
39
return Type_getClass(self) == cls || cls == s_TimestamptzClass;
44
static jvalue Timestamp_coerceDatumTZ_id(Type self, JNIEnv* env, Datum arg, bool tzAdjust)
42
static jvalue Timestamp_coerceDatumTZ_id(Type self, Datum arg, bool tzAdjust)
47
45
int64 ts = DatumGetInt64(arg);
46
int tz = Timestamp_getTimeZone_id(ts);
49
48
/* Expect number of microseconds since 01 Jan 2000
51
50
jlong mSecs = ts / 1000; /* Convert to millisecs */
52
51
jint uSecs = (jint)(ts % 1000); /* preserve remaining microsecs */
54
mSecs += Timestamp_getTimeZone(ts) * 1000;/* Adjust from local time to UTC */
53
mSecs += tz * 1000; /* Adjust from local time to UTC */
55
54
mSecs += EPOCH_DIFF * 1000; /* Adjust for diff between Postgres and Java (Unix) */
56
result.l = PgObject_newJavaObject(env, s_Timestamp_class, s_Timestamp_init, mSecs);
55
result.l = JNI_newObject(s_Timestamp_class, s_Timestamp_init, mSecs);
58
(*env)->CallIntMethod(env, result.l, s_Timestamp_setNanos, uSecs * 1000);
57
JNI_callVoidMethod(result.l, s_Timestamp_setNanos, uSecs * 1000);
62
static jvalue Timestamp_coerceDatumTZ_dd(Type self, JNIEnv* env, Datum arg, bool tzAdjust)
61
static jvalue Timestamp_coerceDatumTZ_dd(Type self, Datum arg, bool tzAdjust)
68
67
double ts = DatumGetFloat8(arg);
68
int tz = Timestamp_getTimeZone_dd(ts);
70
70
/* Expect <seconds since Jan 01 2000>.<fractions of seconds>
73
ts += Timestamp_getTimeZone(ts);/* Adjust from local time to UTC */
73
ts += tz; /* Adjust from local time to UTC */
74
74
ts += EPOCH_DIFF; /* Adjust for diff between Postgres and Java (Unix) */
75
75
ts *= 1000.0; /* Convert to millisecs */
77
77
mSecs = (jlong)tmp;
78
78
uSecs = ((ts - tmp) * 1000.0); /* Preserve remaining microsecs */
79
result.l = PgObject_newJavaObject(env, s_Timestamp_class, s_Timestamp_init, mSecs);
79
result.l = JNI_newObject(s_Timestamp_class, s_Timestamp_init, mSecs);
81
(*env)->CallIntMethod(env, result.l, s_Timestamp_setNanos, uSecs * 1000);
81
JNI_callVoidMethod(result.l, s_Timestamp_setNanos, uSecs * 1000);
85
static jvalue Timestamp_coerceDatumTZ(Type self, JNIEnv* env, Datum arg, bool tzAdjust)
85
static jvalue Timestamp_coerceDatumTZ(Type self, Datum arg, bool tzAdjust)
87
87
return integerDateTimes
88
? Timestamp_coerceDatumTZ_id(self, env, arg, tzAdjust)
89
: Timestamp_coerceDatumTZ_dd(self, env, arg, tzAdjust);
88
? Timestamp_coerceDatumTZ_id(self, arg, tzAdjust)
89
: Timestamp_coerceDatumTZ_dd(self, arg, tzAdjust);
92
static Datum Timestamp_coerceObjectTZ_id(Type self, JNIEnv* env, jobject jts, bool tzAdjust)
92
static Datum Timestamp_coerceObjectTZ_id(Type self, jobject jts, bool tzAdjust)
95
jlong mSecs = (*env)->CallLongMethod(env, jts, s_Timestamp_getTime);
96
jint nSecs = (*env)->CallIntMethod(env, jts, s_Timestamp_getNanos);
95
jlong mSecs = JNI_callLongMethod(jts, s_Timestamp_getTime);
96
jint nSecs = JNI_callIntMethod(jts, s_Timestamp_getNanos);
97
97
mSecs -= ((jlong)EPOCH_DIFF) * 1000L;
98
98
ts = mSecs * 1000L; /* Convert millisecs to microsecs */
100
100
ts += nSecs / 1000; /* Convert nanosecs to microsecs */
102
ts -= ((jlong)Timestamp_getTimeZone(ts)) * 1000000L; /* Adjust from UTC to local time */
102
ts -= ((jlong)Timestamp_getTimeZone_id(ts)) * 1000000L; /* Adjust from UTC to local time */
103
103
return Int64GetDatum(ts);
106
static Datum Timestamp_coerceObjectTZ_dd(Type self, JNIEnv* env, jobject jts, bool tzAdjust)
106
static Datum Timestamp_coerceObjectTZ_dd(Type self, jobject jts, bool tzAdjust)
109
jlong mSecs = (*env)->CallLongMethod(env, jts, s_Timestamp_getTime);
110
jint nSecs = (*env)->CallIntMethod(env, jts, s_Timestamp_getNanos);
109
jlong mSecs = JNI_callLongMethod(jts, s_Timestamp_getTime);
110
jint nSecs = JNI_callIntMethod(jts, s_Timestamp_getNanos);
111
111
ts = ((double)mSecs) / 1000.0; /* Convert to seconds */
112
112
ts -= EPOCH_DIFF;
114
114
ts += ((double)nSecs) / 1000000000.0; /* Convert to seconds */
116
ts -= Timestamp_getTimeZone(ts); /* Adjust from UTC to local time */
116
ts -= Timestamp_getTimeZone_dd(ts); /* Adjust from UTC to local time */
117
117
return Float8GetDatum(ts);
120
static Datum Timestamp_coerceObjectTZ(Type self, JNIEnv* env, jobject jts, bool tzAdjust)
120
static Datum Timestamp_coerceObjectTZ(Type self, jobject jts, bool tzAdjust)
122
122
return integerDateTimes
123
? Timestamp_coerceObjectTZ_id(self, env, jts, tzAdjust)
124
: Timestamp_coerceObjectTZ_dd(self, env, jts, tzAdjust);
127
static jvalue _Timestamp_coerceDatum(Type self, JNIEnv* env, Datum arg)
129
return Timestamp_coerceDatumTZ(self, env, arg, true);
132
static Datum _Timestamp_coerceObject(Type self, JNIEnv* env, jobject ts)
134
return Timestamp_coerceObjectTZ(self, env, ts, true);
123
? Timestamp_coerceObjectTZ_id(self, jts, tzAdjust)
124
: Timestamp_coerceObjectTZ_dd(self, jts, tzAdjust);
127
static jvalue _Timestamp_coerceDatum(Type self, Datum arg)
129
return Timestamp_coerceDatumTZ(self, arg, true);
132
static Datum _Timestamp_coerceObject(Type self, jobject ts)
134
return Timestamp_coerceObjectTZ(self, ts, true);
138
138
* Timestamp with time zone. Basically same as Timestamp but postgres will pass
139
139
* this one in GMT timezone so there's no without ajustment for time zone.
141
static jvalue _Timestamptz_coerceDatum(Type self, JNIEnv* env, Datum arg)
143
return Timestamp_coerceDatumTZ(self, env, arg, false);
146
static Datum _Timestamptz_coerceObject(Type self, JNIEnv* env, jobject ts)
148
return Timestamp_coerceObjectTZ(self, env, ts, false);
151
static Type Timestamp_obtain(Oid typeId)
156
static Type Timestamptz_obtain(Oid typeId)
158
return s_Timestamptz;
161
int Timestamp_getTimeZone(Timestamp ts)
163
#if (PGSQL_MAJOR_VER == 7 && PGSQL_MINOR_VER < 5)
141
static bool _Timestamptz_canReplaceType(Type self, Type other)
143
TypeClass cls = Type_getClass(other);
144
return Type_getClass(self) == cls || cls == s_TimestampClass;
147
static jvalue _Timestamptz_coerceDatum(Type self, Datum arg)
149
return Timestamp_coerceDatumTZ(self, arg, false);
152
static Datum _Timestamptz_coerceObject(Type self, jobject ts)
154
return Timestamp_coerceObjectTZ(self, ts, false);
157
#if !(PGSQL_MAJOR_VER == 8 && PGSQL_MINOR_VER == 0)
158
extern DLLIMPORT pg_tz* global_timezone;
161
static int Timestamp_getTimeZone(pg_time_t time)
163
#if (PGSQL_MAJOR_VER == 8 && PGSQL_MINOR_VER == 0)
164
struct pg_tm* tx = pg_localtime(&time);
166
struct pg_tm* tx = pg_localtime(&time, global_timezone);
170
timestamp2tm(ts, &tz, &tmp_tm, &fsec, NULL);
174
int Timestamp_getCurrentTimeZone(void)
178
AbsoluteTime sec = GetCurrentAbsoluteTimeUsec(&usec);
179
tz = Timestamp_getTimeZone(AbsoluteTimeUsecToTimestampTz(sec, usec));
183
/* Make this datatype available to the postgres system.
185
extern Datum Timestamp_initialize(PG_FUNCTION_ARGS);
186
PG_FUNCTION_INFO_V1(Timestamp_initialize);
187
Datum Timestamp_initialize(PG_FUNCTION_ARGS)
189
JNIEnv* env = (JNIEnv*)PG_GETARG_POINTER(0);
191
s_Timestamp_class = (*env)->NewGlobalRef(
192
env, PgObject_getJavaClass(env, "java/sql/Timestamp"));
193
s_Timestamp_init = PgObject_getJavaMethod(
194
env, s_Timestamp_class, "<init>", "(J)V");
195
s_Timestamp_getNanos = PgObject_getJavaMethod(
196
env, s_Timestamp_class, "getNanos", "()I");
197
s_Timestamp_getTime = PgObject_getJavaMethod(
198
env, s_Timestamp_class, "getTime", "()J");
199
s_Timestamp_setNanos = PgObject_getJavaMethod(
200
env, s_Timestamp_class, "setNanos", "(I)V");
202
s_TimestampClass = TypeClass_alloc("type.Timestamp");
203
s_TimestampClass->JNISignature = "Ljava/sql/Timestamp;";
204
s_TimestampClass->javaTypeName = "java.sql.Timestamp";
205
s_TimestampClass->canReplaceType = _Timestamp_canReplaceType;
206
s_TimestampClass->coerceDatum = _Timestamp_coerceDatum;
207
s_TimestampClass->coerceObject = _Timestamp_coerceObject;
208
s_Timestamp = TypeClass_allocInstance(s_TimestampClass, TIMESTAMPOID);
210
s_TimestamptzClass = TypeClass_alloc("type.Timestamptz");
211
s_TimestamptzClass->JNISignature = "Ljava/sql/Timestamp;";
212
s_TimestamptzClass->javaTypeName = "java.sql.Timestamp";
213
s_TimestamptzClass->canReplaceType = _Timestamp_canReplaceType;
214
s_TimestamptzClass->coerceDatum = _Timestamptz_coerceDatum;
215
s_TimestamptzClass->coerceObject = _Timestamptz_coerceObject;
216
s_Timestamptz = TypeClass_allocInstance(s_TimestamptzClass, TIMESTAMPTZOID);
218
Type_registerPgType(TIMESTAMPOID, Timestamp_obtain);
219
Type_registerPgType(TIMESTAMPTZOID, Timestamptz_obtain);
220
Type_registerJavaType("java.sql.Timestamp", Timestamptz_obtain);
168
return -tx->tm_gmtoff;
171
int32 Timestamp_getTimeZone_id(int64 dt)
173
return Timestamp_getTimeZone(
174
(dt / INT64CONST(1000000) + (POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * 86400));
176
int32 Timestamp_getTimeZone_dd(double dt)
178
return Timestamp_getTimeZone(
179
(pg_time_t)rint(dt + (POSTGRES_EPOCH_JDATE - UNIX_EPOCH_JDATE) * 86400));
182
int32 Timestamp_getCurrentTimeZone(void)
184
return Timestamp_getTimeZone((pg_time_t)GetCurrentAbsoluteTime());
187
extern void Timestamp_initialize(void);
188
void Timestamp_initialize(void)
191
s_Timestamp_class = JNI_newGlobalRef(PgObject_getJavaClass("java/sql/Timestamp"));
192
s_Timestamp_init = PgObject_getJavaMethod(s_Timestamp_class, "<init>", "(J)V");
193
s_Timestamp_getNanos = PgObject_getJavaMethod(s_Timestamp_class, "getNanos", "()I");
194
s_Timestamp_getTime = PgObject_getJavaMethod(s_Timestamp_class, "getTime", "()J");
195
s_Timestamp_setNanos = PgObject_getJavaMethod(s_Timestamp_class, "setNanos", "(I)V");
197
cls = TypeClass_alloc("type.Timestamp");
198
cls->JNISignature = "Ljava/sql/Timestamp;";
199
cls->javaTypeName = "java.sql.Timestamp";
200
cls->canReplaceType = _Timestamp_canReplaceType;
201
cls->coerceDatum = _Timestamp_coerceDatum;
202
cls->coerceObject = _Timestamp_coerceObject;
203
Type_registerType(0, TypeClass_allocInstance(cls, TIMESTAMPOID));
204
s_TimestampClass = cls;
206
cls = TypeClass_alloc("type.Timestamptz");
207
cls->JNISignature = "Ljava/sql/Timestamp;";
208
cls->javaTypeName = "java.sql.Timestamp";
209
cls->canReplaceType = _Timestamptz_canReplaceType;
210
cls->coerceDatum = _Timestamptz_coerceDatum;
211
cls->coerceObject = _Timestamptz_coerceObject;
212
Type_registerType("java.sql.Timestamp", TypeClass_allocInstance(cls, TIMESTAMPTZOID));
213
s_TimestamptzClass = cls;
added
removed
src/C/pljava/type/Timestamp.c
