1
1
/* -*- mode: c++; c-basic-offset: 2; indent-tabs-mode: nil; -*-
2
2
* vim:expandtab:shiftwidth=2:tabstop=2:smarttab:
4
* Copyright (C) 2009 Sun Microsystems, Inc.
4
* Copyright (C) 2009 Sun Microsystems
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
23
23
instance of table share per one table in the database.
26
#ifndef DRIZZLED_TABLE_INSTANCE_BASE_H
27
#define DRIZZLED_TABLE_INSTANCE_BASE_H
26
#ifndef DRIZZLED_TABLE_SHARE_H
27
#define DRIZZLED_TABLE_SHARE_H
31
31
#include <boost/unordered_map.hpp>
32
32
#include <boost/thread/condition_variable.hpp>
33
#include <boost/dynamic_bitset.hpp>
34
#include <boost/shared_ptr.hpp>
35
#include <boost/scoped_ptr.hpp>
37
34
#include "drizzled/typelib.h"
38
35
#include "drizzled/memory/root.h"
39
#include "drizzled/message.h"
36
#include "drizzled/message/table.pb.h"
40
37
#include "drizzled/util/string.h"
42
#include "drizzled/lex_string.h"
43
#include "drizzled/key_map.h"
45
#include "drizzled/table/cache.h"
47
#include <drizzled/field.h>
53
const static std::string NO_PROTOBUFFER_AVAILABLE("NO PROTOBUFFER AVAILABLE");
42
typedef boost::unordered_map< TableIdentifier::Key, TableShare *> TableDefinitionCache;
44
const static std::string STANDARD_STRING("STANDARD");
45
const static std::string TEMPORARY_STRING("TEMPORARY");
46
const static std::string INTERNAL_STRING("INTERNAL");
47
const static std::string FUNCTION_STRING("FUNCTION");
57
51
class EventObserverList;
69
58
typedef std::vector<std::string> StringVector;
72
typedef boost::shared_ptr<TableShare> shared_ptr;
73
typedef std::vector <shared_ptr> vector;
75
TableShare(const identifier::Table::Type type_arg);
77
TableShare(const identifier::Table &identifier, const identifier::Table::Key &key); // Used by placeholder
79
TableShare(const identifier::Table &identifier); // Just used during createTable()
81
TableShare(const identifier::Table::Type type_arg,
82
const identifier::Table &identifier,
60
TableShare(TableIdentifier::Type type_arg);
62
TableShare(TableIdentifier &identifier, const TableIdentifier::Key &key); // Used by placeholder
64
TableShare(const TableIdentifier &identifier); // Just used during createTable()
66
TableShare(TableIdentifier::Type type_arg,
67
TableIdentifier &identifier,
83
68
char *path_arg= NULL, uint32_t path_length_arg= 0); // Shares for cache
85
virtual ~TableShare();
88
73
/** Category of this table. */
89
74
enum_table_category table_category;
76
uint32_t open_count; /* Number of tables in open list */
92
79
bool isTemporaryCategory() const
94
81
return (table_category == TABLE_CATEGORY_TEMPORARY);
102
89
/* The following is copied to each Table on OPEN */
103
90
typedef std::vector<Field *> Fields;
109
94
const Fields getFields() const
119
99
Field ** getFields(bool)
124
104
void setFields(uint32_t arg)
129
109
uint32_t positionFields(Field **arg) const
131
return (arg - (Field **)&_fields[0]);
111
return (arg - (Field **)&field[0]);
134
114
void pushField(Field *arg)
137
_fields.push_back(arg);
117
field.push_back(arg);
140
121
Field **found_next_number_field;
143
123
Field *timestamp_field; /* Used only during open */
147
126
Field *getTimestampField() const /* Used only during open */
166
144
std::vector<uint> blob_field; /* Index to blobs in Field arrray*/
169
146
/* hash of field names (contains pointers to elements of field array) */
170
148
typedef boost::unordered_map < std::string, Field **, util::insensitive_hash, util::insensitive_equal_to> FieldMap;
171
149
typedef std::pair< std::string, Field ** > FieldMapPair;
172
150
FieldMap name_hash; /* hash of field names */
175
152
size_t getNamedFieldSize() const
213
191
arg.begin(), ::toupper);
214
192
_keynames.push_back(arg);
218
195
bool doesKeyNameExist(const char *name_arg, uint32_t name_length, uint32_t &position) const
220
return doesKeyNameExist(std::string(name_arg, name_length), position);
197
std::string arg(name_arg, name_length);
198
std::transform(arg.begin(), arg.end(),
199
arg.begin(), ::toupper);
201
std::vector<std::string>::const_iterator iter= std::find(_keynames.begin(), _keynames.end(), arg);
203
if (iter == _keynames.end())
206
position= iter - _keynames.begin();
223
211
bool doesKeyNameExist(std::string arg, uint32_t &position) const
242
230
std::vector<TYPELIB> intervals; /* pointer to interval info */
232
boost::mutex mutex; /* For locking the share */
233
boost::condition_variable cond; /* To signal that share is ready */
248
virtual void unlock()
252
248
std::vector<unsigned char> default_values; /* row with default values */
255
// @note This needs to be made to be const in the future
256
unsigned char *getDefaultValues()
250
unsigned char * getDefaultValues()
258
252
return &default_values[0];
262
256
default_values.resize(arg);
265
const charset_info_st *table_charset; /* Default charset of string fields */
267
boost::dynamic_bitset<> all_set;
259
const CHARSET_INFO *table_charset; /* Default charset of string fields */
263
std::vector<my_bitmap_map> all_bitmap;
270
267
Key which is used for looking-up table in table cache and in the list
271
268
of thread's temporary tables. Has the form of:
277
274
To ensure this one can use set_table_cache() methods.
280
identifier::Table::Key private_key_for_cache; // This will not exist in the final design.
277
TableIdentifier::Key private_key_for_cache; // This will not exist in the final design.
281
278
std::vector<char> private_normalized_path; // This will not exist in the final design.
282
279
LEX_STRING db; /* Pointer to db */
283
280
LEX_STRING table_name; /* Table name (for open) */
284
281
LEX_STRING path; /* Path to table (from datadir) */
285
282
LEX_STRING normalized_path; /* unpack_filename(path) */
289
285
const char *getNormalizedPath() const
359
352
uint64_t version;
362
354
uint64_t getVersion() const
367
void refreshVersion();
359
void refreshVersion()
361
version= refresh_version;
369
364
void resetVersion()
375
369
uint32_t timestamp_offset; /* Set to offset+1 of record */
377
uint32_t reclength; /* Recordlength */
378
uint32_t stored_rec_length; /* Stored record length*/
371
uint32_t reclength; /* Recordlength */
381
uint32_t sizeStoredRecord() const
383
return stored_rec_length;
373
uint32_t stored_rec_length; /* Stored record length*/
386
375
uint32_t getRecordLength() const
405
394
/* Max rows is a hint to HEAP during a create tmp table */
406
395
uint64_t max_rows;
408
boost::scoped_ptr<message::Table> _table_message;
397
message::Table *table_proto;
412
@note Without a _table_message, we assume we are building a STANDARD table.
401
@note Without a table_proto, we assume we are building a STANDARD table.
413
402
This will be modified once we use Identifiers in the Share itself.
415
404
message::Table::TableType getTableType() const
417
return getTableMessage() ? getTableMessage()->type() : message::Table::STANDARD;
406
return table_proto ? table_proto->type() : message::Table::STANDARD;
420
409
const std::string &getTableTypeAsString() const
422
if (getTableMessage())
423
return message::type(getTableMessage()->type());
425
return NO_PROTOBUFFER_AVAILABLE;
411
switch (table_proto->type())
414
case message::Table::STANDARD:
415
return STANDARD_STRING;
416
case message::Table::TEMPORARY:
417
return TEMPORARY_STRING;
418
case message::Table::INTERNAL:
419
return INTERNAL_STRING;
420
case message::Table::FUNCTION:
421
return FUNCTION_STRING;
428
425
/* This is only used in one location currently */
429
inline message::Table *getTableMessage() const
431
return _table_message.get();
434
void setTableMessage(const message::Table &arg)
436
assert(not getTableMessage());
437
_table_message.reset(new(std::nothrow) message::Table(arg));
440
const message::Table::Field &field(int32_t field_position) const
442
assert(getTableMessage());
443
return getTableMessage()->field(field_position);
426
inline message::Table *getTableProto() const
431
inline void setTableProto(message::Table *arg)
433
assert(table_proto == NULL);
446
437
inline bool hasComment() const
448
return (getTableMessage()) ? getTableMessage()->options().has_comment() : false;
439
return (table_proto) ? table_proto->options().has_comment() : false;
451
442
inline const char *getComment()
453
return (getTableMessage() && getTableMessage()->has_options()) ? getTableMessage()->options().comment().c_str() : NULL;
444
return (table_proto && table_proto->has_options()) ? table_proto->options().comment().c_str() : NULL;
456
447
inline uint32_t getCommentLength() const
458
return (getTableMessage()) ? getTableMessage()->options().comment().length() : 0;
449
return (table_proto) ? table_proto->options().comment().length() : 0;
461
452
inline uint64_t getMaxRows() const
488
identifier::Table::Type tmp_table;
479
TableIdentifier::Type tmp_table;
491
identifier::Table::Type getType() const
482
TableIdentifier::Type getType() const
493
484
return tmp_table;
497
uint32_t _ref_count; /* How many Table objects uses this */
488
uint32_t ref_count; /* How many Table objects uses this */
500
490
uint32_t getTableCount() const
505
495
void incrementTableCount()
512
uint32_t decrementTableCount()
517
502
uint32_t null_bytes;
518
503
uint32_t last_null_bit_pos;
520
uint32_t _field_size; /* Number of fields */
523
void setFieldSize(uint32_t arg)
504
uint32_t fields; /* Number of fields */
528
506
uint32_t sizeFields() const
533
511
uint32_t rec_buff_length; /* Size of table->record[] buffer */
542
520
uint32_t uniques; /* Number of UNIQUE index */
543
521
uint32_t null_fields; /* number of null fields */
544
522
uint32_t blob_fields; /* number of blob fields */
546
bool has_variable_width; /* number of varchar fields */
549
bool hasVariableWidth() const
551
return has_variable_width; // We should calculate this.
553
void setVariableWidth()
555
has_variable_width= true;
523
uint32_t timestamp_field_offset; /* Field number for timestamp field */
524
uint32_t varchar_fields; /* number of varchar fields */
557
525
uint32_t db_create_options; /* Create options from database */
558
526
uint32_t db_options_in_use; /* Options in use */
559
527
uint32_t db_record_offset; /* if HA_REC_IN_SEQ */
586
554
uint32_t next_number_key_offset; /* autoinc keypart offset in a key */
587
555
uint32_t next_number_keypart; /* autoinc keypart number in a key */
588
556
uint32_t error, open_errno, errarg; /* error from open_table_def() */
557
uint32_t column_bitmap_size;
591
559
uint8_t blob_ptr_size; /* 4 or 8 */
594
uint8_t sizeBlobPtr() const
596
return blob_ptr_size;
599
560
bool db_low_byte_first; /* Portable row format */
565
bool isNameLock() const
570
bool replace_with_name_lock;
573
bool waiting_on_cond; /* Protection against free */
575
bool isWaitingOnCondition()
577
return waiting_on_cond;
602
581
Set of keys in use, implemented as a Bitmap.
603
582
Excludes keys disabled by ALTER Table ... DISABLE KEYS.
609
588
event_observers is a class containing all the event plugins that have
610
589
registered an interest in this table.
612
virtual plugin::EventObserverList *getTableObservers()
592
plugin::EventObserverList *event_observers;
594
plugin::EventObserverList *getTableObservers()
596
return event_observers;
617
virtual void setTableObservers(plugin::EventObserverList *)
599
void setTableObservers(plugin::EventObserverList *observers)
601
event_observers= observers;
621
605
Set share's identifier information.
629
void setIdentifier(const identifier::Table &identifier_arg);
613
void setIdentifier(TableIdentifier &identifier_arg);
615
inline bool honor_global_locks()
617
return (table_category == TABLE_CATEGORY_USER);
632
622
Initialize share for temporary tables
648
638
void init(const char *new_table_name,
649
639
const char *new_path);
652
642
void open_table_error(int pass_error, int db_errno, int pass_errarg);
656
static TableShare::shared_ptr getShareCreate(Session *session,
657
const identifier::Table &identifier,
644
static void cacheStart(void);
645
static void release(TableShare *share);
646
static void release(TableIdentifier &identifier);
647
static const TableDefinitionCache &getCache();
648
static TableShare *getShare(TableIdentifier &identifier);
649
static TableShare *getShareCreate(Session *session,
650
TableIdentifier &identifier,
660
653
friend std::ostream& operator<<(std::ostream& output, const TableShare &share)
672
665
return output; // for multiple << operators.
676
friend class drizzled::table::Singular;
678
Field *make_field(const message::Table::Field &pfield,
668
Field *make_field(unsigned char *ptr,
680
669
uint32_t field_length,
681
670
bool is_nullable,
682
671
unsigned char *null_pos,
683
672
unsigned char null_bit,
684
673
uint8_t decimals,
685
674
enum_field_types field_type,
686
const charset_info_st * field_charset,
675
const CHARSET_INFO * field_charset,
687
676
Field::utype unireg_check,
688
677
TYPELIB *interval,
689
678
const char *field_name);
691
Field *make_field(const message::Table::Field &pfield,
693
uint32_t field_length,
695
unsigned char *null_pos,
696
unsigned char null_bit,
698
enum_field_types field_type,
699
const charset_info_st * field_charset,
700
Field::utype unireg_check,
702
const char *field_name,
706
int open_table_def(Session& session, const identifier::Table &identifier);
680
int open_table_def(Session& session, TableIdentifier &identifier);
708
682
int open_table_from_share(Session *session,
709
const identifier::Table &identifier,
683
const TableIdentifier &identifier,
710
684
const char *alias,
711
685
uint32_t db_stat, uint32_t ha_open_flags,
712
686
Table &outparam);
687
int parse_table_proto(Session& session, message::Table &table);
714
int open_table_from_share_inner(Session *session,
718
int open_table_cursor_inner(const identifier::Table &identifier,
719
uint32_t db_stat, uint32_t ha_open_flags,
721
bool &error_reported);
723
bool parse_table_proto(Session& session, message::Table &table);
689
int inner_parse_table_proto(Session& session, message::Table &table);
726
692
} /* namespace drizzled */
728
#endif /* DRIZZLED_TABLE_INSTANCE_BASE_H */
694
#endif /* DRIZZLED_TABLE_SHARE_H */