68
66
int doCreateTable(drizzled::Session &session,
69
67
drizzled::Table &table_arg,
70
const drizzled::identifier::Table &identifier,
68
const drizzled::TableIdentifier &identifier,
71
69
drizzled::message::Table &table_proto);
73
71
int doRenameTable(drizzled::Session &session,
74
const drizzled::identifier::Table &from_identifier,
75
const drizzled::identifier::Table &to_identifier);
72
const drizzled::TableIdentifier &from_identifier,
73
const drizzled::TableIdentifier &to_identifier);
77
75
int doDropTable(drizzled::Session &session,
78
const drizzled::identifier::Table &identifier);
76
const drizzled::TableIdentifier &identifier);
80
78
int doGetTableDefinition(drizzled::Session &session,
81
const drizzled::identifier::Table &identifier,
79
const drizzled::TableIdentifier &identifier,
82
80
drizzled::message::Table &table_proto);
84
82
void doGetTableIdentifiers(drizzled::CachedDirectory &directory,
85
const drizzled::identifier::Schema &schema_identifier,
86
drizzled::identifier::Table::vector &set_of_identifiers);
83
const drizzled::SchemaIdentifier &schema_identifier,
84
drizzled::TableIdentifier::vector &set_of_identifiers);
88
86
bool doDoesTableExist(drizzled::Session &session,
89
const drizzled::identifier::Table &identifier);
87
const drizzled::TableIdentifier &identifier);
91
89
bool validateCreateTableOption(const std::string &key,
92
90
const std::string &state);
124
122
int BlitzEngine::doCreateTable(drizzled::Session &,
125
123
drizzled::Table &table,
126
const drizzled::identifier::Table &identifier,
124
const drizzled::TableIdentifier &identifier,
127
125
drizzled::message::Table &proto) {
166
164
int BlitzEngine::doRenameTable(drizzled::Session &,
167
const drizzled::identifier::Table &from,
168
const drizzled::identifier::Table &to) {
165
const drizzled::TableIdentifier &from,
166
const drizzled::TableIdentifier &to) {
171
169
BlitzData blitz_table;
286
284
int BlitzEngine::doGetTableDefinition(drizzled::Session &,
287
const drizzled::identifier::Table &identifier,
285
const drizzled::TableIdentifier &identifier,
288
286
drizzled::message::Table &proto) {
289
287
struct stat stat_info;
290
288
std::string path(identifier.getPath());
328
326
void BlitzEngine::doGetTableIdentifiers(drizzled::CachedDirectory &directory,
329
const drizzled::identifier::Schema &schema_id,
330
drizzled::identifier::Table::vector &ids) {
327
const drizzled::SchemaIdentifier &schema_id,
328
drizzled::TableIdentifier::vector &ids) {
331
329
drizzled::CachedDirectory::Entries entries = directory.getEntries();
333
331
for (drizzled::CachedDirectory::Entries::iterator entry_iter = entries.begin();
346
344
char uname[NAME_LEN + 1];
347
345
uint32_t file_name_len;
349
file_name_len = identifier::Table::filename_to_tablename(filename->c_str(),
347
file_name_len = TableIdentifier::filename_to_tablename(filename->c_str(),
353
351
uname[file_name_len - sizeof(BLITZ_DATA_EXT) + 1]= '\0';
354
ids.push_back(identifier::Table(schema_id, uname));
352
ids.push_back(TableIdentifier(schema_id, uname));
359
357
bool BlitzEngine::doDoesTableExist(drizzled::Session &,
360
const drizzled::identifier::Table &identifier) {
358
const drizzled::TableIdentifier &identifier) {
361
359
std::string proto_path(identifier.getPath());
362
360
proto_path.append(BLITZ_DATA_EXT);
500
498
int ha_blitz::doStartTableScan(bool scan) {
501
499
/* Obtain the query type for this scan */
502
sql_command_type = getTable()->getSession()->getSqlCommand();
500
sql_command_type = session_sql_command(getTable()->getSession());
503
501
table_scan = scan;
504
502
table_based = true;
625
623
int ha_blitz::doStartIndexScan(uint32_t key_num, bool) {
626
624
active_index = key_num;
627
sql_command_type = getTable()->getSession()->getSqlCommand();
625
sql_command_type = session_sql_command(getTable()->getSession());
629
627
/* This is unlikely to happen but just for assurance, re-obtain
630
628
the lock if this thread already has a certain lock. This makes