thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-11-27 01:51:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Resolve bad caching of INCBIN'd external data

Browse Source
This commit is contained in:
Robert Schulze 2023-09-21 17:40:16 +00:00
parent 2b8a263355
commit a46e0deb85
No known key found for this signature in database
GPG Key ID: 26703B55FB13728A
7 changed files with 355 additions and 313 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

105
src/Storages/System/InformationSchema/columns.sql
View File

@ -1,105 +0,0 @@
ATTACH VIEW columns
(
`table_catalog` String,
`table_schema` String,
`table_name` String,
`column_name` String,
`ordinal_position` UInt64,
`column_default` String,
`is_nullable` String,
`data_type` String,
`character_maximum_length` Nullable(UInt64),
`character_octet_length` Nullable(UInt64),
`numeric_precision` Nullable(UInt64),
`numeric_precision_radix` Nullable(UInt64),
`numeric_scale` Nullable(UInt64),
`datetime_precision` Nullable(UInt64),
`character_set_catalog` Nullable(String),
`character_set_schema` Nullable(String),
`character_set_name` Nullable(String),
`collation_catalog` Nullable(String),
`collation_schema` Nullable(String),
`collation_name` Nullable(String),
`domain_catalog` Nullable(String),
`domain_schema` Nullable(String),
`domain_name` Nullable(String),
`column_comment` String,
`column_type` String,
`TABLE_CATALOG` String,
`TABLE_SCHEMA` String,
`TABLE_NAME` String,
`COLUMN_NAME` String,
`ORDINAL_POSITION` UInt64,
`COLUMN_DEFAULT` String,
`IS_NULLABLE` String,
`DATA_TYPE` String,
`CHARACTER_MAXIMUM_LENGTH` Nullable(UInt64),
`CHARACTER_OCTET_LENGTH` Nullable(UInt64),
`NUMERIC_PRECISION` Nullable(UInt64),
`NUMERIC_PRECISION_RADIX` Nullable(UInt64),
`NUMERIC_SCALE` Nullable(UInt64),
`DATETIME_PRECISION` Nullable(UInt64),
`CHARACTER_SET_CATALOG` Nullable(String),
`CHARACTER_SET_SCHEMA` Nullable(String),
`CHARACTER_SET_NAME` Nullable(String),
`COLLATION_CATALOG` Nullable(String),
`COLLATION_SCHEMA` Nullable(String),
`COLLATION_NAME` Nullable(String),
`DOMAIN_CATALOG` Nullable(String),
`DOMAIN_SCHEMA` Nullable(String),
`DOMAIN_NAME` Nullable(String),
`COLUMN_COMMENT` String,
`COLUMN_TYPE` String
) AS
SELECT
database AS table_catalog,
database AS table_schema,
table AS table_name,
name AS column_name,
position AS ordinal_position,
default_expression AS column_default,
type LIKE 'Nullable(%)' AS is_nullable,
type AS data_type,
character_octet_length AS character_maximum_length,
character_octet_length,
numeric_precision,
numeric_precision_radix,
numeric_scale,
datetime_precision,
NULL AS character_set_catalog,
NULL AS character_set_schema,
NULL AS character_set_name,
NULL AS collation_catalog,
NULL AS collation_schema,
NULL AS collation_name,
NULL AS domain_catalog,
NULL AS domain_schema,
NULL AS domain_name,
comment AS column_comment,
type AS column_type,
table_catalog AS TABLE_CATALOG,
table_schema AS TABLE_SCHEMA,
table_name AS TABLE_NAME,
column_name AS COLUMN_NAME,
ordinal_position AS ORDINAL_POSITION,
column_default AS COLUMN_DEFAULT,
is_nullable AS IS_NULLABLE,
data_type AS DATA_TYPE,
character_maximum_length AS CHARACTER_MAXIMUM_LENGTH,
character_octet_length AS CHARACTER_OCTET_LENGTH,
numeric_precision AS NUMERIC_PRECISION,
numeric_precision_radix AS NUMERIC_PRECISION_RADIX,
numeric_scale AS NUMERIC_SCALE,
datetime_precision AS DATETIME_PRECISION,
character_set_catalog AS CHARACTER_SET_CATALOG,
character_set_schema AS CHARACTER_SET_SCHEMA,
character_set_name AS CHARACTER_SET_NAME,
collation_catalog AS COLLATION_CATALOG,
collation_schema AS COLLATION_SCHEMA,
collation_name AS COLLATION_NAME,
domain_catalog AS DOMAIN_CATALOG,
domain_schema AS DOMAIN_SCHEMA,
domain_name AS DOMAIN_NAME,
column_comment AS COLUMN_COMMENT,
column_type AS COLUMN_TYPE
FROM system.columns

