@@ -261,9 +261,7 @@ static void set_datum_value(Decoderbufs__DatumMessage *datum_msg, Oid typid,
261
261
const char * output = NULL ;
262
262
Point * p = NULL ;
263
263
Timestamp ts ;
264
- double duration ;
265
264
TimeTzADT * timetz = NULL ;
266
- Interval * interval = NULL ;
267
265
Decoderbufs__Point dp = DECODERBUFS__POINT__INIT ;
268
266
269
267
int size = 0 ;
@@ -308,6 +306,7 @@ static void set_datum_value(Decoderbufs__DatumMessage *datum_msg, Oid typid,
308
306
case BITOID :
309
307
case VARBITOID :
310
308
case UUIDOID :
309
+ case INTERVALOID :
311
310
output = OidOutputFunctionCall (typoutput , datum );
312
311
datum_msg -> datum_string = pnstrdup (output , strlen (output ));
313
312
datum_msg -> datum_case = DECODERBUFS__DATUM_MESSAGE__DATUM_DATUM_STRING ;
@@ -347,15 +346,6 @@ static void set_datum_value(Decoderbufs__DatumMessage *datum_msg, Oid typid,
347
346
datum_msg -> datum_double = (double ) (timetz -> time + (timetz -> zone * 1000000.0 ));
348
347
datum_msg -> datum_case = DECODERBUFS__DATUM_MESSAGE__DATUM_DATUM_DOUBLE ;
349
348
break ;
350
- case INTERVALOID :
351
- interval = DatumGetIntervalP (datum );
352
- /*
353
- Convert the month part of Interval to days using assumed average month length of 365.25/12.0 days.
354
- */
355
- duration = interval -> time + interval -> day * (double ) USECS_PER_DAY + interval -> month * ((DAYS_PER_YEAR / (double ) MONTHS_PER_YEAR ) * USECS_PER_DAY );
356
- datum_msg -> datum_double = duration ;
357
- datum_msg -> datum_case = DECODERBUFS__DATUM_MESSAGE__DATUM_DATUM_DOUBLE ;
358
- break ;
359
349
case BYTEAOID :
360
350
valptr = DatumGetByteaPCopy (datum );
361
351
size = VARSIZE (valptr ) - VARHDRSZ ;
0 commit comments