database/mariadb-columnstore-engine
1
0
Fork 0
mirror of https://github.com/mariadb-corporation/mariadb-columnstore-engine.git synced 2025-08-07 03:22:57 +03:00
Code Activity

add partial support for unsupported query syntax

Browse Source
This commit is contained in:
mariadb-KristinaPavlova
2025-06-27 13:09:45 +03:00
committed by Leonid Fedorov
parent dd3ce850b7
commit a29ac85c7c
1 changed files with 25 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

38
dbcon/mysql/ha_mcs_ddl.cpp
View File

@@ -761,7 +761,7 @@ int ProcessDDLStatement(string& ddlStatement, string& schema, const string& /*ta
#ifdef MCS_DEBUG #ifdef MCS_DEBUG
cout << "ProcessDDLStatement: " << schema << "." << table << ":" << ddlStatement << endl; cout << "ProcessDDLStatement: " << schema << "." << table << ":" << ddlStatement << endl;
#endif #endif
parser.setDefaultSchema(schema); parser.setDefaultSchema(schema);
parser.setDefaultCharset(default_table_charset); parser.setDefaultCharset(default_table_charset);
int rc = 0; int rc = 0;
@@ -2199,26 +2199,38 @@ int ProcessDDLStatement(string& ddlStatement, string& schema, const string& /*ta
//@Bug 3602. Error message for MySql syntax for autoincrement //@Bug 3602. Error message for MySql syntax for autoincrement
algorithm::to_upper(ddlStatement); algorithm::to_upper(ddlStatement);
std::string errMsg = "The syntax "
if (ddlStatement.find("AUTO_INCREMENT") != string::npos) if (ddlStatement.find("AUTO_INCREMENT") != string::npos)
{ {
thd->raise_error_printf(ER_CHECK_NOT_IMPLEMENTED, errMsg += "auto_increment is not supported in Columnstore.";
"Use of the MySQL auto_increment syntax is not supported in Columnstore. If " }
"you wish to create an auto increment column in Columnstore, please consult " else if(ddlStatement.find("RENAME COLUMN") != string::npos)
"the Columnstore SQL Syntax Guide for the correct usage."); {
ci->alterTableState = cal_connection_info::NOT_ALTER; errMsg += "rename column is not supported by Columnstore.";
ci->isAlter = false; }
else if(ddlStatement.find("MAX_ROWS") != string::npos || ddlStatement.find("MIN_ROWS") != string::npos)
{
errMsg += "min_rows/max_rows is not supported by Columnstore.";
}
else if(ddlStatement.find("REPLACE TABLE") != string::npos)
{
errMsg += "replace table is not supported by Columnstore.";
}
else if(ddlStatement.find("DROP COLUMN IF EXISTS") != string::npos)
{
errMsg += "drop column if exists is not supported by Columnstore.";
} }
else else
{ {
//@Bug 1888,1885. update error message //@Bug 1888,1885. update error message
thd->raise_error_printf(ER_CHECK_NOT_IMPLEMENTED, errMsg += " or the data type(s) is not supported by Columnstore.";
"The syntax or the data type(s) is not supported by Columnstore. Please check "
"the Columnstore syntax guide for supported syntax or data types.");
ci->alterTableState = cal_connection_info::NOT_ALTER;
ci->isAlter = false;
} }
errMsg += " Please check the Columnstore syntax guide for supported syntax or data types.";
thd->raise_error_printf(ER_CHECK_NOT_IMPLEMENTED, errMsg);
ci->alterTableState = cal_connection_info::NOT_ALTER;
ci->isAlter = false;
} }
return rc; return rc;
} }