54
src/Storages/System/InformationSchema/key_column_usage.sql
View File

@ -1,54 +0,0 @@
ATTACH VIEW key_column_usage
(
`constraint_catalog` String,
`constraint_schema` String,
`constraint_name` Nullable(String),
`table_catalog` String,
`table_schema` String,
`table_name` String,
`column_name` Nullable(String),
`ordinal_position` UInt32,
`position_in_unique_constraint` Nullable(UInt32),
`referenced_table_schema` Nullable(String),
`referenced_table_name` Nullable(String),
`referenced_column_name` Nullable(String),
`CONSTRAINT_CATALOG` Nullable(String),
`CONSTRAINT_SCHEMA` Nullable(String),
`CONSTRAINT_NAME` Nullable(String),
`TABLE_CATALOG` String,
`TABLE_SCHEMA` String,
`TABLE_NAME` String,
`COLUMN_NAME` Nullable(String),
`ORDINAL_POSITION` UInt32,
`POSITION_IN_UNIQUE_CONSTRAINT` Nullable(UInt32),
`REFERENCED_TABLE_SCHEMA` Nullable(String),
`REFERENCED_TABLE_NAME` Nullable(String),
`REFERENCED_COLUMN_NAME` Nullable(String)
) AS
SELECT
'def' AS constraint_catalog,
database AS constraint_schema,
'PRIMARY' AS constraint_name,
'def' AS table_catalog,
database AS table_schema,
table AS table_name,
name AS column_name,
1 AS ordinal_position,
NULL AS position_in_unique_constraint,
NULL AS referenced_table_schema,
NULL AS referenced_table_name,
NULL AS referenced_column_name,
constraint_catalog AS CONSTRAINT_CATALOG,
constraint_schema AS CONSTRAINT_SCHEMA,
constraint_name AS CONSTRAINT_NAME,
table_catalog AS TABLE_CATALOG,
table_schema AS TABLE_SCHEMA,
table_name AS TABLE_NAME,
column_name AS COLUMN_NAME,
ordinal_position AS ORDINAL_POSITION,
position_in_unique_constraint AS POSITION_IN_UNIQUE_CONSTRAINT,
referenced_table_schema AS REFERENCED_TABLE_SCHEMA,
referenced_table_name AS REFERENCED_TABLE_NAME,
referenced_column_name AS REFERENCED_COLUMN_NAME
FROM system.columns
WHERE is_in_primary_key;

25
src/Storages/System/InformationSchema/referential_constraints.sql
View File

@ -1,25 +0,0 @@
CREATE TABLE referential_constraints
(
`constraint_catalog` String,
`constraint_schema` String,
`constraint_name` Nullable(String),
`unique_constraint_catalog` String,
`unique_constraint_schema` String,
`unique_constraint_name` Nullable(String),
`match_option` String,
`update_rule` String,
`delete_rule` String,
`table_name` String,
`referenced_table_name` String,
`CONSTRAINT_CATALOG` String,
`CONSTRAINT_SCHEMA` String,
`CONSTRAINT_NAME` Nullable(String),
`UNIQUE_CONSTRAINT_CATALOG` String,
`UNIQUE_CONSTRAINT_SCHEMA` String,
`UNIQUE_CONSTRAINT_NAME` Nullable(String),
`MATCH_OPTION` String,
`UPDATE_RULE` String,
`DELETE_RULE` String,
`TABLE_NAME` String,
`REFERENCED_TABLE_NAME` String
) ENGINE Memory;

33
src/Storages/System/InformationSchema/schemata.sql
View File

