1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
|
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#ifndef DRILL_METADATA_H
#define DRILL_METADATA_H
#include <boost/ref.hpp>
#include "drill/common.hpp"
#include "drill/drillClient.hpp"
#include "env.h"
#include "User.pb.h"
namespace Drill {
class DrillClientImpl;
namespace meta {
class DrillCatalogMetadata: public meta::CatalogMetadata {
public:
DrillCatalogMetadata(const ::exec::user::CatalogMetadata& metadata):
meta::CatalogMetadata(),
m_pMetadata(metadata){
}
bool hasCatalogName() const { return m_pMetadata.get().has_catalog_name(); }
const std::string& getCatalogName() const { return m_pMetadata.get().catalog_name(); }
bool hasDescription() const { return m_pMetadata.get().has_description(); }
const std::string& getDescription() const { return m_pMetadata.get().description(); }
bool hasConnect() const { return m_pMetadata.get().has_connect(); }
const std::string& getConnect() const { return m_pMetadata.get().connect(); }
private:
boost::reference_wrapper<const ::exec::user::CatalogMetadata> m_pMetadata;
};
class DrillSchemaMetadata: public meta::SchemaMetadata {
public:
DrillSchemaMetadata(const ::exec::user::SchemaMetadata& metadata):
meta::SchemaMetadata(),
m_pMetadata(metadata){
}
bool hasCatalogName() const { return m_pMetadata.get().has_catalog_name(); }
const std::string& getCatalogName() const { return m_pMetadata.get().catalog_name(); }
bool hasSchemaName() const { return m_pMetadata.get().has_schema_name(); }
const std::string& getSchemaName() const { return m_pMetadata.get().schema_name(); }
bool hasOwnerName() const { return m_pMetadata.get().has_owner(); }
const std::string& getOwner() const { return m_pMetadata.get().owner(); }
bool hasType() const { return m_pMetadata.get().has_type(); }
const std::string& getType() const { return m_pMetadata.get().type(); }
bool hasMutable() const { return m_pMetadata.get().has_mutable_(); }
const std::string& getMutable() const { return m_pMetadata.get().mutable_(); }
private:
boost::reference_wrapper<const ::exec::user::SchemaMetadata> m_pMetadata;
};
class DrillTableMetadata: public meta::TableMetadata {
public:
DrillTableMetadata(const ::exec::user::TableMetadata& metadata):
meta::TableMetadata(),
m_pMetadata(metadata){
}
bool hasCatalogName() const { return m_pMetadata.get().has_catalog_name(); }
const std::string& getCatalogName() const { return m_pMetadata.get().catalog_name(); }
bool hasSchemaName() const { return m_pMetadata.get().has_schema_name(); }
const std::string& getSchemaName() const { return m_pMetadata.get().schema_name(); }
bool hasTableName() const { return m_pMetadata.get().has_table_name(); }
const std::string& getTableName() const { return m_pMetadata.get().table_name(); }
bool hasType() const { return m_pMetadata.get().has_type(); }
const std::string& getType() const { return m_pMetadata.get().type(); }
private:
boost::reference_wrapper<const ::exec::user::TableMetadata> m_pMetadata;
};
class DrillColumnMetadata: public meta::ColumnMetadata {
public:
DrillColumnMetadata(const ::exec::user::ColumnMetadata& metadata):
meta::ColumnMetadata(),
m_pMetadata(metadata){
}
bool hasCatalogName() const { return m_pMetadata.get().has_catalog_name(); }
const std::string& getCatalogName() const { return m_pMetadata.get().catalog_name(); }
bool hasSchemaName() const { return m_pMetadata.get().has_schema_name(); }
const std::string& getSchemaName() const { return m_pMetadata.get().schema_name(); }
bool hasTableName() const { return m_pMetadata.get().has_table_name(); }
const std::string& getTableName() const { return m_pMetadata.get().table_name(); }
bool hasColumnName() const { return m_pMetadata.get().has_column_name(); }
const std::string& getColumnName() const { return m_pMetadata.get().column_name(); }
bool hasOrdinalPosition() const { return m_pMetadata.get().has_ordinal_position(); }
std::size_t getOrdinalPosition() const { return m_pMetadata.get().ordinal_position(); }
bool hasDefaultValue() const { return m_pMetadata.get().has_default_value(); }
const std::string& getDefaultValue() const { return m_pMetadata.get().default_value(); }
bool hasNullable() const { return m_pMetadata.get().has_is_nullable(); }
bool isNullable() const { return m_pMetadata.get().is_nullable(); }
bool hasDataType() const { return m_pMetadata.get().has_data_type(); }
const std::string& getDataType() const { return m_pMetadata.get().data_type(); }
bool hasColumnSize() const { return m_pMetadata.get().has_column_size(); }
std::size_t getColumnSize() const { return m_pMetadata.get().column_size(); }
bool hasCharMaxLength() const { return m_pMetadata.get().has_char_max_length(); }
std::size_t getCharMaxLength() const { return m_pMetadata.get().char_max_length(); }
bool hasCharOctetLength() const { return m_pMetadata.get().has_char_octet_length(); }
std::size_t getCharOctetLength() const { return m_pMetadata.get().char_octet_length(); }
bool hasNumericPrecision() const { return m_pMetadata.get().has_numeric_precision(); }
int32_t getNumericPrecision() const { return m_pMetadata.get().numeric_precision(); }
bool hasNumericRadix() const { return m_pMetadata.get().has_numeric_precision_radix(); }
int32_t getNumericRadix() const { return m_pMetadata.get().numeric_precision_radix(); }
bool hasNumericScale() const { return m_pMetadata.get().has_numeric_scale(); }
int32_t getNumericScale() const { return m_pMetadata.get().numeric_scale(); }
bool hasIntervalType() const { return m_pMetadata.get().has_interval_type(); }
const std::string& getIntervalType() const { return m_pMetadata.get().interval_type(); }
bool hasIntervalPrecision() const { return m_pMetadata.get().has_interval_precision(); }
int32_t getIntervalPrecision() const { return m_pMetadata.get().interval_precision(); }
private:
boost::reference_wrapper<const ::exec::user::ColumnMetadata> m_pMetadata;
};
class DrillMetadata: public Metadata {
public:
static const std::string s_connectorName;
static const std::string s_connectorVersion;
static const std::string s_serverName;
static const std::string s_serverVersion;
static const std::string s_catalogSeparator;
static const std::string s_catalogTerm;
static const std::string s_identifierQuoteString;
static const std::vector<std::string> s_sqlKeywords;
static const std::vector<std::string> s_numericFunctions;
static const std::string s_schemaTerm;
static const std::string s_searchEscapeString;
static const std::string s_specialCharacters;
static const std::vector<std::string> s_stringFunctions;
static const std::vector<std::string> s_systemFunctions;
static const std::string s_tableTerm;
static const std::vector<std::string> s_dateTimeFunctions;
DrillMetadata(DrillClientImpl& client): Metadata(), m_client(client) {}
~DrillMetadata() {}
DrillClientImpl& client() { return m_client; }
const std::string& getConnectorName() const { return s_connectorName; };
const std::string& getConnectorVersion() const { return s_connectorVersion; }
uint32_t getConnectorMajorVersion() const { return DRILL_VERSION_MAJOR; }
uint32_t getConnectorMinorVersion() const { return DRILL_VERSION_MINOR; }
uint32_t getConnectorPatchVersion() const { return DRILL_VERSION_PATCH; }
const std::string& getServerName() const;
const std::string& getServerVersion() const;
uint32_t getServerMajorVersion() const;
uint32_t getServerMinorVersion() const;
uint32_t getServerPatchVersion() const;
status_t getCatalogs(const std::string& catalogPattern, Metadata::pfnCatalogMetadataListener listener, void* listenerCtx, QueryHandle_t* qHandle);
status_t getSchemas(const std::string& catalogPattern, const std::string& schemaPattern, Metadata::pfnSchemaMetadataListener listener, void* listenerCtx, QueryHandle_t* qHandle);
status_t getTables(const std::string& catalogPattern, const std::string& schemaPattern, const std::string& tablePattern, const std::vector<std::string>* tableTypes, Metadata::pfnTableMetadataListener listener, void* listenerCtx, QueryHandle_t* qHandle);
status_t getColumns(const std::string& catalogPattern, const std::string& schemaPattern, const std:: string& tablePattern, const std::string& columnPattern, Metadata::pfnColumnMetadataListener listener, void* listenerCtx, QueryHandle_t* qHandle);
bool areAllTableSelectable() const { return false; }
bool isCatalogAtStart() const { return true; }
const std::string& getCatalogSeparator() const { return s_catalogSeparator; }
const std::string& getCatalogTerm() const { return s_catalogTerm; }
bool isColumnAliasingSupported() const { return true; }
bool isNullPlusNonNullNull() const { return true; }
bool isConvertSupported(common::MinorType from, common::MinorType to) const;
meta::CorrelationNamesSupport getCorrelationNames() const { return meta::CN_ANY_NAMES; }
bool isReadOnly() const { return false; }
meta::DateTimeLiteralSupport getDateTimeLiteralsSupport() const {
return DL_DATE
| DL_TIME
| DL_TIMESTAMP
| DL_INTERVAL_YEAR
| DL_INTERVAL_MONTH
| DL_INTERVAL_DAY
| DL_INTERVAL_HOUR
| DL_INTERVAL_MINUTE
| DL_INTERVAL_SECOND
| DL_INTERVAL_YEAR_TO_MONTH
| DL_INTERVAL_DAY_TO_HOUR
| DL_INTERVAL_DAY_TO_MINUTE
| DL_INTERVAL_DAY_TO_SECOND
| DL_INTERVAL_HOUR_TO_MINUTE
| DL_INTERVAL_HOUR_TO_SECOND
| DL_INTERVAL_MINUTE_TO_SECOND;
}
meta::CollateSupport getCollateSupport() const { return meta::C_NONE; }// supported?
meta::GroupBySupport getGroupBySupport() const { return meta::GB_UNRELATED; }
meta::IdentifierCase getIdentifierCase() const { return meta::IC_STORES_UPPER; } // to check?
const std::string& getIdentifierQuoteString() const { return s_identifierQuoteString; }
const std::vector<std::string>& getSQLKeywords() const { return s_sqlKeywords; }
bool isLikeEscapeClauseSupported() const { return true; }
std::size_t getMaxBinaryLiteralLength() const { return 0; }
std::size_t getMaxCatalogNameLength() const { return 0; }
std::size_t getMaxCharLiteralLength() const { return 0; }
std::size_t getMaxColumnNameLength() const { return 0; }
std::size_t getMaxColumnsInGroupBy() const { return 0; }
std::size_t getMaxColumnsInOrderBy() const { return 0; }
std::size_t getMaxColumnsInSelect() const { return 0; }
std::size_t getMaxCursorNameLength() const { return 0; }
std::size_t getMaxLogicalLobSize() const { return 0; }
std::size_t getMaxStatements() const { return 0; }
std::size_t getMaxRowSize() const { return 0; }
bool isBlobIncludedInMaxRowSize() const { return true; }
std::size_t getMaxSchemaNameLength() const { return 0; }
std::size_t getMaxStatementLength() const { return 0; }
std::size_t getMaxTableNameLength() const { return 0; }
std::size_t getMaxTablesInSelect() const { return 0; }
std::size_t getMaxUserNameLength() const { return 0; }
meta::NullCollation getNullCollation() const { return meta::NC_AT_END; }
const std::vector<std::string>& getNumericFunctions() const { return s_numericFunctions; }
meta::OuterJoinSupport getOuterJoinSupport() const { return meta::OJ_LEFT
| meta::OJ_RIGHT
| meta::OJ_FULL;
}
bool isUnrelatedColumnsInOrderBySupported() const { return true; }
meta::QuotedIdentifierCase getQuotedIdentifierCase() const { return meta::QIC_SUPPORTS_MIXED; }
const std::string& getSchemaTerm() const { return s_schemaTerm; }
const std::string& getSearchEscapeString() const { return s_searchEscapeString; }
const std::string& getSpecialCharacters() const { return s_specialCharacters; }
const std::vector<std::string>& getStringFunctions() const { return s_stringFunctions; }
meta::SubQuerySupport getSubQuerySupport() const { return SQ_CORRELATED
| SQ_IN_COMPARISON
| SQ_IN_EXISTS
| SQ_IN_QUANTIFIED;
}
const std::vector<std::string>& getSystemFunctions() const { return s_systemFunctions; }
const std::string& getTableTerm() const { return s_tableTerm; }
const std::vector<std::string>& getDateTimeFunctions() const { return s_dateTimeFunctions; }
bool isTransactionSupported() const { return false; }
meta::UnionSupport getUnionSupport() const { return meta::U_UNION | meta::U_UNION_ALL; }
bool isSelectForUpdateSupported() const { return false; }
private:
DrillClientImpl& m_client;
};
} // namespace meta
} // namespace Drill
#endif // DRILL_METADATA
|
