1
1
/* -*- mode: c++ c-basic-offset: 2; indent-tabs-mode: nil; -*-
2
2
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
4
* Copyright (C) 2008 Sun Microsystems
4
* Copyright (C) 2008 Sun Microsystems, Inc.
6
6
* This program is free software; you can redistribute it and/or modify
7
7
* it under the terms of the GNU General Public License as published by
18
18
* Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
22
23
#include <boost/lexical_cast.hpp>
23
#include <drizzled/field/timestamp.h>
24
#include <drizzled/field/epoch.h>
24
25
#include <drizzled/error.h>
25
26
#include <drizzled/tztime.h>
26
27
#include <drizzled/table.h>
27
28
#include <drizzled/session.h>
29
#include <drizzled/current_session.h>
33
#include "drizzled/temporal.h"
35
#include <drizzled/temporal.h>
39
44
TIMESTAMP type holds datetime values in range from 1970-01-01 00:00:01 UTC to
40
45
2038-01-01 00:00:00 UTC stored as number of seconds since Unix
78
83
course is non-standard.) In most cases user won't notice any change, only
79
84
exception is different behavior of old/new timestamps during ALTER TABLE.
81
Field_timestamp::Field_timestamp(unsigned char *ptr_arg,
83
unsigned char *null_ptr_arg,
84
unsigned char null_bit_arg,
85
enum utype unireg_check_arg,
86
const char *field_name_arg,
88
const CHARSET_INFO * const cs)
90
DateTime::MAX_STRING_LENGTH - 1 /* no \0 */,
86
Epoch::Epoch(unsigned char *ptr_arg,
87
unsigned char *null_ptr_arg,
88
unsigned char null_bit_arg,
89
enum utype unireg_check_arg,
90
const char *field_name_arg,
91
drizzled::TableShare *share) :
93
MicroTimestamp::MAX_STRING_LENGTH - 1, /* no \0 */
96
/* For 4.0 MYD and 4.0 InnoDB compatibility */
97
flags|= UNSIGNED_FLAG;
98
99
unireg_check= unireg_check_arg;
99
100
if (! share->getTimestampField() && unireg_check != NONE)
101
102
/* This timestamp has auto-update */
102
103
share->setTimestampField(this);
103
flags|= TIMESTAMP_FLAG;
104
flags|= FUNCTION_DEFAULT_FLAG;
104
105
if (unireg_check != TIMESTAMP_DN_FIELD)
105
106
flags|= ON_UPDATE_NOW_FLAG;
109
Field_timestamp::Field_timestamp(bool maybe_null_arg,
110
const char *field_name_arg,
111
const CHARSET_INFO * const cs)
112
:Field_str((unsigned char*) NULL,
113
DateTime::MAX_STRING_LENGTH - 1 /* no \0 */,
114
maybe_null_arg ? (unsigned char*) "": 0,
110
Epoch::Epoch(bool maybe_null_arg,
111
const char *field_name_arg) :
112
Field_str((unsigned char*) NULL,
113
MicroTimestamp::MAX_STRING_LENGTH - 1, /* no \0 */
114
maybe_null_arg ? (unsigned char*) "": 0,
119
/* For 4.0 MYD and 4.0 InnoDB compatibility */
120
flags|= UNSIGNED_FLAG;
121
119
if (unireg_check != TIMESTAMP_DN_FIELD)
122
120
flags|= ON_UPDATE_NOW_FLAG;
159
int Field_timestamp::store(const char *from,
161
const CHARSET_INFO * const )
157
int Epoch::store(const char *from,
159
const CHARSET_INFO * const )
163
161
Timestamp temporal;
165
163
ASSERT_COLUMN_MARKED_FOR_WRITE;
167
if (! temporal.from_string(from, (size_t) len))
165
if (not temporal.from_string(from, (size_t) len))
169
my_error(ER_INVALID_UNIX_TIMESTAMP_VALUE, MYF(ME_FATALERROR), from);
167
my_error(ER_INVALID_TIMESTAMP_VALUE, MYF(ME_FATALERROR), from);
174
temporal.to_time_t(&tmp);
172
temporal.to_time_t(tmp);
176
store_timestamp(tmp);
174
uint64_t time_tmp= tmp;
180
int Field_timestamp::store(double from)
179
int Epoch::store(double from)
182
181
ASSERT_COLUMN_MARKED_FOR_WRITE;
184
if (from < 0 || from > 99991231235959.0)
183
uint64_t from_tmp= (uint64_t)from;
186
if (not temporal.from_int64_t(from_tmp))
186
/* Convert the double to a string using stringstream */
187
std::stringstream ss;
189
ss.precision(18); /* 18 places should be fine for error display of double input. */
188
/* Convert the integer to a string using boost::lexical_cast */
189
std::string tmp(boost::lexical_cast<std::string>(from));
193
my_error(ER_INVALID_UNIX_TIMESTAMP_VALUE, MYF(ME_FATALERROR), tmp.c_str());
191
my_error(ER_INVALID_TIMESTAMP_VALUE, MYF(ME_FATALERROR), tmp.c_str());
196
return Field_timestamp::store((int64_t) rint(from), false);
199
int Field_timestamp::store(int64_t from, bool)
196
temporal.to_time_t(tmp);
198
uint64_t tmp_micro= tmp;
204
int Epoch::store_decimal(const type::Decimal *value)
212
int Epoch::store(int64_t from, bool)
201
214
ASSERT_COLUMN_MARKED_FOR_WRITE;
205
218
* if unable to create a valid DateTime.
207
220
Timestamp temporal;
208
if (! temporal.from_int64_t(from))
221
if (not temporal.from_int64_t(from))
210
223
/* Convert the integer to a string using boost::lexical_cast */
211
224
std::string tmp(boost::lexical_cast<std::string>(from));
213
my_error(ER_INVALID_UNIX_TIMESTAMP_VALUE, MYF(ME_FATALERROR), tmp.c_str());
226
my_error(ER_INVALID_TIMESTAMP_VALUE, MYF(ME_FATALERROR), tmp.c_str());
218
temporal.to_time_t(&tmp);
220
store_timestamp(tmp);
231
temporal.to_time_t(tmp);
224
double Field_timestamp::val_real(void)
239
double Epoch::val_real(void) const
226
return (double) Field_timestamp::val_int();
241
return (double) Epoch::val_int();
229
int64_t Field_timestamp::val_int(void)
244
int64_t Epoch::val_int(void) const
233
248
ASSERT_COLUMN_MARKED_FOR_READ;
235
#ifdef WORDS_BIGENDIAN
236
if (getTable() && getTable()->getShare()->db_low_byte_first)
237
temp= uint8korr(ptr);
240
int64_tget(temp, ptr);
242
252
Timestamp temporal;
243
253
(void) temporal.from_time_t((time_t) temp);
251
String *Field_timestamp::val_str(String *val_buffer, String *)
261
String *Epoch::val_str(String *val_buffer, String *) const
255
265
int to_len= field_length + 1;
257
267
val_buffer->alloc(to_len);
258
268
to= (char *) val_buffer->ptr();
260
#ifdef WORDS_BIGENDIAN
261
if (getTable() && getTable()->getShare()->db_low_byte_first)
262
temp= uint8korr(ptr);
265
int64_tget(temp, ptr);
267
272
val_buffer->set_charset(&my_charset_bin); /* Safety */
277
282
return val_buffer;
280
bool Field_timestamp::get_date(DRIZZLE_TIME *ltime, uint32_t)
285
bool Epoch::get_date(type::Time <ime, uint32_t) const
288
type::Time::epoch_t time_temp;
284
#ifdef WORDS_BIGENDIAN
285
if (getTable() && getTable()->getShare()->db_low_byte_first)
286
temp= uint8korr(ptr);
289
int64_tget(temp, ptr);
291
memset(ltime, 0, sizeof(*ltime));
294
(void) temporal.from_time_t((time_t) temp);
296
/* @TODO Goodbye the below code when DRIZZLE_TIME is finally gone.. */
298
ltime->time_type= DRIZZLE_TIMESTAMP_DATETIME;
299
ltime->year= temporal.years();
300
ltime->month= temporal.months();
301
ltime->day= temporal.days();
302
ltime->hour= temporal.hours();
303
ltime->minute= temporal.minutes();
304
ltime->second= temporal.seconds();
295
ltime.store(time_temp);
309
bool Field_timestamp::get_time(DRIZZLE_TIME *ltime)
311
return Field_timestamp::get_date(ltime,0);
314
int Field_timestamp::cmp(const unsigned char *a_ptr, const unsigned char *b_ptr)
317
#ifdef WORDS_BIGENDIAN
318
if (getTable() && getTable()->getShare()->db_low_byte_first)
326
int64_tget(a, a_ptr);
327
int64_tget(b, b_ptr);
329
return ((uint64_t) a < (uint64_t) b) ? -1 : ((uint64_t) a > (uint64_t) b) ? 1 : 0;
333
void Field_timestamp::sort_string(unsigned char *to,uint32_t )
300
bool Epoch::get_time(type::Time <ime) const
302
return Epoch::get_date(ltime, 0);
305
int Epoch::cmp(const unsigned char *a_ptr, const unsigned char *b_ptr)
309
unpack_num(a, a_ptr);
310
unpack_num(b, b_ptr);
312
return (a < b) ? -1 : (a > b) ? 1 : 0;
316
void Epoch::sort_string(unsigned char *to,uint32_t )
335
318
#ifdef WORDS_BIGENDIAN
336
319
if (!getTable() || !getTable()->getShare()->db_low_byte_first)
361
void Field_timestamp::sql_type(String &res) const
344
void Epoch::sql_type(String &res) const
363
346
res.set_ascii(STRING_WITH_LEN("timestamp"));
366
void Field_timestamp::set_time()
349
void Epoch::set_time()
368
351
Session *session= getTable() ? getTable()->in_use : current_session;
369
time_t tmp= session->query_start();
352
time_t tmp= session->getCurrentTimestampEpoch();
371
store_timestamp(tmp);
355
pack_num(static_cast<uint32_t>(tmp));
374
void Field_timestamp::set_default()
358
void Epoch::set_default()
376
360
if (getTable()->timestamp_field == this &&
377
361
unireg_check != TIMESTAMP_UN_FIELD)
380
367
Field::set_default();
383
long Field_timestamp::get_timestamp(bool *null_value)
371
long Epoch::get_timestamp(bool *null_value) const
385
373
if ((*null_value= is_null()))
387
#ifdef WORDS_BIGENDIAN
388
if (getTable() && getTable()->getShare()->db_low_byte_first)
389
return sint8korr(ptr);
392
int64_tget(tmp, ptr);
377
return unpack_num(tmp);
396
void Field_timestamp::store_timestamp(int64_t timestamp)
380
size_t Epoch::max_string_length()
398
#ifdef WORDS_BIGENDIAN
399
if (getTable() && getTable()->getShare()->db_low_byte_first)
401
int8store(ptr, timestamp);
405
int64_tstore(ptr, timestamp);
382
return sizeof(uint64_t);
385
} /* namespace field */
408
386
} /* namespace drizzled */