@ -1,33 +0,0 @@
ATTACH VIEW schemata
(
`catalog_name` String,
`schema_name` String,
`schema_owner` String,
`default_character_set_catalog` Nullable(String),
`default_character_set_schema` Nullable(String),
`default_character_set_name` Nullable(String),
`sql_path` Nullable(String),
`CATALOG_NAME` String,
`SCHEMA_NAME` String,
`SCHEMA_OWNER` String,
`DEFAULT_CHARACTER_SET_CATALOG` Nullable(String),
`DEFAULT_CHARACTER_SET_SCHEMA` Nullable(String),
`DEFAULT_CHARACTER_SET_NAME` Nullable(String),
`SQL_PATH` Nullable(String)
) AS
SELECT
name AS catalog_name,
name AS schema_name,
'default' AS schema_owner,
NULL AS default_character_set_catalog,
NULL AS default_character_set_schema,
NULL AS default_character_set_name,
NULL AS sql_path,
catalog_name AS CATALOG_NAME,
schema_name AS SCHEMA_NAME,
schema_owner AS SCHEMA_OWNER,
default_character_set_catalog AS DEFAULT_CHARACTER_SET_CATALOG,
default_character_set_schema AS DEFAULT_CHARACTER_SET_SCHEMA,
default_character_set_name AS DEFAULT_CHARACTER_SET_NAME,
sql_path AS SQL_PATH
FROM system.databases

34
src/Storages/System/InformationSchema/tables.sql
View File

@ -1,34 +0,0 @@
ATTACH VIEW tables
(
`table_catalog` String,
`table_schema` String,
`table_name` String,
`table_type` String,
`table_collation` Nullable(String),
`table_comment` Nullable(String),
`TABLE_CATALOG` String,
`TABLE_SCHEMA` String,
`TABLE_NAME` String,
`TABLE_TYPE` String,
`TABLE_COLLATION` Nullable(String),
`TABLE_COMMENT` Nullable(String)
) AS
SELECT
database AS table_catalog,
database AS table_schema,
name AS table_name,
multiIf(is_temporary, 'LOCAL TEMPORARY',
engine LIKE '%View', 'VIEW',
engine LIKE 'System%', 'SYSTEM VIEW',
has_own_data = 0, 'FOREIGN TABLE',
'BASE TABLE'
) AS table_type,
'utf8mb4_0900_ai_ci' AS table_collation,
comment AS table_comment,
table_catalog AS TABLE_CATALOG,
table_schema AS TABLE_SCHEMA,
table_name AS TABLE_NAME,
table_type AS TABLE_TYPE,
table_collation AS TABLE_COLLATION,
table_comment AS TABLE_COMMENT
FROM system.tables

46
src/Storages/System/InformationSchema/views.sql
View File

@ -1,46 +0,0 @@
ATTACH VIEW views
(
`table_catalog` String,
`table_schema` String,
`table_name` String,
`view_definition` String,
`check_option` String,
`is_updatable` Enum8('NO' = 0, 'YES' = 1),
`is_insertable_into` Enum8('NO' = 0, 'YES' = 1),
`is_trigger_updatable` Enum8('NO' = 0, 'YES' = 1),
`is_trigger_deletable` Enum8('NO' = 0, 'YES' = 1),
`is_trigger_insertable_into` Enum8('NO' = 0, 'YES' = 1),
`TABLE_CATALOG` String,
`TABLE_SCHEMA` String,
`TABLE_NAME` String,
`VIEW_DEFINITION` String,
`CHECK_OPTION` String,
`IS_UPDATABLE` Enum8('NO' = 0, 'YES' = 1),
`IS_INSERTABLE_INTO` Enum8('NO' = 0, 'YES' = 1),
`IS_TRIGGER_UPDATABLE` Enum8('NO' = 0, 'YES' = 1),
`IS_TRIGGER_DELETABLE` Enum8('NO' = 0, 'YES' = 1),
`IS_TRIGGER_INSERTABLE_INTO` Enum8('NO' = 0, 'YES' = 1)
) AS
SELECT
database AS table_catalog,
database AS table_schema,
name AS table_name,
as_select AS view_definition,
'NONE' AS check_option,
0 AS is_updatable,
engine = 'MaterializedView' AS is_insertable_into,
0 AS is_trigger_updatable,
0 AS is_trigger_deletable,
0 AS is_trigger_insertable_into,
table_catalog AS TABLE_CATALOG,
table_schema AS TABLE_SCHEMA,
table_name AS TABLE_NAME,
view_definition AS VIEW_DEFINITION,
check_option AS CHECK_OPTION,
is_updatable AS IS_UPDATABLE,
is_insertable_into AS IS_INSERTABLE_INTO,
is_trigger_updatable AS IS_TRIGGER_UPDATABLE,
is_trigger_deletable AS IS_TRIGGER_DELETABLE,
is_trigger_insertable_into AS IS_TRIGGER_INSERTABLE_INTO
FROM system.tables
WHERE engine LIKE '%View'

