24
24
#define DRIZZLED_PLUGIN_TABLE_FUNCTION_H
26
26
#include <drizzled/definitions.h>
27
#include <drizzled/plugin.h>
28
#include <drizzled/plugin/plugin.h>
29
#include <drizzled/identifier.h>
30
#include <drizzled/message/table.pb.h>
31
#include <drizzled/charset.h>
32
#include <drizzled/field.h>
27
#include "drizzled/plugin.h"
28
#include "drizzled/plugin/plugin.h"
29
#include "drizzled/table_identifier.h"
30
#include "drizzled/message/table.pb.h"
31
#include "drizzled/charset.h"
32
#include "drizzled/field.h"
36
36
#include <algorithm>
38
#include <drizzled/visibility.h>
41
extern int wild_case_compare(const CHARSET_INFO * const cs,
42
const char *str,const char *wildstr);
46
#define TABLE_FUNCTION_BLOB_SIZE 2049
48
// Not thread safe, but plugins are just loaded in a single thread right
50
static const char *local_string_append(const char *arg1, const char *arg2)
52
static char buffer[1024];
53
char *buffer_ptr= buffer;
54
strcpy(buffer_ptr, arg1);
55
buffer_ptr+= strlen(arg1);
58
strcpy(buffer_ptr, arg2);
63
class DRIZZLED_API TableFunction : public Plugin
48
class TableFunction : public Plugin
66
51
TableFunction(const TableFunction &);
67
52
TableFunction& operator=(const TableFunction &);
69
54
message::Table proto;
70
identifier::Table identifier;
55
TableIdentifier identifier;
71
56
std::string local_path;
72
std::string original_table_label;
57
std::string local_schema;
74
59
void setName(); // init name
80
64
TableFunction(const char *schema_arg, const char *table_arg) :
81
Plugin(local_string_append(schema_arg, table_arg) , "TableFunction"),
82
identifier(schema_arg, table_arg),
83
original_table_label(table_arg)
65
Plugin(table_arg, "TableFunction"),
66
identifier(schema_arg, table_arg)
147
120
arg.CopyFrom(proto);
150
const std::string &getTableLabel()
152
return original_table_label;
155
const std::string &getIdentifierTableName()
157
return identifier.getTableName();
160
123
const std::string &getSchemaHome()
162
return identifier.getSchemaName();
125
if (local_schema.length() == 0)
127
local_schema= identifier.getSchemaName();
128
std::transform(local_schema.begin(), local_schema.end(),
129
local_schema.begin(), ::tolower);
165
135
const std::string &getPath()
167
return identifier.getPath();
137
if (local_path.length() == 0)
139
local_path= identifier.getPath();
140
std::transform(local_path.begin(), local_path.end(),
141
local_path.begin(), ::tolower);
170
147
virtual Generator *generator(Field **arg);
174
151
uint32_t length= 0);
176
153
void add_field(const char *label,
177
uint32_t field_length= MAXIMUM_IDENTIFIER_LENGTH);
154
uint32_t field_length= 64);
179
156
void add_field(const char *label,
180
157
TableFunction::ColumnType type,