371
src/Storages/System/attachInformationSchemaTables.cpp
View File

@ -3,21 +3,360 @@
#include <Storages/System/attachSystemTablesImpl.h>
#include <Parsers/ParserCreateQuery.h>
#include <Parsers/parseQuery.h>
#include <incbin.h>
#include "config.h"
/// Embedded SQL definitions
INCBIN(resource_schemata_sql, SOURCE_DIR "/src/Storages/System/InformationSchema/schemata.sql");
INCBIN(resource_tables_sql, SOURCE_DIR "/src/Storages/System/InformationSchema/tables.sql");
INCBIN(resource_views_sql, SOURCE_DIR "/src/Storages/System/InformationSchema/views.sql");
INCBIN(resource_columns_sql, SOURCE_DIR "/src/Storages/System/InformationSchema/columns.sql");
INCBIN(resource_key_column_usage_sql, SOURCE_DIR "/src/Storages/System/InformationSchema/key_column_usage.sql");
INCBIN(resource_referential_constraints_sql, SOURCE_DIR "/src/Storages/System/InformationSchema/referential_constraints.sql");
namespace DB
{
/// Below are SQL definitions for views in "information_schema". Perhaps it would be more aesthetic to have them in .sql files
/// and embed them here instead. In fact, it has been that way using INCBIN macros until #54773. The problem was that when
/// existing .sql files were changed, the build system did not recognize that this source (.cpp) file changed and instead used
/// cached object files from previous builds.
///
/// INCBIN is one of many libraries to embed external data. We might wait a little bit longer and try #embed (*) which should
/// solve the problem once and for all after 40 years.
///
/// (*) https://thephd.dev/finally-embed-in-c23
static constexpr std::string_view schemata = R"(
ATTACH VIEW schemata
(
`catalog_name` String,
`schema_name` String,
`schema_owner` String,
`default_character_set_catalog` Nullable(String),
`default_character_set_schema` Nullable(String),
`default_character_set_name` Nullable(String),
`sql_path` Nullable(String),
`CATALOG_NAME` String,
`SCHEMA_NAME` String,
`SCHEMA_OWNER` String,
`DEFAULT_CHARACTER_SET_CATALOG` Nullable(String),
`DEFAULT_CHARACTER_SET_SCHEMA` Nullable(String),
`DEFAULT_CHARACTER_SET_NAME` Nullable(String),
`SQL_PATH` Nullable(String)
) AS
SELECT
name AS catalog_name,
name AS schema_name,
'default' AS schema_owner,
NULL AS default_character_set_catalog,
NULL AS default_character_set_schema,
NULL AS default_character_set_name,
NULL AS sql_path,
catalog_name AS CATALOG_NAME,
schema_name AS SCHEMA_NAME,
schema_owner AS SCHEMA_OWNER,
default_character_set_catalog AS DEFAULT_CHARACTER_SET_CATALOG,
default_character_set_schema AS DEFAULT_CHARACTER_SET_SCHEMA,
default_character_set_name AS DEFAULT_CHARACTER_SET_NAME,
sql_path AS SQL_PATH
FROM system.databases
)";
static constexpr std::string_view tables = R"(
ATTACH VIEW tables
(
`table_catalog` String,
`table_schema` String,
`table_name` String,
`table_type` String,
`table_collation` Nullable(String),
`table_comment` Nullable(String),
`TABLE_CATALOG` String,
`TABLE_SCHEMA` String,
`TABLE_NAME` String,
`TABLE_TYPE` String,
`TABLE_COLLATION` Nullable(String),
`TABLE_COMMENT` Nullable(String)
) AS
SELECT
database AS table_catalog,
database AS table_schema,
name AS table_name,
multiIf(is_temporary, 'LOCAL TEMPORARY',
engine LIKE '%View', 'VIEW',
engine LIKE 'System%', 'SYSTEM VIEW',
has_own_data = 0, 'FOREIGN TABLE',
'BASE TABLE'
) AS table_type,
'utf8mb4_0900_ai_ci' AS table_collation,
comment AS table_comment,
table_catalog AS TABLE_CATALOG,
table_schema AS TABLE_SCHEMA,
table_name AS TABLE_NAME,
table_type AS TABLE_TYPE,
table_collation AS TABLE_COLLATION,
table_comment AS TABLE_COMMENT
FROM system.tables
)";
static constexpr std::string_view views = R"(
ATTACH VIEW views
(
`table_catalog` String,
`table_schema` String,
`table_name` String,
`view_definition` String,
`check_option` String,
`is_updatable` Enum8('NO' = 0, 'YES' = 1),
`is_insertable_into` Enum8('NO' = 0, 'YES' = 1),
`is_trigger_updatable` Enum8('NO' = 0, 'YES' = 1),
`is_trigger_deletable` Enum8('NO' = 0, 'YES' = 1),
`is_trigger_insertable_into` Enum8('NO' = 0, 'YES' = 1),
`TABLE_CATALOG` String,
`TABLE_SCHEMA` String,
`TABLE_NAME` String,
`VIEW_DEFINITION` String,
`CHECK_OPTION` String,
`IS_UPDATABLE` Enum8('NO' = 0, 'YES' = 1),
`IS_INSERTABLE_INTO` Enum8('NO' = 0, 'YES' = 1),
`IS_TRIGGER_UPDATABLE` Enum8('NO' = 0, 'YES' = 1),
`IS_TRIGGER_DELETABLE` Enum8('NO' = 0, 'YES' = 1),
`IS_TRIGGER_INSERTABLE_INTO` Enum8('NO' = 0, 'YES' = 1)
) AS
SELECT
database AS table_catalog,
database AS table_schema,
name AS table_name,
as_select AS view_definition,
'NONE' AS check_option,
0 AS is_updatable,
engine = 'MaterializedView' AS is_insertable_into,
0 AS is_trigger_updatable,
0 AS is_trigger_deletable,
0 AS is_trigger_insertable_into,
table_catalog AS TABLE_CATALOG,
table_schema AS TABLE_SCHEMA,
table_name AS TABLE_NAME,
view_definition AS VIEW_DEFINITION,
check_option AS CHECK_OPTION,
is_updatable AS IS_UPDATABLE,
is_insertable_into AS IS_INSERTABLE_INTO,
is_trigger_updatable AS IS_TRIGGER_UPDATABLE,
is_trigger_deletable AS IS_TRIGGER_DELETABLE,
is_trigger_insertable_into AS IS_TRIGGER_INSERTABLE_INTO
FROM system.tables
WHERE engine LIKE '%View'
)";
static constexpr std::string_view columns = R"(
ATTACH VIEW columns
(
`table_catalog` String,
`table_schema` String,
`table_name` String,
`column_name` String,
`ordinal_position` UInt64,
`column_default` String,
`is_nullable` String,
`data_type` String,
`character_maximum_length` Nullable(UInt64),
`character_octet_length` Nullable(UInt64),
`numeric_precision` Nullable(UInt64),
`numeric_precision_radix` Nullable(UInt64),
`numeric_scale` Nullable(UInt64),
`datetime_precision` Nullable(UInt64),
`character_set_catalog` Nullable(String),
`character_set_schema` Nullable(String),
`character_set_name` Nullable(String),
`collation_catalog` Nullable(String),
`collation_schema` Nullable(String),
`collation_name` Nullable(String),
`domain_catalog` Nullable(String),
`domain_schema` Nullable(String),
`domain_name` Nullable(String),
`column_comment` String,
`column_type` String,
`TABLE_CATALOG` String,
`TABLE_SCHEMA` String,
`TABLE_NAME` String,
`COLUMN_NAME` String,
`ORDINAL_POSITION` UInt64,
`COLUMN_DEFAULT` String,
`IS_NULLABLE` String,
`DATA_TYPE` String,
`CHARACTER_MAXIMUM_LENGTH` Nullable(UInt64),
`CHARACTER_OCTET_LENGTH` Nullable(UInt64),
`NUMERIC_PRECISION` Nullable(UInt64),
`NUMERIC_PRECISION_RADIX` Nullable(UInt64),
`NUMERIC_SCALE` Nullable(UInt64),
`DATETIME_PRECISION` Nullable(UInt64),
`CHARACTER_SET_CATALOG` Nullable(String),
`CHARACTER_SET_SCHEMA` Nullable(String),
`CHARACTER_SET_NAME` Nullable(String),
`COLLATION_CATALOG` Nullable(String),
`COLLATION_SCHEMA` Nullable(String),
`COLLATION_NAME` Nullable(String),
`DOMAIN_CATALOG` Nullable(String),
`DOMAIN_SCHEMA` Nullable(String),
`DOMAIN_NAME` Nullable(String),
`COLUMN_COMMENT` String,
`COLUMN_TYPE` String
) AS
SELECT
database AS table_catalog,
database AS table_schema,
table AS table_name,
name AS column_name,
position AS ordinal_position,
default_expression AS column_default,
type LIKE 'Nullable(%)' AS is_nullable,
type AS data_type,
character_octet_length AS character_maximum_length,
character_octet_length,
numeric_precision,
numeric_precision_radix,
numeric_scale,
datetime_precision,
NULL AS character_set_catalog,
NULL AS character_set_schema,
NULL AS character_set_name,
NULL AS collation_catalog,
NULL AS collation_schema,
NULL AS collation_name,
NULL AS domain_catalog,
NULL AS domain_schema,
NULL AS domain_name,
comment AS column_comment,
type AS column_type,
table_catalog AS TABLE_CATALOG,
table_schema AS TABLE_SCHEMA,
table_name AS TABLE_NAME,
column_name AS COLUMN_NAME,
ordinal_position AS ORDINAL_POSITION,
column_default AS COLUMN_DEFAULT,
is_nullable AS IS_NULLABLE,
data_type AS DATA_TYPE,
character_maximum_length AS CHARACTER_MAXIMUM_LENGTH,
character_octet_length AS CHARACTER_OCTET_LENGTH,
numeric_precision AS NUMERIC_PRECISION,
numeric_precision_radix AS NUMERIC_PRECISION_RADIX,
numeric_scale AS NUMERIC_SCALE,
datetime_precision AS DATETIME_PRECISION,
character_set_catalog AS CHARACTER_SET_CATALOG,
character_set_schema AS CHARACTER_SET_SCHEMA,
character_set_name AS CHARACTER_SET_NAME,
collation_catalog AS COLLATION_CATALOG,
collation_schema AS COLLATION_SCHEMA,
collation_name AS COLLATION_NAME,
domain_catalog AS DOMAIN_CATALOG,
domain_schema AS DOMAIN_SCHEMA,
domain_name AS DOMAIN_NAME,
column_comment AS COLUMN_COMMENT,
column_type AS COLUMN_TYPE
FROM system.columns
)";
static constexpr std::string_view key_column_usage = R"(
ATTACH VIEW key_column_usage
(
`constraint_catalog` String,
`constraint_schema` String,
`constraint_name` Nullable(String),
`table_catalog` String,
`table_schema` String,
`table_name` String,
`column_name` Nullable(String),
`ordinal_position` UInt32,
`position_in_unique_constraint` Nullable(UInt32),
`referenced_table_schema` Nullable(String),
`referenced_table_name` Nullable(String),
`referenced_column_name` Nullable(String),
`CONSTRAINT_CATALOG` Nullable(String),
`CONSTRAINT_SCHEMA` Nullable(String),
`CONSTRAINT_NAME` Nullable(String),
`TABLE_CATALOG` String,
`TABLE_SCHEMA` String,
`TABLE_NAME` String,
`COLUMN_NAME` Nullable(String),
`ORDINAL_POSITION` UInt32,
`POSITION_IN_UNIQUE_CONSTRAINT` Nullable(UInt32),
`REFERENCED_TABLE_SCHEMA` Nullable(String),
`REFERENCED_TABLE_NAME` Nullable(String),
`REFERENCED_COLUMN_NAME` Nullable(String)
) AS
SELECT
'def' AS constraint_catalog,
database AS constraint_schema,
'PRIMARY' AS constraint_name,
'def' AS table_catalog,
database AS table_schema,
table AS table_name,
name AS column_name,
1 AS ordinal_position,
NULL AS position_in_unique_constraint,
NULL AS referenced_table_schema,
NULL AS referenced_table_name,
NULL AS referenced_column_name,
constraint_catalog AS CONSTRAINT_CATALOG,
constraint_schema AS CONSTRAINT_SCHEMA,
constraint_name AS CONSTRAINT_NAME,
table_catalog AS TABLE_CATALOG,
table_schema AS TABLE_SCHEMA,
table_name AS TABLE_NAME,
column_name AS COLUMN_NAME,
ordinal_position AS ORDINAL_POSITION,
position_in_unique_constraint AS POSITION_IN_UNIQUE_CONSTRAINT,
referenced_table_schema AS REFERENCED_TABLE_SCHEMA,
referenced_table_name AS REFERENCED_TABLE_NAME,
referenced_column_name AS REFERENCED_COLUMN_NAME
FROM system.columns
WHERE is_in_primary_key;
)";
static constexpr std::string_view referential_constraints = R"(
ATTACH VIEW referential_constraints
(
`constraint_catalog` String,
`constraint_schema` String,
`constraint_name` Nullable(String),
`unique_constraint_catalog` String,
`unique_constraint_schema` String,
`unique_constraint_name` Nullable(String),
`match_option` String,
`update_rule` String,
`delete_rule` String,
`table_name` String,
`referenced_table_name` String,
`CONSTRAINT_CATALOG` String,
`CONSTRAINT_SCHEMA` String,
`CONSTRAINT_NAME` Nullable(String),
`UNIQUE_CONSTRAINT_CATALOG` String,
`UNIQUE_CONSTRAINT_SCHEMA` String,
`UNIQUE_CONSTRAINT_NAME` Nullable(String),
`MATCH_OPTION` String,
`UPDATE_RULE` String,
`DELETE_RULE` String,
`TABLE_NAME` String,
`REFERENCED_TABLE_NAME` String
) AS
SELECT
'' AS constraint_catalog,
NULL AS constraint_name,
'' AS constraint_schema,
'' AS unique_constraint_catalog,
NULL AS unique_constraint_name,
'' AS unique_constraint_schema,
'' AS match_option,
'' AS update_rule,
'' AS delete_rule,
'' AS table_name,
'' AS referenced_table_name,
constraint_catalog AS CONSTRAINT_CATALOG,
constraint_name AS CONSTRAINT_NAME,
constraint_schema AS CONSTRAINT_SCHEMA,
unique_constraint_catalog AS UNIQUE_CONSTRAINT_CATALOG,
unique_constraint_name AS UNIQUE_CONSTRAINT_NAME,
unique_constraint_schema AS UNIQUE_CONSTRAINT_SCHEMA,
match_option AS MATCH_OPTION,
update_rule AS UPDATE_RULE,
delete_rule AS DELETE_RULE,
table_name AS TABLE_NAME,
referenced_table_name AS REFERENCED_TABLE_NAME
WHERE false; -- make sure this view is always empty
)";
/// View structures are taken from http://www.contrib.andrew.cmu.edu/~shadow/sql/sql1992.txt
static void createInformationSchemaView(ContextMutablePtr context, IDatabase & database, const String & view_name, std::string_view query)
@ -63,12 +402,12 @@ static void createInformationSchemaView(ContextMutablePtr context, IDatabase & d
void attachInformationSchema(ContextMutablePtr context, IDatabase & information_schema_database)
{
createInformationSchemaView(context, information_schema_database, "schemata", std::string_view(reinterpret_cast<const char *>(gresource_schemata_sqlData), gresource_schemata_sqlSize));
createInformationSchemaView(context, information_schema_database, "tables", std::string_view(reinterpret_cast<const char *>(gresource_tables_sqlData), gresource_tables_sqlSize));
createInformationSchemaView(context, information_schema_database, "views", std::string_view(reinterpret_cast<const char *>(gresource_views_sqlData), gresource_views_sqlSize));
createInformationSchemaView(context, information_schema_database, "columns", std::string_view(reinterpret_cast<const char *>(gresource_columns_sqlData), gresource_columns_sqlSize));
createInformationSchemaView(context, information_schema_database, "key_column_usage", std::string_view(reinterpret_cast<const char *>(gresource_key_column_usage_sqlData), gresource_key_column_usage_sqlSize));
createInformationSchemaView(context, information_schema_database, "referential_constraints", std::string_view(reinterpret_cast<const char *>(gresource_referential_constraints_sqlData), gresource_referential_constraints_sqlSize));
createInformationSchemaView(context, information_schema_database, "schemata", schemata);
createInformationSchemaView(context, information_schema_database, "tables", tables);
createInformationSchemaView(context, information_schema_database, "views", views);
createInformationSchemaView(context, information_schema_database, "columns", columns);
createInformationSchemaView(context, information_schema_database, "key_column_usage", key_column_usage);
createInformationSchemaView(context, information_schema_database, "referential_constraints", referential_constraints);
}
}