You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2021/11/20 13:39:50 UTC
[incubator-doris] branch master updated: [feat](mysql-compatibility) Increase compatibility with mysql (#7041)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 52ebb3d [feat](mysql-compatibility) Increase compatibility with mysql (#7041)
52ebb3d is described below
commit 52ebb3d8f56cf6fcd0df2f9cdbb056bafd136c6d
Author: Zhengguo Yang <ya...@gmail.com>
AuthorDate: Sat Nov 20 21:39:37 2021 +0800
[feat](mysql-compatibility) Increase compatibility with mysql (#7041)
Increase compatibility with mysql
1. Added two system tables files and partitions
2. Improved the return logic of mysql error code to make the error code more compatible with mysql
3. Added lock/unlock tables statement and show columns statement for compatibility with mysql dump
4. Compatible with mysqldump tool, now you can use mysql dump to dump data and table structure from doris
now use mysqldump may print error message like
```
$ mysqldump -h127.0.0.1 -P9130 -uroot test_query_qa > a
mysqldump: Error: 'errCode = 2, detailMessage = select list expression not produced by aggregation output (missing from GROUP BY clause?): `EXTRA`' when trying to dump tablespaces
```
This error message not effect the export file, you can add `--no-tablespaces` to avoid this error
---
be/src/exec/CMakeLists.txt | 2 +
be/src/exec/schema_scan_node.cpp | 6 +-
be/src/exec/schema_scanner.cpp | 6 +
.../exec/schema_scanner/schema_files_scanner.cpp | 115 ++
.../src/exec/schema_scanner/schema_files_scanner.h | 48 +-
.../schema_scanner/schema_partitions_scanner.cpp | 103 ++
.../schema_scanner/schema_partitions_scanner.h | 48 +-
.../exec/schema_scanner/schema_tables_scanner.cpp | 2 -
fe/fe-core/src/main/cup/sql_parser.cup | 109 +-
.../doris/analysis/AlterDatabaseQuotaStmt.java | 2 +-
.../apache/doris/analysis/AlterDatabaseRename.java | 2 +-
.../org/apache/doris/analysis/CreateDbStmt.java | 2 +-
.../java/org/apache/doris/analysis/DropDbStmt.java | 4 +-
.../java/org/apache/doris/analysis/LockTable.java | 62 +
.../org/apache/doris/analysis/LockTablesStmt.java | 100 ++
.../org/apache/doris/analysis/RecoverDbStmt.java | 2 +-
.../java/org/apache/doris/analysis/SelectStmt.java | 4 +-
.../org/apache/doris/analysis/ShowBackupStmt.java | 2 +-
.../apache/doris/analysis/ShowCreateDbStmt.java | 2 +-
.../doris/analysis/ShowCreateFunctionStmt.java | 2 +-
.../apache/doris/analysis/ShowEncryptKeysStmt.java | 2 +-
.../apache/doris/analysis/ShowFunctionsStmt.java | 2 +-
.../org/apache/doris/analysis/ShowRestoreStmt.java | 2 +-
.../apache/doris/analysis/ShowSmallFilesStmt.java | 2 +-
.../apache/doris/analysis/ShowTableStatusStmt.java | 2 +-
.../UnlockTablesStmt.java} | 14 +-
.../java/org/apache/doris/analysis/UseStmt.java | 2 +-
.../java/org/apache/doris/catalog/Catalog.java | 25 +-
.../java/org/apache/doris/catalog/Database.java | 3 +-
.../java/org/apache/doris/catalog/SchemaTable.java | 79 +
.../org/apache/doris/common/AnalysisException.java | 5 +
.../java/org/apache/doris/common/DdlException.java | 4 +
.../java/org/apache/doris/common/ErrorCode.java | 1760 ++++++++++++++++++--
.../java/org/apache/doris/common/ErrorReport.java | 4 +-
.../apache/doris/common/MetaNotFoundException.java | 5 +
.../org/apache/doris/common/UserException.java | 15 +
.../org/apache/doris/mysql/nio/AcceptListener.java | 3 +-
.../java/org/apache/doris/qe/ConnectProcessor.java | 31 +-
.../java/org/apache/doris/qe/ConnectScheduler.java | 3 +-
.../java/org/apache/doris/qe/SessionVariable.java | 12 +
.../java/org/apache/doris/qe/ShowExecutor.java | 5 +-
.../java/org/apache/doris/qe/StmtExecutor.java | 36 +-
fe/fe-core/src/main/jflex/sql_scanner.flex | 6 +
.../analysis/CreateTableAsSelectStmtTest.java | 24 +-
fe/pom.xml | 2 +-
45 files changed, 2372 insertions(+), 299 deletions(-)
diff --git a/be/src/exec/CMakeLists.txt b/be/src/exec/CMakeLists.txt
index 5d4b631..e33e30d 100644
--- a/be/src/exec/CMakeLists.txt
+++ b/be/src/exec/CMakeLists.txt
@@ -88,6 +88,8 @@ set(EXEC_FILES
schema_scanner/schema_table_privileges_scanner.cpp
schema_scanner/schema_schema_privileges_scanner.cpp
schema_scanner/schema_user_privileges_scanner.cpp
+ schema_scanner/schema_files_scanner.cpp
+ schema_scanner/schema_partitions_scanner.cpp
partitioned_hash_table.cc
partitioned_hash_table_ir.cc
diff --git a/be/src/exec/schema_scan_node.cpp b/be/src/exec/schema_scan_node.cpp
index 4a85c0f..b393452 100644
--- a/be/src/exec/schema_scan_node.cpp
+++ b/be/src/exec/schema_scan_node.cpp
@@ -170,8 +170,10 @@ Status SchemaScanNode::prepare(RuntimeState* state) {
}
if (_src_tuple_desc->slots()[j]->type().type != _dest_tuple_desc->slots()[i]->type().type) {
- LOG(WARNING) << "schema not match. input is " << _src_tuple_desc->slots()[j]->type()
- << " and output is " << _dest_tuple_desc->slots()[i]->type();
+ LOG(WARNING) << "schema not match. input is " << _src_tuple_desc->slots()[j]->col_name()
+ << "(" << _src_tuple_desc->slots()[j]->type() << ") and output is "
+ << _dest_tuple_desc->slots()[i]->col_name() << "("
+ << _dest_tuple_desc->slots()[i]->type() << ")";
return Status::InternalError("schema not match.");
}
_index_map[i] = j;
diff --git a/be/src/exec/schema_scanner.cpp b/be/src/exec/schema_scanner.cpp
index 20d796f..a5c084d 100644
--- a/be/src/exec/schema_scanner.cpp
+++ b/be/src/exec/schema_scanner.cpp
@@ -21,6 +21,8 @@
#include "exec/schema_scanner/schema_collations_scanner.h"
#include "exec/schema_scanner/schema_columns_scanner.h"
#include "exec/schema_scanner/schema_dummy_scanner.h"
+#include "exec/schema_scanner/schema_files_scanner.h"
+#include "exec/schema_scanner/schema_partitions_scanner.h"
#include "exec/schema_scanner/schema_schema_privileges_scanner.h"
#include "exec/schema_scanner/schema_schemata_scanner.h"
#include "exec/schema_scanner/schema_statistics_scanner.h"
@@ -105,6 +107,10 @@ SchemaScanner* SchemaScanner::create(TSchemaTableType::type type) {
return new (std::nothrow) SchemaSchemaPrivilegesScanner();
case TSchemaTableType::SCH_USER_PRIVILEGES:
return new (std::nothrow) SchemaUserPrivilegesScanner();
+ case TSchemaTableType::SCH_FILES:
+ return new (std::nothrow) SchemaFilesScanner();
+ case TSchemaTableType::SCH_PARTITIONS:
+ return new (std::nothrow) SchemaPartitionsScanner();
default:
return new (std::nothrow) SchemaDummyScanner();
break;
diff --git a/be/src/exec/schema_scanner/schema_files_scanner.cpp b/be/src/exec/schema_scanner/schema_files_scanner.cpp
new file mode 100644
index 0000000..ffd9800
--- /dev/null
+++ b/be/src/exec/schema_scanner/schema_files_scanner.cpp
@@ -0,0 +1,115 @@
+// 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.
+
+#include "exec/schema_scanner/schema_files_scanner.h"
+
+#include "exec/schema_scanner/schema_helper.h"
+#include "runtime/primitive_type.h"
+#include "runtime/string_value.h"
+
+namespace doris {
+
+SchemaScanner::ColumnDesc SchemaFilesScanner::_s_tbls_columns[] = {
+ // name, type, size, is_null
+ {"FILE_ID", TYPE_BIGINT, sizeof(int64_t), true},
+ {"FILE_NAME", TYPE_STRING, sizeof(StringValue), true},
+ {"FILE_TYPE", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"TABLESPACE_NAME", TYPE_VARCHAR, sizeof(StringValue), false},
+ {"TABLE_CATALOG", TYPE_CHAR, sizeof(StringValue), false},
+ {"TABLE_SCHEMA", TYPE_STRING, sizeof(StringValue), true},
+ {"TABLE_NAME", TYPE_STRING, sizeof(StringValue), true},
+ {"LOGFILE_GROUP_NAME", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"LOGFILE_GROUP_NUMBER", TYPE_BIGINT, sizeof(int64_t), true},
+ {"ENGINE", TYPE_VARCHAR, sizeof(StringValue), false},
+ {"FULLTEXT_KEYS", TYPE_STRING, sizeof(StringValue), true},
+ {"DELETED_ROWS", TYPE_STRING, sizeof(StringValue), true},
+ {"UPDATE_COUNT", TYPE_STRING, sizeof(StringValue), true},
+ {"FREE_EXTENTS", TYPE_BIGINT, sizeof(int64_t), true},
+ {"TOTAL_EXTENTS", TYPE_BIGINT, sizeof(int64_t), true},
+ {"EXTENT_SIZE", TYPE_BIGINT, sizeof(int64_t), true},
+ {"INITIAL_SIZE", TYPE_BIGINT, sizeof(int64_t), true},
+ {"MAXIMUM_SIZE", TYPE_BIGINT, sizeof(int64_t), true},
+ {"AUTOEXTEND_SIZE", TYPE_BIGINT, sizeof(int64_t), true},
+ {"CREATION_TIME", TYPE_STRING, sizeof(StringValue), true},
+ {"LAST_UPDATE_TIME", TYPE_STRING, sizeof(StringValue), true},
+ {"LAST_ACCESS_TIME", TYPE_STRING, sizeof(StringValue), true},
+ {"RECOVER_TIME", TYPE_STRING, sizeof(StringValue), true},
+ {"TRANSACTION_COUNTER", TYPE_STRING, sizeof(StringValue), true},
+ {"VERSION", TYPE_BIGINT, sizeof(int64_t), true},
+ {"ROW_FORMAT", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"TABLE_ROWS", TYPE_STRING, sizeof(StringValue), true},
+ {"AVG_ROW_LENGTH", TYPE_STRING, sizeof(StringValue), true},
+ {"DATA_LENGTH", TYPE_STRING, sizeof(StringValue), true},
+ {"MAX_DATA_LENGTH", TYPE_STRING, sizeof(StringValue), true},
+ {"INDEX_LENGTH", TYPE_STRING, sizeof(StringValue), true},
+ {"DATA_FREE", TYPE_BIGINT, sizeof(int64_t), true},
+ {"CREATE_TIME", TYPE_STRING, sizeof(StringValue), true},
+ {"UPDATE_TIME", TYPE_STRING, sizeof(StringValue), true},
+ {"CHECK_TIME", TYPE_STRING, sizeof(StringValue), true},
+ {"CHECKSUM", TYPE_STRING, sizeof(StringValue), true},
+ {"STATUS", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"EXTRA", TYPE_VARCHAR, sizeof(StringValue), true},
+};
+
+SchemaFilesScanner::SchemaFilesScanner()
+ : SchemaScanner(_s_tbls_columns,
+ sizeof(_s_tbls_columns) / sizeof(SchemaScanner::ColumnDesc)),
+ _db_index(0),
+ _table_index(0) {}
+
+SchemaFilesScanner::~SchemaFilesScanner() {}
+
+Status SchemaFilesScanner::start(RuntimeState* state) {
+ if (!_is_init) {
+ return Status::InternalError("used before initialized.");
+ }
+ TGetDbsParams db_params;
+ if (NULL != _param->db) {
+ db_params.__set_pattern(*(_param->db));
+ }
+ if (NULL != _param->current_user_ident) {
+ db_params.__set_current_user_ident(*(_param->current_user_ident));
+ } else {
+ if (NULL != _param->user) {
+ db_params.__set_user(*(_param->user));
+ }
+ if (NULL != _param->user_ip) {
+ db_params.__set_user_ip(*(_param->user_ip));
+ }
+ }
+
+ if (NULL != _param->ip && 0 != _param->port) {
+ RETURN_IF_ERROR(
+ SchemaHelper::get_db_names(*(_param->ip), _param->port, db_params, &_db_result));
+ } else {
+ return Status::InternalError("IP or port doesn't exists");
+ }
+ return Status::OK();
+}
+
+Status SchemaFilesScanner::get_next_row(Tuple* tuple, MemPool* pool, bool* eos) {
+ if (!_is_init) {
+ return Status::InternalError("Used before initialized.");
+ }
+ if (nullptr == tuple || nullptr == pool || nullptr == eos) {
+ return Status::InternalError("input pointer is nullptr.");
+ }
+ *eos = true;
+ return Status::OK();
+}
+
+} // namespace doris
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java b/be/src/exec/schema_scanner/schema_files_scanner.h
similarity index 54%
copy from fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java
copy to be/src/exec/schema_scanner/schema_files_scanner.h
index 14b5ed9..9c779cd 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java
+++ b/be/src/exec/schema_scanner/schema_files_scanner.h
@@ -15,25 +15,29 @@
// specific language governing permissions and limitations
// under the License.
-package org.apache.doris.common;
-
-/**
- * Exception for meta info is null, like db table partition tablet replica job
- */
-public class MetaNotFoundException extends UserException {
- public MetaNotFoundException(String msg) {
- super(InternalErrorCode.META_NOT_FOUND_ERR, msg);
- }
-
- public MetaNotFoundException(InternalErrorCode errcode, String msg) {
- super(errcode, msg);
- }
-
- public MetaNotFoundException(Throwable e) {
- super(e);
- }
-
- public MetaNotFoundException(String msg, Throwable e) {
- super(msg, e);
- }
-}
+#ifndef DORIS_BE_SRC_QUERY_EXEC_SCHEMA_SCANNER_SCHEMA_FILES_SCANNER_H
+#define DORIS_BE_SRC_QUERY_EXEC_SCHEMA_SCANNER_SCHEMA_FILES_SCANNER_H
+
+#include "exec/schema_scanner.h"
+#include "gen_cpp/FrontendService_types.h"
+
+namespace doris {
+
+class SchemaFilesScanner : public SchemaScanner {
+public:
+ SchemaFilesScanner();
+ virtual ~SchemaFilesScanner();
+
+ virtual Status start(RuntimeState* state);
+ virtual Status get_next_row(Tuple* tuple, MemPool* pool, bool* eos);
+
+ int _db_index;
+ int _table_index;
+ TGetDbsResult _db_result;
+ TListTableStatusResult _table_result;
+ static SchemaScanner::ColumnDesc _s_tbls_columns[];
+};
+
+} // namespace doris
+
+#endif
diff --git a/be/src/exec/schema_scanner/schema_partitions_scanner.cpp b/be/src/exec/schema_scanner/schema_partitions_scanner.cpp
new file mode 100644
index 0000000..204d222
--- /dev/null
+++ b/be/src/exec/schema_scanner/schema_partitions_scanner.cpp
@@ -0,0 +1,103 @@
+// 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.
+
+#include "exec/schema_scanner/schema_partitions_scanner.h"
+
+#include "exec/schema_scanner/schema_helper.h"
+#include "runtime/datetime_value.h"
+#include "runtime/primitive_type.h"
+#include "runtime/string_value.h"
+
+namespace doris {
+
+SchemaScanner::ColumnDesc SchemaPartitionsScanner::_s_tbls_columns[] = {
+ // name, type, size, is_null
+ {"TABLE_CATALOG", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"TABLE_SCHEMA", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"TABLE_NAME", TYPE_VARCHAR, sizeof(StringValue), false},
+ {"PARTITION_NAME", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"SUBPARTITION_NAME", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"PARTITION_ORDINAL_POSITION", TYPE_INT, sizeof(int32_t), true},
+ {"SUBPARTITION_ORDINAL_POSITION", TYPE_INT, sizeof(int32_t), true},
+ {"PARTITION_METHOD", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"SUBPARTITION_METHOD", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"PARTITION_EXPRESSION", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"SUBPARTITION_EXPRESSION", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"PARTITION_DESCRIPTION", TYPE_STRING, sizeof(StringValue), true},
+ {"TABLE_ROWS", TYPE_BIGINT, sizeof(int64_t), true},
+ {"AVG_ROW_LENGTH", TYPE_BIGINT, sizeof(int64_t), true},
+ {"DATA_LENGTH", TYPE_BIGINT, sizeof(int64_t), true},
+ {"MAX_DATA_LENGTH", TYPE_BIGINT, sizeof(int64_t), true},
+ {"INDEX_LENGTH", TYPE_BIGINT, sizeof(int64_t), true},
+ {"DATA_FREE", TYPE_BIGINT, sizeof(int64_t), true},
+ {"CREATE_TIME", TYPE_BIGINT, sizeof(int64_t), false},
+ {"UPDATE_TIME", TYPE_DATETIME, sizeof(DateTimeValue), true},
+ {"CHECK_TIME", TYPE_DATETIME, sizeof(DateTimeValue), true},
+ {"CHECKSUM", TYPE_BIGINT, sizeof(int64_t), true},
+ {"PARTITION_COMMENT", TYPE_STRING, sizeof(StringValue), false},
+ {"NODEGROUP", TYPE_VARCHAR, sizeof(StringValue), true},
+ {"TABLESPACE_NAME", TYPE_VARCHAR, sizeof(StringValue), true},
+};
+
+SchemaPartitionsScanner::SchemaPartitionsScanner()
+ : SchemaScanner(_s_tbls_columns,
+ sizeof(_s_tbls_columns) / sizeof(SchemaScanner::ColumnDesc)),
+ _db_index(0),
+ _table_index(0) {}
+
+SchemaPartitionsScanner::~SchemaPartitionsScanner() {}
+
+Status SchemaPartitionsScanner::start(RuntimeState* state) {
+ if (!_is_init) {
+ return Status::InternalError("used before initialized.");
+ }
+ TGetDbsParams db_params;
+ if (NULL != _param->db) {
+ db_params.__set_pattern(*(_param->db));
+ }
+ if (NULL != _param->current_user_ident) {
+ db_params.__set_current_user_ident(*(_param->current_user_ident));
+ } else {
+ if (NULL != _param->user) {
+ db_params.__set_user(*(_param->user));
+ }
+ if (NULL != _param->user_ip) {
+ db_params.__set_user_ip(*(_param->user_ip));
+ }
+ }
+
+ if (NULL != _param->ip && 0 != _param->port) {
+ RETURN_IF_ERROR(
+ SchemaHelper::get_db_names(*(_param->ip), _param->port, db_params, &_db_result));
+ } else {
+ return Status::InternalError("IP or port doesn't exists");
+ }
+ return Status::OK();
+}
+
+Status SchemaPartitionsScanner::get_next_row(Tuple* tuple, MemPool* pool, bool* eos) {
+ if (!_is_init) {
+ return Status::InternalError("Used before initialized.");
+ }
+ if (nullptr == tuple || nullptr == pool || nullptr == eos) {
+ return Status::InternalError("input pointer is nullptr.");
+ }
+ *eos = true;
+ return Status::OK();
+}
+
+} // namespace doris
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java b/be/src/exec/schema_scanner/schema_partitions_scanner.h
similarity index 53%
copy from fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java
copy to be/src/exec/schema_scanner/schema_partitions_scanner.h
index 14b5ed9..a68b1bb 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java
+++ b/be/src/exec/schema_scanner/schema_partitions_scanner.h
@@ -15,25 +15,29 @@
// specific language governing permissions and limitations
// under the License.
-package org.apache.doris.common;
-
-/**
- * Exception for meta info is null, like db table partition tablet replica job
- */
-public class MetaNotFoundException extends UserException {
- public MetaNotFoundException(String msg) {
- super(InternalErrorCode.META_NOT_FOUND_ERR, msg);
- }
-
- public MetaNotFoundException(InternalErrorCode errcode, String msg) {
- super(errcode, msg);
- }
-
- public MetaNotFoundException(Throwable e) {
- super(e);
- }
-
- public MetaNotFoundException(String msg, Throwable e) {
- super(msg, e);
- }
-}
+#ifndef DORIS_BE_SRC_QUERY_EXEC_SCHEMA_SCANNER_SCHEMA_PARTITIONS_SCANNER_H
+#define DORIS_BE_SRC_QUERY_EXEC_SCHEMA_SCANNER_SCHEMA_PARTITIONS_SCANNER_H
+
+#include "exec/schema_scanner.h"
+#include "gen_cpp/FrontendService_types.h"
+
+namespace doris {
+
+class SchemaPartitionsScanner : public SchemaScanner {
+public:
+ SchemaPartitionsScanner();
+ virtual ~SchemaPartitionsScanner();
+
+ virtual Status start(RuntimeState* state);
+ virtual Status get_next_row(Tuple* tuple, MemPool* pool, bool* eos);
+
+ int _db_index;
+ int _table_index;
+ TGetDbsResult _db_result;
+ TListTableStatusResult _table_result;
+ static SchemaScanner::ColumnDesc _s_tbls_columns[];
+};
+
+} // namespace doris
+
+#endif
diff --git a/be/src/exec/schema_scanner/schema_tables_scanner.cpp b/be/src/exec/schema_scanner/schema_tables_scanner.cpp
index 078ac3f..8e39116 100644
--- a/be/src/exec/schema_scanner/schema_tables_scanner.cpp
+++ b/be/src/exec/schema_scanner/schema_tables_scanner.cpp
@@ -20,8 +20,6 @@
#include "exec/schema_scanner/schema_helper.h"
#include "runtime/primitive_type.h"
#include "runtime/string_value.h"
-//#include "runtime/datetime_value.h"
-
namespace doris {
SchemaScanner::ColumnDesc SchemaTablesScanner::_s_tbls_columns[] = {
diff --git a/fe/fe-core/src/main/cup/sql_parser.cup b/fe/fe-core/src/main/cup/sql_parser.cup
index 1b76f28..6b5e375 100644
--- a/fe/fe-core/src/main/cup/sql_parser.cup
+++ b/fe/fe-core/src/main/cup/sql_parser.cup
@@ -241,8 +241,8 @@ terminal String KW_ADD, KW_ADMIN, KW_AFTER, KW_AGGREGATE, KW_ALIAS, KW_ALL, KW_A
KW_DATA, KW_DATABASE, KW_DATABASES, KW_DATE, KW_DATETIME, KW_DAY, KW_DECIMAL, KW_DECOMMISSION, KW_DEFAULT, KW_DESC, KW_DESCRIBE,
KW_DELETE, KW_UPDATE, KW_DISTINCT, KW_DISTINCTPC, KW_DISTINCTPCSA, KW_DISTRIBUTED, KW_DISTRIBUTION, KW_DYNAMIC, KW_BUCKETS, KW_DIV, KW_DOUBLE, KW_DROP, KW_DROPP, KW_DUPLICATE,
KW_ELSE, KW_ENABLE, KW_ENCRYPTKEY, KW_ENCRYPTKEYS, KW_END, KW_ENGINE, KW_ENGINES, KW_ENTER, KW_ERRORS, KW_EVENTS, KW_EXCEPT, KW_EXCLUDE,
- KW_EXISTS, KW_EXPORT, KW_EXTERNAL, KW_EXTRACT,
- KW_FALSE, KW_FEATURE, KW_FOLLOWER, KW_FOLLOWING, KW_FREE, KW_FROM, KW_FILE, KW_FILTER, KW_FIRST, KW_FLOAT, KW_FOR, KW_FORCE, KW_FORMAT, KW_FRONTEND, KW_FRONTENDS, KW_FULL, KW_FUNCTION, KW_FUNCTIONS,
+ KW_EXISTS, KW_EXPORT, KW_EXTENDED, KW_EXTERNAL, KW_EXTRACT,
+ KW_FALSE, KW_FEATURE, KW_FOLLOWER, KW_FOLLOWING, KW_FREE, KW_FROM, KW_FIELDS, KW_FILE, KW_FILTER, KW_FIRST, KW_FLOAT, KW_FOR, KW_FORCE, KW_FORMAT, KW_FRONTEND, KW_FRONTENDS, KW_FULL, KW_FUNCTION, KW_FUNCTIONS,
KW_GLOBAL, KW_GRANT, KW_GRANTS, KW_GRAPH, KW_GROUP, KW_GROUPING,
KW_HASH, KW_HAVING, KW_HDFS, KW_HELP,KW_HLL, KW_HLL_UNION, KW_HOUR, KW_HUB,
KW_IDENTIFIED, KW_IF, KW_IN, KW_INDEX, KW_INDEXES, KW_INFILE, KW_INSTALL,
@@ -250,7 +250,7 @@ terminal String KW_ADD, KW_ADMIN, KW_AFTER, KW_AGGREGATE, KW_ALIAS, KW_ALL, KW_A
KW_JOB, KW_JOIN,
KW_KEY, KW_KEYS, KW_KILL,
KW_LABEL, KW_LARGEINT, KW_LAST, KW_LEFT, KW_LESS, KW_LEVEL, KW_LIKE, KW_LIMIT, KW_LINK, KW_LIST, KW_LOAD,
- KW_LOCAL, KW_LOCATION, KW_LATERAL,
+ KW_LOCAL, KW_LOCATION, KW_LOCK, KW_LOW_PRIORITY, KW_LATERAL,
KW_MAP, KW_MATERIALIZED, KW_MAX, KW_MAX_VALUE, KW_MERGE, KW_MIN, KW_MINUTE, KW_MINUS, KW_MIGRATE, KW_MIGRATIONS, KW_MODIFY, KW_MONTH,
KW_NAME, KW_NAMES, KW_NEGATIVE, KW_NO, KW_NOT, KW_NULL, KW_NULLS,
KW_OBSERVER, KW_OFFSET, KW_ON, KW_ONLY, KW_OPEN, KW_OR, KW_ORDER, KW_OUTER, KW_OUTFILE, KW_OVER,
@@ -267,7 +267,7 @@ terminal String KW_ADD, KW_ADMIN, KW_AFTER, KW_AGGREGATE, KW_ALIAS, KW_ALL, KW_A
KW_SUM, KW_SUPERUSER, KW_SYNC, KW_SYSTEM,
KW_TABLE, KW_TABLES, KW_TABLET, KW_TASK, KW_TEMPORARY, KW_TERMINATED, KW_TEXT, KW_THAN, KW_TIME, KW_THEN, KW_TIMESTAMP, KW_TINYINT,KW_TRASH,
KW_TO, KW_TRANSACTION, KW_TRIGGERS, KW_TRIM, KW_TRUE, KW_TRUNCATE, KW_TYPE, KW_TYPES,
- KW_UNCOMMITTED, KW_UNBOUNDED, KW_UNION, KW_UNIQUE, KW_UNSIGNED, KW_USE, KW_USER, KW_USING, KW_UNINSTALL,
+ KW_UNCOMMITTED, KW_UNBOUNDED, KW_UNION, KW_UNIQUE, KW_UNLOCK, KW_UNSIGNED, KW_USE, KW_USER, KW_USING, KW_UNINSTALL,
KW_VALUE, KW_VALUES, KW_VARCHAR, KW_VARIABLES, KW_VERBOSE, KW_VIEW,
KW_WARNINGS, KW_WEEK, KW_WHEN, KW_WHITELIST, KW_WHERE, KW_WITH, KW_WORK, KW_WRITE,
KW_YEAR, KW_SQL_BLOCK_RULE;
@@ -295,7 +295,7 @@ nonterminal StatementBase stmt, show_stmt, show_param, help_stmt, load_stmt,
use_stmt, kill_stmt, drop_stmt, recover_stmt, grant_stmt, revoke_stmt, create_stmt, set_stmt, sync_stmt, cancel_stmt, cancel_param, delete_stmt,
link_stmt, migrate_stmt, enter_stmt, transaction_stmt, unsupported_stmt, export_stmt, admin_stmt, truncate_stmt,
import_columns_stmt, import_delete_on_stmt, import_sequence_stmt, import_where_stmt, install_plugin_stmt, uninstall_plugin_stmt,
- import_preceding_filter_stmt;
+ import_preceding_filter_stmt, unlock_tables_stmt, lock_tables_stmt;
nonterminal String transaction_label;
nonterminal ImportColumnDesc import_column_desc;
@@ -346,7 +346,7 @@ nonterminal Expr set_expr_or_default;
nonterminal ArrayList<Expr> expr_list, values, row_value, opt_values;
nonterminal ArrayList<Expr> func_arg_list;
nonterminal ArrayList<Expr> expr_pipe_list;
-nonterminal String select_alias, opt_table_alias;
+nonterminal String select_alias, opt_table_alias, lock_alias;
nonterminal ArrayList<String> ident_list;
nonterminal PartitionNames opt_partition_names, partition_names;
nonterminal ClusterName cluster_name;
@@ -517,6 +517,9 @@ nonterminal Boolean opt_signed_unsigned;
nonterminal StorageBackend storage_backend;
+nonterminal ArrayList<LockTable> opt_lock_tables_list;
+nonterminal LockTable lock_table;
+
precedence nonassoc COMMA;
precedence nonassoc STRING_LITERAL;
precedence nonassoc KW_COLUMNS;
@@ -726,6 +729,10 @@ stmt ::=
{: RESULT = stmt; :}
| uninstall_plugin_stmt : stmt
{: RESULT = stmt; :}
+ | lock_tables_stmt:stmt
+ {: RESULT = stmt; :}
+ | unlock_tables_stmt:stmt
+ {: RESULT = stmt; :}
| /* empty: query only has comments */
{:
RESULT = new EmptyStmt();
@@ -2997,10 +3004,26 @@ describe_stmt ::=
{:
RESULT = new DescribeStmt(table, false);
:}
+ | KW_SHOW KW_FIELDS KW_FROM table_name:table
+ {:
+ RESULT = new DescribeStmt(table, false);
+ :}
+ | KW_SHOW KW_COLUMNS KW_FROM table_name:table
+ {:
+ RESULT = new DescribeStmt(table, false);
+ :}
| describe_command table_name:table KW_ALL
{:
RESULT = new DescribeStmt(table, true);
:}
+ | KW_SHOW KW_EXTENDED KW_FIELDS KW_FROM table_name:table
+ {:
+ RESULT = new DescribeStmt(table, true);
+ :}
+ | KW_SHOW KW_EXTENDED KW_COLUMNS KW_FROM table_name:table
+ {:
+ RESULT = new DescribeStmt(table, true);
+ :}
| describe_command opt_explain_options:options query_stmt:query
{:
query.setIsExplain(options);
@@ -3343,6 +3366,74 @@ backup_stmt ::=
:}
;
+unlock_tables_stmt ::=
+ KW_UNLOCK KW_TABLES
+ {:
+ RESULT = new UnlockTablesStmt();
+ :}
+ ;
+lock_alias ::=
+ /* empty */
+ {:
+ RESULT = null;
+ :}
+ | KW_AS ident:ident
+ {:
+ RESULT = ident;
+ :}
+ | KW_AS STRING_LITERAL:l
+ {:
+ RESULT = l;
+ :}
+ ;
+
+lock_table ::=
+ table_name:name lock_alias:alias KW_READ
+ {:
+ RESULT = new LockTable(name, alias, LockTable.LockType.READ);
+ :}
+ |
+ table_name:name lock_alias:alias KW_READ KW_LOCAL
+ {:
+ RESULT = new LockTable(name, alias, LockTable.LockType.READ_LOCAL);
+ :}
+ |
+ table_name:name lock_alias:alias KW_WRITE
+ {:
+ RESULT = new LockTable(name, alias, LockTable.LockType.WRITE);
+ :}
+ |
+ table_name:name lock_alias:alias KW_LOW_PRIORITY KW_WRITE
+ {:
+ RESULT = new LockTable(name, alias, LockTable.LockType.LOW_PRIORITY_WRITE);
+ :}
+ ;
+
+opt_lock_tables_list ::=
+ lock_table: table
+ {:
+ ArrayList<LockTable> lock_tables = new ArrayList<LockTable>();
+ lock_tables.add(table);
+ RESULT = lock_tables;
+ :}
+ | opt_lock_tables_list:lock_tables COMMA lock_table:table
+ {:
+ lock_tables.add(table);
+ RESULT = lock_tables;
+ :}
+ |
+ {:
+ RESULT = new ArrayList<LockTable>();
+ :}
+ ;
+
+lock_tables_stmt ::=
+ KW_LOCK KW_TABLES opt_lock_tables_list:lock_tables
+ {:
+ RESULT = new LockTablesStmt(lock_tables);
+ :}
+ ;
+
opt_backup_table_ref_list ::=
backup_exclude_or_not:isExclude LPAREN base_table_ref_list:tbls RPAREN
{:
@@ -5277,6 +5368,8 @@ keyword ::=
{: RESULT = id; :}
| KW_FILE:id
{: RESULT = id; :}
+ | KW_FIELDS:id
+ {: RESULT = id; :}
| KW_FILTER:id
{: RESULT = id; :}
| KW_FIRST:id
@@ -5341,6 +5434,10 @@ keyword ::=
{: RESULT = id; :}
| KW_LOCATION:id
{: RESULT = id; :}
+ | KW_LOCK:id
+ {: RESULT = id; :}
+ | KW_UNLOCK:id
+ {: RESULT = id; :}
| KW_MATERIALIZED:id
{: RESULT = id; :}
| KW_MERGE:id
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterDatabaseQuotaStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterDatabaseQuotaStmt.java
index 725d3b0..a45ff28 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterDatabaseQuotaStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterDatabaseQuotaStmt.java
@@ -63,7 +63,7 @@ public class AlterDatabaseQuotaStmt extends DdlStmt {
super.analyze(analyzer);
if (!Catalog.getCurrentCatalog().getAuth().checkGlobalPriv(ConnectContext.get(), PrivPredicate.ADMIN)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED, analyzer.getQualifiedUser(), dbName);
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR, analyzer.getQualifiedUser(), dbName);
}
if (Strings.isNullOrEmpty(dbName)) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterDatabaseRename.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterDatabaseRename.java
index e9e1def..5982e02 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterDatabaseRename.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/AlterDatabaseRename.java
@@ -60,7 +60,7 @@ public class AlterDatabaseRename extends DdlStmt {
PrivPredicate.of(PrivBitSet.of(PaloPrivilege.ADMIN_PRIV,
PaloPrivilege.ALTER_PRIV),
Operator.OR))) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED, analyzer.getQualifiedUser(), dbName);
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR, analyzer.getQualifiedUser(), dbName);
}
if (Strings.isNullOrEmpty(newDbName)) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDbStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDbStmt.java
index 8787f8f..a00a059 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDbStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDbStmt.java
@@ -57,7 +57,7 @@ public class CreateDbStmt extends DdlStmt {
dbName = ClusterNamespace.getFullName(getClusterName(), dbName);
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), dbName, PrivPredicate.CREATE)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED, analyzer.getQualifiedUser(), dbName);
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR, analyzer.getQualifiedUser(), dbName);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/DropDbStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/DropDbStmt.java
index 1f39cd2..2c01a96 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/DropDbStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/DropDbStmt.java
@@ -61,11 +61,11 @@ public class DropDbStmt extends DdlStmt {
dbName = ClusterNamespace.getFullName(getClusterName(), dbName);
// Don't allowed to drop 'information_schema'
if (dbName.equalsIgnoreCase(ClusterNamespace.getFullName(getClusterName(), InfoSchemaDb.DATABASE_NAME))) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED, analyzer.getQualifiedUser(), dbName);
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR, analyzer.getQualifiedUser(), dbName);
}
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), dbName, PrivPredicate.DROP)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED,
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR,
ConnectContext.get().getQualifiedUser(), dbName);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/LockTable.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/LockTable.java
new file mode 100644
index 0000000..07b51ca
--- /dev/null
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/LockTable.java
@@ -0,0 +1,62 @@
+// 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.
+
+package org.apache.doris.analysis;
+
+public class LockTable {
+ public enum LockType {
+ READ("READ"),
+ READ_LOCAL("READ LOCAL"),
+ WRITE("WRITE"),
+ LOW_PRIORITY_WRITE("LOW_PRIORITY WRITE");
+ private String desc;
+
+ LockType(String description) {
+ this.desc = description;
+ }
+
+ @Override
+ public String toString() {
+ return desc;
+ }
+ }
+ private TableName tableName;
+ private String alias;
+ private LockType lockType;
+
+ public LockTable(TableName tableName, String alias, LockType lockType) {
+ this.tableName = tableName;
+ this.alias = alias;
+ this.lockType = lockType;
+ }
+
+ public LockTable(TableName tableName, LockType lockType) {
+ this(tableName, null, lockType);
+ }
+
+ public TableName getTableName() {
+ return tableName;
+ }
+
+ public String getAlias() {
+ return alias;
+ }
+
+ public LockType getLockType() {
+ return lockType;
+ }
+}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/LockTablesStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/LockTablesStmt.java
new file mode 100644
index 0000000..115bd0f
--- /dev/null
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/LockTablesStmt.java
@@ -0,0 +1,100 @@
+// 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.
+
+package org.apache.doris.analysis;
+
+import org.apache.doris.catalog.Catalog;
+import org.apache.doris.catalog.Database;
+import org.apache.doris.catalog.Table;
+import org.apache.doris.cluster.ClusterNamespace;
+import org.apache.doris.common.ErrorCode;
+import org.apache.doris.common.ErrorReport;
+import org.apache.doris.common.UserException;
+import org.apache.doris.mysql.privilege.PrivPredicate;
+import org.apache.doris.qe.ConnectContext;
+
+import com.google.common.base.Strings;
+
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import java.util.ArrayList;
+import java.util.List;
+
+public class LockTablesStmt extends StatementBase {
+ private static final Logger LOG = LogManager.getLogger(LockTablesStmt.class);
+
+ private List<LockTable> lockTables;
+
+ public LockTablesStmt(ArrayList<LockTable> lockTables) {
+ this.lockTables = lockTables;
+ }
+
+ @Override
+ public void analyze(Analyzer analyzer) throws UserException {
+ super.analyze(analyzer);
+ for (LockTable lockTable : lockTables) {
+ String dbName = lockTable.getTableName().getDb();
+ String tableName = lockTable.getTableName().getTbl();
+ if (Strings.isNullOrEmpty(dbName)) {
+ dbName = analyzer.getDefaultDb();
+ } else {
+ dbName = ClusterNamespace.getFullName(analyzer.getClusterName(), dbName);
+ }
+ if (Strings.isNullOrEmpty(dbName)) {
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_NO_DB_ERROR);
+ }
+ if (Strings.isNullOrEmpty(tableName)) {
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_UNKNOWN_TABLE, tableName, dbName);
+ }
+ Database db = analyzer.getCatalog().getDbOrAnalysisException(dbName);
+ Table table = db.getTableOrAnalysisException(tableName);
+
+ // check auth
+ if (!Catalog.getCurrentCatalog().getAuth().checkTblPriv(ConnectContext.get(), dbName,
+ tableName,
+ PrivPredicate.SELECT)) {
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_TABLEACCESS_DENIED_ERROR, "SELECT",
+ ConnectContext.get().getQualifiedUser(),
+ ConnectContext.get().getRemoteIP(),
+ tableName);
+ }
+ }
+ }
+
+ @Override
+ public String toSql() {
+ StringBuilder sb = new StringBuilder();
+ sb.append("LOCK TABLES ");
+ for (int i = 0; i < lockTables.size(); i++) {
+ if (i != 0) {
+ sb.append(", ");
+ }
+ sb.append(lockTables.get(i).getTableName().toSql());
+ if (lockTables.get(i).getAlias() != null) {
+ sb.append(" AS ").append(lockTables.get(i).getAlias());
+ }
+ sb.append(" ").append(lockTables.get(i).getLockType().toString());
+ }
+ return sb.toString();
+ }
+
+ @Override
+ public RedirectStatus getRedirectStatus() {
+ return RedirectStatus.NO_FORWARD;
+ }
+}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/RecoverDbStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/RecoverDbStmt.java
index 65dd37e..5be7c6b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/RecoverDbStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/RecoverDbStmt.java
@@ -55,7 +55,7 @@ public class RecoverDbStmt extends DdlStmt {
PaloPrivilege.CREATE_PRIV,
PaloPrivilege.ADMIN_PRIV),
Operator.OR))) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED, analyzer.getQualifiedUser(), dbName);
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR, analyzer.getQualifiedUser(), dbName);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java
index cf5c77e..5920a87 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/SelectStmt.java
@@ -299,7 +299,7 @@ public class SelectStmt extends QueryStmt {
ErrorReport.reportAnalysisException(ErrorCode.ERR_NO_DB_ERROR);
}
if (Strings.isNullOrEmpty(tableName)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_BAD_TABLE_ERROR);
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_UNKNOWN_TABLE, tableName, dbName);
}
Database db = analyzer.getCatalog().getDbOrAnalysisException(dbName);
Table table = db.getTableOrAnalysisException(tableName);
@@ -861,7 +861,7 @@ public class SelectStmt extends QueryStmt {
private void expandStar(Analyzer analyzer, TableName tblName) throws AnalysisException {
Collection<TupleDescriptor> descs = analyzer.getDescriptor(tblName);
if (descs == null || descs.isEmpty()) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_BAD_TABLE_ERROR, tblName.getTbl());
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_UNKNOWN_TABLE, tblName.getTbl(), tblName.getDb());
}
for (TupleDescriptor desc : descs) {
expandStar(tblName, desc);
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackupStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackupStmt.java
index 053d5c8..eec2968 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackupStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowBackupStmt.java
@@ -71,7 +71,7 @@ public class ShowBackupStmt extends ShowStmt {
// check auth
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), dbName, PrivPredicate.LOAD)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED,
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR,
ConnectContext.get().getQualifiedUser(), dbName);
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateDbStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateDbStmt.java
index 99daec4..078c512 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateDbStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateDbStmt.java
@@ -68,7 +68,7 @@ public class ShowCreateDbStmt extends ShowStmt {
PaloPrivilege.CREATE_PRIV,
PaloPrivilege.DROP_PRIV),
Operator.OR))) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED,
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR,
ConnectContext.get().getQualifiedUser(), db);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateFunctionStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateFunctionStmt.java
index 2519d79..c0de0c6 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateFunctionStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowCreateFunctionStmt.java
@@ -76,7 +76,7 @@ public class ShowCreateFunctionStmt extends ShowStmt {
// check operation privilege
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), dbName, PrivPredicate.SHOW)) {
ErrorReport.reportAnalysisException(
- ErrorCode.ERR_DB_ACCESS_DENIED, ConnectContext.get().getQualifiedUser(), dbName);
+ ErrorCode.ERR_DBACCESS_DENIED_ERROR, ConnectContext.get().getQualifiedUser(), dbName);
}
// analyze arguments
argsDef.analyze(analyzer);
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEncryptKeysStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEncryptKeysStmt.java
index c2c3a10..89a5709 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEncryptKeysStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowEncryptKeysStmt.java
@@ -68,7 +68,7 @@ public class ShowEncryptKeysStmt extends ShowStmt{
// must check after analyze dbName, for case dbName is null.
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), dbName, PrivPredicate.ADMIN)) {
ErrorReport.reportAnalysisException(
- ErrorCode.ERR_DB_ACCESS_DENIED, ConnectContext.get().getQualifiedUser(), dbName);
+ ErrorCode.ERR_DBACCESS_DENIED_ERROR, ConnectContext.get().getQualifiedUser(), dbName);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFunctionsStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFunctionsStmt.java
index d2686e5..22c5fd7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFunctionsStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowFunctionsStmt.java
@@ -96,7 +96,7 @@ public class ShowFunctionsStmt extends ShowStmt {
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), dbName, PrivPredicate.SHOW)) {
ErrorReport.reportAnalysisException(
- ErrorCode.ERR_DB_ACCESS_DENIED, ConnectContext.get().getQualifiedUser(), dbName);
+ ErrorCode.ERR_DBACCESS_DENIED_ERROR, ConnectContext.get().getQualifiedUser(), dbName);
}
if (expr != null) {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRestoreStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRestoreStmt.java
index 22baa5b..c8b7898 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRestoreStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowRestoreStmt.java
@@ -77,7 +77,7 @@ public class ShowRestoreStmt extends ShowStmt {
// check auth
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), dbName, PrivPredicate.LOAD)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED,
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR,
ConnectContext.get().getQualifiedUser(), dbName);
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSmallFilesStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSmallFilesStmt.java
index 3d6ec14..e83328b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSmallFilesStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowSmallFilesStmt.java
@@ -64,7 +64,7 @@ public class ShowSmallFilesStmt extends ShowStmt {
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), dbName, PrivPredicate.SHOW)) {
ErrorReport.reportAnalysisException(
- ErrorCode.ERR_DB_ACCESS_DENIED, ConnectContext.get().getQualifiedUser(), dbName);
+ ErrorCode.ERR_DBACCESS_DENIED_ERROR, ConnectContext.get().getQualifiedUser(), dbName);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatusStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatusStmt.java
index 4dff43c..356dfde 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatusStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/ShowTableStatusStmt.java
@@ -88,7 +88,7 @@ public class ShowTableStatusStmt extends ShowStmt {
db = ClusterNamespace.getFullName(analyzer.getClusterName(), db);
}
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), db, PrivPredicate.SHOW)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED, analyzer.getQualifiedUser(), db);
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR, analyzer.getQualifiedUser(), db);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/DdlException.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/UnlockTablesStmt.java
similarity index 75%
copy from fe/fe-core/src/main/java/org/apache/doris/common/DdlException.java
copy to fe/fe-core/src/main/java/org/apache/doris/analysis/UnlockTablesStmt.java
index 803810d..4c66198 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/DdlException.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/UnlockTablesStmt.java
@@ -15,14 +15,16 @@
// specific language governing permissions and limitations
// under the License.
-package org.apache.doris.common;
+package org.apache.doris.analysis;
-public class DdlException extends UserException {
- public DdlException(String msg) {
- super(msg);
+public class UnlockTablesStmt extends StatementBase {
+ @Override
+ public String toSql() {
+ return "UNLOCK TABLES";
}
- public DdlException(String msg, Throwable e) {
- super(msg, e);
+ @Override
+ public RedirectStatus getRedirectStatus() {
+ return RedirectStatus.NO_FORWARD;
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/UseStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/UseStmt.java
index c55dcbc..2a9410f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/UseStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/UseStmt.java
@@ -64,7 +64,7 @@ public class UseStmt extends StatementBase {
database = ClusterNamespace.getFullName(getClusterName(), database);
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), database, PrivPredicate.SHOW)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED, analyzer.getQualifiedUser(), database);
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR, analyzer.getQualifiedUser(), database);
}
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java
index ec315ce..6cf0aca 100755
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Catalog.java
@@ -2862,7 +2862,7 @@ public class Catalog {
ErrorReport.reportDdlException(ErrorCode.ERR_TABLE_EXISTS_ERROR, tableName);
}
if (!Catalog.getCurrentRecycleBin().recoverTable(db, tableName)) {
- ErrorReport.reportDdlException(ErrorCode.ERR_BAD_TABLE_ERROR, tableName);
+ ErrorReport.reportDdlException(ErrorCode.ERR_UNKNOWN_TABLE, tableName, dbName);
}
} finally {
db.writeUnlock();
@@ -4313,7 +4313,6 @@ public class Catalog {
sb.append(new PrintableMap<>(hiveTable.getHiveProperties(), " = ", true, true, false).toString());
sb.append("\n)");
}
- sb.append(";");
createTableStmt.add(sb.toString());
@@ -4518,7 +4517,7 @@ public class Catalog {
LOG.info("drop table[{}] which does not exist", tableName);
return;
} else {
- ErrorReport.reportDdlException(ErrorCode.ERR_BAD_TABLE_ERROR, tableName);
+ ErrorReport.reportDdlException(ErrorCode.ERR_UNKNOWN_TABLE, tableName, dbName);
}
}
// Check if a view
@@ -4793,27 +4792,33 @@ public class Catalog {
}
public Database getDbOrMetaException(String dbName) throws MetaNotFoundException {
- return getDbOrException(dbName, s -> new MetaNotFoundException("unknown databases, dbName=" + s));
+ return getDbOrException(dbName, s -> new MetaNotFoundException("unknown databases, dbName=" + s,
+ ErrorCode.ERR_BAD_DB_ERROR));
}
public Database getDbOrMetaException(long dbId) throws MetaNotFoundException {
- return getDbOrException(dbId, s -> new MetaNotFoundException("unknown databases, dbId=" + s));
+ return getDbOrException(dbId, s -> new MetaNotFoundException("unknown databases, dbId=" + s,
+ ErrorCode.ERR_BAD_DB_ERROR));
}
public Database getDbOrDdlException(String dbName) throws DdlException {
- return getDbOrException(dbName, s -> new DdlException(ErrorCode.ERR_BAD_DB_ERROR.formatErrorMsg(s)));
+ return getDbOrException(dbName, s -> new DdlException(ErrorCode.ERR_BAD_DB_ERROR.formatErrorMsg(s),
+ ErrorCode.ERR_BAD_DB_ERROR));
}
public Database getDbOrDdlException(long dbId) throws DdlException {
- return getDbOrException(dbId, s -> new DdlException(ErrorCode.ERR_BAD_DB_ERROR.formatErrorMsg(s)));
+ return getDbOrException(dbId, s -> new DdlException(ErrorCode.ERR_BAD_DB_ERROR.formatErrorMsg(s),
+ ErrorCode.ERR_BAD_DB_ERROR));
}
public Database getDbOrAnalysisException(String dbName) throws AnalysisException {
- return getDbOrException(dbName, s -> new AnalysisException(ErrorCode.ERR_BAD_DB_ERROR.formatErrorMsg(s)));
+ return getDbOrException(dbName, s -> new AnalysisException(ErrorCode.ERR_BAD_DB_ERROR.formatErrorMsg(s),
+ ErrorCode.ERR_BAD_DB_ERROR));
}
public Database getDbOrAnalysisException(long dbId) throws AnalysisException {
- return getDbOrException(dbId, s -> new AnalysisException(ErrorCode.ERR_BAD_DB_ERROR.formatErrorMsg(s)));
+ return getDbOrException(dbId, s -> new AnalysisException(ErrorCode.ERR_BAD_DB_ERROR.formatErrorMsg(s),
+ ErrorCode.ERR_BAD_DB_ERROR));
}
public EditLog getEditLog() {
@@ -5816,7 +5821,7 @@ public class Catalog {
// Change current database of this session.
public void changeDb(ConnectContext ctx, String qualifiedDb) throws DdlException {
if (!auth.checkDbPriv(ctx, qualifiedDb, PrivPredicate.SHOW)) {
- ErrorReport.reportDdlException(ErrorCode.ERR_DB_ACCESS_DENIED, ctx.getQualifiedUser(), qualifiedDb);
+ ErrorReport.reportDdlException(ErrorCode.ERR_DBACCESS_DENIED_ERROR, ctx.getQualifiedUser(), qualifiedDb);
}
this.getDbOrDdlException(qualifiedDb);
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/Database.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/Database.java
index 128e9af..2e2bab2 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/Database.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/Database.java
@@ -522,7 +522,8 @@ public class Database extends MetaObject implements Writable {
}
public Table getTableOrAnalysisException(String tableName) throws AnalysisException {
- return getTableOrException(tableName, t -> new AnalysisException(ErrorCode.ERR_BAD_TABLE_ERROR.formatErrorMsg(t)));
+ return getTableOrException(tableName, t -> new AnalysisException(ErrorCode.ERR_UNKNOWN_TABLE.formatErrorMsg(t
+ , fullQualifiedName)));
}
public OlapTable getOlapTableOrAnalysisException(String tableName) throws AnalysisException {
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
index abd44d1..2d634fb 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/SchemaTable.java
@@ -338,6 +338,85 @@ public class SchemaTable extends Table {
.column("INDEX_TYPE", ScalarType.createVarchar(16))
.column("COMMENT", ScalarType.createVarchar(16))
.build()))
+ .put("files",
+ new SchemaTable(
+ SystemIdGenerator.getNextId(),
+ "files",
+ TableType.SCHEMA,
+ builder()
+ .column("FILE_ID", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("FILE_NAME", ScalarType.createStringType())
+ .column("FILE_TYPE", ScalarType.createVarchar(256))
+ .column("TABLESPACE_NAME", ScalarType.createVarchar(256))
+ .column("TABLE_CATALOG", ScalarType.createCharType(16))
+ .column("TABLE_SCHEMA", ScalarType.createStringType())
+ .column("TABLE_NAME", ScalarType.createStringType())
+ .column("LOGFILE_GROUP_NAME", ScalarType.createVarchar(256))
+ .column("LOGFILE_GROUP_NUMBER", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("ENGINE", ScalarType.createVarchar(64))
+ .column("FULLTEXT_KEYS", ScalarType.createStringType())
+ .column("DELETED_ROWS", ScalarType.createStringType())
+ .column("UPDATE_COUNT", ScalarType.createStringType())
+ .column("FREE_EXTENTS", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("TOTAL_EXTENTS", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("EXTENT_SIZE", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("INITIAL_SIZE", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("MAXIMUM_SIZE", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("AUTOEXTEND_SIZE", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("CREATION_TIME", ScalarType.createStringType())
+ .column("LAST_UPDATE_TIME", ScalarType.createStringType())
+ .column("LAST_ACCESS_TIME", ScalarType.createStringType())
+ .column("RECOVER_TIME", ScalarType.createStringType())
+ .column("TRANSACTION_COUNTER", ScalarType.createStringType())
+ .column("VERSION", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("ROW_FORMAT", ScalarType.createVarchar(256))
+ .column("TABLE_ROWS", ScalarType.createStringType())
+ .column("AVG_ROW_LENGTH", ScalarType.createStringType())
+ .column("DATA_LENGTH", ScalarType.createStringType())
+ .column("MAX_DATA_LENGTH", ScalarType.createStringType())
+ .column("INDEX_LENGTH", ScalarType.createStringType())
+ .column("DATA_FREE", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("CREATE_TIME", ScalarType.createStringType())
+ .column("UPDATE_TIME", ScalarType.createStringType())
+ .column("CHECK_TIME", ScalarType.createStringType())
+ .column("CHECKSUM", ScalarType.createStringType())
+ .column("STATUS", ScalarType.createVarchar(256))
+ .column("EXTRA", ScalarType.createVarchar(256))
+ .build()))
+ .put("partitions",
+ new SchemaTable(
+ SystemIdGenerator.getNextId(),
+ "partitions",
+ TableType.SCHEMA,
+ builder()
+ .column("TABLE_CATALOG", ScalarType.createVarchar(64))
+ .column("TABLE_SCHEMA", ScalarType.createVarchar(64))
+ .column("TABLE_NAME", ScalarType.createVarchar(64))
+ .column("PARTITION_NAME", ScalarType.createVarchar(64))
+ .column("SUBPARTITION_NAME", ScalarType.createVarchar(64))
+ .column("PARTITION_ORDINAL_POSITION",
+ ScalarType.createType(PrimitiveType.INT))
+ .column("SUBPARTITION_ORDINAL_POSITION",
+ ScalarType.createType(PrimitiveType.INT))
+ .column("PARTITION_METHOD", ScalarType.createVarchar(13))
+ .column("SUBPARTITION_METHOD", ScalarType.createVarchar(13))
+ .column("PARTITION_EXPRESSION", ScalarType.createVarchar(2048))
+ .column("SUBPARTITION_EXPRESSION", ScalarType.createVarchar(2048))
+ .column("PARTITION_DESCRIPTION", ScalarType.createStringType())
+ .column("TABLE_ROWS", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("AVG_ROW_LENGTH", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("DATA_LENGTH", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("MAX_DATA_LENGTH", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("INDEX_LENGTH", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("DATA_FREE", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("CREATE_TIME", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("UPDATE_TIME", ScalarType.createType(PrimitiveType.DATETIME))
+ .column("CHECK_TIME", ScalarType.createType(PrimitiveType.DATETIME))
+ .column("CHECKSUM", ScalarType.createType(PrimitiveType.BIGINT))
+ .column("PARTITION_COMMENT", ScalarType.createStringType())
+ .column("NODEGROUP", ScalarType.createVarchar(256))
+ .column("TABLESPACE_NAME", ScalarType.createVarchar(268))
+ .build()))
.build();
// statistics is table provides information about table indexes in mysql: 5.7
// views column is from show create table views in mysql: 5.5.6
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/AnalysisException.java b/fe/fe-core/src/main/java/org/apache/doris/common/AnalysisException.java
index 74cce3c..8f715fb 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/AnalysisException.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/AnalysisException.java
@@ -29,4 +29,9 @@ public class AnalysisException extends UserException {
public AnalysisException(String msg) {
super(msg);
}
+
+ public AnalysisException(String msg, ErrorCode mysqlErrorCode) {
+ super(msg);
+ setMysqlErrorCode(mysqlErrorCode);
+ }
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/DdlException.java b/fe/fe-core/src/main/java/org/apache/doris/common/DdlException.java
index 803810d..eb96451 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/DdlException.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/DdlException.java
@@ -21,6 +21,10 @@ public class DdlException extends UserException {
public DdlException(String msg) {
super(msg);
}
+ public DdlException(String msg, ErrorCode mysqlErrorCode) {
+ super(msg);
+ setMysqlErrorCode(mysqlErrorCode);
+ }
public DdlException(String msg, Throwable e) {
super(msg, e);
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/ErrorCode.java b/fe/fe-core/src/main/java/org/apache/doris/common/ErrorCode.java
index 69b9bae..08b7a2e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/ErrorCode.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/ErrorCode.java
@@ -22,172 +22,1593 @@ import java.util.MissingFormatArgumentException;
// Error code used to indicate what error happened.
public enum ErrorCode {
// Try our best to compatible with MySQL's
- ERR_CANT_CREATE_TABLE(1005, new byte[] { 'H', 'Y', '0', '0', '0' }, "Can't create table '%s' (errno: %s)"),
- ERR_DB_CREATE_EXISTS(1007, new byte[] {'H', 'Y', '0', '0', '0'}, "Can't create database '%s'; database exists"),
- ERR_DB_DROP_EXISTS(1008, new byte[] { 'H', 'Y', '0', '0', '0' },
- "Can't drop database '%s'; database doesn't exist"),
- ERR_DB_ACCESS_DENIED(1044, new byte[] {'4', '2', '0', '0', '0'}, "Access denied for user '%s' to database '%s'"),
- ERR_ACCESS_DENIED_ERROR(1045, new byte[] {'2', '8', '0', '0', '0'},
- "Access denied for user '%s' (using password: %s)"),
- ERR_NO_DB_ERROR(1046, new byte[] {'3', 'D', '0', '0', '0'}, "No database selected"),
- ERR_UNKNOWN_COM_ERROR(1047, new byte[] {'0', '8', 'S', '0', '1'}, "Unknown command"),
- ERR_BAD_DB_ERROR(1049, new byte[] {'4', '2', '0', '0', '0'}, "Unknown database '%s'"),
- ERR_TABLE_EXISTS_ERROR(1050, new byte[] {'4', '2', 'S', '0', '1'}, "Table '%s' already exists"),
- ERR_BAD_TABLE_ERROR(1051, new byte[] {'4', '2', 'S', '0', '2'}, "Unknown table '%s'"),
- ERR_NON_UNIQ_ERROR(1052, new byte[] {'2', '3', '0', '0', '0'}, "Column '%s' in is ambiguous"),
- ERR_ILLEGAL_COLUMN_REFERENCE_ERROR(1053, new byte[] {'2', '3', '0', '0', '1'},
- "Illegal column/field reference '%s' of semi-/anti-join"),
- ERR_BAD_FIELD_ERROR(1054, new byte[] {'4', '2', 'S', '2', '2'}, "Unknown column '%s' in '%s'"),
- ERR_WRONG_VALUE_COUNT(1058, new byte[] {'2', '1', 'S', '0', '1'}, "Column count doesn't match value count"),
- ERR_DUP_FIELDNAME(1060, new byte[] {'4', '2', 'S', '2', '1'}, "Duplicate column name '%s'"),
- ERR_NONUNIQ_TABLE(1066, new byte[] {'4', '2', '0', '0', '0'}, "Not unique table/alias: '%s'"),
- ERR_NO_SUCH_THREAD(1094, new byte[] {'H', 'Y', '0', '0', '0'}, "Unknown thread id: %d"),
- ERR_KILL_DENIED_ERROR(1095, new byte[] {'H', 'Y', '0', '0', '0'}, "You are not owner of thread %d"),
- ERR_NO_TABLES_USED(1096, new byte[] {'H', 'Y', '0', '0', '0'}, "No tables used"),
- ERR_WRONG_DB_NAME(1102, new byte[] {'4', '2', '0', '0', '0'}, "Incorrect database name '%s'"),
- ERR_WRONG_TABLE_NAME(1104, new byte[] {'4', '2', '0', '0', '0'}, "Incorrect table name '%s'"),
- ERR_UNKNOWN_ERROR(1105, new byte[] {'H', 'Y', '0', '0', '0'}, "Unknown error"),
- ERR_FIELD_SPECIFIED_TWICE(1110, new byte[] {'4', '2', '0', '0', '0'}, "Column '%s' specified twice"),
- ERR_INVALID_GROUP_FUNC_USE(1111, new byte[] {'H', 'Y', '0', '0', '0'}, "Invalid use of group function"),
- ERR_TABLE_MUST_HAVE_COLUMNS(1113, new byte[] {'4', '2', '0', '0', '0'}, "A table must have at least 1 column"),
- ERR_UNKNOWN_CHARACTER_SET(1115, new byte[] {'4', '2', '0', '0', '0'}, "Unknown character set: '%s'"),
- ERR_IP_NOT_ALLOWED(1130, new byte[] { '4', '2', '0', '0', '0' },
- "Host %s is not allowed to connect to this MySQL server"),
- ERR_PASSWORD_NOT_ALLOWED(1132, new byte[] {'4', '2', '0', '0', '0'},
- "You must have privileges to "
- + "update tables in the mysql database to be able to change passwords for others"),
- ERR_NONEXISTING_GRANT(1141, new byte[] { '4', '2', '0', '0', '0' },
- "There is no such grant defined for user '%s' on host '%s'"),
- ERR_TABLEACCESS_DENIED_ERROR(1142, new byte[] { '4', '2', '0', '0', '0' },
- "%s command denied to user '%s'@'%s' for table '%s'"),
- ERR_WRONG_COLUMN_NAME(1166, new byte[] {'4', '2', '0', '0', '0'}, "Incorrect column name '%s'"),
- ERR_UNKNOWN_SYSTEM_VARIABLE(1193, new byte[] {'H', 'Y', '0', '0', '0'}, "Unknown system variable '%s'"),
- ERR_TOO_MANY_USER_CONNECTIONS(1203, new byte[] {'4', '2', '0', '0', '0'},
- "User %s already has more than 'max_user_connections' active connections"),
- ERR_NO_PERMISSION_TO_CREATE_USER(1211, new byte[] {'4', '2', '0', '0', '0'},
- "'%s' is not allowed to create new users"),
- ERR_SPECIFIC_ACCESS_DENIED_ERROR(1227, new byte[] {'4', '2', '0', '0', '0'},
- "Access denied; you need (at least one of) the %s privilege(s) for this operation"),
- ERR_LOCAL_VARIABLE(1228, new byte[] {'H', 'Y', '0', '0', '0'},
- "Variable '%s' is a SESSION variable and can't be used with SET GLOBAL"),
- ERR_GLOBAL_VARIABLE(1229, new byte[] {'H', 'Y', '0', '0', '0'},
- "Variable '%s' is a GLOBAL variable and should be set with SET GLOBAL"),
- ERR_NO_DEFAULT(1230, new byte[] {'4', '2', '0', '0', '0'}, "Variable '%s' doesn't have a default value"),
- ERR_WRONG_VALUE_FOR_VAR(1231, new byte[] {'4', '2', '0', '0', '0'},
- "Variable '%s' can't be set to the value of '%s'"),
- ERR_WRONG_TYPE_FOR_VAR(1232, new byte[] {'4', '2', '0', '0', '0'}, "Incorrect argument type to variable '%s'"),
- ERR_DERIVED_MUST_HAVE_ALIAS(1248, new byte[] {'4', '2', '0', '0', '0'},
- "Every derived table must have its own alias"),
- ERR_NOT_SUPPORTED_AUTH_MODE(1251, new byte[] {'0', '8', '0', '0', '4'},
- "Client does not support authentication protocol requested by server; consider upgrading MySQL client"),
- ERR_UNKNOWN_STORAGE_ENGINE(1286, new byte[] {'4', '2', '0', '0', '0'}, "Unknown storage engine '%s'"),
- ERR_UNKNOWN_TIME_ZONE(1298, new byte[] {'H', 'Y', '0', '0', '0'}, "Unknown or incorrect time zone: '%s'"),
- ERR_WRONG_OBJECT(1347, new byte[] {'H', 'Y', '0', '0', '0'}, "'%s'.'%s' is not '%s'"),
- ERR_VIEW_WRONG_LIST(1353, new byte[] {'H', 'Y', '0', '0', '0'},
- "View's SELECT and view's field list have different column counts"),
- ERR_NO_DEFAULT_FOR_FIELD(1364, new byte[] {'H', 'Y', '0', '0', '0'},
- "Field '%s' is not null but doesn't have a default value"),
- ERR_PASSWD_LENGTH(1372, new byte[] {'H', 'Y', '0', '0', '0'},
- "Password hash should be a %d-digit hexadecimal number"),
- ERR_CANNOT_USER(1396, new byte[] {'H', 'Y', '0', '0', '0'}, "Operation %s failed for %s"),
- ERR_NON_INSERTABLE_TABLE(1471, new byte[] {'H', 'Y', '0', '0', '0'},
- "The target table %s of the %s is not insertable-into"),
- ERR_DROP_PARTITION_NON_EXISTENT(1507, new byte[] { 'H', 'Y', '0', '0', '0' },
- "Error in list of partitions to %s"),
- ERR_DROP_LAST_PARTITION(1508, new byte[] { 'H', 'Y', '0', '0', '0' },
- "Cannot remove all partitions, use DROP TABLE instead"),
- ERR_SAME_NAME_PARTITION(1517, new byte[] { 'H', 'Y', '0', '0', '0' }, "Duplicate partition name %s"),
- ERR_WRONG_PARTITION_NAME(1567, new byte[] {'H', 'Y', '0', '0', '0'}, "Incorrect partition name '%s'"),
- ERR_VARIABLE_IS_READONLY(1621, new byte[] {'H', 'Y', '0', '0', '0'}, "Variable '%s' is a read only variable"),
- ERR_UNKNOWN_PARTITION(1735, new byte[] {'H', 'Y', '0', '0', '0'}, "Unknown partition '%s' in table '%s'"),
- ERR_PARTITION_CLAUSE_ON_NONPARTITIONED(1747, new byte[] {'H', 'Y', '0', '0', '0'},
- "PARTITION () clause on non partitioned table"),
- ERR_EMPTY_PARTITION_IN_TABLE(1748, new byte[] {'H', 'Y', '0', '0', '0'},
- "data cannot be inserted into table with empty partition. " +
- "Use `SHOW PARTITIONS FROM %s` to see the currently partitions of this table. "),
- ERR_NO_SUCH_PARTITION(1749, new byte[] {'H', 'Y', '0', '0', '0'}, "partition '%s' doesn't exist"),
+ ERR_HASHCHK(1000, new byte[]{'H', 'Y', '0', '0', '0'}, "hashchk"),
+ ERR_NISAMCHK(1001, new byte[]{'H', 'Y', '0', '0', '0'}, "isamchk"),
+ ERR_NO(1002, new byte[]{'H', 'Y', '0', '0', '0'}, "NO"),
+ ERR_YES(1003, new byte[]{'H', 'Y', '0', '0', '0'}, "YES"),
+ ERR_CANT_CREATE_FILE(1004, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't create file '%s' (errno: %d)"),
+ ERR_CANT_CREATE_TABLE(1005, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't create table '%s' (errno: %d)"),
+ ERR_CANT_CREATE_DB(1006, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't create database '%s' (errno: %d"),
+ ERR_DB_CREATE_EXISTS(1007, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't create database '%s'; database exists"),
+ ERR_DB_DROP_EXISTS(1008, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't drop database '%s'; database doesn't exist"),
+ ERR_DB_DROP_DELETE(1009, new byte[]{'H', 'Y', '0', '0', '0'},
+ "Error dropping database (can't delete '%s', errno: %d)"),
+ ERR_DB_DROP_RMDIR(1010, new byte[]{'H', 'Y', '0', '0', '0'},
+ "Error dropping database (can't rmdir '%s', errno: %d)"),
+ ERR_CANT_DELETE_FILE(1011, new byte[]{'H', 'Y', '0', '0', '0'}, "Error on delete of '%s' (errno: %d)"),
+ ERR_CANT_FIND_SYSTEM_REC(1012, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't read record in system table"),
+ ERR_CANT_GET_STAT(1013, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't get status of '%s' (errno: %d)"),
+ ERR_CANT_GET_WD(1014, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't get working directory (errno: %d)"),
+ ERR_CANT_LOCK(1015, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't lock file (errno: %d)"),
+ ERR_CANT_OPEN_FILE(1016, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't open file: '%s' (errno: %d)"),
+ ERR_FILE_NOT_FOUND(1017, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't find file: '%s' (errno: %d)"),
+ ERR_CANT_READ_DIR(1018, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't read dir of '%s' (errno: %d)"),
+ ERR_CANT_SET_WD(1019, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't change dir to '%s' (errno: %d)"),
+ ERR_CHECKREAD(1020, new byte[]{'H', 'Y', '0', '0', '0'}, "Record has changed since last read in table '%s'"),
+ ERR_DISK_FULL(1021, new byte[]{'H', 'Y', '0', '0', '0'}, "Disk full (%s); waiting for someone to free some space." +
+ ".."),
+ ERR_DUP_KEY(1022, new byte[]{'2', '3', '0', '0', '0'}, "Can't write; duplicate key in table '%s'"),
+ ERR_ERROR_ON_CLOSE(1023, new byte[]{'H', 'Y', '0', '0', '0'}, "Error on close of '%s' (errno: %d)"),
+ ERR_ERROR_ON_READ(1024, new byte[]{'H', 'Y', '0', '0', '0'}, "Error reading file '%s' (errno: %d)"),
+ ERR_ERROR_ON_RENAME(1025, new byte[]{'H', 'Y', '0', '0', '0'}, "Error on rename of '%s' to '%s' (errno: %d)"),
+ ERR_ERROR_ON_WRITE(1026, new byte[]{'H', 'Y', '0', '0', '0'}, "Error writing file '%s' (errno: %d)"),
+ ERR_FILE_USED(1027, new byte[]{'H', 'Y', '0', '0', '0'}, "'%s' is locked against change"),
+ ERR_FILSORT_ABORT(1028, new byte[]{'H', 'Y', '0', '0', '0'}, "Sort aborted"),
+ ERR_FORM_NOT_FOUND(1029, new byte[]{'H', 'Y', '0', '0', '0'}, "View '%s' doesn't exist for '%s'"),
+ ERR_GET_ERRN(1030, new byte[]{'H', 'Y', '0', '0', '0'}, "Got error %d from storage engine"),
+ ERR_ILLEGAL_HA(1031, new byte[]{'H', 'Y', '0', '0', '0'}, "Table storage engine for '%s' doesn't have this option"),
+ ERR_KEY_NOT_FOUND(1032, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't find record in '%s'"),
+ ERR_NOT_FORM_FILE(1033, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect information in file: '%s'"),
+ ERR_NOT_KEYFILE(1034, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect key file for table '%s'; try to repair it"),
+ ERR_OLD_KEYFILE(1035, new byte[]{'H', 'Y', '0', '0', '0'}, "Old key file for table '%s'; repair it!"),
+ ERR_OPEN_AS_READONLY(1036, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s' is read only"),
+ ERR_OUTOFMEMORY(1037, new byte[]{'H', 'Y', '0', '0', '1'}, "Out of memory; restart server and try again (needed " +
+ "%d bytes)"),
+ ERR_OUT_OF_SORTMEMORY(1038, new byte[]{'H', 'Y', '0', '0', '1'}, "Out of sort memory, consider increasing server " +
+ "sort buffer size"),
+ ERR_UNEXPECTED_EOF(1039, new byte[]{'H', 'Y', '0', '0', '0'}, "Unexpected EOF found when reading file '%s' " +
+ "(Errno: %d)"),
+ ERR_CON_COUNT_ERROR(1040, new byte[]{'0', '8', '0', '0', '4'}, "Too many connections"),
+ ERR_OUT_OF_RESOURCES(1041, new byte[]{'H', 'Y', '0', '0', '0'}, "Out of memory; check if mysqld or some other " +
+ "process uses all available memory; if not, you may have to use 'ulimit' to allow mysqld to use more " +
+ "memory or " +
+ "you can add more swap space"),
+ ERR_BAD_HOST_ERROR(1042, new byte[]{'0', '8', 'S', '0', '1'}, "Can't get hostname for your address"),
+ ERR_HANDSHAKE_ERROR(1043, new byte[]{'0', '8', 'S', '0', '1'}, "Bad handshake"),
+ ERR_DBACCESS_DENIED_ERROR(1044, new byte[]{'4', '2', '0', '0', '0'}, "Access denied for user '%s'@'%s' to " +
+ "database '%s'"),
+ ERR_ACCESS_DENIED_ERROR(1045, new byte[]{'2', '8', '0', '0', '0'}, "Access denied for user '%s'@'%s' (using " +
+ "password: %s)"),
+ ERR_NO_DB_ERROR(1046, new byte[]{'3', 'D', '0', '0', '0'}, "No database selected"),
+ ERR_UNKNOWN_COM_ERROR(1047, new byte[]{'0', '8', 'S', '0', '1'}, "Unknown command"),
+ ERR_BAD_NULL_ERROR(1048, new byte[]{'2', '3', '0', '0', '0'}, "Column '%s' cannot be null"),
+ ERR_BAD_DB_ERROR(1049, new byte[]{'4', '2', '0', '0', '0'}, "Unknown database '%s'"),
+ ERR_TABLE_EXISTS_ERROR(1050, new byte[]{'4', '2', 'S', '0', '1'}, "Table '%s' already exists"),
+ ERR_BAD_TABLE_ERROR(1051, new byte[]{'4', '2', 'S', '0', '2'}, "Unknown table '%s'"),
+ ERR_NON_UNIQ_ERROR(1052, new byte[]{'2', '3', '0', '0', '0'}, "Column '%s' in %s is ambiguous"),
+ ERR_SERVER_SHUTDOWN(1053, new byte[]{'0', '8', 'S', '0', '1'}, "Server shutdown in progress"),
+ ERR_BAD_FIELD_ERROR(1054, new byte[]{'4', '2', 'S', '2', '2'}, "Unknown column '%s' in '%s'"),
+ ERR_WRONG_FIELD_WITH_GROUP(1055, new byte[]{'4', '2', '0', '0', '0'}, "'%s' isn't in GROUP BY"),
+ ERR_WRONG_GROUP_FIELD(1056, new byte[]{'4', '2', '0', '0', '0'}, "Can't group on '%s'"),
+ ERR_WRONG_SUM_SELECT(1057, new byte[]{'4', '2', '0', '0', '0'}, "Statement has sum functions and columns in same " +
+ "statement"),
+ ERR_WRONG_VALUE_COUNT(1058, new byte[]{'2', '1', 'S', '0', '1'}, "Column count doesn't match value count"),
+ ERR_TOO_LONG_IDENT(1059, new byte[]{'4', '2', '0', '0', '0'}, "Identifier name '%s' is too long"),
+ ERR_DUP_FIELDNAME(1060, new byte[]{'4', '2', 'S', '2', '1'}, "Duplicate column name '%s'"),
+ ERR_DUP_KEYNAME(1061, new byte[]{'4', '2', '0', '0', '0'}, "Duplicate key name '%s'"),
+ ERR_DUP_ENTRY(1062, new byte[]{'2', '3', '0', '0', '0'}, "Duplicate entry '%s' for key %d"),
+ ERR_WRONG_FIELD_SPEC(1063, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect column specifier for column '%s'"),
+ ERR_PARSE_ERROR(1064, new byte[]{'4', '2', '0', '0', '0'}, "%s near '%s' at line %d"),
+ ERR_EMPTY_QUERY(1065, new byte[]{'4', '2', '0', '0', '0'}, "Query was empty"),
+ ERR_NONUNIQ_TABLE(1066, new byte[]{'4', '2', '0', '0', '0'}, "Not unique table/alias: '%s'"),
+ ERR_INVALID_DEFAULT(1067, new byte[]{'4', '2', '0', '0', '0'}, "Invalid default value for '%s'"),
+ ERR_MULTIPLE_PRI_KEY(1068, new byte[]{'4', '2', '0', '0', '0'}, "Multiple primary key defined"),
+ ERR_TOO_MANY_KEYS(1069, new byte[]{'4', '2', '0', '0', '0'}, "Too many keys specified; max %d keys allowed"),
+ ERR_TOO_MANY_KEY_PARTS(1070, new byte[]{'4', '2', '0', '0', '0'}, "Too many key parts specified; max %d parts " +
+ "allowed"),
+ ERR_TOO_LONG_KEY(1071, new byte[]{'4', '2', '0', '0', '0'}, "Specified key was too long; max key length is %d " +
+ "bytes"),
+ ERR_KEY_COLUMN_DOES_NOT_EXITS(1072, new byte[]{'4', '2', '0', '0', '0'}, "Key column '%s' doesn't exist in table"),
+ ERR_BLOB_USED_AS_KEY(1073, new byte[]{'4', '2', '0', '0', '0'}, "BLOB column '%s' can't be used in key " +
+ "specification with the used table type"),
+ ERR_TOO_BIG_FIELDLENGTH(1074, new byte[]{'4', '2', '0', '0', '0'}, "Column length too big for column '%s' (max = " +
+ "%lu); use BLOB or TEXT instead"),
+ ERR_WRONG_AUTO_KEY(1075, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect table definition; there can be only one " +
+ "auto column and it must be defined as a key"),
+ ERR_READY(1076, new byte[]{'H', 'Y', '0', '0', '0'}, "%s: ready for connections. Version: '%s' socket: '%s' port:" +
+ " %d"),
+ ERR_NORMAL_SHUTDOWN(1077, new byte[]{'H', 'Y', '0', '0', '0'}, "%s: Normal shutdown"),
+ ERR_GOT_SIGNAL(1078, new byte[]{'H', 'Y', '0', '0', '0'}, "%s: Got signal %d. Aborting!"),
+ ERR_SHUTDOWN_COMPLETE(1079, new byte[]{'H', 'Y', '0', '0', '0'}, "%s: Shutdown complete"),
+ ERR_FORCING_CLOSE(1080, new byte[]{'0', '8', 'S', '0', '1'}, "%s: Forcing close of thread %ld user: '%s'"),
+ ERR_IPSOCK_ERROR(1081, new byte[]{'0', '8', 'S', '0', '1'}, "Can't create IP socket"),
+ ERR_NO_SUCH_INDEX(1082, new byte[]{'4', '2', 'S', '1', '2'}, "Table '%s' has no index like the one used in CREATE" +
+ " INDEX; recreate the table"),
+ ERR_WRONG_FIELD_TERMINATORS(1083, new byte[]{'4', '2', '0', '0', '0'}, "Field separator argument is not what is " +
+ "expected; check the manual"),
+ ERR_BLOBS_AND_NO_TERMINATED(1084, new byte[]{'4', '2', '0', '0', '0'}, "You can't use fixed rowlength with BLOBs;" +
+ " please use 'fields terminated by'"),
+ ERR_TEXTFILE_NOT_READABLE(1085, new byte[]{'H', 'Y', '0', '0', '0'}, "The file '%s' must be in the database " +
+ "directory or be readable by all"),
+ ERR_FILE_EXISTS_ERROR(1086, new byte[]{'H', 'Y', '0', '0', '0'}, "File '%s' already exists"),
+ ERR_LOAD_INF(1087, new byte[]{'H', 'Y', '0', '0', '0'}, "Records: %ld Deleted: %ld Skipped: %ld Warnings: %ld"),
+ ERR_ALTER_INF(1088, new byte[]{'H', 'Y', '0', '0', '0'}, "Records: %ld Duplicates: %ld"),
+ ERR_WRONG_SUB_KEY(1089, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect prefix key; the used key part isn't a " +
+ "string, the used length is longer than the key part, or the storage engine doesn't support unique prefix" +
+ " keys"),
+ ERR_CANT_REMOVE_ALL_FIELDS(1090, new byte[]{'4', '2', '0', '0', '0'}, "You can't delete all columns with ALTER " +
+ "TABLE; use DROP TABLE instead"),
+ ERR_CANT_DROP_FIELD_OR_KEY(1091, new byte[]{'4', '2', '0', '0', '0'}, "Can't DROP '%s'; check that column/key " +
+ "exists"),
+ ERR_INSERT_INF(1092, new byte[]{'H', 'Y', '0', '0', '0'}, "Records: %ld Duplicates: %ld Warnings: %ld"),
+ ERR_UPDATE_TABLE_USED(1093, new byte[]{'H', 'Y', '0', '0', '0'}, "You can't specify target table '%s' for update " +
+ "in FROM clause"),
+ ERR_NO_SUCH_THREAD(1094, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown thread id: %lu"),
+ ERR_KILL_DENIED_ERROR(1095, new byte[]{'H', 'Y', '0', '0', '0'}, "You are not owner of thread %lu"),
+ ERR_NO_TABLES_USED(1096, new byte[]{'H', 'Y', '0', '0', '0'}, "No tables used"),
+ ERR_TOO_BIG_SET(1097, new byte[]{'H', 'Y', '0', '0', '0'}, "Too many strings for column %s and SET"),
+ ERR_NO_UNIQUE_LOGFILE(1098, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't generate a unique log-filename %s.(1-999)"),
+ ERR_TABLE_NOT_LOCKED_FOR_WRITE(1099, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s' was locked with a READ lock" +
+ " and can't be updated"),
+ ERR_TABLE_NOT_LOCKED(1100, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s' was not locked with LOCK TABLES"),
+ ERR_UNUSED_17(1101, new byte[]{}, "You should never see it"),
+ ERR_WRONG_DB_NAME(1102, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect database name '%s'"),
+ ERR_WRONG_TABLE_NAME(1103, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect table name '%s'"),
+ ERR_TOO_BIG_SELECT(1104, new byte[]{'4', '2', '0', '0', '0'}, "The SELECT would examine more than MAX_JOIN_SIZE " +
+ "rows; check your WHERE and use SET SQL_BIG_SELECTS=1 or SET MAX_JOIN_SIZE=# if the SELECT is okay"),
+ ERR_UNKNOWN_ERROR(1105, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown error"),
+ ERR_UNKNOWN_PROCEDURE(1106, new byte[]{'4', '2', '0', '0', '0'}, "Unknown procedure '%s'"),
+ ERR_WRONG_PARAMCOUNT_TO_PROCEDURE(1107, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect parameter count to " +
+ "procedure '%s'"),
+ ERR_WRONG_PARAMETERS_TO_PROCEDURE(1108, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect parameters to procedure " +
+ "'%s'"),
+ ERR_UNKNOWN_TABLE(1109, new byte[]{'4', '2', 'S', '0', '2'}, "Unknown table '%s' in %s"),
+ ERR_FIELD_SPECIFIED_TWICE(1110, new byte[]{'4', '2', '0', '0', '0'}, "Column '%s' specified twice"),
+ ERR_INVALID_GROUP_FUNC_USE(1111, new byte[]{'H', 'Y', '0', '0', '0'}, "Invalid use of group function"),
+ ERR_UNSUPPORTED_EXTENSION(1112, new byte[]{'4', '2', '0', '0', '0'}, "Table '%s' uses an extension that doesn't " +
+ "exist in this MariaDB version"),
+ ERR_TABLE_MUST_HAVE_COLUMNS(1113, new byte[]{'4', '2', '0', '0', '0'}, "A table must have at least 1 column"),
+ ERR_RECORD_FILE_FULL(1114, new byte[]{'H', 'Y', '0', '0', '0'}, "The table '%s' is full"),
+ ERR_UNKNOWN_CHARACTER_SET(1115, new byte[]{'4', '2', '0', '0', '0'}, "Unknown character set: '%s'"),
+ ERR_TOO_MANY_TABLES(1116, new byte[]{'H', 'Y', '0', '0', '0'}, "Too many tables; MariaDB can only use %d tables " +
+ "in a join"),
+ ERR_TOO_MANY_FIELDS(1117, new byte[]{'H', 'Y', '0', '0', '0'}, "Too many columns"),
+ ERR_TOO_BIG_ROWSIZE(1118, new byte[]{'4', '2', '0', '0', '0'}, "Row size too large. The maximum row size for the " +
+ "used table type, not counting BLOBs, is %ld. You have to change some columns to TEXT or BLOBs"),
+ ERR_STACK_OVERRUN(1119, new byte[]{'H', 'Y', '0', '0', '0'}, "Thread stack overrun: Used: %ld of a %ld stack. Use" +
+ " 'mysqld --thread_stack=#' to specify a bigger stack if needed"),
+ ERR_WRONG_OUTER_JOIN(1120, new byte[]{'4', '2', '0', '0', '0'}, "Cross dependency found in OUTER JOIN; examine " +
+ "your ON conditions"),
+ ERR_NULL_COLUMN_IN_INDEX(1121, new byte[]{'4', '2', '0', '0', '0'}, "Table handler doesn't support NULL in given " +
+ "index. Please change column '%s' to be NOT NULL or use another handler"),
+ ERR_CANT_FIND_UDF(1122, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't load function '%s'"),
+ ERR_CANT_INITIALIZE_UDF(1123, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't initialize function '%s'; %s"),
+ ERR_UDF_NO_PATHS(1124, new byte[]{'H', 'Y', '0', '0', '0'}, "No paths allowed for shared library"),
+ ERR_UDF_EXISTS(1125, new byte[]{'H', 'Y', '0', '0', '0'}, "Function '%s' already exists"),
+ ERR_CANT_OPEN_LIBRARY(1126, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't open shared library '%s' (Errno: %d %s)"),
+ ERR_CANT_FIND_DL_ENTRY(1127, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't find symbol '%s' in library"),
+ ERR_FUNCTION_NOT_DEFINED(1128, new byte[]{'H', 'Y', '0', '0', '0'}, "Function '%s' is not defined"),
+ ERR_HOST_IS_BLOCKED(1129, new byte[]{'H', 'Y', '0', '0', '0'}, "Host '%s' is blocked because of many connection " +
+ "errors; unblock with 'mysqladmin flush-hosts'"),
+ ERR_HOST_NOT_PRIVILEGED(1130, new byte[]{'H', 'Y', '0', '0', '0'}, "Host '%s' is not allowed to connect to this " +
+ "MariaDB server"),
+ ERR_PASSWORD_ANONYMOUS_USER(1131, new byte[]{'4', '2', '0', '0', '0'}, "You are using MariaDB as an anonymous " +
+ "user and anonymous users are not allowed to change passwords"),
+ ERR_PASSWORD_NOT_ALLOWED(1132, new byte[]{'4', '2', '0', '0', '0'}, "You must have privileges to update tables in" +
+ " the mysql database to be able to change passwords for others"),
+ ERR_PASSWORD_NO_MATCH(1133, new byte[]{'4', '2', '0', '0', '0'}, "Can't find any matching row in the user table"),
+ ERR_UPDATE_INF(1134, new byte[]{'H', 'Y', '0', '0', '0'}, "Rows matched: %ld Changed: %ld Warnings: %ld"),
+ ERR_CANT_CREATE_THREAD(1135, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't create a new thread (Errno %d); if you " +
+ "are not out of available memory, you can consult the manual for a possible OS-dependent bug"),
+ ERR_WRONG_VALUE_COUNT_ON_ROW(1136, new byte[]{'2', '1', 'S', '0', '1'}, "Column count doesn't match value count " +
+ "at row %ld"),
+ ERR_CANT_REOPEN_TABLE(1137, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't reopen table: '%s'"),
+ ERR_INVALID_USE_OF_NULL(1138, new byte[]{'2', '2', '0', '0', '4'}, "Invalid use of NULL value"),
+ ERR_REGEXP_ERROR(1139, new byte[]{'4', '2', '0', '0', '0'}, "Got error '%s' from regexp"),
+ ERR_MIX_OF_GROUP_FUNC_AND_FIELDS(1140, new byte[]{'4', '2', '0', '0', '0'}, "Mixing of GROUP columns (MIN(),MAX()" +
+ ",COUNT(),...) with no GROUP columns is illegal if there is no GROUP BY clause"),
+ ERR_NONEXISTING_GRANT(1141, new byte[]{'4', '2', '0', '0', '0'}, "There is no such grant defined for user '%s' on" +
+ " host '%s'"),
+ ERR_TABLEACCESS_DENIED_ERROR(1142, new byte[]{'4', '2', '0', '0', '0'}, "%s command denied to user '%s'@'%s' for " +
+ "table '%s'"),
+ ERR_COLUMNACCESS_DENIED_ERROR(1143, new byte[]{'4', '2', '0', '0', '0'}, "%s command denied to user '%s'@'%s' for" +
+ " column '%s' in table '%s'"),
+ ERR_ILLEGAL_GRANT_FOR_TABLE(1144, new byte[]{'4', '2', '0', '0', '0'}, "Illegal GRANT/REVOKE command; please " +
+ "consult the manual to see which privileges can be used"),
+ ERR_GRANT_WRONG_HOST_OR_USER(1145, new byte[]{'4', '2', '0', '0', '0'}, "The host or user argument to GRANT is " +
+ "too long"),
+ ERR_NO_SUCH_TABLE(1146, new byte[]{'4', '2', 'S', '0', '2'}, "Table '%s.%s' doesn't exist"),
+ ERR_NONEXISTING_TABLE_GRANT(1147, new byte[]{'4', '2', '0', '0', '0'}, "There is no such grant defined for user " +
+ "'%s' on host '%s' on table '%s'"),
+ ERR_NOT_ALLOWED_COMMAND(1148, new byte[]{'4', '2', '0', '0', '0'}, "The used command is not allowed with this " +
+ "MariaDB version"),
+ ERR_SYNTAX_ERROR(1149, new byte[]{'4', '2', '0', '0', '0'}, "You have an error in your SQL syntax; check the " +
+ "manual that corresponds to your MariaDB server version for the right syntax to use"),
+ ERR_DELAYED_CANT_CHANGE_LOCK(1150, new byte[]{'H', 'Y', '0', '0', '0'}, "Delayed insert thread couldn't get " +
+ "requested lock for table %s"),
+ ERR_TOO_MANY_DELAYED_THREADS(1151, new byte[]{'H', 'Y', '0', '0', '0'}, "Too many delayed threads in use"),
+ ERR_ABORTING_CONNECTION(1152, new byte[]{'0', '8', 'S', '0', '1'}, "Aborted connection %ld to db: '%s' user: '%s'" +
+ " (%s)"),
+ ERR_NET_PACKET_TOO_LARGE(1153, new byte[]{'0', '8', 'S', '0', '1'}, "Got a packet bigger than " +
+ "'max_allowed_packet' bytes"),
+ ERR_NET_READ_ERROR_FROM_PIPE(1154, new byte[]{'0', '8', 'S', '0', '1'}, "Got a read error from the connection " +
+ "pipe"),
+ ERR_NET_FCNTL_ERROR(1155, new byte[]{'0', '8', 'S', '0', '1'}, "Got an error from fcntl()"),
+ ERR_NET_PACKETS_OUT_OF_ORDER(1156, new byte[]{'0', '8', 'S', '0', '1'}, "Got packets out of order"),
+ ERR_NET_UNCOMPRESS_ERROR(1157, new byte[]{'0', '8', 'S', '0', '1'}, "Couldn't uncompress communication packet"),
+ ERR_NET_READ_ERROR(1158, new byte[]{'0', '8', 'S', '0', '1'}, "Got an error reading communication packets"),
+ ERR_NET_READ_INTERRUPTED(1159, new byte[]{'0', '8', 'S', '0', '1'}, "Got timeout reading communication packets"),
+ ERR_NET_ERROR_ON_WRITE(1160, new byte[]{'0', '8', 'S', '0', '1'}, "Got an error writing communication packets"),
+ ERR_NET_WRITE_INTERRUPTED(1161, new byte[]{'0', '8', 'S', '0', '1'}, "Got timeout writing communication packets"),
+ ERR_TOO_LONG_STRING(1162, new byte[]{'4', '2', '0', '0', '0'}, "Result string is longer than 'max_allowed_packet'" +
+ " bytes"),
+ ERR_TABLE_CANT_HANDLE_BLOB(1163, new byte[]{'4', '2', '0', '0', '0'}, "The used table type doesn't support " +
+ "BLOB/TEXT columns"),
+ ERR_TABLE_CANT_HANDLE_AUTO_INCREMENT(1164, new byte[]{'4', '2', '0', '0', '0'}, "The used table type doesn't " +
+ "support AUTO_INCREMENT columns"),
+ ERR_DELAYED_INSERT_TABLE_LOCKED(1165, new byte[]{'H', 'Y', '0', '0', '0'}, "INSERT DELAYED can't be used with " +
+ "table '%s' because it is locked with LOCK TABLES"),
+ ERR_WRONG_COLUMN_NAME(1166, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect column name '%s'"),
+ ERR_WRONG_KEY_COLUMN(1167, new byte[]{'4', '2', '0', '0', '0'}, "The used storage engine can't index column '%s'"),
+ ERR_WRONG_MRG_TABLE(1168, new byte[]{'H', 'Y', '0', '0', '0'}, "Unable to open underlying table which is " +
+ "differently defined or of non-MyISAM type or doesn't exist"),
+ ERR_DUP_UNIQUE(1169, new byte[]{'2', '3', '0', '0', '0'}, "Can't write, because of unique constraint, to table " +
+ "'%s'"),
+ ERR_BLOB_KEY_WITHOUT_LENGTH(1170, new byte[]{'4', '2', '0', '0', '0'}, "BLOB/TEXT column '%s' used in key " +
+ "specification without a key length"),
+ ERR_PRIMARY_CANT_HAVE_NULL(1171, new byte[]{'4', '2', '0', '0', '0'}, "All parts of a PRIMARY KEY must be NOT " +
+ "NULL; if you need NULL in a key, use UNIQUE instead"),
+ ERR_TOO_MANY_ROWS(1172, new byte[]{'4', '2', '0', '0', '0'}, "Result consisted of more than one row"),
+ ERR_REQUIRES_PRIMARY_KEY(1173, new byte[]{'4', '2', '0', '0', '0'}, "This table type requires a primary key"),
+ ERR_NO_RAID_COMPILED(1174, new byte[]{'H', 'Y', '0', '0', '0'}, "This version of MariaDB is not compiled with " +
+ "RAID support"),
+ ERR_UPDATE_WITHOUT_KEY_IN_SAFE_MODE(1175, new byte[]{'H', 'Y', '0', '0', '0'}, "You are using safe update mode " +
+ "and you tried to update a table without a WHERE that uses a KEY column"),
+ ERR_KEY_DOES_NOT_EXITS(1176, new byte[]{'4', '2', '0', '0', '0'}, "Key '%s' doesn't exist in table '%s'"),
+ ERR_CHECK_NO_SUCH_TABLE(1177, new byte[]{'4', '2', '0', '0', '0'}, "Can't open table"),
+ ERR_CHECK_NOT_IMPLEMENTED(1178, new byte[]{'4', '2', '0', '0', '0'}, "The storage engine for the table doesn't " +
+ "support %s"),
+ ERR_CANT_DO_THIS_DURING_AN_TRANSACTION(1179, new byte[]{'2', '5', '0', '0', '0'}, "You are not allowed to execute" +
+ " this command in a transaction"),
+ ERR_ERROR_DURING_COMMIT(1180, new byte[]{'H', 'Y', '0', '0', '0'}, "Got error %d during COMMIT"),
+ ERR_ERROR_DURING_ROLLBACK(1181, new byte[]{'H', 'Y', '0', '0', '0'}, "Got error %d during ROLLBACK"),
+ ERR_ERROR_DURING_FLUSH_LOGS(1182, new byte[]{'H', 'Y', '0', '0', '0'}, "Got error %d during FLUSH_LOGS"),
+ ERR_ERROR_DURING_CHECKPOINT(1183, new byte[]{'H', 'Y', '0', '0', '0'}, "Got error %d during CHECKPOINT"),
+ ERR_NEW_ABORTING_CONNECTION(1184, new byte[]{'0', '8', 'S', '0', '1'}, "Aborted connection %ld to db: '%s' user: " +
+ "'%s' host: '%s' (%s)"),
+ ERR_UNUSED_10(1185, new byte[]{}, "You should never see it"),
+ ERR_FLUSH_MASTER_BINLOG_CLOSED(1186, new byte[]{'H', 'Y', '0', '0', '0'}, "Binlog closed, cannot RESET MASTER"),
+ ERR_INDEX_REBUILD(1187, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed rebuilding the index of dumped table '%s'"),
+ ERR_MASTER(1188, new byte[]{'H', 'Y', '0', '0', '0'}, "Error from master: '%s'"),
+ ERR_MASTER_NET_READ(1189, new byte[]{'0', '8', 'S', '0', '1'}, "Net error reading from master"),
+ ERR_MASTER_NET_WRITE(1190, new byte[]{'0', '8', 'S', '0', '1'}, "Net error writing to master"),
+ ERR_FT_MATCHING_KEY_NOT_FOUND(1191, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't find FULLTEXT index matching the " +
+ "column list"),
+ ERR_LOCK_OR_ACTIVE_TRANSACTION(1192, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't execute the given command " +
+ "because you have active locked tables or an active transaction"),
+ ERR_UNKNOWN_SYSTEM_VARIABLE(1193, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown system variable '%s'"),
+ ERR_CRASHED_ON_USAGE(1194, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s' is marked as crashed and should be " +
+ "repaired"),
+ ERR_CRASHED_ON_REPAIR(1195, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s' is marked as crashed and last " +
+ "(automatic?) repair failed"),
+ ERR_WARNING_NOT_COMPLETE_ROLLBACK(1196, new byte[]{'H', 'Y', '0', '0', '0'}, "Some non-transactional changed " +
+ "tables couldn't be rolled back"),
+ ERR_TRANS_CACHE_FULL(1197, new byte[]{'H', 'Y', '0', '0', '0'}, "Multi-statement transaction required more than " +
+ "'max_binlog_cache_size' bytes of storage; increase this mysqld variable and try again"),
+ ERR_SLAVE_MUST_STOP(1198, new byte[]{'H', 'Y', '0', '0', '0'}, "This operation cannot be performed with a running" +
+ " slave; run STOP SLAVE first"),
+ ERR_SLAVE_NOT_RUNNING(1199, new byte[]{'H', 'Y', '0', '0', '0'}, "This operation requires a running slave; " +
+ "configure slave and do START SLAVE"),
+ ERR_BAD_SLAVE(1200, new byte[]{'H', 'Y', '0', '0', '0'}, "The server is not configured as slave; fix in config " +
+ "file or with CHANGE MASTER TO"),
+ ERR_MASTER_INF(1201, new byte[]{'H', 'Y', '0', '0', '0'}, "Could not initialize master info structure; more error" +
+ " messages can be found in the MariaDB error log"),
+ ERR_SLAVE_THREAD(1202, new byte[]{'H', 'Y', '0', '0', '0'}, "Could not create slave thread; check system " +
+ "resources"),
+ ERR_TOO_MANY_USER_CONNECTIONS(1203, new byte[]{'4', '2', '0', '0', '0'}, "User %s already has more than " +
+ "'max_user_connections' active connections"),
+ ERR_SET_CONSTANTS_ONLY(1204, new byte[]{'H', 'Y', '0', '0', '0'}, "You may only use constant expressions with SET"),
+ ERR_LOCK_WAIT_TIMEOUT(1205, new byte[]{'H', 'Y', '0', '0', '0'}, "Lock wait timeout exceeded; try restarting " +
+ "transaction"),
+ ERR_LOCK_TABLE_FULL(1206, new byte[]{'H', 'Y', '0', '0', '0'}, "The total number of locks exceeds the lock table " +
+ "size"),
+ ERR_READ_ONLY_TRANSACTION(1207, new byte[]{'2', '5', '0', '0', '0'}, "Update locks cannot be acquired during a " +
+ "READ UNCOMMITTED transaction"),
+ ERR_DROP_DB_WITH_READ_LOCK(1208, new byte[]{'H', 'Y', '0', '0', '0'}, "DROP DATABASE not allowed while thread is " +
+ "holding global read lock"),
+ ERR_CREATE_DB_WITH_READ_LOCK(1209, new byte[]{'H', 'Y', '0', '0', '0'}, "CREATE DATABASE not allowed while thread" +
+ " is holding global read lock"),
+ ERR_WRONG_ARGUMENTS(1210, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect arguments to %s"),
+ ERR_NO_PERMISSION_TO_CREATE_USER(1211, new byte[]{'4', '2', '0', '0', '0'}, "'%s'@'%s' is not allowed to create " +
+ "new users"),
+ ERR_UNION_TABLES_IN_DIFFERENT_DIR(1212, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect table definition; all " +
+ "MERGE tables must be in the same database"),
+ ERR_LOCK_DEADLOCK(1213, new byte[]{'4', '0', '0', '0', '1'}, "Deadlock found when trying to get lock; try " +
+ "restarting transaction"),
+ ERR_TABLE_CANT_HANDLE_FT(1214, new byte[]{'H', 'Y', '0', '0', '0'}, "The used table type doesn't support FULLTEXT" +
+ " indexes"),
+ ERR_CANNOT_ADD_FOREIGN(1215, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot add foreign key constraint"),
+ ERR_NO_REFERENCED_ROW(1216, new byte[]{'2', '3', '0', '0', '0'}, "Cannot add or update a child row: a foreign key" +
+ " constraint fails"),
+ ERR_ROW_IS_REFERENCED(1217, new byte[]{'2', '3', '0', '0', '0'}, "Cannot delete or update a parent row: a foreign" +
+ " key constraint fails"),
+ ERR_CONNECT_TO_MASTER(1218, new byte[]{'0', '8', 'S', '0', '1'}, "Error connecting to master: %s"),
+ ERR_QUERY_ON_MASTER(1219, new byte[]{'H', 'Y', '0', '0', '0'}, "Error running query on master: %s"),
+ ERR_ERROR_WHEN_EXECUTING_COMMAND(1220, new byte[]{'H', 'Y', '0', '0', '0'}, "Error when executing command %s: %s"),
+ ERR_WRONG_USAGE(1221, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect usage of %s and %s"),
+ ERR_WRONG_NUMBER_OF_COLUMNS_IN_SELECT(1222, new byte[]{'2', '1', '0', '0', '0'}, "The used SELECT statements have" +
+ " a different number of columns"),
+ ERR_CANT_UPDATE_WITH_READLOCK(1223, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't execute the query because you " +
+ "have a conflicting read lock"),
+ ERR_MIXING_NOT_ALLOWED(1224, new byte[]{'H', 'Y', '0', '0', '0'}, "Mixing of transactional and non-transactional " +
+ "tables is disabled"),
+ ERR_DUP_ARGUMENT(1225, new byte[]{'H', 'Y', '0', '0', '0'}, "Option '%s' used twice in statement"),
+ ERR_USER_LIMIT_REACHED(1226, new byte[]{'4', '2', '0', '0', '0'}, "User '%s' has exceeded the '%s' resource " +
+ "(current value: %ld)"),
+ ERR_SPECIFIC_ACCESS_DENIED_ERROR(1227, new byte[]{'4', '2', '0', '0', '0'}, "Access denied; you need (at least " +
+ "one of) the %s privilege(s) for this operation"),
+ ERR_LOCAL_VARIABLE(1228, new byte[]{'H', 'Y', '0', '0', '0'}, "Variable '%s' is a SESSION variable and can't be " +
+ "used with SET GLOBAL"),
+ ERR_GLOBAL_VARIABLE(1229, new byte[]{'H', 'Y', '0', '0', '0'}, "Variable '%s' is a GLOBAL variable and should be " +
+ "set with SET GLOBAL"),
+ ERR_NO_DEFAULT(1230, new byte[]{'4', '2', '0', '0', '0'}, "Variable '%s' doesn't have a default value"),
+ ERR_WRONG_VALUE_FOR_VAR(1231, new byte[]{'4', '2', '0', '0', '0'}, "Variable '%s' can't be set to the value of " +
+ "'%s'"),
+ ERR_WRONG_TYPE_FOR_VAR(1232, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect argument type to variable '%s'"),
+ ERR_VAR_CANT_BE_READ(1233, new byte[]{'H', 'Y', '0', '0', '0'}, "Variable '%s' can only be set, not read"),
+ ERR_CANT_USE_OPTION_HERE(1234, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect usage/placement of '%s'"),
+ ERR_NOT_SUPPORTED_YET(1235, new byte[]{'4', '2', '0', '0', '0'}, "This version of MariaDB doesn't yet support " +
+ "'%s'"),
+ ERR_MASTER_FATAL_ERROR_READING_BINLOG(1236, new byte[]{'H', 'Y', '0', '0', '0'}, "Got fatal error %d from master " +
+ "when reading data from binary log: '%s'"),
+ ERR_SLAVE_IGNORED_TABLE(1237, new byte[]{'H', 'Y', '0', '0', '0'}, "Slave SQL thread ignored the query because of" +
+ " replicate-*-table rules"),
+ ERR_INCORRECT_GLOBAL_LOCAL_VAR(1238, new byte[]{'H', 'Y', '0', '0', '0'}, "Variable '%s' is a %s variable"),
+ ERR_WRONG_FK_DEF(1239, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect foreign key definition for '%s': %s"),
+ ERR_KEY_REF_DO_NOT_MATCH_TABLE_REF(1240, new byte[]{'H', 'Y', '0', '0', '0'}, "Key reference and table reference " +
+ "don't match"),
+ ERR_OPERAND_COLUMNS(1241, new byte[]{'2', '1', '0', '0', '0'}, "Operand should contain %d column(s)"),
+ ERR_SUBQUERY_NO_1_ROW(1242, new byte[]{'2', '1', '0', '0', '0'}, "Subquery returns more than 1 row"),
+ ERR_UNKNOWN_STMT_HANDLER(1243, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown prepared statement handler (%.*s) " +
+ "given to %s"),
+ ERR_CORRUPT_HELP_DB(1244, new byte[]{'H', 'Y', '0', '0', '0'}, "Help database is corrupt or does not exist"),
+ ERR_CYCLIC_REFERENCE(1245, new byte[]{'H', 'Y', '0', '0', '0'}, "Cyclic reference on subqueries"),
+ ERR_AUTO_CONVERT(1246, new byte[]{'H', 'Y', '0', '0', '0'}, "Converting column '%s' from %s to %s"),
+ ERR_ILLEGAL_REFERENCE(1247, new byte[]{'4', '2', 'S', '2', '2'}, "Reference '%s' not supported (%s)"),
+ ERR_DERIVED_MUST_HAVE_ALIAS(1248, new byte[]{'4', '2', '0', '0', '0'}, "Every derived table must have its own " +
+ "alias"),
+ ERR_SELECT_REDUCED(1249, new byte[]{'0', '1', '0', '0', '0'}, "Select %u was reduced during optimization"),
+ ERR_TABLENAME_NOT_ALLOWED_HERE(1250, new byte[]{'4', '2', '0', '0', '0'}, "Table '%s' from one of the SELECTs " +
+ "cannot be used in %s"),
+ ERR_NOT_SUPPORTED_AUTH_MODE(1251, new byte[]{'0', '8', '0', '0', '4'}, "Client does not support authentication " +
+ "protocol requested by server; consider upgrading MariaDB client"),
+ ERR_SPATIAL_CANT_HAVE_NULL(1252, new byte[]{'4', '2', '0', '0', '0'}, "All parts of a SPATIAL index must be NOT " +
+ "NULL"),
+ ERR_COLLATION_CHARSET_MISMATCH(1253, new byte[]{'4', '2', '0', '0', '0'}, "COLLATION '%s' is not valid for " +
+ "CHARACTER SET '%s'"),
+ ERR_SLAVE_WAS_RUNNING(1254, new byte[]{'H', 'Y', '0', '0', '0'}, "Slave is already running"),
+ ERR_SLAVE_WAS_NOT_RUNNING(1255, new byte[]{'H', 'Y', '0', '0', '0'}, "Slave already has been stopped"),
+ ERR_TOO_BIG_FOR_UNCOMPRESS(1256, new byte[]{'H', 'Y', '0', '0', '0'}, "Uncompressed data size too large; the " +
+ "maximum size is %d (probably, length of uncompressed data was corrupted)"),
+ ERR_ZLIB_Z_MEM_ERROR(1257, new byte[]{'H', 'Y', '0', '0', '0'}, "ZLIB: Not enough memory"),
+ ERR_ZLIB_Z_BUF_ERROR(1258, new byte[]{'H', 'Y', '0', '0', '0'}, "ZLIB: Not enough room in the output buffer " +
+ "(probably, length of uncompressed data was corrupted)"),
+ ERR_ZLIB_Z_DATA_ERROR(1259, new byte[]{'H', 'Y', '0', '0', '0'}, "ZLIB: Input data corrupted"),
+ ERR_CUT_VALUE_GROUP_CONCAT(1260, new byte[]{'H', 'Y', '0', '0', '0'}, "Row %u was cut by GROUP_CONCAT()"),
+ ERR_WARN_TOO_FEW_RECORDS(1261, new byte[]{'0', '1', '0', '0', '0'}, "Row %ld doesn't contain data for all columns"),
+ ERR_WARN_TOO_MANY_RECORDS(1262, new byte[]{'0', '1', '0', '0', '0'}, "Row %ld was truncated; it contained more " +
+ "data than there were input columns"),
+ ERR_WARN_NULL_TO_NOTNULL(1263, new byte[]{'2', '2', '0', '0', '4'}, "Column set to default value; NULL supplied " +
+ "to NOT NULL column '%s' at row %ld"),
+ ERR_WARN_DATA_OUT_OF_RANGE(1264, new byte[]{'2', '2', '0', '0', '3'}, "Out of range value for column '%s' at row " +
+ "%ld"),
+ WARN_DATA_TRUNCATED(1265, new byte[]{'0', '1', '0', '0', '0'}, "Data truncated for column '%s' at row %ld"),
+ ERR_WARN_USING_OTHER_HANDLER(1266, new byte[]{'H', 'Y', '0', '0', '0'}, "Using storage engine %s for table '%s'"),
+ ERR_CANT_AGGREGATE_2COLLATIONS(1267, new byte[]{'H', 'Y', '0', '0', '0'}, "Illegal mix of collations (%s,%s) and " +
+ "(%s,%s) for operation '%s'"),
+ ERR_DROP_USER(1268, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot drop one or more of the requested users"),
+ ERR_REVOKE_GRANTS(1269, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't revoke all privileges for one or more of the " +
+ "requested users"),
+ ERR_CANT_AGGREGATE_3COLLATIONS(1270, new byte[]{'H', 'Y', '0', '0', '0'}, "Illegal mix of collations (%s,%s), " +
+ "(%s,%s), (%s,%s) for operation '%s'"),
+ ERR_CANT_AGGREGATE_NCOLLATIONS(1271, new byte[]{'H', 'Y', '0', '0', '0'}, "Illegal mix of collations for " +
+ "operation '%s'"),
+ ERR_VARIABLE_IS_NOT_STRUCT(1272, new byte[]{'H', 'Y', '0', '0', '0'}, "Variable '%s' is not a variable component " +
+ "(can't be used as XXXX.variable_name)"),
+ ERR_UNKNOWN_COLLATION(1273, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown collation: '%s'"),
+ ERR_SLAVE_IGNORED_SSL_PARAMS(1274, new byte[]{'H', 'Y', '0', '0', '0'}, "SSL parameters in CHANGE MASTER are " +
+ "ignored because this MariaDB slave was compiled without SSL support; they can be used later if MariaDB " +
+ "slave " +
+ "with SSL is started"),
+ ERR_SERVER_IS_IN_SECURE_AUTH_MODE(1275, new byte[]{'H', 'Y', '0', '0', '0'}, "Server is running in --secure-auth " +
+ "mode, but '%s'@'%s' has a password in the old format; please change the password to the new format"),
+ ERR_WARN_FIELD_RESOLVED(1276, new byte[]{'H', 'Y', '0', '0', '0'}, "Field or reference '%s%s%s%s%s' of SELECT #%d" +
+ " was resolved in SELECT #%d"),
+ ERR_BAD_SLAVE_UNTIL_COND(1277, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect parameter or combination of " +
+ "parameters for START SLAVE UNTIL"),
+ ERR_MISSING_SKIP_SLAVE(1278, new byte[]{'H', 'Y', '0', '0', '0'}, "It is recommended to use --skip-slave-start " +
+ "when doing step-by-step replication with START SLAVE UNTIL; otherwise, you will get problems if you get " +
+ "an " +
+ "unexpected slave's mysqld restart"),
+ ERR_UNTIL_COND_IGNORED(1279, new byte[]{'H', 'Y', '0', '0', '0'}, "SQL thread is not to be started so UNTIL " +
+ "options are ignored"),
+ ERR_WRONG_NAME_FOR_INDEX(1280, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect index name '%s'"),
+ ERR_WRONG_NAME_FOR_CATALOG(1281, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect catalog name '%s'"),
+ ERR_WARN_QC_RESIZE(1282, new byte[]{'H', 'Y', '0', '0', '0'}, "Query cache failed to set size %lu; new query " +
+ "cache size is %lu"),
+ ERR_BAD_FT_COLUMN(1283, new byte[]{'H', 'Y', '0', '0', '0'}, "Column '%s' cannot be part of FULLTEXT index"),
+ ERR_UNKNOWN_KEY_CACHE(1284, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown key cache '%s'"),
+ ERR_WARN_HOSTNAME_WONT_WORK(1285, new byte[]{'H', 'Y', '0', '0', '0'}, "MariaDB is started in --skip-name-resolve" +
+ " mode; you must restart it without this switch for this grant to work"),
+ ERR_UNKNOWN_STORAGE_ENGINE(1286, new byte[]{'4', '2', '0', '0', '0'}, "Unknown storage engine '%s'"),
+ ERR_WARN_DEPRECATED_SYNTAX(1287, new byte[]{'H', 'Y', '0', '0', '0'}, "'%s' is deprecated and will be removed in " +
+ "a future release. Please use %s instead"),
+ ERR_NON_UPDATABLE_TABLE(1288, new byte[]{'H', 'Y', '0', '0', '0'}, "The target table %s of the %s is not " +
+ "updatable"),
+ ERR_FEATURE_DISABLED(1289, new byte[]{'H', 'Y', '0', '0', '0'}, "The '%s' feature is disabled; you need MariaDB " +
+ "built with '%s' to have it working"),
+ ERR_OPTION_PREVENTS_STATEMENT(1290, new byte[]{'H', 'Y', '0', '0', '0'}, "The MariaDB server is running with the " +
+ "%s option so it cannot execute this statement"),
+ ERR_DUPLICATED_VALUE_IN_TYPE(1291, new byte[]{'H', 'Y', '0', '0', '0'}, "Column '%s' has duplicated value '%s' in" +
+ " %s"),
+ ERR_TRUNCATED_WRONG_VALUE(1292, new byte[]{'2', '2', '0', '0', '7'}, "Truncated incorrect %s value: '%s'"),
+ ERR_TOO_MUCH_AUTO_TIMESTAMP_COLS(1293, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect table definition; there " +
+ "can be only one TIMESTAMP column with CURRENT_TIMESTAMP in DEFAULT or ON UPDATE clause"),
+ ERR_INVALID_ON_UPDATE(1294, new byte[]{'H', 'Y', '0', '0', '0'}, "Invalid ON UPDATE clause for '%s' column"),
+ ERR_UNSUPPORTED_PS(1295, new byte[]{'H', 'Y', '0', '0', '0'}, "This command is not supported in the prepared " +
+ "statement protocol yet"),
+ ERR_GET_ERRMSG(1296, new byte[]{'H', 'Y', '0', '0', '0'}, "Got error %d '%s' from %s"),
+ ERR_GET_TEMPORARY_ERRMSG(1297, new byte[]{'H', 'Y', '0', '0', '0'}, "Got temporary error %d '%s' from %s"),
+ ERR_UNKNOWN_TIME_ZONE(1298, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown or incorrect time zone: '%s'"),
+ ERR_WARN_INVALID_TIMESTAMP(1299, new byte[]{'H', 'Y', '0', '0', '0'}, "Invalid TIMESTAMP value in column '%s' at " +
+ "row %ld"),
+ ERR_INVALID_CHARACTER_STRING(1300, new byte[]{'H', 'Y', '0', '0', '0'}, "Invalid %s character string: '%s'"),
+ ERR_WARN_ALLOWED_PACKET_OVERFLOWED(1301, new byte[]{'H', 'Y', '0', '0', '0'}, "Result of %s() was larger than " +
+ "max_allowed_packet (%ld) - truncated"),
+ ERR_CONFLICTING_DECLARATIONS(1302, new byte[]{'H', 'Y', '0', '0', '0'}, "Conflicting declarations: '%s%s' and " +
+ "'%s%s'"),
+ ERR_SP_NO_RECURSIVE_CREATE(1303, new byte[]{'2', 'F', '0', '0', '3'}, "Can't create a %s from within another " +
+ "stored routine"),
+ ERR_SP_ALREADY_EXISTS(1304, new byte[]{'4', '2', '0', '0', '0'}, "%s %s already exists"),
+ ERR_SP_DOES_NOT_EXIST(1305, new byte[]{'4', '2', '0', '0', '0'}, "%s %s does not exist"),
+ ERR_SP_DROP_FAILED(1306, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to DROP %s %s"),
+ ERR_SP_STORE_FAILED(1307, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to CREATE %s %s"),
+ ERR_SP_LILABEL_MISMATCH(1308, new byte[]{'4', '2', '0', '0', '0'}, "%s with no matching label: %s"),
+ ERR_SP_LABEL_REDEFINE(1309, new byte[]{'4', '2', '0', '0', '0'}, "Redefining label %s"),
+ ERR_SP_LABEL_MISMATCH(1310, new byte[]{'4', '2', '0', '0', '0'}, "End-label %s without match"),
+ ERR_SP_UNINIT_VAR(1311, new byte[]{'0', '1', '0', '0', '0'}, "Referring to uninitialized variable %s"),
+ ERR_SP_BADSELECT(1312, new byte[]{'0', 'A', '0', '0', '0'}, "PROCEDURE %s can't return a result set in the given " +
+ "context"),
+ ERR_SP_BADRETURN(1313, new byte[]{'4', '2', '0', '0', '0'}, "RETURN is only allowed in a FUNCTION"),
+ ERR_SP_BADSTATEMENT(1314, new byte[]{'0', 'A', '0', '0', '0'}, "%s is not allowed in stored procedures"),
+ ERR_UPDATE_LOG_DEPRECATED_IGNORED(1315, new byte[]{'4', '2', '0', '0', '0'}, "The update log is deprecated and " +
+ "replaced by the binary log; SET SQL_LOG_UPDATE has been ignored. This option will be removed in MariaDB " +
+ "5.6."),
+ ERR_UPDATE_LOG_DEPRECATED_TRANSLATED(1316, new byte[]{'4', '2', '0', '0', '0'}, "The update log is deprecated and" +
+ " replaced by the binary log; SET SQL_LOG_UPDATE has been translated to SET SQL_LOG_BIN. This option will" +
+ " be " +
+ "removed in MariaDB 5.6."),
+ ERR_QUERY_INTERRUPTED(1317, new byte[]{'7', '0', '1', '0', '0'}, "Query execution was interrupted"),
+ ERR_SP_WRONG_NO_OF_ARGS(1318, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect number of arguments for %s %s; " +
+ "expected %u, got %u"),
+ ERR_SP_COND_MISMATCH(1319, new byte[]{'4', '2', '0', '0', '0'}, "Undefined CONDITION: %s"),
+ ERR_SP_NORETURN(1320, new byte[]{'4', '2', '0', '0', '0'}, "No RETURN found in FUNCTION %s"),
+ ERR_SP_NORETURNEND(1321, new byte[]{'2', 'F', '0', '0', '5'}, "FUNCTION %s ended without RETURN"),
+ ERR_SP_BAD_CURSOR_QUERY(1322, new byte[]{'4', '2', '0', '0', '0'}, "Cursor statement must be a SELECT"),
+ ERR_SP_BAD_CURSOR_SELECT(1323, new byte[]{'4', '2', '0', '0', '0'}, "Cursor SELECT must not have INTO"),
+ ERR_SP_CURSOR_MISMATCH(1324, new byte[]{'4', '2', '0', '0', '0'}, "Undefined CURSOR: %s"),
+ ERR_SP_CURSOR_ALREADY_OPEN(1325, new byte[]{'2', '4', '0', '0', '0'}, "Cursor is already open"),
+ ERR_SP_CURSOR_NOT_OPEN(1326, new byte[]{'2', '4', '0', '0', '0'}, "Cursor is not open"),
+ ERR_SP_UNDECLARED_VAR(1327, new byte[]{'4', '2', '0', '0', '0'}, "Undeclared variable: %s"),
+ ERR_SP_WRONG_NO_OF_FETCH_ARGS(1328, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect number of FETCH variables"),
+ ERR_SP_FETCH_NO_DATA(1329, new byte[]{'0', '2', '0', '0', '0'}, "No data - zero rows fetched, selected, or " +
+ "processed"),
+ ERR_SP_DUP_PARAM(1330, new byte[]{'4', '2', '0', '0', '0'}, "Duplicate parameter: %s"),
+ ERR_SP_DUP_VAR(1331, new byte[]{'4', '2', '0', '0', '0'}, "Duplicate variable: %s"),
+ ERR_SP_DUP_COND(1332, new byte[]{'4', '2', '0', '0', '0'}, "Duplicate condition: %s"),
+ ERR_SP_DUP_CURS(1333, new byte[]{'4', '2', '0', '0', '0'}, "Duplicate cursor: %s"),
+ ERR_SP_CANT_ALTER(1334, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to ALTER %s %s"),
+ ERR_SP_SUBSELECT_NYI(1335, new byte[]{'0', 'A', '0', '0', '0'}, "Subquery value not supported"),
+ ERR_STMT_NOT_ALLOWED_IN_SF_OR_TRG(1336, new byte[]{'0', 'A', '0', '0', '0'}, "%s is not allowed in stored " +
+ "function or trigger"),
+ ERR_SP_VARCOND_AFTER_CURSHNDLR(1337, new byte[]{'4', '2', '0', '0', '0'}, "Variable or condition declaration " +
+ "after cursor or handler declaration"),
+ ERR_SP_CURSOR_AFTER_HANDLER(1338, new byte[]{'4', '2', '0', '0', '0'}, "Cursor declaration after handler " +
+ "declaration"),
+ ERR_SP_CASE_NOT_FOUND(1339, new byte[]{'2', '0', '0', '0', '0'}, "Case not found for CASE statement"),
+ ERR_FPARSER_TOO_BIG_FILE(1340, new byte[]{'H', 'Y', '0', '0', '0'}, "Configuration file '%s' is too big"),
+ ERR_FPARSER_BAD_HEADER(1341, new byte[]{'H', 'Y', '0', '0', '0'}, "Malformed file type header in file '%s'"),
+ ERR_FPARSER_EOF_IN_COMMENT(1342, new byte[]{'H', 'Y', '0', '0', '0'}, "Unexpected end of file while parsing " +
+ "comment '%s'"),
+ ERR_FPARSER_ERROR_IN_PARAMETER(1343, new byte[]{'H', 'Y', '0', '0', '0'}, "Error while parsing parameter '%s' " +
+ "(line: '%s')"),
+ ERR_FPARSER_EOF_IN_UNKNOWN_PARAMETER(1344, new byte[]{'H', 'Y', '0', '0', '0'}, "Unexpected end of file while " +
+ "skipping unknown parameter '%s'"),
+ ERR_VIEW_NO_EXPLAIN(1345, new byte[]{'H', 'Y', '0', '0', '0'}, "EXPLAIN/SHOW can not be issued; lacking " +
+ "privileges for underlying table"),
+ ERR_FRM_UNKNOWN_TYPE(1346, new byte[]{'H', 'Y', '0', '0', '0'}, "File '%s' has unknown type '%s' in its header"),
+ ERR_WRONG_OBJECT(1347, new byte[]{'H', 'Y', '0', '0', '0'}, "'%s.%s' is not %s"),
+ ERR_NONUPDATEABLE_COLUMN(1348, new byte[]{'H', 'Y', '0', '0', '0'}, "Column '%s' is not updatable"),
+ ERR_VIEW_SELECT_DERIVED(1349, new byte[]{'H', 'Y', '0', '0', '0'}, "View's SELECT contains a subquery in the FROM" +
+ " clause"),
+ ERR_VIEW_SELECT_CLAUSE(1350, new byte[]{'H', 'Y', '0', '0', '0'}, "View's SELECT contains a '%s' clause"),
+ ERR_VIEW_SELECT_VARIABLE(1351, new byte[]{'H', 'Y', '0', '0', '0'}, "View's SELECT contains a variable or " +
+ "parameter"),
+ ERR_VIEW_SELECT_TMPTABLE(1352, new byte[]{'H', 'Y', '0', '0', '0'}, "View's SELECT refers to a temporary table " +
+ "'%s'"),
+ ERR_VIEW_WRONG_LIST(1353, new byte[]{'H', 'Y', '0', '0', '0'}, "View's SELECT and view's field list have " +
+ "different column counts"),
+ ERR_WARN_VIEW_MERGE(1354, new byte[]{'H', 'Y', '0', '0', '0'}, "View merge algorithm can't be used here for now " +
+ "(assumed undefined algorithm)"),
+ ERR_WARN_VIEW_WITHOUT_KEY(1355, new byte[]{'H', 'Y', '0', '0', '0'}, "View being updated does not have complete " +
+ "key of underlying table in it"),
+ ERR_VIEW_INVALID(1356, new byte[]{'H', 'Y', '0', '0', '0'}, "View '%s.%s' references invalid table(s) or column" +
+ "(s) or function(s) or definer/invoker of view lack rights to use them"),
+ ERR_SP_NO_DROP_SP(1357, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't drop or alter a %s from within another stored" +
+ " routine"),
+ ERR_SP_GOTO_IN_HNDLR(1358, new byte[]{'H', 'Y', '0', '0', '0'}, "GOTO is not allowed in a stored procedure " +
+ "handler"),
+ ERR_TRG_ALREADY_EXISTS(1359, new byte[]{'H', 'Y', '0', '0', '0'}, "Trigger already exists"),
+ ERR_TRG_DOES_NOT_EXIST(1360, new byte[]{'H', 'Y', '0', '0', '0'}, "Trigger does not exist"),
+ ERR_TRG_ON_VIEW_OR_TEMP_TABLE(1361, new byte[]{'H', 'Y', '0', '0', '0'}, "Trigger's '%s' is view or temporary " +
+ "table"),
+ ERR_TRG_CANT_CHANGE_ROW(1362, new byte[]{'H', 'Y', '0', '0', '0'}, "Updating of %s row is not allowed in " +
+ "%strigger"),
+ ERR_TRG_NO_SUCH_ROW_IN_TRG(1363, new byte[]{'H', 'Y', '0', '0', '0'}, "There is no %s row in %s trigger"),
+ ERR_NO_DEFAULT_FOR_FIELD(1364, new byte[]{'H', 'Y', '0', '0', '0'}, "Field '%s' doesn't have a default value"),
+ ERR_DIVISION_BY_ZER(1365, new byte[]{'2', '2', '0', '1', '2'}, "Division by 0"),
+ ERR_TRUNCATED_WRONG_VALUE_FOR_FIELD(1366, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect %s value: '%s' for " +
+ "column '%s' at row %ld"),
+ ERR_ILLEGAL_VALUE_FOR_TYPE(1367, new byte[]{'2', '2', '0', '0', '7'}, "Illegal %s '%s' value found during parsing"),
+ ERR_VIEW_NONUPD_CHECK(1368, new byte[]{'H', 'Y', '0', '0', '0'}, "CHECK OPTION on non-updatable view '%s.%s'"),
+ ERR_VIEW_CHECK_FAILED(1369, new byte[]{'H', 'Y', '0', '0', '0'}, "CHECK OPTION failed '%s.%s'"),
+ ERR_PROCACCESS_DENIED_ERROR(1370, new byte[]{'4', '2', '0', '0', '0'}, "%s command denied to user '%s'@'%s' for " +
+ "routine '%s'"),
+ ERR_RELAY_LOG_FAIL(1371, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed purging old relay logs: %s"),
+ ERR_PASSWD_LENGTH(1372, new byte[]{'H', 'Y', '0', '0', '0'}, "Password hash should be a %d-digit hexadecimal " +
+ "number"),
+ ERR_UNKNOWN_TARGET_BINLOG(1373, new byte[]{'H', 'Y', '0', '0', '0'}, "Target log not found in binlog index"),
+ ERR_IO_ERR_LOG_INDEX_READ(1374, new byte[]{'H', 'Y', '0', '0', '0'}, "I/O error reading log index file"),
+ ERR_BINLOG_PURGE_PROHIBITED(1375, new byte[]{'H', 'Y', '0', '0', '0'}, "Server configuration does not permit " +
+ "binlog purge"),
+ ERR_FSEEK_FAIL(1376, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed on fseek()"),
+ ERR_BINLOG_PURGE_FATAL_ERR(1377, new byte[]{'H', 'Y', '0', '0', '0'}, "Fatal error during log purge"),
+ ERR_LOG_IN_USE(1378, new byte[]{'H', 'Y', '0', '0', '0'}, "A purgeable log is in use, will not purge"),
+ ERR_LOG_PURGE_UNKNOWN_ERR(1379, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown error during log purge"),
+ ERR_RELAY_LOG_INIT(1380, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed initializing relay log position: %s"),
+ ERR_NO_BINARY_LOGGING(1381, new byte[]{'H', 'Y', '0', '0', '0'}, "You are not using binary logging"),
+ ERR_RESERVED_SYNTAX(1382, new byte[]{'H', 'Y', '0', '0', '0'}, "The '%s' syntax is reserved for purposes internal" +
+ " to the MariaDB server"),
+ ERR_WSAS_FAILED(1383, new byte[]{'H', 'Y', '0', '0', '0'}, "WSAStartup Failed"),
+ ERR_DIFF_GROUPS_PROC(1384, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't handle procedures with different groups " +
+ "yet"),
+ ERR_NO_GROUP_FOR_PROC(1385, new byte[]{'H', 'Y', '0', '0', '0'}, "Select must have a group with this procedure"),
+ ERR_ORDER_WITH_PROC(1386, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't use ORDER clause with this procedure"),
+ ERR_LOGGING_PROHIBIT_CHANGING_OF(1387, new byte[]{'H', 'Y', '0', '0', '0'}, "Binary logging and replication " +
+ "forbid changing the global server %s"),
+ ERR_NO_FILE_MAPPING(1388, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't map file: %s, errno: %d"),
+ ERR_WRONG_MAGIC(1389, new byte[]{'H', 'Y', '0', '0', '0'}, "Wrong magic in %s"),
+ ERR_PS_MANY_PARAM(1390, new byte[]{'H', 'Y', '0', '0', '0'}, "Prepared statement contains too many placeholders"),
+ ERR_KEY_PART_0(1391, new byte[]{'H', 'Y', '0', '0', '0'}, "Key part '%s' length cannot be 0"),
+ ERR_VIEW_CHECKSUM(1392, new byte[]{'H', 'Y', '0', '0', '0'}, "View text checksum failed"),
+ ERR_VIEW_MULTIUPDATE(1393, new byte[]{'H', 'Y', '0', '0', '0'}, "Can not modify more than one base table through " +
+ "a join view '%s.%s'"),
+ ERR_VIEW_NO_INSERT_FIELD_LIST(1394, new byte[]{'H', 'Y', '0', '0', '0'}, "Can not insert into join view '%s.%s' " +
+ "without fields list"),
+ ERR_VIEW_DELETE_MERGE_VIEW(1395, new byte[]{'H', 'Y', '0', '0', '0'}, "Can not delete from join view '%s.%s'"),
+ ERR_CANNOT_USER(1396, new byte[]{'H', 'Y', '0', '0', '0'}, "Operation %s failed for %s"),
+ ERR_XAER_NOTA(1397, new byte[]{'X', 'A', 'E', '0', '4'}, "XAER_NOTA: Unknown XID"),
+ ERR_XAER_INVAL(1398, new byte[]{'X', 'A', 'E', '0', '5'}, "XAER_INVAL: Invalid arguments (or unsupported command)"),
+ ERR_XAER_RMFAIL(1399, new byte[]{'X', 'A', 'E', '0', '7'}, "XAER_RMFAIL: The command cannot be executed when " +
+ "global transaction is in the %s state"),
+ ERR_XAER_OUTSIDE(1400, new byte[]{'X', 'A', 'E', '0', '9'}, "XAER_OUTSIDE: Some work is done outside global " +
+ "transaction"),
+ ERR_XAER_RMERR(1401, new byte[]{'X', 'A', 'E', '0', '3'}, "XAER_RMERR: Fatal error occurred in the transaction " +
+ "branch - check your data for consistency"),
+ ERR_XA_RBROLLBACK(1402, new byte[]{'X', 'A', '1', '0', '0'}, "XA_RBROLLBACK: Transaction branch was rolled back"),
+ ERR_NONEXISTING_PROC_GRANT(1403, new byte[]{'4', '2', '0', '0', '0'}, "There is no such grant defined for user " +
+ "'%s' on host '%s' on routine '%s'"),
+ ERR_PROC_AUTO_GRANT_FAIL(1404, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to grant EXECUTE and ALTER ROUTINE " +
+ "privileges"),
+ ERR_PROC_AUTO_REVOKE_FAIL(1405, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to revoke all privileges to dropped " +
+ "routine"),
+ ERR_DATA_TOO_LONG(1406, new byte[]{'2', '2', '0', '0', '1'}, "Data too long for column '%s' at row %ld"),
+ ERR_SP_BAD_SQLSTATE(1407, new byte[]{'4', '2', '0', '0', '0'}, "Bad SQLSTATE: '%s'"),
+ ERR_STARTUP(1408, new byte[]{'H', 'Y', '0', '0', '0'}, "%s: ready for connections. Version: '%s' socket: '%s' " +
+ "port: %d %s"),
+ ERR_LOAD_FROM_FIXED_SIZE_ROWS_TO_VAR(1409, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't load value from file with " +
+ "fixed size rows to variable"),
+ ERR_CANT_CREATE_USER_WITH_GRANT(1410, new byte[]{'4', '2', '0', '0', '0'}, "You are not allowed to create a user " +
+ "with GRANT"),
+ ERR_WRONG_VALUE_FOR_TYPE(1411, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect %s value: '%s' for function %s"),
+ ERR_TABLE_DEF_CHANGED(1412, new byte[]{'H', 'Y', '0', '0', '0'}, "Table definition has changed, please retry " +
+ "transaction"),
+ ERR_SP_DUP_HANDLER(1413, new byte[]{'4', '2', '0', '0', '0'}, "Duplicate handler declared in the same block"),
+ ERR_SP_NOT_VAR_ARG(1414, new byte[]{'4', '2', '0', '0', '0'}, "OUT or INOUT argument %d for routine %s is not a " +
+ "variable or NEW pseudo-variable in BEFORE trigger"),
+ ERR_SP_NO_RETSET(1415, new byte[]{'0', 'A', '0', '0', '0'}, "Not allowed to return a result set from a %s"),
+ ERR_CANT_CREATE_GEOMETRY_OBJECT(1416, new byte[]{'2', '2', '0', '0', '3'}, "Cannot get geometry object from data " +
+ "you send to the GEOMETRY field"),
+ ERR_FAILED_ROUTINE_BREAK_BINLOG(1417, new byte[]{'H', 'Y', '0', '0', '0'}, "A routine failed and has neither NO " +
+ "SQL nor READS SQL DATA in its declaration and binary logging is enabled; if non-transactional tables " +
+ "were " +
+ "updated, the binary log will miss their changes"),
+ ERR_BINLOG_UNSAFE_ROUTINE(1418, new byte[]{'H', 'Y', '0', '0', '0'}, "This function has none of DETERMINISTIC, NO" +
+ " SQL, or READS SQL DATA in its declaration and binary logging is enabled (you *might* want to use the " +
+ "less safe" +
+ " log_bin_trust_function_creators variable)"),
+ ERR_BINLOG_CREATE_ROUTINE_NEED_SUPER(1419, new byte[]{'H', 'Y', '0', '0', '0'}, "You do not have the SUPER " +
+ "privilege and binary logging is enabled (you *might* want to use the less safe " +
+ "log_bin_trust_function_creators " +
+ "variable)"),
+ ERR_EXEC_STMT_WITH_OPEN_CURSOR(1420, new byte[]{'H', 'Y', '0', '0', '0'}, "You can't execute a prepared statement" +
+ " which has an open cursor associated with it. Reset the statement to re-execute it."),
+ ERR_STMT_HAS_NO_OPEN_CURSOR(1421, new byte[]{'H', 'Y', '0', '0', '0'}, "The statement (%lu) has no open cursor."),
+ ERR_COMMIT_NOT_ALLOWED_IN_SF_OR_TRG(1422, new byte[]{'H', 'Y', '0', '0', '0'}, "Explicit or implicit commit is " +
+ "not allowed in stored function or trigger."),
+ ERR_NO_DEFAULT_FOR_VIEW_FIELD(1423, new byte[]{'H', 'Y', '0', '0', '0'}, "Field of view '%s.%s' underlying table " +
+ "doesn't have a default value"),
+ ERR_SP_NO_RECURSION(1424, new byte[]{'H', 'Y', '0', '0', '0'}, "Recursive stored functions and triggers are not " +
+ "allowed."),
+ ERR_TOO_BIG_SCALE(1425, new byte[]{'4', '2', '0', '0', '0'}, "Too big scale %d specified for column '%s'. Maximum" +
+ " is %lu."),
+ ERR_TOO_BIG_PRECISION(1426, new byte[]{'4', '2', '0', '0', '0'}, "Too big precision %d specified for column '%s'." +
+ " Maximum is %lu."),
+ ERR_M_BIGGER_THAN_D(1427, new byte[]{'4', '2', '0', '0', '0'}, "For float(M,D, double(M,D or decimal(M,D, M must " +
+ "be >= D (column '%s')."),
+ ERR_WRONG_LOCK_OF_SYSTEM_TABLE(1428, new byte[]{'H', 'Y', '0', '0', '0'}, "You can't combine write-locking of " +
+ "system tables with other tables or lock types"),
+ ERR_CONNECT_TO_FOREIGN_DATA_SOURCE(1429, new byte[]{'H', 'Y', '0', '0', '0'}, "Unable to connect to foreign data " +
+ "source: %s"),
+ ERR_QUERY_ON_FOREIGN_DATA_SOURCE(1430, new byte[]{'H', 'Y', '0', '0', '0'}, "There was a problem processing the " +
+ "query on the foreign data source. Data source error: %s"),
+ ERR_FOREIGN_DATA_SOURCE_DOESNT_EXIST(1431, new byte[]{'H', 'Y', '0', '0', '0'}, "The foreign data source you are " +
+ "trying to reference does not exist. Data source error: %s"),
+ ERR_FOREIGN_DATA_STRING_INVALID_CANT_CREATE(1432, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't create federated " +
+ "table. The data source connection string '%s' is not in the correct format"),
+ ERR_FOREIGN_DATA_STRING_INVALID(1433, new byte[]{'H', 'Y', '0', '0', '0'}, "The data source connection string " +
+ "'%s' is not in the correct format"),
+ ERR_CANT_CREATE_FEDERATED_TABLE(1434, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't create federated table. Foreign" +
+ " data src error: %s"),
+ ERR_TRG_IN_WRONG_SCHEMA(1435, new byte[]{'H', 'Y', '0', '0', '0'}, "Trigger in wrong schema"),
+ ERR_STACK_OVERRUN_NEED_MORE(1436, new byte[]{'H', 'Y', '0', '0', '0'}, "Thread stack overrun: %ld bytes used of a" +
+ " %ld byte stack, and %ld bytes needed. Use 'mysqld --thread_stack=#' to specify a bigger stack."),
+ ERR_TOO_LONG_BODY(1437, new byte[]{'4', '2', '0', '0', '0'}, "Routine body for '%s' is too long"),
+ ERR_WARN_CANT_DROP_DEFAULT_KEYCACHE(1438, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot drop default keycache"),
+ ERR_TOO_BIG_DISPLAYWIDTH(1439, new byte[]{'4', '2', '0', '0', '0'}, "Display width out of range for column '%s' " +
+ "(max = %lu)"),
+ ERR_XAER_DUPID(1440, new byte[]{'X', 'A', 'E', '0', '8'}, "XAER_DUPID: The XID already exists"),
+ ERR_DATETIME_FUNCTION_OVERFLOW(1441, new byte[]{'2', '2', '0', '0', '8'}, "Datetime function: %s field overflow"),
+ ERR_CANT_UPDATE_USED_TABLE_IN_SF_OR_TRG(1442, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't update table '%s' in " +
+ "stored function/trigger because it is already used by statement which invoked this stored " +
+ "function/trigger."),
+ ERR_VIEW_PREVENT_UPDATE(1443, new byte[]{'H', 'Y', '0', '0', '0'}, "The definition of table '%s' prevents " +
+ "operation %s on table '%s'."),
+ ERR_PS_NO_RECURSION(1444, new byte[]{'H', 'Y', '0', '0', '0'}, "The prepared statement contains a stored routine " +
+ "call that refers to that same statement. It's not allowed to execute a prepared statement in such a " +
+ "recursive " +
+ "manner"),
+ ERR_SP_CANT_SET_AUTOCOMMIT(1445, new byte[]{'H', 'Y', '0', '0', '0'}, "Not allowed to set autocommit from a " +
+ "stored function or trigger"),
+ ERR_MALFORMED_DEFINER(1446, new byte[]{'H', 'Y', '0', '0', '0'}, "Definer is not fully qualified"),
+ ERR_VIEW_FRM_NO_USER(1447, new byte[]{'H', 'Y', '0', '0', '0'}, "View '%s'.'%s' has no definer information (old " +
+ "table format). Current user is used as definer. Please recreate the view!"),
+ ERR_VIEW_OTHER_USER(1448, new byte[]{'H', 'Y', '0', '0', '0'}, "You need the SUPER privilege for creation view " +
+ "with '%s'@'%s' definer"),
+ ERR_NO_SUCH_USER(1449, new byte[]{'H', 'Y', '0', '0', '0'}, "The user specified as a definer ('%s'@'%s') does not" +
+ " exist"),
+ ERR_FORBID_SCHEMA_CHANGE(1450, new byte[]{'H', 'Y', '0', '0', '0'}, "Changing schema from '%s' to '%s' is not " +
+ "allowed."),
+ ERR_ROW_IS_REFERENCED_2(1451, new byte[]{'2', '3', '0', '0', '0'}, "Cannot delete or update a parent row: a " +
+ "foreign key constraint fails (%s)"),
+ ERR_NO_REFERENCED_ROW_2(1452, new byte[]{'2', '3', '0', '0', '0'}, "Cannot add or update a child row: a foreign " +
+ "key constraint fails (%s)"),
+ ERR_SP_BAD_VAR_SHADOW(1453, new byte[]{'4', '2', '0', '0', '0'}, "Variable '%s' must be quoted with `...`, or " +
+ "renamed"),
+ ERR_TRG_NO_DEFINER(1454, new byte[]{'H', 'Y', '0', '0', '0'}, "No definer attribute for trigger '%s'.'%s'. The " +
+ "trigger will be activated under the authorization of the invoker, which may have insufficient privileges" +
+ ". " +
+ "Please recreate the trigger."),
+ ERR_OLD_FILE_FORMAT(1455, new byte[]{'H', 'Y', '0', '0', '0'}, "'%s' has an old format, you should re-create the " +
+ "'%s' object(s)"),
+ ERR_SP_RECURSION_LIMIT(1456, new byte[]{'H', 'Y', '0', '0', '0'}, "Recursive limit %d (as set by the " +
+ "max_sp_recursion_depth variable) was exceeded for routine %s"),
+ ERR_SP_PROC_TABLE_CORRUPT(1457, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to load routine %s. The table mysql" +
+ ".proc is missing, corrupt, or contains bad data (internal code %d)"),
+ ERR_SP_WRONG_NAME(1458, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect routine name '%s'"),
+ ERR_TABLE_NEEDS_UPGRADE(1459, new byte[]{'H', 'Y', '0', '0', '0'}, "Table upgrade required. Please do \"REPAIR " +
+ "TABLE `%s`\" or dump/reload to fix it!"),
+ ERR_SP_NO_AGGREGATE(1460, new byte[]{'4', '2', '0', '0', '0'}, "AGGREGATE is not supported for stored functions"),
+ ERR_MAX_PREPARED_STMT_COUNT_REACHED(1461, new byte[]{'4', '2', '0', '0', '0'}, "Can't create more than " +
+ "max_prepared_stmt_count statements (current value: %lu)"),
+ ERR_VIEW_RECURSIVE(1462, new byte[]{'H', 'Y', '0', '0', '0'}, "`%s`.`%s` contains view recursion"),
+ ERR_NON_GROUPING_FIELD_USED(1463, new byte[]{'4', '2', '0', '0', '0'}, "Non-grouping field '%s' is used in %s " +
+ "clause"),
+ ERR_TABLE_CANT_HANDLE_SPKEYS(1464, new byte[]{'H', 'Y', '0', '0', '0'}, "The used table type doesn't support " +
+ "SPATIAL indexes"),
+ ERR_NO_TRIGGERS_ON_SYSTEM_SCHEMA(1465, new byte[]{'H', 'Y', '0', '0', '0'}, "Triggers can not be created on " +
+ "system tables"),
+ ERR_REMOVED_SPACES(1466, new byte[]{'H', 'Y', '0', '0', '0'}, "Leading spaces are removed from name '%s'"),
+ ERR_AUTOINC_READ_FAILED(1467, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to read auto-increment value from " +
+ "storage engine"),
+ ERR_USERNAME(1468, new byte[]{'H', 'Y', '0', '0', '0'}, "user name"),
+ ERR_HOSTNAME(1469, new byte[]{'H', 'Y', '0', '0', '0'}, "host name"),
+ ERR_WRONG_STRING_LENGTH(1470, new byte[]{'H', 'Y', '0', '0', '0'}, "String '%s' is too long for %s (should be no " +
+ "longer than %d)"),
+ ERR_NON_INSERTABLE_TABLE(1471, new byte[]{'H', 'Y', '0', '0', '0'}, "The target table %s of the %s is not " +
+ "insertable-into"),
+ ERR_ADMIN_WRONG_MRG_TABLE(1472, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s' is differently defined or of " +
+ "non-MyISAM type or doesn't exist"),
+ ERR_TOO_HIGH_LEVEL_OF_NESTING_FOR_SELECT(1473, new byte[]{'H', 'Y', '0', '0', '0'}, "Too high level of nesting " +
+ "for select"),
+ ERR_NAME_BECOMES_EMPTY(1474, new byte[]{'H', 'Y', '0', '0', '0'}, "Name '%s' has become ''"),
+ ERR_AMBIGUOUS_FIELD_TERM(1475, new byte[]{'H', 'Y', '0', '0', '0'}, "First character of the FIELDS TERMINATED " +
+ "string is ambiguous; please use non-optional and non-empty FIELDS ENCLOSED BY"),
+ ERR_FOREIGN_SERVER_EXISTS(1476, new byte[]{'H', 'Y', '0', '0', '0'}, "The foreign server, %s, you are trying to " +
+ "create already exists."),
+ ERR_FOREIGN_SERVER_DOESNT_EXIST(1477, new byte[]{'H', 'Y', '0', '0', '0'}, "The foreign server name you are " +
+ "trying to reference does not exist. Data source error: %s"),
+ ERR_ILLEGAL_HA_CREATE_OPTION(1478, new byte[]{'H', 'Y', '0', '0', '0'}, "Table storage engine '%s' does not " +
+ "support the create option '%s'"),
+ ERR_PARTITION_REQUIRES_VALUES_ERROR(1479, new byte[]{'H', 'Y', '0', '0', '0'}, "Syntax error: %s PARTITIONING " +
+ "requires definition of VALUES %s for each partition"),
+ ERR_PARTITION_WRONG_VALUES_ERROR(1480, new byte[]{'H', 'Y', '0', '0', '0'}, "Only %s PARTITIONING can use VALUES " +
+ "%s in partition definition"),
+ ERR_PARTITION_MAXVALUE_ERROR(1481, new byte[]{'H', 'Y', '0', '0', '0'}, "MAXVALUE can only be used in last " +
+ "partition definition"),
+ ERR_PARTITION_SUBPARTITION_ERROR(1482, new byte[]{'H', 'Y', '0', '0', '0'}, "Subpartitions can only be hash " +
+ "partitions and by key"),
+ ERR_PARTITION_SUBPART_MIX_ERROR(1483, new byte[]{'H', 'Y', '0', '0', '0'}, "Must define subpartitions on all " +
+ "partitions if on one partition"),
+ ERR_PARTITION_WRONG_NO_PART_ERROR(1484, new byte[]{'H', 'Y', '0', '0', '0'}, "Wrong number of partitions defined," +
+ " mismatch with previous setting"),
+ ERR_PARTITION_WRONG_NO_SUBPART_ERROR(1485, new byte[]{'H', 'Y', '0', '0', '0'}, "Wrong number of subpartitions " +
+ "defined, mismatch with previous setting"),
+ ERR_CONST_EXPR_IN_PARTITION_FUNC_ERROR(1486, new byte[]{'H', 'Y', '0', '0', '0'}, "Constant/Random expression in " +
+ "(sub)partitioning function is not allowed"),
+ ERR_WRONG_EXPR_IN_PARTITION_FUNC_ERROR(1486, new byte[]{'H', 'Y', '0', '0', '0'}, "Constant, random or " +
+ "timezone-dependent expressions in (sub)partitioning function are not allowed"),
+ ERR_NO_CONST_EXPR_IN_RANGE_OR_LIST_ERROR(1487, new byte[]{'H', 'Y', '0', '0', '0'}, "Expression in RANGE/LIST " +
+ "VALUES must be constant"),
+ ERR_FIELD_NOT_FOUND_PART_ERROR(1488, new byte[]{'H', 'Y', '0', '0', '0'}, "Field in list of fields for partition " +
+ "function not found in table"),
+ ERR_LIST_OF_FIELDS_ONLY_IN_HASH_ERROR(1489, new byte[]{'H', 'Y', '0', '0', '0'}, "List of fields is only allowed " +
+ "in KEY partitions"),
+ ERR_INCONSISTENT_PARTITION_INFO_ERROR(1490, new byte[]{'H', 'Y', '0', '0', '0'}, "The partition info in the frm " +
+ "file is not consistent with what can be written into the frm file"),
+ ERR_PARTITION_FUNC_NOT_ALLOWED_ERROR(1491, new byte[]{'H', 'Y', '0', '0', '0'}, "The %s function returns the " +
+ "wrong type"),
+ ERR_PARTITIONS_MUST_BE_DEFINED_ERROR(1492, new byte[]{'H', 'Y', '0', '0', '0'}, "For %s partitions each partition" +
+ " must be defined"),
+ ERR_RANGE_NOT_INCREASING_ERROR(1493, new byte[]{'H', 'Y', '0', '0', '0'}, "VALUES LESS THAN value must be " +
+ "strictly increasing for each partition"),
+ ERR_INCONSISTENT_TYPE_OF_FUNCTIONS_ERROR(1494, new byte[]{'H', 'Y', '0', '0', '0'}, "VALUES value must be of same" +
+ " type as partition function"),
+ ERR_MULTIPLE_DEF_CONST_IN_LIST_PART_ERROR(1495, new byte[]{'H', 'Y', '0', '0', '0'}, "Multiple definition of same" +
+ " constant in list partitioning"),
+ ERR_PARTITION_ENTRY_ERROR(1496, new byte[]{'H', 'Y', '0', '0', '0'}, "Partitioning can not be used stand-alone in" +
+ " query"),
+ ERR_MIX_HANDLER_ERROR(1497, new byte[]{'H', 'Y', '0', '0', '0'}, "The mix of handlers in the partitions is not " +
+ "allowed in this version of MariaDB"),
+ ERR_PARTITION_NOT_DEFINED_ERROR(1498, new byte[]{'H', 'Y', '0', '0', '0'}, "For the partitioned engine it is " +
+ "necessary to define all %s"),
+ ERR_TOO_MANY_PARTITIONS_ERROR(1499, new byte[]{'H', 'Y', '0', '0', '0'}, "Too many partitions (including " +
+ "subpartitions) were defined"),
+ ERR_SUBPARTITION_ERROR(1500, new byte[]{'H', 'Y', '0', '0', '0'}, "It is only possible to mix RANGE/LIST " +
+ "partitioning with HASH/KEY partitioning for subpartitioning"),
+ ERR_CANT_CREATE_HANDLER_FILE(1501, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to create specific handler file"),
+ ERR_BLOB_FIELD_IN_PART_FUNC_ERROR(1502, new byte[]{'H', 'Y', '0', '0', '0'}, "A BLOB field is not allowed in " +
+ "partition function"),
+ ERR_UNIQUE_KEY_NEED_ALL_FIELDS_IN_PF(1503, new byte[]{'H', 'Y', '0', '0', '0'}, "A %s must include all columns in" +
+ " the table's partitioning function"),
+ ERR_NO_PARTS_ERROR(1504, new byte[]{'H', 'Y', '0', '0', '0'}, "Number of %s = 0 is not an allowed value"),
+ ERR_PARTITION_MGMT_ON_NONPARTITIONED(1505, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition management on a not " +
+ "partitioned table is not possible"),
+ ERR_FOREIGN_KEY_ON_PARTITIONED(1506, new byte[]{'H', 'Y', '0', '0', '0'}, "Foreign key clause is not yet " +
+ "supported in conjunction with partitioning"),
+ ERR_DROP_PARTITION_NON_EXISTENT(1507, new byte[]{'H', 'Y', '0', '0', '0'}, "Error in list of partitions to %s"),
+ ERR_DROP_LAST_PARTITION(1508, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot remove all partitions, use DROP TABLE " +
+ "instead"),
+ ERR_COALESCE_ONLY_ON_HASH_PARTITION(1509, new byte[]{'H', 'Y', '0', '0', '0'}, "COALESCE PARTITION can only be " +
+ "used on HASH/KEY partitions"),
+ ERR_REORG_HASH_ONLY_ON_SAME_N(1510, new byte[]{'H', 'Y', '0', '0', '0'}, "REORGANIZE PARTITION can only be used " +
+ "to reorganize partitions not to change their numbers"),
+ ERR_REORG_NO_PARAM_ERROR(1511, new byte[]{'H', 'Y', '0', '0', '0'}, "REORGANIZE PARTITION without parameters can " +
+ "only be used on auto-partitioned tables using HASH PARTITIONs"),
+ ERR_ONLY_ON_RANGE_LIST_PARTITION(1512, new byte[]{'H', 'Y', '0', '0', '0'}, "%s PARTITION can only be used on " +
+ "RANGE/LIST partitions"),
+ ERR_ADD_PARTITION_SUBPART_ERROR(1513, new byte[]{'H', 'Y', '0', '0', '0'}, "Trying to Add partition(s) with wrong" +
+ " number of subpartitions"),
+ ERR_ADD_PARTITION_NO_NEW_PARTITION(1514, new byte[]{'H', 'Y', '0', '0', '0'}, "At least one partition must be " +
+ "added"),
+ ERR_COALESCE_PARTITION_NO_PARTITION(1515, new byte[]{'H', 'Y', '0', '0', '0'}, "At least one partition must be " +
+ "coalesced"),
+ ERR_REORG_PARTITION_NOT_EXIST(1516, new byte[]{'H', 'Y', '0', '0', '0'}, "More partitions to reorganize than " +
+ "there are partitions"),
+ ERR_SAME_NAME_PARTITION(1517, new byte[]{'H', 'Y', '0', '0', '0'}, "Duplicate partition name %s"),
+ ERR_NO_BINLOG_ERROR(1518, new byte[]{'H', 'Y', '0', '0', '0'}, "It is not allowed to shut off binlog on this " +
+ "command"),
+ ERR_CONSECUTIVE_REORG_PARTITIONS(1519, new byte[]{'H', 'Y', '0', '0', '0'}, "When reorganizing a set of " +
+ "partitions they must be in consecutive order"),
+ ERR_REORG_OUTSIDE_RANGE(1520, new byte[]{'H', 'Y', '0', '0', '0'}, "Reorganize of range partitions cannot change " +
+ "total ranges except for last partition where it can extend the range"),
+ ERR_PARTITION_FUNCTION_FAILURE(1521, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition function not supported in " +
+ "this version for this handler"),
+ ERR_PART_STATE_ERROR(1522, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition state cannot be defined from " +
+ "CREATE/ALTER TABLE"),
+ ERR_LIMITED_PART_RANGE(1523, new byte[]{'H', 'Y', '0', '0', '0'}, "The %s handler only supports 32 bit integers " +
+ "in VALUES"),
+ ERR_PLUGIN_IS_NOT_LOADED(1524, new byte[]{'H', 'Y', '0', '0', '0'}, "Plugin '%s' is not loaded"),
+ ERR_WRONG_VALUE(1525, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect %s value: '%s'"),
+ ERR_NO_PARTITION_FOR_GIVEN_VALUE(1526, new byte[]{'H', 'Y', '0', '0', '0'}, "Table has no partition for value %s"),
+ ERR_FILEGROUP_OPTION_ONLY_ONCE(1527, new byte[]{'H', 'Y', '0', '0', '0'}, "It is not allowed to specify %s more " +
+ "than once"),
+ ERR_CREATE_FILEGROUP_FAILED(1528, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to create %s"),
+ ERR_DROP_FILEGROUP_FAILED(1529, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to drop %s"),
+ ERR_TABLESPACE_AUTO_EXTEND_ERROR(1530, new byte[]{'H', 'Y', '0', '0', '0'}, "The handler doesn't support " +
+ "autoextend of tablespaces"),
+ ERR_WRONG_SIZE_NUMBER(1531, new byte[]{'H', 'Y', '0', '0', '0'}, "A size parameter was incorrectly specified, " +
+ "either number or on the form 10M"),
+ ERR_SIZE_OVERFLOW_ERROR(1532, new byte[]{'H', 'Y', '0', '0', '0'}, "The size number was correct but we don't " +
+ "allow the digit part to be more than 2 billion"),
+ ERR_ALTER_FILEGROUP_FAILED(1533, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to alter: %s"),
+ ERR_BINLOG_ROW_LOGGING_FAILED(1534, new byte[]{'H', 'Y', '0', '0', '0'}, "Writing one row to the row-based binary" +
+ " log failed"),
+ ERR_BINLOG_ROW_WRONG_TABLE_DEF(1535, new byte[]{'H', 'Y', '0', '0', '0'}, "Table definition on master and slave " +
+ "does not match: %s"),
+ ERR_BINLOG_ROW_RBR_TO_SBR(1536, new byte[]{'H', 'Y', '0', '0', '0'}, "Slave running with --log-slave-updates must" +
+ " use row-based binary logging to be able to replicate row-based binary log events"),
+ ERR_EVENT_ALREADY_EXISTS(1537, new byte[]{'H', 'Y', '0', '0', '0'}, "Event '%s' already exists"),
+ ERR_EVENT_STORE_FAILED(1538, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to store event %s. Error code %d from " +
+ "storage engine."),
+ ERR_EVENT_DOES_NOT_EXIST(1539, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown event '%s'"),
+ ERR_EVENT_CANT_ALTER(1540, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to alter event '%s'"),
+ ERR_EVENT_DROP_FAILED(1541, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to drop %s"),
+ ERR_EVENT_INTERVAL_NOT_POSITIVE_OR_TOO_BIG(1542, new byte[]{'H', 'Y', '0', '0', '0'}, "INTERVAL is either not " +
+ "positive or too big"),
+ ERR_EVENT_ENDS_BEFORE_STARTS(1543, new byte[]{'H', 'Y', '0', '0', '0'}, "ENDS is either invalid or before STARTS"),
+ ERR_EVENT_EXEC_TIME_IN_THE_PAST(1544, new byte[]{'H', 'Y', '0', '0', '0'}, "Event execution time is in the past. " +
+ "Event has been disabled"),
+ ERR_EVENT_OPEN_TABLE_FAILED(1545, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to open mysql.event"),
+ ERR_EVENT_NEITHER_M_EXPR_NOR_M_AT(1546, new byte[]{'H', 'Y', '0', '0', '0'}, "No datetime expression provided"),
+ ERR_COL_COUNT_DOESNT_MATCH_CORRUPTED(1547, new byte[]{'H', 'Y', '0', '0', '0'}, "Column count of mysql.%s is " +
+ "wrong. Expected %d, found %d. The table is probably corrupted"),
+ ERR_CANNOT_LOAD_FROM_TABLE(1548, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot load from mysql.%s. The table is " +
+ "probably corrupted"),
+ ERR_EVENT_CANNOT_DELETE(1549, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to delete the event from mysql.event"),
+ ERR_EVENT_COMPILE_ERROR(1550, new byte[]{'H', 'Y', '0', '0', '0'}, "Error during compilation of event's body"),
+ ERR_EVENT_SAME_NAME(1551, new byte[]{'H', 'Y', '0', '0', '0'}, "Same old and new event name"),
+ ERR_EVENT_DATA_TOO_LONG(1552, new byte[]{'H', 'Y', '0', '0', '0'}, "Data for column '%s' too long"),
+ ERR_DROP_INDEX_FK(1553, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot drop index '%s': needed in a foreign key " +
+ "constraint"),
+ ERR_WARN_DEPRECATED_SYNTAX_WITH_VER(1554, new byte[]{'H', 'Y', '0', '0', '0'}, "The syntax '%s' is deprecated and" +
+ " will be removed in MariaDB %s. Please use %s instead"),
+ ERR_CANT_WRITE_LOCK_LOG_TABLE(1555, new byte[]{'H', 'Y', '0', '0', '0'}, "You can't write-lock a log table. Only " +
+ "read access is possible"),
+ ERR_CANT_LOCK_LOG_TABLE(1556, new byte[]{'H', 'Y', '0', '0', '0'}, "You can't use locks with log tables."),
+ ERR_FOREIGN_DUPLICATE_KEY(1557, new byte[]{'2', '3', '0', '0', '0'}, "Upholding foreign key constraints for table" +
+ " '%s', entry '%s', key %d would lead to a duplicate entry"),
+ ERR_COL_COUNT_DOESNT_MATCH_PLEASE_UPDATE(1558, new byte[]{'H', 'Y', '0', '0', '0'}, "Column count of mysql.%s is " +
+ "wrong. Expected %d, found %d. Created with MariaDB %d, now running %d. Please use mysql_upgrade to fix " +
+ "this " +
+ "error."),
+ ERR_TEMP_TABLE_PREVENTS_SWITCH_OUT_OF_RBR(1559, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot switch out of the " +
+ "row-based binary log format when the session has open temporary tables"),
+ ERR_STORED_FUNCTION_PREVENTS_SWITCH_BINLOG_FORMAT(1560, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot change the " +
+ "binary logging format inside a stored function or trigger"),
+ ERR_UNUSED_13(1561, new byte[]{}, "You should never see it"),
+ ERR_PARTITION_NO_TEMPORARY(1562, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot create temporary table with " +
+ "partitions"),
+ ERR_PARTITION_CONST_DOMAIN_ERROR(1563, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition constant is out of " +
+ "partition function domain"),
+ ERR_PARTITION_FUNCTION_IS_NOT_ALLOWED(1564, new byte[]{'H', 'Y', '0', '0', '0'}, "This partition function is not " +
+ "allowed"),
+ ERR_DDL_LOG_ERROR(1565, new byte[]{'H', 'Y', '0', '0', '0'}, "Error in DDL log"),
+ ERR_NULL_IN_VALUES_LESS_THAN(1566, new byte[]{'H', 'Y', '0', '0', '0'}, "Not allowed to use NULL value in VALUES " +
+ "LESS THAN"),
+ ERR_WRONG_PARTITION_NAME(1567, new byte[]{'H', 'Y', '0', '0', '0'}, "Incorrect partition name"),
+ ERR_CANT_CHANGE_TX_ISOLATION(1568, new byte[]{'2', '5', '0', '0', '1'}, "Transaction isolation level can't be " +
+ "changed while a transaction is in progress"),
+ ERR_DUP_ENTRY_AUTOINCREMENT_CASE(1569, new byte[]{'H', 'Y', '0', '0', '0'}, "ALTER TABLE causes auto_increment " +
+ "resequencing, resulting in duplicate entry '%s' for key '%s'"),
+ ERR_EVENT_MODIFY_QUEUE_ERROR(1570, new byte[]{'H', 'Y', '0', '0', '0'}, "Internal scheduler error %d"),
+ ERR_EVENT_SET_VAR_ERROR(1571, new byte[]{'H', 'Y', '0', '0', '0'}, "Error during starting/stopping of the " +
+ "scheduler. Error code %u"),
+ ERR_PARTITION_MERGE_ERROR(1572, new byte[]{'H', 'Y', '0', '0', '0'}, "Engine cannot be used in partitioned tables"),
+ ERR_CANT_ACTIVATE_LOG(1573, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot activate '%s' log"),
+ ERR_RBR_NOT_AVAILABLE(1574, new byte[]{'H', 'Y', '0', '0', '0'}, "The server was not built with row-based " +
+ "replication"),
+ ERR_BASE64_DECODE_ERROR(1575, new byte[]{'H', 'Y', '0', '0', '0'}, "Decoding of base64 string failed"),
+ ERR_EVENT_RECURSION_FORBIDDEN(1576, new byte[]{'H', 'Y', '0', '0', '0'}, "Recursion of EVENT DDL statements is " +
+ "forbidden when body is present"),
+ ERR_EVENTS_DB_ERROR(1577, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot proceed because system tables used by " +
+ "Event Scheduler were found damaged at server start"),
+ ERR_ONLY_INTEGERS_ALLOWED(1578, new byte[]{'H', 'Y', '0', '0', '0'}, "Only integers allowed as number here"),
+ ERR_UNSUPORTED_LOG_ENGINE(1579, new byte[]{'H', 'Y', '0', '0', '0'}, "This storage engine cannot be used for log " +
+ "tables"),
+ ERR_BAD_LOG_STATEMENT(1580, new byte[]{'H', 'Y', '0', '0', '0'}, "You cannot '%s' a log table if logging is " +
+ "enabled"),
+ ERR_CANT_RENAME_LOG_TABLE(1581, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot rename '%s'. When logging enabled, " +
+ "rename to/from log table must rename two tables: the log table to an archive table and another table " +
+ "back to " +
+ "'%s'"),
+ ERR_WRONG_PARAMCOUNT_TO_NATIVE_FCT(1582, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect parameter count in the " +
+ "call to native function '%s'"),
+ ERR_WRONG_PARAMETERS_TO_NATIVE_FCT(1583, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect parameters in the call " +
+ "to native function '%s'"),
+ ERR_WRONG_PARAMETERS_TO_STORED_FCT(1584, new byte[]{'4', '2', '0', '0', '0'}, "Incorrect parameters in the call " +
+ "to stored function '%s'"),
+ ERR_NATIVE_FCT_NAME_COLLISION(1585, new byte[]{'H', 'Y', '0', '0', '0'}, "This function '%s' has the same name as" +
+ " a native function"),
+ ERR_DUP_ENTRY_WITH_KEY_NAME(1586, new byte[]{'2', '3', '0', '0', '0'}, "Duplicate entry '%s' for key '%s'"),
+ ERR_BINLOG_PURGE_EMFILE(1587, new byte[]{'H', 'Y', '0', '0', '0'}, "Too many files opened, please execute the " +
+ "command again"),
+ ERR_EVENT_CANNOT_CREATE_IN_THE_PAST(1588, new byte[]{'H', 'Y', '0', '0', '0'}, "Event execution time is in the " +
+ "past and ON COMPLETION NOT PRESERVE is set. The event was dropped immediately after creation."),
+ ERR_EVENT_CANNOT_ALTER_IN_THE_PAST(1589, new byte[]{'H', 'Y', '0', '0', '0'}, "Event execution time is in the " +
+ "past and ON COMPLETION NOT PRESERVE is set. The event was dropped immediately after creation."),
+ ERR_SLAVE_INCIDENT(1590, new byte[]{'H', 'Y', '0', '0', '0'}, "The incident %s occured on the master. Message: %s"),
+ ERR_NO_PARTITION_FOR_GIVEN_VALUE_SILENT(1591, new byte[]{'H', 'Y', '0', '0', '0'}, "Table has no partition for " +
+ "some existing values"),
+ ERR_BINLOG_UNSAFE_STATEMENT(1592, new byte[]{'H', 'Y', '0', '0', '0'}, "Unsafe statement written to the binary " +
+ "log using statement format since BINLOG_FORMAT = STATEMENT. %s"),
+ ERR_SLAVE_FATAL_ERROR(1593, new byte[]{'H', 'Y', '0', '0', '0'}, "Fatal error: %s"),
+ ERR_SLAVE_RELAY_LOG_READ_FAILURE(1594, new byte[]{'H', 'Y', '0', '0', '0'}, "Relay log read failure: %s"),
+ ERR_SLAVE_RELAY_LOG_WRITE_FAILURE(1595, new byte[]{'H', 'Y', '0', '0', '0'}, "Relay log write failure: %s"),
+ ERR_SLAVE_CREATE_EVENT_FAILURE(1596, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to create %s"),
+ ERR_SLAVE_MASTER_COM_FAILURE(1597, new byte[]{'H', 'Y', '0', '0', '0'}, "Master command %s failed: %s"),
+ ERR_BINLOG_LOGGING_IMPOSSIBLE(1598, new byte[]{'H', 'Y', '0', '0', '0'}, "Binary logging not possible. Message: " +
+ "%s"),
+ ERR_VIEW_NO_CREATION_CTX(1599, new byte[]{'H', 'Y', '0', '0', '0'}, "View `%s`.`%s` has no creation context"),
+ ERR_VIEW_INVALID_CREATION_CTX(1600, new byte[]{'H', 'Y', '0', '0', '0'}, "Creation context of view `%s`.`%s' is " +
+ "invalid"),
+ ERR_SR_INVALID_CREATION_CTX(1601, new byte[]{'H', 'Y', '0', '0', '0'}, "Creation context of stored routine `%s`" +
+ ".`%s` is invalid"),
+ ERR_TRG_CORRUPTED_FILE(1602, new byte[]{'H', 'Y', '0', '0', '0'}, "Corrupted TRG file for table `%s`.`%s`"),
+ ERR_TRG_NO_CREATION_CTX(1603, new byte[]{'H', 'Y', '0', '0', '0'}, "Triggers for table `%s`.`%s` have no creation" +
+ " context"),
+ ERR_TRG_INVALID_CREATION_CTX(1604, new byte[]{'H', 'Y', '0', '0', '0'}, "Trigger creation context of table `%s`" +
+ ".`%s` is invalid"),
+ ERR_EVENT_INVALID_CREATION_CTX(1605, new byte[]{'H', 'Y', '0', '0', '0'}, "Creation context of event `%s`.`%s` is" +
+ " invalid"),
+ ERR_TRG_CANT_OPEN_TABLE(1606, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot open table for trigger `%s`.`%s`"),
+ ERR_CANT_CREATE_SROUTINE(1607, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot create stored routine `%s`. Check " +
+ "warnings"),
+ ERR_UNUSED_11(1608, new byte[]{}, "You should never see it"),
+ ERR_NO_FORMAT_DESCRIPTION_EVENT_BEFORE_BINLOG_STATEMENT(1609, new byte[]{'H', 'Y', '0', '0', '0'}, "The BINLOG " +
+ "statement of type `%s` was not preceded by a format description BINLOG statement."),
+ ERR_SLAVE_CORRUPT_EVENT(1610, new byte[]{'H', 'Y', '0', '0', '0'}, "Corrupted replication event was detected"),
+ ERR_LOAD_DATA_INVALID_COLUMN(1611, new byte[]{'H', 'Y', '0', '0', '0'}, "Invalid column reference (%s) in LOAD " +
+ "DATA"),
+ ERR_LOG_PURGE_NO_FILE(1612, new byte[]{'H', 'Y', '0', '0', '0'}, "Being purged log %s was not found"),
+ ERR_XA_RBTIMEOUT(1613, new byte[]{'X', 'A', '1', '0', '6'}, "XA_RBTIMEOUT: Transaction branch was rolled back: " +
+ "took too long"),
+ ERR_XA_RBDEADLOCK(1614, new byte[]{'X', 'A', '1', '0', '2'}, "XA_RBDEADLOCK: Transaction branch was rolled back: " +
+ "deadlock was detected"),
+ ERR_NEED_REPREPARE(1615, new byte[]{'H', 'Y', '0', '0', '0'}, "Prepared statement needs to be re-prepared"),
+ ERR_DELAYED_NOT_SUPPORTED(1616, new byte[]{'H', 'Y', '0', '0', '0'}, "DELAYED option not supported for table '%s'"),
+ WARN_NO_MASTER_INF(1617, new byte[]{'H', 'Y', '0', '0', '0'}, "The master info structure does not exist"),
+ WARN_OPTION_IGNORED(1618, new byte[]{'H', 'Y', '0', '0', '0'}, "<%s> option ignored"),
+ WARN_PLUGIN_DELETE_BUILTIN(1619, new byte[]{'H', 'Y', '0', '0', '0'}, "Built-in plugins cannot be deleted"),
+ WARN_PLUGIN_BUSY(1620, new byte[]{'H', 'Y', '0', '0', '0'}, "Plugin is busy and will be uninstalled on shutdown"),
+ ERR_VARIABLE_IS_READONLY(1621, new byte[]{'H', 'Y', '0', '0', '0'}, "%s variable '%s' is read-only. Use SET %s to" +
+ " assign the value"),
+ ERR_WARN_ENGINE_TRANSACTION_ROLLBACK(1622, new byte[]{'H', 'Y', '0', '0', '0'}, "Storage engine %s does not " +
+ "support rollback for this statement. Transaction rolled back and must be restarted"),
+ ERR_SLAVE_HEARTBEAT_FAILURE(1623, new byte[]{'H', 'Y', '0', '0', '0'}, "Unexpected master's heartbeat data: %s"),
+ ERR_SLAVE_HEARTBEAT_VALUE_OUT_OF_RANGE(1624, new byte[]{'H', 'Y', '0', '0', '0'}, "The requested value for the " +
+ "heartbeat period is either negative or exceeds the maximum allowed (%s seconds)."),
+ ERR_UNUSED_14(1625, new byte[]{}, "You should never see it"),
+ ERR_CONFLICT_FN_PARSE_ERROR(1626, new byte[]{'H', 'Y', '0', '0', '0'}, "Error in parsing conflict function. " +
+ "Message: %s"),
+ ERR_EXCEPTIONS_WRITE_ERROR(1627, new byte[]{'H', 'Y', '0', '0', '0'}, "Write to exceptions table failed. Message:" +
+ " %s"),
+ ERR_TOO_LONG_TABLE_COMMENT(1628, new byte[]{'H', 'Y', '0', '0', '0'}, "Comment for table '%s' is too long (max = " +
+ "%lu)"),
+ ERR_TOO_LONG_FIELD_COMMENT(1629, new byte[]{'H', 'Y', '0', '0', '0'}, "Comment for field '%s' is too long (max = " +
+ "%lu)"),
+ ERR_FUNC_INEXISTENT_NAME_COLLISION(1630, new byte[]{'4', '2', '0', '0', '0'}, "FUNCTION %s does not exist. Check " +
+ "the 'Function Name Parsing and Resolution' section in the Reference Manual"),
+ ERR_DATABASE_NAME(1631, new byte[]{'H', 'Y', '0', '0', '0'}, "Database"),
+ ERR_TABLE_NAME(1632, new byte[]{'H', 'Y', '0', '0', '0'}, "Table"),
+ ERR_PARTITION_NAME(1633, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition"),
+ ERR_SUBPARTITION_NAME(1634, new byte[]{'H', 'Y', '0', '0', '0'}, "Subpartition"),
+ ERR_TEMPORARY_NAME(1635, new byte[]{'H', 'Y', '0', '0', '0'}, "Temporary"),
+ ERR_RENAMED_NAME(1636, new byte[]{'H', 'Y', '0', '0', '0'}, "Renamed"),
+ ERR_TOO_MANY_CONCURRENT_TRXS(1637, new byte[]{'H', 'Y', '0', '0', '0'}, "Too many active concurrent transactions"),
+ WARN_NON_ASCII_SEPARATOR_NOT_IMPLEMENTED(1638, new byte[]{'H', 'Y', '0', '0', '0'}, "Non-ASCII separator " +
+ "arguments are not fully supported"),
+ ERR_DEBUG_SYNC_TIMEOUT(1639, new byte[]{'H', 'Y', '0', '0', '0'}, "debug sync point wait timed out"),
+ ERR_DEBUG_SYNC_HIT_LIMIT(1640, new byte[]{'H', 'Y', '0', '0', '0'}, "debug sync point hit limit reached"),
+ ERR_DUP_SIGNAL_SET(1641, new byte[]{'4', '2', '0', '0', '0'}, "Duplicate condition information item '%s'"),
+ ERR_SIGNAL_WARN(1642, new byte[]{'0', '1', '0', '0', '0'}, "Unhandled user-defined warning condition"),
+ ERR_SIGNAL_NOT_FOUND(1643, new byte[]{'0', '2', '0', '0', '0'}, "Unhandled user-defined not found condition"),
+ ERR_SIGNAL_EXCEPTION(1644, new byte[]{'H', 'Y', '0', '0', '0'}, "Unhandled user-defined exception condition"),
+ ERR_RESIGNAL_WITHOUT_ACTIVE_HANDLER(1645, new byte[]{'0', 'K', '0', '0', '0'}, "RESIGNAL when handler not active"),
+ ERR_SIGNAL_BAD_CONDITION_TYPE(1646, new byte[]{'H', 'Y', '0', '0', '0'}, "SIGNAL/RESIGNAL can only use a " +
+ "CONDITION defined with SQLSTATE"),
+ WARN_COND_ITEM_TRUNCATED(1647, new byte[]{'H', 'Y', '0', '0', '0'}, "Data truncated for condition item '%s'"),
+ ERR_COND_ITEM_TOO_LONG(1648, new byte[]{'H', 'Y', '0', '0', '0'}, "Data too long for condition item '%s'"),
+ ERR_UNKNOWN_LOCALE(1649, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown locale: '%s'"),
+ ERR_SLAVE_IGNORE_SERVER_IDS(1650, new byte[]{'H', 'Y', '0', '0', '0'}, "The requested server id %d clashes with " +
+ "the slave startup option --replicate-same-server-id"),
+ ERR_QUERY_CACHE_DISABLED(1651, new byte[]{'H', 'Y', '0', '0', '0'}, "Query cache is disabled; restart the server " +
+ "with query_cache_type=1 to enable it"),
+ ERR_SAME_NAME_PARTITION_FIELD(1652, new byte[]{'H', 'Y', '0', '0', '0'}, "Duplicate partition field name '%s'"),
+ ERR_PARTITION_COLUMN_LIST_ERROR(1653, new byte[]{'H', 'Y', '0', '0', '0'}, "Inconsistency in usage of column " +
+ "lists for partitioning"),
+ ERR_WRONG_TYPE_COLUMN_VALUE_ERROR(1654, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition column values of " +
+ "incorrect type"),
+ ERR_TOO_MANY_PARTITION_FUNC_FIELDS_ERROR(1655, new byte[]{'H', 'Y', '0', '0', '0'}, "Too many fields in '%s'"),
+ ERR_MAXVALUE_IN_VALUES_IN(1656, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot use MAXVALUE as value in VALUES IN"),
+ ERR_TOO_MANY_VALUES_ERROR(1657, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot have more than one value for this " +
+ "type of %s partitioning"),
+ ERR_ROW_SINGLE_PARTITION_FIELD_ERROR(1658, new byte[]{'H', 'Y', '0', '0', '0'}, "Row expressions in VALUES IN " +
+ "only allowed for multi-field column partitioning"),
+ ERR_FIELD_TYPE_NOT_ALLOWED_AS_PARTITION_FIELD(1659, new byte[]{'H', 'Y', '0', '0', '0'}, "Field '%s' is of a not " +
+ "allowed type for this type of partitioning"),
+ ERR_PARTITION_FIELDS_TOO_LONG(1660, new byte[]{'H', 'Y', '0', '0', '0'}, "The total length of the partitioning " +
+ "fields is too large"),
+ ERR_BINLOG_ROW_ENGINE_AND_STMT_ENGINE(1661, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute statement: " +
+ "impossible to write to binary log since both row-incapable engines and statement-incapable engines are " +
+ "involved" +
+ "."),
+ ERR_BINLOG_ROW_MODE_AND_STMT_ENGINE(1662, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute statement: " +
+ "impossible to write to binary log since BINLOG_FORMAT = ROW and at least one table uses a storage engine" +
+ " " +
+ "limited to statement-based logging."),
+ ERR_BINLOG_UNSAFE_AND_STMT_ENGINE(1663, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute statement: " +
+ "impossible to write to binary log since statement is unsafe, storage engine is limited to " +
+ "statement-based " +
+ "logging, and BINLOG_FORMAT = MIXED. %s"),
+ ERR_BINLOG_ROW_INJECTION_AND_STMT_ENGINE(1664, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute statement: " +
+ "impossible to write to binary log since statement is in row format and at least one table uses a storage" +
+ " engine" +
+ " limited to statement-based logging."),
+ ERR_BINLOG_STMT_MODE_AND_ROW_ENGINE(1665, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute statement: " +
+ "impossible to write to binary log since BINLOG_FORMAT = STATEMENT and at least one table uses a storage " +
+ "engine " +
+ "limited to row-based logging.%s"),
+ ERR_BINLOG_ROW_INJECTION_AND_STMT_MODE(1666, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute statement: " +
+ "impossible to write to binary log since statement is in row format and BINLOG_FORMAT = STATEMENT."),
+ ERR_BINLOG_MULTIPLE_ENGINES_AND_SELF_LOGGING_ENGINE(1667, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute " +
+ "statement: impossible to write to binary log since more than one engine is involved and at least one " +
+ "engine is " +
+ "self-logging."),
+ ERR_BINLOG_UNSAFE_LIMIT(1668, new byte[]{'H', 'Y', '0', '0', '0'}, "The statement is unsafe because it uses a " +
+ "LIMIT clause. This is unsafe because the set of rows included cannot be predicted."),
+ ERR_BINLOG_UNSAFE_INSERT_DELAYED(1669, new byte[]{'H', 'Y', '0', '0', '0'}, "The statement is unsafe because it " +
+ "uses INSERT DELAYED. This is unsafe because the times when rows are inserted cannot be predicted."),
+ ERR_BINLOG_UNSAFE_SYSTEM_TABLE(1670, new byte[]{'H', 'Y', '0', '0', '0'}, "The statement is unsafe because it " +
+ "uses the general log, slow query log, or performance_schema table(s). This is unsafe because system " +
+ "tables may " +
+ "differ on slaves."),
+ ERR_BINLOG_UNSAFE_AUTOINC_COLUMNS(1671, new byte[]{'H', 'Y', '0', '0', '0'}, "Statement is unsafe because it " +
+ "invokes a trigger or a stored function that inserts into an AUTO_INCREMENT column. Inserted values " +
+ "cannot be " +
+ "logged correctly."),
+ ERR_BINLOG_UNSAFE_UDF(1672, new byte[]{'H', 'Y', '0', '0', '0'}, "Statement is unsafe because it uses a UDF which" +
+ " may not return the same value on the slave."),
+ ERR_BINLOG_UNSAFE_SYSTEM_VARIABLE(1673, new byte[]{'H', 'Y', '0', '0', '0'}, "Statement is unsafe because it uses" +
+ " a system variable that may have a different value on the slave."),
+ ERR_BINLOG_UNSAFE_SYSTEM_FUNCTION(1674, new byte[]{'H', 'Y', '0', '0', '0'}, "Statement is unsafe because it uses" +
+ " a system function that may return a different value on the slave."),
+ ERR_BINLOG_UNSAFE_NONTRANS_AFTER_TRANS(1675, new byte[]{'H', 'Y', '0', '0', '0'}, "Statement is unsafe because it" +
+ " accesses a non-transactional table after accessing a transactional table within the same transaction."),
+ ERR_MESSAGE_AND_STATEMENT(1676, new byte[]{'H', 'Y', '0', '0', '0'}, "%s Statement: %s"),
+ ERR_SLAVE_CONVERSION_FAILED(1677, new byte[]{'H', 'Y', '0', '0', '0'}, "Column %d of table '%s.%s' cannot be " +
+ "converted from type '%s' to type '%s'"),
+ ERR_SLAVE_CANT_CREATE_CONVERSION(1678, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't create conversion table for " +
+ "table '%s.%s'"),
+ ERR_INSIDE_TRANSACTION_PREVENTS_SWITCH_BINLOG_FORMAT(1679, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot modify " +
+ "@@session.binlog_format inside a transaction"),
+ ERR_PATH_LENGTH(1680, new byte[]{'H', 'Y', '0', '0', '0'}, "The path specified for %s is too long."),
+ ERR_WARN_DEPRECATED_SYNTAX_NO_REPLACEMENT(1681, new byte[]{'H', 'Y', '0', '0', '0'}, "'%s' is deprecated and will" +
+ " be removed in a future release."),
+ ERR_WRONG_NATIVE_TABLE_STRUCTURE(1682, new byte[]{'H', 'Y', '0', '0', '0'}, "Native table '%s'.'%s' has the wrong" +
+ " structure"),
+ ERR_WRONG_PERFSCHEMA_USAGE(1683, new byte[]{'H', 'Y', '0', '0', '0'}, "Invalid performance_schema usage."),
+ ERR_WARN_I_S_SKIPPED_TABLE(1684, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s'.'%s' was skipped since its " +
+ "definition is being modified by concurrent DDL statement"),
+ ERR_INSIDE_TRANSACTION_PREVENTS_SWITCH_BINLOG_DIRECT(1685, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot modify " +
+ "@@session.binlog_direct_non_transactional_updates inside a transaction"),
+ ERR_STORED_FUNCTION_PREVENTS_SWITCH_BINLOG_DIRECT(1686, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot change the " +
+ "binlog direct flag inside a stored function or trigger"),
+ ERR_SPATIAL_MUST_HAVE_GEOM_COL(1687, new byte[]{'4', '2', '0', '0', '0'}, "A SPATIAL index may only contain a " +
+ "geometrical type column"),
+ ERR_TOO_LONG_INDEX_COMMENT(1688, new byte[]{'H', 'Y', '0', '0', '0'}, "Comment for index '%s' is too long (max = " +
+ "%lu)"),
+ ERR_LOCK_ABORTED(1689, new byte[]{'H', 'Y', '0', '0', '0'}, "Wait on a lock was aborted due to a pending " +
+ "exclusive lock"),
+ ERR_DATA_OUT_OF_RANGE(1690, new byte[]{'2', '2', '0', '0', '3'}, "%s value is out of range in '%s'"),
+ ERR_WRONG_SPVAR_TYPE_IN_LIMIT(1691, new byte[]{'H', 'Y', '0', '0', '0'}, "A variable of a non-integer based type " +
+ "in LIMIT clause"),
+ ERR_BINLOG_UNSAFE_MULTIPLE_ENGINES_AND_SELF_LOGGING_ENGINE(1692, new byte[]{'H', 'Y', '0', '0', '0'}, "Mixing " +
+ "self-logging and non-self-logging engines in a statement is unsafe."),
+ ERR_BINLOG_UNSAFE_MIXED_STATEMENT(1693, new byte[]{'H', 'Y', '0', '0', '0'}, "Statement accesses nontransactional" +
+ " table as well as transactional or temporary table, and writes to any of them."),
+ ERR_INSIDE_TRANSACTION_PREVENTS_SWITCH_SQL_LOG_BIN(1694, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot modify " +
+ "@@session.sql_log_bin inside a transaction"),
+ ERR_STORED_FUNCTION_PREVENTS_SWITCH_SQL_LOG_BIN(1695, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot change the " +
+ "sql_log_bin inside a stored function or trigger"),
+ ERR_FAILED_READ_FROM_PAR_FILE(1696, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to read from the .par file"),
+ ERR_VALUES_IS_NOT_INT_TYPE_ERROR(1697, new byte[]{'H', 'Y', '0', '0', '0'}, "VALUES value for partition '%s' must" +
+ " have type INT"),
+ ERR_ACCESS_DENIED_NO_PASSWORD_ERROR(1698, new byte[]{'2', '8', '0', '0', '0'}, "Access denied for user '%s'@'%s'"),
+ ERR_SET_PASSWORD_AUTH_PLUGIN(1699, new byte[]{'H', 'Y', '0', '0', '0'}, "SET PASSWORD has no significance for " +
+ "users authenticating via plugins"),
+ ERR_GRANT_PLUGIN_USER_EXISTS(1700, new byte[]{'H', 'Y', '0', '0', '0'}, "GRANT with IDENTIFIED WITH is illegal " +
+ "because the user %-.*s already exists"),
+ ERR_TRUNCATE_ILLEGAL_FK(1701, new byte[]{'4', '2', '0', '0', '0'}, "Cannot truncate a table referenced in a " +
+ "foreign key constraint (%s)"),
+ ERR_PLUGIN_IS_PERMANENT(1702, new byte[]{'H', 'Y', '0', '0', '0'}, "Plugin '%s' is force_plus_permanent and can " +
+ "not be unloaded"),
+ ERR_SLAVE_HEARTBEAT_VALUE_OUT_OF_RANGE_MIN(1703, new byte[]{'H', 'Y', '0', '0', '0'}, "The requested value for " +
+ "the heartbeat period is less than 1 millisecond. The value is reset to 0, meaning that heartbeating will" +
+ " " +
+ "effectively be disabled."),
+ ERR_SLAVE_HEARTBEAT_VALUE_OUT_OF_RANGE_MAX(1704, new byte[]{'H', 'Y', '0', '0', '0'}, "The requested value for " +
+ "the heartbeat period exceeds the value of slave_net_timeout seconds. A sensible value for the period " +
+ "should be " +
+ "less than the timeout."),
+ ERR_STMT_CACHE_FULL(1705, new byte[]{'H', 'Y', '0', '0', '0'}, "Multi-row statements required more than " +
+ "'max_binlog_stmt_cache_size' bytes of storage; increase this mysqld variable and try again"),
+ ERR_MULTI_UPDATE_KEY_CONFLICT(1706, new byte[]{'H', 'Y', '0', '0', '0'}, "Primary key/partition key update is not" +
+ " allowed since the table is updated both as '%s' and '%s'."),
+ ERR_TABLE_NEEDS_REBUILD(1707, new byte[]{'H', 'Y', '0', '0', '0'}, "Table rebuild required. Please do \"ALTER " +
+ "TABLE `%s` FORCE\" or dump/reload to fix it!"),
+ WARN_OPTION_BELOW_LIMIT(1708, new byte[]{'H', 'Y', '0', '0', '0'}, "The value of '%s' should be no less than the " +
+ "value of '%s'"),
+ ERR_INDEX_COLUMN_TOO_LONG(1709, new byte[]{'H', 'Y', '0', '0', '0'}, "Index column size too large. The maximum " +
+ "column size is %lu bytes."),
+ ERR_ERROR_IN_TRIGGER_BODY(1710, new byte[]{'H', 'Y', '0', '0', '0'}, "Trigger '%s' has an error in its body: '%s'"),
+ ERR_ERROR_IN_UNKNOWN_TRIGGER_BODY(1711, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown trigger has an error in its" +
+ " body: '%s'"),
+ ERR_INDEX_CORRUPT(1712, new byte[]{'H', 'Y', '0', '0', '0'}, "Index %s is corrupted"),
+ ERR_UNDO_RECORD_TOO_BIG(1713, new byte[]{'H', 'Y', '0', '0', '0'}, "Undo log record is too big."),
+ ERR_BINLOG_UNSAFE_INSERT_IGNORE_SELECT(1714, new byte[]{'H', 'Y', '0', '0', '0'}, "INSERT IGNORE... SELECT is " +
+ "unsafe because the order in which rows are retrieved by the SELECT determines which (if any) rows are " +
+ "ignored. " +
+ "This order cannot be predicted and may differ on master and the slave."),
+ ERR_BINLOG_UNSAFE_INSERT_SELECT_UPDATE(1715, new byte[]{'H', 'Y', '0', '0', '0'}, "INSERT... SELECT... ON " +
+ "DUPLICATE KEY UPDATE is unsafe because the order in which rows are retrieved by the SELECT determines " +
+ "which (if" +
+ " any) rows are updated. This order cannot be predicted and may differ on master and the slave."),
+ ERR_BINLOG_UNSAFE_REPLACE_SELECT(1716, new byte[]{'H', 'Y', '0', '0', '0'}, "REPLACE... SELECT is unsafe because " +
+ "the order in which rows are retrieved by the SELECT determines which (if any) rows are replaced. This " +
+ "order " +
+ "cannot be predicted and may differ on master and the slave."),
+ ERR_BINLOG_UNSAFE_CREATE_IGNORE_SELECT(1717, new byte[]{'H', 'Y', '0', '0', '0'}, "CREATE... IGNORE SELECT is " +
+ "unsafe because the order in which rows are retrieved by the SELECT determines which (if any) rows are " +
+ "ignored. " +
+ "This order cannot be predicted and may differ on master and the slave."),
+ ERR_BINLOG_UNSAFE_CREATE_REPLACE_SELECT(1718, new byte[]{'H', 'Y', '0', '0', '0'}, "CREATE... REPLACE SELECT is " +
+ "unsafe because the order in which rows are retrieved by the SELECT determines which (if any) rows are " +
+ "replaced." +
+ " This order cannot be predicted and may differ on master and the slave."),
+ ERR_BINLOG_UNSAFE_UPDATE_IGNORE(1719, new byte[]{'H', 'Y', '0', '0', '0'}, "UPDATE IGNORE is unsafe because the " +
+ "order in which rows are updated determines which (if any) rows are ignored. This order cannot be " +
+ "predicted and " +
+ "may differ on master and the slave."),
+ ERR_UNUSED_15(1720, new byte[]{}, "You should never see it"),
+ ERR_UNUSED_16(1721, new byte[]{}, "You should never see it"),
+ ERR_BINLOG_UNSAFE_WRITE_AUTOINC_SELECT(1722, new byte[]{'H', 'Y', '0', '0', '0'}, "Statements writing to a table " +
+ "with an auto-increment column after selecting from another table are unsafe because the order in which " +
+ "rows are" +
+ " retrieved determines what (if any) rows will be written. This order cannot be predicted and may differ " +
+ "on " +
+ "master and the slave."),
+ ERR_BINLOG_UNSAFE_CREATE_SELECT_AUTOINC(1723, new byte[]{'H', 'Y', '0', '0', '0'}, "CREATE TABLE... SELECT... on " +
+ "a table with an auto-increment column is unsafe because the order in which rows are retrieved by the " +
+ "SELECT " +
+ "determines which (if any) rows are inserted. This order cannot be predicted and may differ on master and" +
+ " the " +
+ "slave."),
+ ERR_BINLOG_UNSAFE_INSERT_TWO_KEYS(1724, new byte[]{'H', 'Y', '0', '0', '0'}, "INSERT... ON DUPLICATE KEY UPDATE " +
+ "on a table with more than one UNIQUE KEY is unsafe"),
+ ERR_TABLE_IN_FK_CHECK(1725, new byte[]{'H', 'Y', '0', '0', '0'}, "Table is being used in foreign key check."),
+ ERR_UNSUPPORTED_ENGINE(1726, new byte[]{'H', 'Y', '0', '0', '0'}, "Storage engine '%s' does not support system " +
+ "tables. [%s.%s]"),
+ ERR_BINLOG_UNSAFE_AUTOINC_NOT_FIRST(1727, new byte[]{'H', 'Y', '0', '0', '0'}, "INSERT into autoincrement field " +
+ "which is not the first part in the composed primary key is unsafe."),
+ ERR_CANNOT_LOAD_FROM_TABLE_V2(1728, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot load from %s.%s. The table is " +
+ "probably corrupted"),
+ ERR_MASTER_DELAY_VALUE_OUT_OF_RANGE(1729, new byte[]{'H', 'Y', '0', '0', '0'}, "The requested value %s for the " +
+ "master delay exceeds the maximum %u"),
+ ERR_ONLY_FD_AND_RBR_EVENTS_ALLOWED_IN_BINLOG_STATEMENT(1730, new byte[]{'H', 'Y', '0', '0', '0'}, "Only " +
+ "Format_description_log_event and row events are allowed in BINLOG statements (but %s was provided"),
+ ERR_PARTITION_EXCHANGE_DIFFERENT_OPTION(1731, new byte[]{'H', 'Y', '0', '0', '0'}, "Non matching attribute '%s' " +
+ "between partition and table"),
+ ERR_PARTITION_EXCHANGE_PART_TABLE(1732, new byte[]{'H', 'Y', '0', '0', '0'}, "Table to exchange with partition is" +
+ " partitioned: '%s'"),
+ ERR_PARTITION_EXCHANGE_TEMP_TABLE(1733, new byte[]{'H', 'Y', '0', '0', '0'}, "Table to exchange with partition is" +
+ " temporary: '%s'"),
+ ERR_PARTITION_INSTEAD_OF_SUBPARTITION(1734, new byte[]{'H', 'Y', '0', '0', '0'}, "Subpartitioned table, use " +
+ "subpartition instead of partition"),
+ ERR_UNKNOWN_PARTITION(1735, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown partition '%s' in table '%s'"),
+ ERR_TABLES_DIFFERENT_METADATA(1736, new byte[]{'H', 'Y', '0', '0', '0'}, "Tables have different definitions"),
+ ERR_ROW_DOES_NOT_MATCH_PARTITION(1737, new byte[]{'H', 'Y', '0', '0', '0'}, "Found a row that does not match the " +
+ "partition"),
+ ERR_BINLOG_CACHE_SIZE_GREATER_THAN_MAX(1738, new byte[]{'H', 'Y', '0', '0', '0'}, "Option binlog_cache_size (%lu)" +
+ " is greater than max_binlog_cache_size (%lu); setting binlog_cache_size equal to max_binlog_cache_size."),
+ ERR_WARN_INDEX_NOT_APPLICABLE(1739, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot use %s access on index '%s' due " +
+ "to type or collation conversion on field '%s'"),
+ ERR_PARTITION_EXCHANGE_FOREIGN_KEY(1740, new byte[]{'H', 'Y', '0', '0', '0'}, "Table to exchange with partition " +
+ "has foreign key references: '%s'"),
+ ERR_NO_SUCH_KEY_VALUE(1741, new byte[]{'H', 'Y', '0', '0', '0'}, "Key value '%s' was not found in table '%s.%s'"),
+ ERR_RPL_INFO_DATA_TOO_LONG(1742, new byte[]{'H', 'Y', '0', '0', '0'}, "Data for column '%s' too long"),
+ ERR_NETWORK_READ_EVENT_CHECKSUM_FAILURE(1743, new byte[]{'H', 'Y', '0', '0', '0'}, "Replication event checksum " +
+ "verification failed while reading from network."),
+ ERR_BINLOG_READ_EVENT_CHECKSUM_FAILURE(1744, new byte[]{'H', 'Y', '0', '0', '0'}, "Replication event checksum " +
+ "verification failed while reading from a log file."),
+ ERR_BINLOG_STMT_CACHE_SIZE_GREATER_THAN_MAX(1745, new byte[]{'H', 'Y', '0', '0', '0'}, "Option " +
+ "binlog_stmt_cache_size (%lu) is greater than max_binlog_stmt_cache_size (%lu); setting " +
+ "binlog_stmt_cache_size " +
+ "equal to max_binlog_stmt_cache_size."),
+ ERR_CANT_UPDATE_TABLE_IN_CREATE_TABLE_SELECT(1746, new byte[]{'H', 'Y', '0', '0', '0'}, "Can't update table '%s' " +
+ "while '%s' is being created."),
+ ERR_PARTITION_CLAUSE_ON_NONPARTITIONED(1747, new byte[]{'H', 'Y', '0', '0', '0'}, "PARTITION () clause on non " +
+ "partitioned table"),
+ ERR_ROW_DOES_NOT_MATCH_GIVEN_PARTITION_SET(1748, new byte[]{'H', 'Y', '0', '0', '0'}, "Found a row not matching " +
+ "the given partition set"),
+ ERR_NO_SUCH_PARTITION(1749, new byte[]{'H', 'Y', '0', '0', '0'}, "partition '%s' doesn't exist"),
+ ERR_CHANGE_RPL_INFO_REPOSITORY_FAILURE(1750, new byte[]{'H', 'Y', '0', '0', '0'}, "Failure while changing the " +
+ "type of replication repository: %s."),
+ ERR_WARNING_NOT_COMPLETE_ROLLBACK_WITH_CREATED_TEMP_TABLE(1751, new byte[]{'H', 'Y', '0', '0', '0'}, "The " +
+ "creation of some temporary tables could not be rolled back."),
+ ERR_WARNING_NOT_COMPLETE_ROLLBACK_WITH_DROPPED_TEMP_TABLE(1752, new byte[]{'H', 'Y', '0', '0', '0'}, "Some " +
+ "temporary tables were dropped, but these operations could not be rolled back."),
+ ERR_MTS_FEATURE_IS_NOT_SUPPORTED(1753, new byte[]{'H', 'Y', '0', '0', '0'}, "%s is not supported in " +
+ "multi-threaded slave mode. %s"),
+ ERR_MTS_UPDATED_DBS_GREATER_MAX(1754, new byte[]{'H', 'Y', '0', '0', '0'}, "The number of modified databases " +
+ "exceeds the maximum %d; the database names will not be included in the replication event metadata."),
+ ERR_MTS_CANT_PARALLEL(1755, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute the current event group in the " +
+ "parallel mode. Encountered event %s, relay-log name %s, position %s which prevents execution of this " +
+ "event " +
+ "group in parallel mode. Reason: %s."),
+ ERR_MTS_INCONSISTENT_DATA(1756, new byte[]{'H', 'Y', '0', '0', '0'}, "%s"),
+ ERR_FULLTEXT_NOT_SUPPORTED_WITH_PARTITIONING(1757, new byte[]{'H', 'Y', '0', '0', '0'}, "FULLTEXT index is not " +
+ "supported for partitioned tables."),
+ ERR_DA_INVALID_CONDITION_NUMBER(1758, new byte[]{'3', '5', '0', '0', '0'}, "Invalid condition number"),
+ ERR_INSECURE_PLAIN_TEXT(1759, new byte[]{'H', 'Y', '0', '0', '0'}, "Sending passwords in plain text without " +
+ "SSL/TLS is extremely insecure."),
+ ERR_INSECURE_CHANGE_MASTER(1760, new byte[]{'H', 'Y', '0', '0', '0'}, "Storing MySQL user name or password " +
+ "information in the master info repository is not secure and is therefore not recommended. Please " +
+ "consider using" +
+ " the USER and PASSWORD connection options for START SLAVE; see the 'START SLAVE Syntax' in the MySQL " +
+ "Manual " +
+ "for more information."),
+ ERR_FOREIGN_DUPLICATE_KEY_WITH_CHILD_INFO(1761, new byte[]{'2', '3', '0', '0', '0'}, "Foreign key constraint for " +
+ "table '%s', record '%s' would lead to a duplicate entry in table '%s', key '%s'"),
+ ERR_FOREIGN_DUPLICATE_KEY_WITHOUT_CHILD_INFO(1762, new byte[]{'2', '3', '0', '0', '0'}, "Foreign key constraint " +
+ "for table '%s', record '%s' would lead to a duplicate entry in a child table"),
+ ERR_SQLTHREAD_WITH_SECURE_SLAVE(1763, new byte[]{'H', 'Y', '0', '0', '0'}, "Setting authentication options is not" +
+ " possible when only the Slave SQL Thread is being started."),
+ ERR_TABLE_HAS_NO_FT(1764, new byte[]{'H', 'Y', '0', '0', '0'}, "The table does not have FULLTEXT index to support" +
+ " this query"),
+ ERR_VARIABLE_NOT_SETTABLE_IN_SF_OR_TRIGGER(1765, new byte[]{'H', 'Y', '0', '0', '0'}, "The system variable %s " +
+ "cannot be set in stored functions or triggers."),
+ ERR_VARIABLE_NOT_SETTABLE_IN_TRANSACTION(1766, new byte[]{'H', 'Y', '0', '0', '0'}, "The system variable %s " +
+ "cannot be set when there is an ongoing transaction."),
+ ERR_GTID_NEXT_IS_NOT_IN_GTID_NEXT_LIST(1767, new byte[]{'H', 'Y', '0', '0', '0'}, "The system variable @@SESSION" +
+ ".GTID_NEXT has the value %s, which is not listed in @@SESSION.GTID_NEXT_LIST."),
+ ERR_CANT_CHANGE_GTID_NEXT_IN_TRANSACTION_WHEN_GTID_NEXT_LIST_IS_NULL(1768, new byte[]{'H', 'Y', '0', '0', '0'},
+ "The system variable @@SESSION.GTID_NEXT cannot change inside a transaction."),
+ ERR_SET_STATEMENT_CANNOT_INVOKE_FUNCTION(1769, new byte[]{'H', 'Y', '0', '0', '0'}, "The statement 'SET %s' " +
+ "cannot invoke a stored function."),
+ ERR_GTID_NEXT_CANT_BE_AUTOMATIC_IF_GTID_NEXT_LIST_IS_NON_NULL(1770, new byte[]{'H', 'Y', '0', '0', '0'}, "The " +
+ "system variable @@SESSION.GTID_NEXT cannot be 'AUTOMATIC' when @@SESSION.GTID_NEXT_LIST is non-NULL."),
+ ERR_SKIPPING_LOGGED_TRANSACTION(1771, new byte[]{'H', 'Y', '0', '0', '0'}, "Skipping transaction %s because it " +
+ "has already been executed and logged."),
+ ERR_MALFORMED_GTID_SET_SPECIFICATION(1772, new byte[]{'H', 'Y', '0', '0', '0'}, "Malformed GTID set specification" +
+ " '%s'."),
+ ERR_MALFORMED_GTID_SET_ENCODING(1773, new byte[]{'H', 'Y', '0', '0', '0'}, "Malformed GTID set encoding."),
+ ERR_MALFORMED_GTID_SPECIFICATION(1774, new byte[]{'H', 'Y', '0', '0', '0'}, "Malformed GTID specification '%s'."),
+ ERR_GNO_EXHAUSTED(1775, new byte[]{'H', 'Y', '0', '0', '0'}, "Impossible to generate Global Transaction " +
+ "Identifier: the integer component reached the maximal value. Restart the server with a new server_uuid."),
+ ERR_BAD_SLAVE_AUTO_POSITION(1776, new byte[]{'H', 'Y', '0', '0', '0'}, "Parameters MASTER_LOG_FILE, " +
+ "MASTER_LOG_POS, RELAY_LOG_FILE and RELAY_LOG_POS cannot be set when MASTER_AUTO_POSITION is active."),
+ ERR_AUTO_POSITION_REQUIRES_GTID_MODE_ON(1777, new byte[]{'H', 'Y', '0', '0', '0'}, "CHANGE MASTER TO " +
+ "MASTER_AUTO_POSITION = 1 can only be executed when @@GLOBAL.GTID_MODE = ON."),
+ ERR_CANT_DO_IMPLICIT_COMMIT_IN_TRX_WHEN_GTID_NEXT_IS_SET(1778, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot " +
+ "execute statements with implicit commit inside a transaction when @@SESSION.GTID_NEXT != AUTOMATIC."),
+ ERR_GTID_MODE_2_OR_3_REQUIRES_DISABLE_GTID_UNSAFE_STATEMENTS_ON(1779, new byte[]{'H', 'Y', '0', '0', '0'},
+ "GTID_MODE = ON or GTID_MODE = UPGRADE_STEP_2 requires DISABLE_GTID_UNSAFE_STATEMENTS = 1."),
+ ERR_GTID_MODE_2_OR_3_REQUIRES_ENFORCE_GTID_CONSISTENCY_ON(1779, new byte[]{'H', 'Y', '0', '0', '0'}, "@@GLOBAL" +
+ ".GTID_MODE = ON or UPGRADE_STEP_2 requires @@GLOBAL.ENFORCE_GTID_CONSISTENCY = 1."),
+ ERR_GTID_MODE_REQUIRES_BINLOG(1780, new byte[]{'H', 'Y', '0', '0', '0'}, "@@GLOBAL.GTID_MODE = ON or " +
+ "UPGRADE_STEP_1 or UPGRADE_STEP_2 requires --log-bin and --log-slave-updates."),
+ ERR_CANT_SET_GTID_NEXT_TO_GTID_WHEN_GTID_MODE_IS_OFF(1781, new byte[]{'H', 'Y', '0', '0', '0'}, "@@SESSION" +
+ ".GTID_NEXT cannot be set to UUID:NUMBER when @@GLOBAL.GTID_MODE = OFF."),
+ ERR_CANT_SET_GTID_NEXT_TO_ANONYMOUS_WHEN_GTID_MODE_IS_ON(1782, new byte[]{'H', 'Y', '0', '0', '0'}, "@@SESSION" +
+ ".GTID_NEXT cannot be set to ANONYMOUS when @@GLOBAL.GTID_MODE = ON."),
+ ERR_CANT_SET_GTID_NEXT_LIST_TO_NON_NULL_WHEN_GTID_MODE_IS_OFF(1783, new byte[]{'H', 'Y', '0', '0', '0'},
+ "@@SESSION.GTID_NEXT_LIST cannot be set to a non-NULL value when @@GLOBAL.GTID_MODE = OFF."),
+ ERR_FOUND_GTID_EVENT_WHEN_GTID_MODE_IS_OFF(1784, new byte[]{'H', 'Y', '0', '0', '0'}, "Found a Gtid_log_event or " +
+ "Previous_gtids_log_event when @@GLOBAL.GTID_MODE = OFF."),
+ ERR_GTID_UNSAFE_NON_TRANSACTIONAL_TABLE(1785, new byte[]{'H', 'Y', '0', '0', '0'}, "When @@GLOBAL" +
+ ".ENFORCE_GTID_CONSISTENCY = 1, updates to non-transactional tables can only be done in either " +
+ "autocommitted " +
+ "statements or single-statement transactions, and never in the same statement as updates to transactional" +
+ " " +
+ "tables."),
+ ERR_GTID_UNSAFE_CREATE_SELECT(1786, new byte[]{'H', 'Y', '0', '0', '0'}, "CREATE TABLE ... SELECT is forbidden " +
+ "when @@GLOBAL.ENFORCE_GTID_CONSISTENCY = 1."),
+ ERR_GTID_UNSAFE_CREATE_DROP_TEMPORARY_TABLE_IN_TRANSACTION(1787, new byte[]{'H', 'Y', '0', '0', '0'}, "When " +
+ "@@GLOBAL.ENFORCE_GTID_CONSISTENCY = 1, the statements CREATE TEMPORARY TABLE and DROP TEMPORARY TABLE " +
+ "can be " +
+ "executed in a non-transactional context only, and require that AUTOCOMMIT = 1."),
+ ERR_GTID_MODE_CAN_ONLY_CHANGE_ONE_STEP_AT_A_TIME(1788, new byte[]{'H', 'Y', '0', '0', '0'}, "The value of " +
+ "@@GLOBAL.GTID_MODE can only change one step at a time: OFF <-> UPGRADE_STEP_1 <-> UPGRADE_STEP_2 <-> ON." +
+ " Also " +
+ "note that this value must be stepped up or down simultaneously on all servers; see the Manual for " +
+ "instructions" +
+ "."),
+ ERR_MASTER_HAS_PURGED_REQUIRED_GTIDS(1789, new byte[]{'H', 'Y', '0', '0', '0'}, "The slave is connecting using " +
+ "CHANGE MASTER TO MASTER_AUTO_POSITION = 1, but the master has purged binary logs containing GTIDs that " +
+ "the " +
+ "slave requires."),
+ ERR_CANT_SET_GTID_NEXT_WHEN_OWNING_GTID(1790, new byte[]{'H', 'Y', '0', '0', '0'}, "@@SESSION.GTID_NEXT cannot be" +
+ " changed by a client that owns a GTID. The client owns %s. Ownership is released on COMMIT or ROLLBACK."),
+ ERR_UNKNOWN_EXPLAIN_FORMAT(1791, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown EXPLAIN format name: '%s'"),
+ ERR_CANT_EXECUTE_IN_READ_ONLY_TRANSACTION(1792, new byte[]{'2', '5', '0', '0', '6'}, "Cannot execute statement in" +
+ " a READ ONLY transaction."),
+ ERR_TOO_LONG_TABLE_PARTITION_COMMENT(1793, new byte[]{'H', 'Y', '0', '0', '0'}, "Comment for table partition '%s'" +
+ " is too long (max = %lu"),
+ ERR_SLAVE_CONFIGURATION(1794, new byte[]{'H', 'Y', '0', '0', '0'}, "Slave is not configured or failed to " +
+ "initialize properly. You must at least set --server-id to enable either a master or a slave. Additional " +
+ "error " +
+ "messages can be found in the MySQL error log."),
+ ERR_INNODB_FT_LIMIT(1795, new byte[]{'H', 'Y', '0', '0', '0'}, "InnoDB presently supports one FULLTEXT index " +
+ "creation at a time"),
+ ERR_INNODB_NO_FT_TEMP_TABLE(1796, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot create FULLTEXT index on temporary" +
+ " InnoDB table"),
+ ERR_INNODB_FT_WRONG_DOCID_COLUMN(1797, new byte[]{'H', 'Y', '0', '0', '0'}, "Column '%s' is of wrong type for an " +
+ "InnoDB FULLTEXT index"),
+ ERR_INNODB_FT_WRONG_DOCID_INDEX(1798, new byte[]{'H', 'Y', '0', '0', '0'}, "Index '%s' is of wrong type for an " +
+ "InnoDB FULLTEXT index"),
+ ERR_INNODB_ONLINE_LOG_TOO_BIG(1799, new byte[]{'H', 'Y', '0', '0', '0'}, "Creating index '%s' required more than " +
+ "'innodb_online_alter_log_max_size' bytes of modification log. Please try again."),
+ ERR_UNKNOWN_ALTER_ALGORITHM(1800, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown ALGORITHM '%s'"),
+ ERR_UNKNOWN_ALTER_LOCK(1801, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown LOCK type '%s'"),
+ ERR_MTS_CHANGE_MASTER_CANT_RUN_WITH_GAPS(1802, new byte[]{'H', 'Y', '0', '0', '0'}, "CHANGE MASTER cannot be " +
+ "executed when the slave was stopped with an error or killed in MTS mode. Consider using RESET SLAVE or " +
+ "START " +
+ "SLAVE UNTIL."),
+ ERR_MTS_RECOVERY_FAILURE(1803, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot recover after SLAVE errored out in " +
+ "parallel execution mode. Additional error messages can be found in the MySQL error log."),
+ ERR_MTS_RESET_WORKERS(1804, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot clean up worker info tables. Additional " +
+ "error messages can be found in the MySQL error log."),
+ ERR_COL_COUNT_DOESNT_MATCH_CORRUPTED_V2(1805, new byte[]{'H', 'Y', '0', '0', '0'}, "Column count of %s.%s is " +
+ "wrong. Expected %d, found %d. The table is probably corrupted"),
+ ERR_SLAVE_SILENT_RETRY_TRANSACTION(1806, new byte[]{'H', 'Y', '0', '0', '0'}, "Slave must silently retry current " +
+ "transaction"),
+ ERR_DISCARD_FK_CHECKS_RUNNING(1807, new byte[]{'H', 'Y', '0', '0', '0'}, "There is a foreign key check running on" +
+ " table '%s'. Cannot discard the table."),
+ ERR_TABLE_SCHEMA_MISMATCH(1808, new byte[]{'H', 'Y', '0', '0', '0'}, "Schema mismatch (%s"),
+ ERR_TABLE_IN_SYSTEM_TABLESPACE(1809, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s' in system tablespace"),
+ ERR_IO_READ_ERROR(1810, new byte[]{'H', 'Y', '0', '0', '0'}, "IO Read error: (%lu, %s) %s"),
+ ERR_IO_WRITE_ERROR(1811, new byte[]{'H', 'Y', '0', '0', '0'}, "IO Write error: (%lu, %s) %s"),
+ ERR_TABLESPACE_MISSING(1812, new byte[]{'H', 'Y', '0', '0', '0'}, "Tablespace is missing for table '%s'"),
+ ERR_TABLESPACE_EXISTS(1813, new byte[]{'H', 'Y', '0', '0', '0'}, "Tablespace for table '%s' exists. Please " +
+ "DISCARD the tablespace before IMPORT."),
+ ERR_TABLESPACE_DISCARDED(1814, new byte[]{'H', 'Y', '0', '0', '0'}, "Tablespace has been discarded for table '%s'"),
+ ERR_INTERNAL_ERROR(1815, new byte[]{'H', 'Y', '0', '0', '0'}, "Internal error: %s"),
+ ERR_INNODB_IMPORT_ERROR(1816, new byte[]{'H', 'Y', '0', '0', '0'}, "ALTER TABLE '%s' IMPORT TABLESPACE failed " +
+ "with error %lu : '%s'"),
+ ERR_INNODB_INDEX_CORRUPT(1817, new byte[]{'H', 'Y', '0', '0', '0'}, "Index corrupt: %s"),
+ ERR_INVALID_YEAR_COLUMN_LENGTH(1818, new byte[]{'H', 'Y', '0', '0', '0'}, "YEAR(%lu) column type is deprecated. " +
+ "Creating YEAR(4) column instead."),
+ ERR_NOT_VALID_PASSWORD(1819, new byte[]{'H', 'Y', '0', '0', '0'}, "Your password does not satisfy the current " +
+ "policy requirements"),
+ ERR_MUST_CHANGE_PASSWORD(1820, new byte[]{'H', 'Y', '0', '0', '0'}, "You must SET PASSWORD before executing this " +
+ "statement"),
+ ERR_FK_NO_INDEX_CHILD(1821, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to add the foreign key constaint. " +
+ "Missing index for constraint '%s' in the foreign table '%s'"),
+ ERR_FK_NO_INDEX_PARENT(1822, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to add the foreign key constaint. " +
+ "Missing index for constraint '%s' in the referenced table '%s'"),
+ ERR_FK_FAIL_ADD_SYSTEM(1823, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to add the foreign key constraint '%s' " +
+ "to system tables"),
+ ERR_FK_CANNOT_OPEN_PARENT(1824, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to open the referenced table '%s'"),
+ ERR_FK_INCORRECT_OPTION(1825, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed to add the foreign key constraint on " +
+ "table '%s'. Incorrect options in FOREIGN KEY constraint '%s'"),
+ ERR_FK_DUP_NAME(1826, new byte[]{'H', 'Y', '0', '0', '0'}, "Duplicate foreign key constraint name '%s'"),
+ ERR_PASSWORD_FORMAT(1827, new byte[]{'H', 'Y', '0', '0', '0'}, "The password hash doesn't have the expected " +
+ "format. Check if the correct password algorithm is being used with the PASSWORD() function."),
+ ERR_FK_COLUMN_CANNOT_DROP(1828, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot drop column '%s': needed in a " +
+ "foreign key constraint '%s'"),
+ ERR_FK_COLUMN_CANNOT_DROP_CHILD(1829, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot drop column '%s': needed in a " +
+ "foreign key constraint '%s' of table '%s'"),
+ ERR_FK_COLUMN_NOT_NULL(1830, new byte[]{'H', 'Y', '0', '0', '0'}, "Column '%s' cannot be NOT NULL: needed in a " +
+ "foreign key constraint '%s' SET NULL"),
+ ERR_DUP_INDEX(1831, new byte[]{'H', 'Y', '0', '0', '0'}, "Duplicate index '%s' defined on the table '%s.%s'. This" +
+ " is deprecated and will be disallowed in a future release."),
+ ERR_FK_COLUMN_CANNOT_CHANGE(1832, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot change column '%s': used in a " +
+ "foreign key constraint '%s'"),
+ ERR_FK_COLUMN_CANNOT_CHANGE_CHILD(1833, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot change column '%s': used in " +
+ "a foreign key constraint '%s' of table '%s'"),
+ ERR_FK_CANNOT_DELETE_PARENT(1834, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot delete rows from table which is " +
+ "parent in a foreign key constraint '%s' of table '%s'"),
+ ERR_MALFORMED_PACKET(1835, new byte[]{'H', 'Y', '0', '0', '0'}, "Malformed communication packet."),
+ ERR_READ_ONLY_MODE(1836, new byte[]{'H', 'Y', '0', '0', '0'}, "Running in read-only mode"),
+ ERR_GTID_NEXT_TYPE_UNDEFINED_GROUP(1837, new byte[]{'H', 'Y', '0', '0', '0'}, "When @@SESSION.GTID_NEXT is set to" +
+ " a GTID, you must explicitly set it to a different value after a COMMIT or ROLLBACK. Please check " +
+ "GTID_NEXT " +
+ "variable manual page for detailed explanation. Current @@SESSION.GTID_NEXT is '%s'."),
+ ERR_VARIABLE_NOT_SETTABLE_IN_SP(1838, new byte[]{'H', 'Y', '0', '0', '0'}, "The system variable %s cannot be set " +
+ "in stored procedures."),
+ ERR_CANT_SET_GTID_PURGED_WHEN_GTID_MODE_IS_OFF(1839, new byte[]{'H', 'Y', '0', '0', '0'}, "@@GLOBAL.GTID_PURGED " +
+ "can only be set when @@GLOBAL.GTID_MODE = ON."),
+ ERR_CANT_SET_GTID_PURGED_WHEN_GTID_EXECUTED_IS_NOT_EMPTY(1840, new byte[]{'H', 'Y', '0', '0', '0'}, "@@GLOBAL" +
+ ".GTID_PURGED can only be set when @@GLOBAL.GTID_EXECUTED is empty."),
+ ERR_CANT_SET_GTID_PURGED_WHEN_OWNED_GTIDS_IS_NOT_EMPTY(1841, new byte[]{'H', 'Y', '0', '0', '0'}, "@@GLOBAL" +
+ ".GTID_PURGED can only be set when there are no ongoing transactions (not even in other clients)."),
+ ERR_GTID_PURGED_WAS_CHANGED(1842, new byte[]{'H', 'Y', '0', '0', '0'}, "@@GLOBAL.GTID_PURGED was changed from " +
+ "'%s' to '%s'."),
+ ERR_GTID_EXECUTED_WAS_CHANGED(1843, new byte[]{'H', 'Y', '0', '0', '0'}, "@@GLOBAL.GTID_EXECUTED was changed from" +
+ " '%s' to '%s'."),
+ ERR_BINLOG_STMT_MODE_AND_NO_REPL_TABLES(1844, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot execute statement: " +
+ "impossible to write to binary log since BINLOG_FORMAT = STATEMENT, and both replicated and non " +
+ "replicated " +
+ "tables are written to."),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED(1845, new byte[]{'0', 'A', '0', '0', '0'}, "%s is not supported for this " +
+ "operation. Try %s."),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON(1846, new byte[]{'0', 'A', '0', '0', '0'}, "%s is not supported. Reason:" +
+ " %s. Try %s."),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_COPY(1847, new byte[]{'H', 'Y', '0', '0', '0'}, "COPY algorithm requires" +
+ " a lock"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_PARTITION(1848, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition specific" +
+ " operations do not yet support LOCK/ALGORITHM"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_FK_RENAME(1849, new byte[]{'H', 'Y', '0', '0', '0'}, "Columns " +
+ "participating in a foreign key are renamed"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_COLUMN_TYPE(1850, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot change " +
+ "column type INPLACE"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_FK_CHECK(1851, new byte[]{'H', 'Y', '0', '0', '0'}, "Adding foreign keys" +
+ " needs foreign_key_checks=OFF"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_IGNORE(1852, new byte[]{'H', 'Y', '0', '0', '0'}, "Creating unique " +
+ "indexes with IGNORE requires COPY algorithm to remove duplicate rows"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_NOPK(1853, new byte[]{'H', 'Y', '0', '0', '0'}, "Dropping a primary key " +
+ "is not allowed without also adding a new primary key"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_AUTOINC(1854, new byte[]{'H', 'Y', '0', '0', '0'}, "Adding an " +
+ "auto-increment column requires a lock"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_HIDDEN_FTS(1855, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot replace " +
+ "hidden FTS_DOC_ID with a user-visible one"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_CHANGE_FTS(1856, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot drop or " +
+ "rename FTS_DOC_ID"),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_FTS(1857, new byte[]{'H', 'Y', '0', '0', '0'}, "Fulltext index creation " +
+ "requires a lock"),
+ ERR_SQL_SLAVE_SKIP_COUNTER_NOT_SETTABLE_IN_GTID_MODE(1858, new byte[]{'H', 'Y', '0', '0', '0'},
+ "sql_slave_skip_counter can not be set when the server is running with @@GLOBAL.GTID_MODE = ON. Instead, " +
+ "for each" +
+ " transaction that you want to skip, generate an empty transaction with the same GTID as the " +
+ "transaction"),
+ ERR_DUP_UNKNOWN_IN_INDEX(1859, new byte[]{'2', '3', '0', '0', '0'}, "Duplicate entry for key '%s'"),
+ ERR_IDENT_CAUSES_TOO_LONG_PATH(1860, new byte[]{'H', 'Y', '0', '0', '0'}, "Long database name and identifier for " +
+ "object resulted in path length exceeding %d characters. Path: '%s'."),
+ ERR_ALTER_OPERATION_NOT_SUPPORTED_REASON_NOT_NULL(1861, new byte[]{'H', 'Y', '0', '0', '0'}, "cannot silently " +
+ "convert NULL values, as required in this SQL_MODE"),
+ ERR_MUST_CHANGE_PASSWORD_LOGIN(1862, new byte[]{'H', 'Y', '0', '0', '0'}, "Your password has expired. To log in " +
+ "you must change it using a client that supports expired passwords."),
+ ERR_ROW_IN_WRONG_PARTITION(1863, new byte[]{'H', 'Y', '0', '0', '0'}, "Found a row in wrong partition %s"),
+ ERR_MTS_EVENT_BIGGER_PENDING_JOBS_SIZE_MAX(1864, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot schedule event %s, " +
+ "relay-log name %s, position %s to Worker thread because its size %lu exceeds %lu of " +
+ "slave_pending_jobs_size_max" +
+ "."),
+ ERR_INNODB_NO_FT_USES_PARSER(1865, new byte[]{'H', 'Y', '0', '0', '0'}, "Cannot CREATE FULLTEXT INDEX WITH PARSER" +
+ " on InnoDB table"),
+ ERR_BINLOG_LOGICAL_CORRUPTION(1866, new byte[]{'H', 'Y', '0', '0', '0'}, "The binary log file '%s' is logically " +
+ "corrupted: %s"),
+ ERR_WARN_PURGE_LOG_IN_USE(1867, new byte[]{'H', 'Y', '0', '0', '0'}, "file %s was not purged because it was being" +
+ " read by %d thread(s), purged only %d out of %d files."),
+ ERR_WARN_PURGE_LOG_IS_ACTIVE(1868, new byte[]{'H', 'Y', '0', '0', '0'}, "file %s was not purged because it is the" +
+ " active log file."),
+ ERR_AUTO_INCREMENT_CONFLICT(1869, new byte[]{'H', 'Y', '0', '0', '0'}, "Auto-increment value in UPDATE conflicts " +
+ "with internally generated values"),
+ WARN_ON_BLOCKHOLE_IN_RBR(1870, new byte[]{'H', 'Y', '0', '0', '0'}, "Row events are not logged for %s statements " +
+ "that modify BLACKHOLE tables in row format. Table(s): '%s'"),
+ ERR_SLAVE_MI_INIT_REPOSITORY(1871, new byte[]{'H', 'Y', '0', '0', '0'}, "Slave failed to initialize master info " +
+ "structure from the repository"),
+ ERR_SLAVE_RLI_INIT_REPOSITORY(1872, new byte[]{'H', 'Y', '0', '0', '0'}, "Slave failed to initialize relay log " +
+ "info structure from the repository"),
+ ERR_ACCESS_DENIED_CHANGE_USER_ERROR(1873, new byte[]{'2', '8', '0', '0', '0'}, "Access denied trying to change to" +
+ " user '%s'@'%s' (using password: %s). Disconnecting."),
+ ERR_INNODB_READ_ONLY(1874, new byte[]{'H', 'Y', '0', '0', '0'}, "InnoDB is in read only mode."),
+ ERR_STOP_SLAVE_SQL_THREAD_TIMEOUT(1875, new byte[]{'H', 'Y', '0', '0', '0'}, "STOP SLAVE command execution is " +
+ "incomplete: Slave SQL thread got the stop signal, thread is busy, SQL thread will stop once the current " +
+ "task is" +
+ " complete."),
+ ERR_STOP_SLAVE_IO_THREAD_TIMEOUT(1876, new byte[]{'H', 'Y', '0', '0', '0'}, "STOP SLAVE command execution is " +
+ "incomplete: Slave IO thread got the stop signal, thread is busy, IO thread will stop once the current " +
+ "task is " +
+ "complete."),
+ ERR_TABLE_CORRUPT(1877, new byte[]{'H', 'Y', '0', '0', '0'}, "Operation cannot be performed. The table '%s.%s' is" +
+ " missing, corrupt or contains bad data."),
+ ERR_TEMP_FILE_WRITE_FAILURE(1878, new byte[]{'H', 'Y', '0', '0', '0'}, "Temporary file write failure."),
+ ERR_INNODB_FT_AUX_NOT_HEX_ID(1879, new byte[]{'H', 'Y', '0', '0', '0'}, "Upgrade index name failed, please use " +
+ "create index(alter table) algorithm copy to rebuild index."),
+ ERR_LAST_MYSQL_ERROR_MESSAGE(1880, new byte[]{}, ""),
// Following is Palo's error code, which start from 5000
- ERR_NOT_OLAP_TABLE(5000, new byte[] {'H', 'Y', '0', '0', '0'}, "Table '%s' is not a OLAP table"),
- ERR_WRONG_PROC_PATH(5001, new byte[] {'H', 'Y', '0', '0', '0'}, "Proc path '%s' doesn't exist"),
- ERR_COL_NOT_MENTIONED(5002, new byte[] {'H', 'Y', '0', '0', '0'},
+ ERR_NOT_OLAP_TABLE(5000, new byte[]{'H', 'Y', '0', '0', '0'}, "Table '%s' is not a OLAP table"),
+ ERR_WRONG_PROC_PATH(5001, new byte[]{'H', 'Y', '0', '0', '0'}, "Proc path '%s' doesn't exist"),
+ ERR_COL_NOT_MENTIONED(5002, new byte[]{'H', 'Y', '0', '0', '0'},
"'%s' must be explicitly mentioned in column permutation"),
- ERR_OLAP_KEY_MUST_BEFORE_VALUE(5003, new byte[] { 'H', 'Y', '0', '0', '0' },
+ ERR_OLAP_KEY_MUST_BEFORE_VALUE(5003, new byte[]{'H', 'Y', '0', '0', '0'},
"Key column must before value column"),
- ERR_TABLE_MUST_HAVE_KEYS(5004, new byte[] { 'H', 'Y', '0', '0', '0' },
+ ERR_TABLE_MUST_HAVE_KEYS(5004, new byte[]{'H', 'Y', '0', '0', '0'},
"Table must have at least 1 key column"),
- ERR_UNKNOWN_CLUSTER_ID(5005, new byte[] {'H', 'Y', '0', '0', '0'}, "Unknown cluster id '%s'"),
- ERR_UNKNOWN_PLAN_HINT(5006, new byte[] {'H', 'Y', '0', '0', '0'}, "Unknown plan hint '%s'"),
- ERR_PLAN_HINT_CONFILT(5007, new byte[] {'H', 'Y', '0', '0', '0'}, "Conflict plan hint '%s'"),
- ERR_INSERT_HINT_NOT_SUPPORT(5008, new byte[] {'H', 'Y', '0', '0', '0'},
+ ERR_UNKNOWN_CLUSTER_ID(5005, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown cluster id '%s'"),
+ ERR_UNKNOWN_PLAN_HINT(5006, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown plan hint '%s'"),
+ ERR_PLAN_HINT_CONFILT(5007, new byte[]{'H', 'Y', '0', '0', '0'}, "Conflict plan hint '%s'"),
+ ERR_INSERT_HINT_NOT_SUPPORT(5008, new byte[]{'H', 'Y', '0', '0', '0'},
"INSERT hints are only supported for partitioned table"),
- ERR_PARTITION_CLAUSE_NO_ALLOWED(5009, new byte[] {'H', 'Y', '0', '0', '0'},
+ ERR_PARTITION_CLAUSE_NO_ALLOWED(5009, new byte[]{'H', 'Y', '0', '0', '0'},
"PARTITION clause is not valid for INSERT into unpartitioned table"),
- ERR_COL_NUMBER_NOT_MATCH(5010, new byte[] {'H', 'Y', '0', '0', '0'},
+ ERR_COL_NUMBER_NOT_MATCH(5010, new byte[]{'H', 'Y', '0', '0', '0'},
"Number of columns don't equal number of SELECT statement's select list"),
- ERR_UNRESOLVED_TABLE_REF(5011, new byte[] {'H', 'Y', '0', '0', '0'},
+ ERR_UNRESOLVED_TABLE_REF(5011, new byte[]{'H', 'Y', '0', '0', '0'},
"Unresolved table reference '%s'"),
- ERR_BAD_NUMBER(5012, new byte[] {'H', 'Y', '0', '0', '0'}, "'%s' is not a number"),
- ERR_BAD_TIMEUNIT(5013, new byte[] { 'H', 'Y', '0', '0', '0' }, "Unsupported time unit '%s'"),
- ERR_BAD_TABLE_STATE(5014, new byte[] { 'H', 'Y', '0', '0', '0' }, "Table state is not NORMAL: '%s'"),
- ERR_BAD_PARTITION_STATE(5015, new byte[] { 'H', 'Y', '0', '0', '0' }, "Partition state is not NORMAL: '%s':'%s'"),
- ERR_PARTITION_HAS_LOADING_JOBS(5016, new byte[] { 'H', 'Y', '0', '0', '0' }, "Partition has loading jobs: '%s'"),
- ERR_NOT_KEY_COLUMN(5017, new byte[] { 'H', 'Y', '0', '0', '0' }, "Column is not a key column: '%s'"),
- ERR_INVALID_VALUE(5018, new byte[] { 'H', 'Y', '0', '0', '0' }, "Invalid value format: '%s'"),
- ERR_REPLICA_NOT_CATCH_UP_WITH_VERSION(5019, new byte[] { 'H', 'Y', '0', '0', '0' },
+ ERR_BAD_NUMBER(5012, new byte[]{'H', 'Y', '0', '0', '0'}, "'%s' is not a number"),
+ ERR_BAD_TIMEUNIT(5013, new byte[]{'H', 'Y', '0', '0', '0'}, "Unsupported time unit '%s'"),
+ ERR_BAD_TABLE_STATE(5014, new byte[]{'H', 'Y', '0', '0', '0'}, "Table state is not NORMAL: '%s'"),
+ ERR_BAD_PARTITION_STATE(5015, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition state is not NORMAL: '%s':'%s'"),
+ ERR_PARTITION_HAS_LOADING_JOBS(5016, new byte[]{'H', 'Y', '0', '0', '0'}, "Partition has loading jobs: '%s'"),
+ ERR_NOT_KEY_COLUMN(5017, new byte[]{'H', 'Y', '0', '0', '0'}, "Column is not a key column: '%s'"),
+ ERR_INVALID_VALUE(5018, new byte[]{'H', 'Y', '0', '0', '0'}, "Invalid value format: '%s'"),
+ ERR_REPLICA_NOT_CATCH_UP_WITH_VERSION(5019, new byte[]{'H', 'Y', '0', '0', '0'},
"Replica does not catch up with version: '%s':'%s'"),
- ERR_BACKEND_OFFLINE(5021, new byte[] { 'H', 'Y', '0', '0', '0' }, "Backend is offline: '%s'"),
- ERR_BAD_PARTS_IN_UNPARTITION_TABLE(5022, new byte[] { 'H', 'Y', '0', '0', '0' },
+ ERR_BACKEND_OFFLINE(5021, new byte[]{'H', 'Y', '0', '0', '0'}, "Backend is offline: '%s'"),
+ ERR_BAD_PARTS_IN_UNPARTITION_TABLE(5022, new byte[]{'H', 'Y', '0', '0', '0'},
"Number of partitions in unpartitioned table is not 1"),
- ERR_NO_ALTER_OPERATION(5023, new byte[] { 'H', 'Y', '0', '0', '0' },
+ ERR_NO_ALTER_OPERATION(5023, new byte[]{'H', 'Y', '0', '0', '0'},
"No operation in alter statement"),
- ERR_EXECUTE_TIMEOUT(5024, new byte[] { 'H', 'Y', '0', '0', '0' }, "Execute timeout"),
- ERR_FAILED_WHEN_INSERT(5025, new byte[] { 'H', 'Y', '0', '0', '0' }, "Failed when INSERT execute"),
- ERR_UNSUPPORTED_TYPE_IN_CTAS(5026, new byte[] { 'H', 'Y', '0', '0', '0' },
+ ERR_EXECUTE_TIMEOUT(5024, new byte[]{'H', 'Y', '0', '0', '0'}, "Execute timeout"),
+ ERR_FAILED_WHEN_INSERT(5025, new byte[]{'H', 'Y', '0', '0', '0'}, "Failed when INSERT execute"),
+ ERR_UNSUPPORTED_TYPE_IN_CTAS(5026, new byte[]{'H', 'Y', '0', '0', '0'},
"Unsupported type '%s' in create table as select statement"),
- ERR_MISSING_PARAM(5027, new byte[] { 'H', 'Y', '0', '0', '0' }, "Missing param: %s "),
- ERR_CLUSTER_NO_EXISTS(5028, new byte[] { 'H', 'Y', '0', '0', '0' }, "Unknown cluster '%s'"),
- ERR_CLUSTER_NO_AUTHORITY(5030, new byte[] { 'H', 'Y', '0', '0', '0' },
+ ERR_MISSING_PARAM(5027, new byte[]{'H', 'Y', '0', '0', '0'}, "Missing param: %s "),
+ ERR_CLUSTER_NO_EXISTS(5028, new byte[]{'H', 'Y', '0', '0', '0'}, "Unknown cluster '%s'"),
+ ERR_CLUSTER_NO_AUTHORITY(5030, new byte[]{'H', 'Y', '0', '0', '0'},
"User '%s' has no permissions '%s' cluster"),
- ERR_CLUSTER_NO_PARAMETER(5031, new byte[] { 'H', 'Y', '0', '0', '0' }, "No parameter or parameter is incorrect"),
- ERR_CLUSTER_NO_INSTANCE_NUM(5032, new byte[] { 'H', 'Y', '0', '0', '0' }, "No assign properties's instance_num"),
- ERR_CLUSTER_HAS_EXIST(5034, new byte[] { 'H', 'Y', '0', '0', '0' }, "Cluster '%s' has exist"),
- ERR_CLUSTER_INSTANCE_NUM_WRONG(5035, new byte[] { 'H', 'Y', '0', '0', '0' }, "Cluster '%s' has exist"),
- ERR_CLUSTER_BE_NOT_ENOUGH(5036, new byte[] { 'H', 'Y', '0', '0', '0' }, "Be is not enough"),
- ERR_CLUSTER_DELETE_DB_EXIST(5037, new byte[] { 'H', 'Y', '0', '0', '0' },
+ ERR_CLUSTER_NO_PARAMETER(5031, new byte[]{'H', 'Y', '0', '0', '0'}, "No parameter or parameter is incorrect"),
+ ERR_CLUSTER_NO_INSTANCE_NUM(5032, new byte[]{'H', 'Y', '0', '0', '0'}, "No assign properties's instance_num"),
+ ERR_CLUSTER_HAS_EXIST(5034, new byte[]{'H', 'Y', '0', '0', '0'}, "Cluster '%s' has exist"),
+ ERR_CLUSTER_INSTANCE_NUM_WRONG(5035, new byte[]{'H', 'Y', '0', '0', '0'}, "Cluster '%s' has exist"),
+ ERR_CLUSTER_BE_NOT_ENOUGH(5036, new byte[]{'H', 'Y', '0', '0', '0'}, "Be is not enough"),
+ ERR_CLUSTER_DELETE_DB_EXIST(5037, new byte[]{'H', 'Y', '0', '0', '0'},
"All datbases in cluster must be dropped before dropping cluster"),
- ERR_CLUSTER_DELETE_BE_ID_ERROR(5037, new byte[] { 'H', 'Y', '0', '0', '0' }, "There is no be's id in the System"),
- ERR_CLUSTER_NO_CLUSTER_NAME(5038, new byte[] { 'H', 'Y', '0', '0', '0' }, "There is no cluster name"),
- ERR_CLUSTER_UNKNOWN_ERROR(5040, new byte[] {'4', '2', '0', '0', '0'}, "Unknown cluster '%s'"),
- ERR_CLUSTER_NAME_NULL(5041, new byte[] {'4', '2', '0', '0', '0'}, "No cluster name"),
- ERR_CLUSTER_NO_PERMISSIONS(5042, new byte[] {'4', '2', '0', '0', '0'}, "No permissions"),
- ERR_CLUSTER_CREATE_ISTANCE_NUM_ERROR(5043, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_DELETE_BE_ID_ERROR(5037, new byte[]{'H', 'Y', '0', '0', '0'}, "There is no be's id in the System"),
+ ERR_CLUSTER_NO_CLUSTER_NAME(5038, new byte[]{'H', 'Y', '0', '0', '0'}, "There is no cluster name"),
+ ERR_CLUSTER_UNKNOWN_ERROR(5040, new byte[]{'4', '2', '0', '0', '0'}, "Unknown cluster '%s'"),
+ ERR_CLUSTER_NAME_NULL(5041, new byte[]{'4', '2', '0', '0', '0'}, "No cluster name"),
+ ERR_CLUSTER_NO_PERMISSIONS(5042, new byte[]{'4', '2', '0', '0', '0'}, "No permissions"),
+ ERR_CLUSTER_CREATE_ISTANCE_NUM_ERROR(5043, new byte[]{'4', '2', '0', '0', '0'},
"Instance num can't be less than or equal 0"),
- ERR_CLUSTER_SRC_CLUSTER_NOT_EXIST(5046, new byte[] { '4', '2', '0', '0', '0' }, "Src cluster '%s' does not exist"),
- ERR_CLUSTER_DEST_CLUSTER_NOT_EXIST(5047, new byte[] { '4', '2', '0', '0', '0' },
+ ERR_CLUSTER_SRC_CLUSTER_NOT_EXIST(5046, new byte[]{'4', '2', '0', '0', '0'}, "Src cluster '%s' does not exist"),
+ ERR_CLUSTER_DEST_CLUSTER_NOT_EXIST(5047, new byte[]{'4', '2', '0', '0', '0'},
"Dest cluster '%s' does not exist"),
- ERR_CLUSTER_SRC_DB_NOT_EXIST(5048, new byte[] {'4', '2', '0', '0', '0'}, "Src db '%s' no exist"),
- ERR_CLUSTER_DES_DB_NO_EXIT(5049, new byte[] { '4', '2', '0', '0', '0' }, "Dest db '%s' no exist"),
- ERR_CLUSTER_NO_SELECT_CLUSTER(5050, new byte[] {'4', '2', '0', '0', '0'}, "Please enter cluster"),
- ERR_CLUSTER_MIGRATION_NO_LINK(5051, new byte[] {'4', '2', '0', '0', '0'}, "Db %s must be linked to %s at first"),
- ERR_CLUSTER_BACKEND_ERROR(5052, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_SRC_DB_NOT_EXIST(5048, new byte[]{'4', '2', '0', '0', '0'}, "Src db '%s' no exist"),
+ ERR_CLUSTER_DES_DB_NO_EXIT(5049, new byte[]{'4', '2', '0', '0', '0'}, "Dest db '%s' no exist"),
+ ERR_CLUSTER_NO_SELECT_CLUSTER(5050, new byte[]{'4', '2', '0', '0', '0'}, "Please enter cluster"),
+ ERR_CLUSTER_MIGRATION_NO_LINK(5051, new byte[]{'4', '2', '0', '0', '0'}, "Db %s must be linked to %s at first"),
+ ERR_CLUSTER_BACKEND_ERROR(5052, new byte[]{'4', '2', '0', '0', '0'},
"Cluster has internal error, wrong backend info"),
- ERR_CLUSTER_MIGRATION_NO_EXIT(5053, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_MIGRATION_NO_EXIT(5053, new byte[]{'4', '2', '0', '0', '0'},
"There is't migration from '%s' to '%s'"),
- ERR_CLUSTER_DB_STATE_LINK_OR_MIGRATE(5054, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_DB_STATE_LINK_OR_MIGRATE(5054, new byte[]{'4', '2', '0', '0', '0'},
"Db %s is linked or being migrated"),
- ERR_CLUSTER_MIGRATE_SAME_CLUSTER(5055, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_MIGRATE_SAME_CLUSTER(5055, new byte[]{'4', '2', '0', '0', '0'},
"Migrate or link cant't be in same cluster"),
- ERR_CLUSTER_DELETE_DB_ERR(5056, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_DELETE_DB_ERR(5056, new byte[]{'4', '2', '0', '0', '0'},
"Can't delete db '%s', linked or migrating"),
- ERR_CLUSTER_RENAME_DB_ERR(5056, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_RENAME_DB_ERR(5056, new byte[]{'4', '2', '0', '0', '0'},
"Can't rename db '%s', linked or migrating"),
- ERR_CLUSTER_MIGRATE_BE_NOT_ENOUGH(5056, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_MIGRATE_BE_NOT_ENOUGH(5056, new byte[]{'4', '2', '0', '0', '0'},
"Be in the cluster '%s' is not enough"),
- ERR_CLUSTER_ALTER_BE_NO_CHANGE(5056, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_ALTER_BE_NO_CHANGE(5056, new byte[]{'4', '2', '0', '0', '0'},
"There is %d instance already"),
- ERR_CLUSTER_ALTER_BE_IN_DECOMMISSION(5059, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_CLUSTER_ALTER_BE_IN_DECOMMISSION(5059, new byte[]{'4', '2', '0', '0', '0'},
"Cluster '%s' has backends in decommission"),
- ERR_WRONG_CLUSTER_NAME(5062, new byte[] { '4', '2', '0', '0', '0' },
+ ERR_WRONG_CLUSTER_NAME(5062, new byte[]{'4', '2', '0', '0', '0'},
"Incorrect cluster name '%s'(name 'default_cluster' is a reserved name)"),
ERR_WRONG_NAME_FORMAT(5063, new byte[]{'4', '2', '0', '0', '0'},
"Incorrect %s name '%s'"),
@@ -222,40 +1643,54 @@ public enum ErrorCode {
"Invalid dynamic partition end %s"),
ERROR_DYNAMIC_PARTITION_END_EMPTY(5066, new byte[]{'4', '2', '0', '0', '0'},
"Dynamic partition end is empty"),
- ERROR_DYNAMIC_PARTITION_BUCKETS_ZERO(5067, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_BUCKETS_ZERO(5067, new byte[]{'4', '2', '0', '0', '0'},
"Dynamic partition buckets must greater than 0"),
- ERROR_DYNAMIC_PARTITION_BUCKETS_FORMAT(5067, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_BUCKETS_FORMAT(5067, new byte[]{'4', '2', '0', '0', '0'},
"Invalid dynamic partition buckets %s"),
- ERROR_DYNAMIC_PARTITION_BUCKETS_EMPTY(5066, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_BUCKETS_EMPTY(5066, new byte[]{'4', '2', '0', '0', '0'},
"Dynamic partition buckets is empty"),
- ERROR_DYNAMIC_PARTITION_ENABLE(5068, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_ENABLE(5068, new byte[]{'4', '2', '0', '0', '0'},
"Invalid dynamic partition enable: %s. Expected true or false"),
- ERROR_DYNAMIC_PARTITION_PREFIX(5069, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_PREFIX(5069, new byte[]{'4', '2', '0', '0', '0'},
"Invalid dynamic partition prefix: %s."),
- ERR_OPERATION_DISABLED(5070, new byte[] {'4', '2', '0', '0', '0'},
+ ERR_OPERATION_DISABLED(5070, new byte[]{'4', '2', '0', '0', '0'},
"Operation %s is disabled. %s"),
- ERROR_DYNAMIC_PARTITION_REPLICATION_NUM_ZERO(5071, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_REPLICATION_NUM_ZERO(5071, new byte[]{'4', '2', '0', '0', '0'},
"Dynamic partition replication num must greater than 0"),
- ERROR_DYNAMIC_PARTITION_REPLICATION_NUM_FORMAT(5072, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_REPLICATION_NUM_FORMAT(5072, new byte[]{'4', '2', '0', '0', '0'},
"Invalid dynamic partition replication num: %s."),
- ERROR_CREATE_TABLE_LIKE_EMPTY(5073, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_CREATE_TABLE_LIKE_EMPTY(5073, new byte[]{'4', '2', '0', '0', '0'},
"Origin create table stmt is empty"),
ERROR_DYNAMIC_PARTITION_CREATE_HISTORY_PARTITION(5074, new byte[]{'4', '2', '0', '0', '0'},
"Invalid dynamic partition create_history_partition: %s. Expected true or false"),
- ERROR_DYNAMIC_PARTITION_HISTORY_PARTITION_NUM_ZERO(5075, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_HISTORY_PARTITION_NUM_ZERO(5075, new byte[]{'4', '2', '0', '0', '0'},
"Dynamic history partition num must greater than 0"),
- ERROR_DYNAMIC_PARTITION_RESERVED_HISTORY_PERIODS_EMPTY(5076, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_RESERVED_HISTORY_PERIODS_EMPTY(5076, new byte[]{'4', '2', '0', '0', '0'},
"Dynamic reserved history periods is empty."),
- ERROR_DYNAMIC_PARTITION_RESERVED_HISTORY_PERIODS_INVALID(5077, new byte[] {'4', '2', '0', '0', '0'},
- "Invalid \" %s \" value %s. It must be like \"[yyyy-MM-dd,yyyy-MM-dd],[...,...]\" while time_unit is DAY/WEEK/MONTH or \"[yyyy-MM-dd HH:mm:ss,yyyy-MM-dd HH:mm:ss],[...,...]\" while time_unit is HOUR."),
- ERROR_DYNAMIC_PARTITION_RESERVED_HISTORY_PERIODS_START_ENDS_LENGTH_NOT_EQUAL(5078, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_RESERVED_HISTORY_PERIODS_INVALID(5077, new byte[]{'4', '2', '0', '0', '0'},
+ "Invalid \" %s \" value %s. It must be like \"[yyyy-MM-dd,yyyy-MM-dd],[...,...]\" while time_unit is " +
+ "DAY/WEEK/MONTH or \"[yyyy-MM-dd HH:mm:ss,yyyy-MM-dd HH:mm:ss],[...,...]\" while time_unit is HOUR."),
+ ERROR_DYNAMIC_PARTITION_RESERVED_HISTORY_PERIODS_START_ENDS_LENGTH_NOT_EQUAL(5078, new byte[]{'4', '2', '0', '0',
+ '0'},
"RESERVED_HISTORY_PERIODS must have pairs of date value. The input %s is not valid."),
- ERROR_DYNAMIC_PARTITION_RESERVED_HISTORY_PERIODS_START_LARGER_THAN_ENDS(5079, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_DYNAMIC_PARTITION_RESERVED_HISTORY_PERIODS_START_LARGER_THAN_ENDS(5079, new byte[]{'4', '2', '0', '0', '0'},
"The first date is larger than the second date, [%s,%s] is invalid."),
- ERROR_LDAP_CONFIGURATION_ERR(5080, new byte[] {'4', '2', '0', '0', '0'},
+ ERROR_LDAP_CONFIGURATION_ERR(5080, new byte[]{'4', '2', '0', '0', '0'},
"LDAP configuration is incorrect or LDAP admin password is not set."),
- ERROR_LDAP_USER_NOT_UNIQUE_ERR(5081, new byte[] {'4', '2', '0', '0', '0'},
- "%s is not unique in LDAP server.");
+ ERROR_LDAP_USER_NOT_UNIQUE_ERR(5081, new byte[]{'4', '2', '0', '0', '0'},
+ "%s is not unique in LDAP server."),
+ ERR_ILLEGAL_COLUMN_REFERENCE_ERROR(5082, new byte[]{'4', '2', '0', '0', '1'},
+ "Illegal column/field reference '%s' of semi-/anti-join"),
+ ERR_EMPTY_PARTITION_IN_TABLE(5083, new byte[] {'4', '2', '0', '0', '0'},
+ "data cannot be inserted into table with empty partition. " +
+ "Use `SHOW PARTITIONS FROM %s` to see the currently partitions of this table. "),;
+
+ // This is error code
+ private final int code;
+ // This sql state is compatible with ANSI SQL
+ private final byte[] sqlState;
+ // Error message format
+ private final String errorMsg;
ErrorCode(int code, byte[] sqlState, String errorMsg) {
this.code = code;
@@ -263,13 +1698,6 @@ public enum ErrorCode {
this.errorMsg = errorMsg;
}
- // This is error code
- private int code;
- // This sql state is compatible with ANSI SQL
- private byte[] sqlState;
- // Error message format
- private String errorMsg;
-
public int getCode() {
return code;
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/ErrorReport.java b/fe/fe-core/src/main/java/org/apache/doris/common/ErrorReport.java
index 2bd344a..23c65b3 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/ErrorReport.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/ErrorReport.java
@@ -39,7 +39,7 @@ public class ErrorReport {
public static void reportAnalysisException(String pattern, Object... objs)
throws AnalysisException {
- throw new AnalysisException(reportCommon(pattern, ErrorCode.ERR_UNKNOWN_ERROR, objs));
+ throw new AnalysisException(reportCommon(pattern, ErrorCode.ERR_UNKNOWN_ERROR, objs), ErrorCode.ERR_UNKNOWN_ERROR);
}
public static void reportAnalysisException(ErrorCode errorCode, Object... objs)
@@ -49,7 +49,7 @@ public class ErrorReport {
public static void reportAnalysisException(String pattern, ErrorCode errorCode, Object... objs)
throws AnalysisException {
- throw new AnalysisException(reportCommon(pattern, errorCode, objs));
+ throw new AnalysisException(reportCommon(pattern, errorCode, objs), errorCode);
}
public static void reportDdlException(String pattern, Object... objs)
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java b/fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java
index 14b5ed9..0e6456b 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/MetaNotFoundException.java
@@ -25,6 +25,11 @@ public class MetaNotFoundException extends UserException {
super(InternalErrorCode.META_NOT_FOUND_ERR, msg);
}
+ public MetaNotFoundException(String msg, ErrorCode mysqlErrorCode) {
+ super(InternalErrorCode.META_NOT_FOUND_ERR, msg);
+ setMysqlErrorCode(mysqlErrorCode);
+ }
+
public MetaNotFoundException(InternalErrorCode errcode, String msg) {
super(errcode, msg);
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/UserException.java b/fe/fe-core/src/main/java/org/apache/doris/common/UserException.java
index 634cc54..e67eec7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/UserException.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/UserException.java
@@ -24,35 +24,50 @@ import com.google.common.base.Strings;
*/
public class UserException extends Exception {
private InternalErrorCode errorCode;
+ private ErrorCode mysqlErrorCode;
public UserException(String msg, Throwable cause) {
super(Strings.nullToEmpty(msg), cause);
errorCode = InternalErrorCode.INTERNAL_ERR;
+ mysqlErrorCode = ErrorCode.ERR_UNKNOWN_ERROR;
}
public UserException(Throwable cause) {
super(cause);
errorCode = InternalErrorCode.INTERNAL_ERR;
+ mysqlErrorCode = ErrorCode.ERR_UNKNOWN_ERROR;
}
public UserException(String msg, Throwable cause, boolean enableSuppression, boolean writableStackTrace) {
super(Strings.nullToEmpty(msg), cause, enableSuppression, writableStackTrace);
errorCode = InternalErrorCode.INTERNAL_ERR;
+ mysqlErrorCode = ErrorCode.ERR_UNKNOWN_ERROR;
}
public UserException(String msg) {
super(Strings.nullToEmpty(msg));
errorCode = InternalErrorCode.INTERNAL_ERR;
+ mysqlErrorCode = ErrorCode.ERR_UNKNOWN_ERROR;
}
public UserException(InternalErrorCode errCode, String msg) {
super(Strings.nullToEmpty(msg));
this.errorCode = errCode;
+ mysqlErrorCode = ErrorCode.ERR_UNKNOWN_ERROR;
+
}
public InternalErrorCode getErrorCode() {
return errorCode;
}
+ public ErrorCode getMysqlErrorCode() {
+ return mysqlErrorCode;
+ }
+
+ public void setMysqlErrorCode(ErrorCode mysqlErrorCode) {
+ this.mysqlErrorCode = mysqlErrorCode;
+ }
+
@Override
public String getMessage() {
return errorCode + ", detailMessage = " + super.getMessage();
diff --git a/fe/fe-core/src/main/java/org/apache/doris/mysql/nio/AcceptListener.java b/fe/fe-core/src/main/java/org/apache/doris/mysql/nio/AcceptListener.java
index a2e191c..6acab7e 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/mysql/nio/AcceptListener.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/mysql/nio/AcceptListener.java
@@ -17,6 +17,7 @@
package org.apache.doris.mysql.nio;
import org.apache.doris.catalog.Catalog;
+import org.apache.doris.common.ErrorCode;
import org.apache.doris.mysql.MysqlProto;
import org.apache.doris.qe.ConnectContext;
import org.apache.doris.qe.ConnectProcessor;
@@ -67,7 +68,7 @@ public class AcceptListener implements ChannelListener<AcceptingChannel<StreamCo
MysqlProto.sendResponsePacket(context);
connection.setCloseListener(streamConnection -> connectScheduler.unregisterConnection(context));
} else {
- context.getState().setError("Reach limit of connections");
+ context.getState().setError(ErrorCode.ERR_TOO_MANY_USER_CONNECTIONS, "Reach limit of connections");
MysqlProto.sendResponsePacket(context);
throw new AfterConnectedException("Reach limit of connections");
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
index 836e160..eaac1e4 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectProcessor.java
@@ -84,7 +84,7 @@ public class ConnectProcessor {
private void handleInitDb() {
String dbName = new String(packetBuf.array(), 1, packetBuf.limit() - 1);
if (Strings.isNullOrEmpty(ctx.getClusterName())) {
- ctx.getState().setError("Please enter cluster");
+ ctx.getState().setError(ErrorCode.ERR_CLUSTER_NAME_NULL, "Please enter cluster");
return;
}
dbName = ClusterNamespace.getFullName(ctx.getClusterName(), dbName);
@@ -177,7 +177,7 @@ public class ConnectProcessor {
} catch (UnsupportedEncodingException e) {
// impossible
LOG.error("UTF8 is not supported in this environment.");
- ctx.getState().setError("Unsupported character set(UTF-8)");
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_CHARACTER_SET, "Unsupported character set(UTF-8)");
return;
}
String sqlHash = DigestUtils.md5Hex(originStmt);
@@ -186,7 +186,7 @@ public class ConnectProcessor {
Catalog.getCurrentCatalog().getSqlBlockRuleMgr().matchSql(originStmt, sqlHash, ctx.getQualifiedUser());
} catch (AnalysisException e) {
LOG.warn(e.getMessage());
- ctx.getState().setError(e.getMessage());
+ ctx.getState().setError(e.getMysqlErrorCode(), e.getMessage());
return;
}
ctx.getAuditEventBuilder().reset();
@@ -226,17 +226,18 @@ public class ConnectProcessor {
} catch (IOException e) {
// Client failed.
LOG.warn("Process one query failed because IOException: ", e);
- ctx.getState().setError("Doris process failed");
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_ERROR, "Doris process failed");
} catch (UserException e) {
LOG.warn("Process one query failed because.", e);
- ctx.getState().setError(e.getMessage());
+ ctx.getState().setError(e.getMysqlErrorCode(), e.getMessage());
// set is as ANALYSIS_ERR so that it won't be treated as a query failure.
ctx.getState().setErrType(QueryState.ErrType.ANALYSIS_ERR);
} catch (Throwable e) {
// Catch all throwable.
// If reach here, maybe palo bug.
LOG.warn("Process one query failed because unknown reason: ", e);
- ctx.getState().setError(e.getClass().getSimpleName() + ", msg: " + e.getMessage());
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_ERROR,
+ e.getClass().getSimpleName() + ", msg: " + e.getMessage());
if (parsedStmt instanceof KillStmt) {
// ignore kill stmt execute err(not monitor it)
ctx.getState().setErrType(QueryState.ErrType.ANALYSIS_ERR);
@@ -296,17 +297,17 @@ public class ConnectProcessor {
return;
}
if (Strings.isNullOrEmpty(tableName)) {
- ctx.getState().setError("Empty tableName");
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_TABLE, "Empty tableName");
return;
}
Database db = ctx.getCatalog().getDbNullable(ctx.getDatabase());
if (db == null) {
- ctx.getState().setError("Unknown database(" + ctx.getDatabase() + ")");
+ ctx.getState().setError(ErrorCode.ERR_BAD_DB_ERROR, "Unknown database(" + ctx.getDatabase() + ")");
return;
}
Table table = db.getTableNullable(tableName);
if (table == null) {
- ctx.getState().setError("Unknown table(" + tableName + ")");
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_TABLE, "Unknown table(" + tableName + ")");
return;
}
@@ -335,7 +336,7 @@ public class ConnectProcessor {
MysqlCommand command = MysqlCommand.fromCode(code);
if (command == null) {
ErrorReport.report(ErrorCode.ERR_UNKNOWN_COM_ERROR);
- ctx.getState().setError("Unknown command(" + command + ")");
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_COM_ERROR, "Unknown command(" + command + ")");
LOG.warn("Unknown command(" + command + ")");
return;
}
@@ -359,7 +360,7 @@ public class ConnectProcessor {
handlePing();
break;
default:
- ctx.getState().setError("Unsupported command(" + command + ")");
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_COM_ERROR, "Unsupported command(" + command + ")");
LOG.warn("Unsupported command(" + command + ")");
break;
}
@@ -480,7 +481,9 @@ public class ConnectProcessor {
// so ctx.getCurrentUserIdentity() will get null, and causing NullPointerException after using it.
// return error directly.
TMasterOpResult result = new TMasterOpResult();
- ctx.getState().setError("Missing current user identity. You need to upgrade this Frontend to the same version as Master Frontend.");
+ ctx.getState().setError(ErrorCode.ERR_ACCESS_DENIED_ERROR, "Missing current user identity. You need to upgrade this Frontend " +
+ "to the " +
+ "same version as Master Frontend.");
result.setMaxJournalId(Catalog.getCurrentCatalog().getMaxJournalId().longValue());
result.setPacket(getResultPacket());
return result;
@@ -503,12 +506,12 @@ public class ConnectProcessor {
} catch (IOException e) {
// Client failed.
LOG.warn("Process one query failed because IOException: ", e);
- ctx.getState().setError("Doris process failed: " + e.getMessage());
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_ERROR, "Doris process failed: " + e.getMessage());
} catch (Throwable e) {
// Catch all throwable.
// If reach here, maybe Doris bug.
LOG.warn("Process one query failed because unknown reason: ", e);
- ctx.getState().setError("Unexpected exception: " + e.getMessage());
+ ctx.getState().setError(ErrorCode.ERR_UNKNOWN_ERROR, "Unexpected exception: " + e.getMessage());
}
// no matter the master execute success or fail, the master must transfer the result to follower
// and tell the follower the current journalID.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java
index 6501a9a..08039da 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ConnectScheduler.java
@@ -19,6 +19,7 @@ package org.apache.doris.qe;
import org.apache.doris.catalog.Catalog;
import org.apache.doris.common.Config;
+import org.apache.doris.common.ErrorCode;
import org.apache.doris.common.ThreadPoolManager;
import org.apache.doris.ldap.LdapAuthenticate;
import org.apache.doris.mysql.MysqlProto;
@@ -173,7 +174,7 @@ public class ConnectScheduler {
if (registerConnection(context)) {
MysqlProto.sendResponsePacket(context);
} else {
- context.getState().setError("Reach limit of connections");
+ context.getState().setError(ErrorCode.ERR_USER_LIMIT_REACHED, "Reach limit of connections");
MysqlProto.sendResponsePacket(context);
return;
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
index 8f95d0c..d7a4c0f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
@@ -165,6 +165,8 @@ public class SessionVariable implements Serializable, Writable {
public static final String ENABLE_LATERAL_VIEW = "enable_lateral_view";
+ public static final String SQL_QUOTE_SHOW_CREATE = "sql_quote_show_create";
+
// session origin value
public Map<Field, String> sessionOriginValue = new HashMap<Field, String>();
// check stmt is or not [select /*+ SET_VAR(...)*/ ...]
@@ -390,6 +392,9 @@ public class SessionVariable implements Serializable, Writable {
@VariableMgr.VarAttr(name = DISABLE_JOIN_REORDER)
private boolean disableJoinReorder = false;
+ @VariableMgr.VarAttr(name = SQL_QUOTE_SHOW_CREATE)
+ public boolean sqlQuoteShowCreate = true;
+
public long getMaxExecMemByte() {
return maxExecMemByte;
}
@@ -520,6 +525,13 @@ public class SessionVariable implements Serializable, Writable {
}
}
+ public boolean isSqlQuoteShowCreate() {
+ return sqlQuoteShowCreate;
+ }
+
+ public void setSqlQuoteShowCreate(boolean sqlQuoteShowCreate) {
+ this.sqlQuoteShowCreate = sqlQuoteShowCreate;
+ }
public void setLoadMemLimit(long loadMemLimit) {
this.loadMemLimit = loadMemLimit;
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java
index 2e03b71..30e8a53 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/ShowExecutor.java
@@ -1110,7 +1110,7 @@ public class ShowExecutor {
// forward compatibility
if (!Catalog.getCurrentCatalog().getAuth().checkDbPriv(ConnectContext.get(), db.getFullName(),
PrivPredicate.SHOW)) {
- ErrorReport.reportAnalysisException(ErrorCode.ERR_DB_ACCESS_DENIED,
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_DBACCESS_DENIED_ERROR,
ConnectContext.get().getQualifiedUser(),
db.getFullName());
}
@@ -1483,7 +1483,8 @@ public class ShowExecutor {
Long id = olapTable.getIndexIdByName(indexName);
if (id == null) {
// invalid indexName
- ErrorReport.reportAnalysisException(ErrorCode.ERR_BAD_TABLE_ERROR, showStmt.getIndexName());
+ ErrorReport.reportAnalysisException(ErrorCode.ERR_UNKNOWN_TABLE, showStmt.getIndexName(),
+ showStmt.getDbName());
}
indexId = id;
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
index 2804265..f99205d 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/StmtExecutor.java
@@ -27,6 +27,7 @@ import org.apache.doris.analysis.Expr;
import org.apache.doris.analysis.InsertStmt;
import org.apache.doris.analysis.KillStmt;
import org.apache.doris.analysis.LiteralExpr;
+import org.apache.doris.analysis.LockTablesStmt;
import org.apache.doris.analysis.NullLiteral;
import org.apache.doris.analysis.OutFileClause;
import org.apache.doris.analysis.QueryStmt;
@@ -45,6 +46,7 @@ import org.apache.doris.analysis.TransactionBeginStmt;
import org.apache.doris.analysis.TransactionCommitStmt;
import org.apache.doris.analysis.TransactionRollbackStmt;
import org.apache.doris.analysis.TransactionStmt;
+import org.apache.doris.analysis.UnlockTablesStmt;
import org.apache.doris.analysis.UnsupportedStmt;
import org.apache.doris.analysis.UseStmt;
import org.apache.doris.catalog.Catalog;
@@ -398,25 +400,30 @@ public class StmtExecutor implements ProfileWriter {
handleKill();
} else if (parsedStmt instanceof ExportStmt) {
handleExportStmt();
+ } else if (parsedStmt instanceof UnlockTablesStmt) {
+ handleUnlockTablesStmt();
+ } else if (parsedStmt instanceof LockTablesStmt) {
+ handleLockTablesStmt();
} else if (parsedStmt instanceof UnsupportedStmt) {
handleUnsupportedStmt();
} else {
- context.getState().setError("Do not support this query.");
+ context.getState().setError(ErrorCode.ERR_NOT_SUPPORTED_YET, "Do not support this query.");
}
} catch (IOException e) {
LOG.warn("execute IOException ", e);
// the exception happens when interact with client
// this exception shows the connection is gone
- context.getState().setError(e.getMessage());
+ context.getState().setError(ErrorCode.ERR_UNKNOWN_ERROR, e.getMessage());
throw e;
} catch (UserException e) {
// analysis exception only print message, not print the stack
LOG.warn("execute Exception. {}", e.getMessage());
- context.getState().setError(e.getMessage());
+ context.getState().setError(e.getMysqlErrorCode(), e.getMessage());
context.getState().setErrType(QueryState.ErrType.ANALYSIS_ERR);
} catch (Exception e) {
LOG.warn("execute Exception", e);
- context.getState().setError(e.getClass().getSimpleName() + ", msg: " + e.getMessage());
+ context.getState().setError(ErrorCode.ERR_UNKNOWN_ERROR,
+ e.getClass().getSimpleName() + ", msg: " + e.getMessage());
if (parsedStmt instanceof KillStmt) {
// ignore kill stmt execute err(not monitor it)
context.getState().setErrType(QueryState.ErrType.ANALYSIS_ERR);
@@ -431,7 +438,7 @@ public class StmtExecutor implements ProfileWriter {
sessionVariable.clearSessionOriginValue();
} catch (DdlException e) {
LOG.warn("failed to revert Session value.", e);
- context.getState().setError(e.getMessage());
+ context.getState().setError(e.getMysqlErrorCode(), e.getMessage());
}
if (!context.isTxnModel() && parsedStmt instanceof InsertStmt) {
InsertStmt insertStmt = (InsertStmt) parsedStmt;
@@ -701,7 +708,7 @@ public class StmtExecutor implements ProfileWriter {
executor.execute();
} catch (DdlException e) {
// Return error message to client.
- context.getState().setError(e.getMessage());
+ context.getState().setError(ErrorCode.ERR_LOCAL_VARIABLE, e.getMessage());
return;
}
context.getState().setOk();
@@ -1224,7 +1231,8 @@ public class StmtExecutor implements ProfileWriter {
// if in strict mode, insert will fail if there are filtered rows
if (context.getSessionVariable().getEnableInsertStrict()) {
if (filteredRows > 0) {
- context.getState().setError("Insert has filtered data in strict mode, tracking_url="
+ context.getState().setError(ErrorCode.ERR_FAILED_WHEN_INSERT, "Insert has filtered data in strict mode, " +
+ "tracking_url="
+ coord.getTrackingUrl());
return;
}
@@ -1271,7 +1279,7 @@ public class StmtExecutor implements ProfileWriter {
if (!Strings.isNullOrEmpty(coord.getTrackingUrl())) {
sb.append(". url: " + coord.getTrackingUrl());
}
- context.getState().setError(sb.toString());
+ context.getState().setError(ErrorCode.ERR_UNKNOWN_ERROR, sb.toString());
return;
}
@@ -1342,7 +1350,7 @@ public class StmtExecutor implements ProfileWriter {
}
context.getCatalog().changeDb(context, useStmt.getDatabase());
} catch (DdlException e) {
- context.getState().setError(e.getMessage());
+ context.getState().setError(e.getMysqlErrorCode(), e.getMessage());
return;
}
context.getState().setOk();
@@ -1420,6 +1428,10 @@ public class StmtExecutor implements ProfileWriter {
sendResult(resultSet);
}
+ private void handleUnlockTablesStmt() {
+ }
+ private void handleLockTablesStmt() {
+ }
private void handleExplainStmt(String result) throws IOException {
ShowResultSetMetaData metaData =
ShowResultSetMetaData.builder()
@@ -1445,11 +1457,11 @@ public class StmtExecutor implements ProfileWriter {
} catch (UserException e) {
// Return message to info client what happened.
LOG.debug("DDL statement({}) process failed.", originStmt.originStmt, e);
- context.getState().setError(e.getMessage());
+ context.getState().setError(e.getMysqlErrorCode(), e.getMessage());
} catch (Exception e) {
// Maybe our bug
LOG.warn("DDL statement(" + originStmt.originStmt + ") process failed.", e);
- context.getState().setError("Unexpected exception: " + e.getMessage());
+ context.getState().setError(ErrorCode.ERR_UNKNOWN_ERROR, "Unexpected exception: " + e.getMessage());
}
}
@@ -1460,7 +1472,7 @@ public class StmtExecutor implements ProfileWriter {
context.getCatalog().changeCluster(context, enterStmt.getClusterName());
context.setDatabase("");
} catch (DdlException e) {
- context.getState().setError(e.getMessage());
+ context.getState().setError(e.getMysqlErrorCode(), e.getMessage());
return;
}
context.getState().setOk();
diff --git a/fe/fe-core/src/main/jflex/sql_scanner.flex b/fe/fe-core/src/main/jflex/sql_scanner.flex
index f52f3a6..a4945e2 100644
--- a/fe/fe-core/src/main/jflex/sql_scanner.flex
+++ b/fe/fe-core/src/main/jflex/sql_scanner.flex
@@ -188,10 +188,12 @@ import org.apache.doris.qe.SqlModeHelper;
keywordMap.put("exists", new Integer(SqlParserSymbols.KW_EXISTS));
keywordMap.put("explain", new Integer(SqlParserSymbols.KW_DESCRIBE));
keywordMap.put("export", new Integer(SqlParserSymbols.KW_EXPORT));
+ keywordMap.put("extended", new Integer(SqlParserSymbols.KW_EXTENDED));
keywordMap.put("external", new Integer(SqlParserSymbols.KW_EXTERNAL));
keywordMap.put("extract", new Integer(SqlParserSymbols.KW_EXTRACT));
keywordMap.put("false", new Integer(SqlParserSymbols.KW_FALSE));
keywordMap.put("feature", new Integer(SqlParserSymbols.KW_FEATURE));
+ keywordMap.put("fields", new Integer(SqlParserSymbols.KW_FIELDS));
keywordMap.put("file", new Integer(SqlParserSymbols.KW_FILE));
keywordMap.put("filter", new Integer(SqlParserSymbols.KW_FILTER));
keywordMap.put("first", new Integer(SqlParserSymbols.KW_FIRST));
@@ -228,6 +230,7 @@ import org.apache.doris.qe.SqlModeHelper;
keywordMap.put("indexes", new Integer(SqlParserSymbols.KW_INDEXES));
keywordMap.put("infile", new Integer(SqlParserSymbols.KW_INFILE));
keywordMap.put("inner", new Integer(SqlParserSymbols.KW_INNER));
+ keywordMap.put("inner", new Integer(SqlParserSymbols.KW_INNER));
keywordMap.put("insert", new Integer(SqlParserSymbols.KW_INSERT));
keywordMap.put("int", new Integer(SqlParserSymbols.KW_INT));
keywordMap.put("integer", new Integer(SqlParserSymbols.KW_INT));
@@ -258,6 +261,8 @@ import org.apache.doris.qe.SqlModeHelper;
keywordMap.put("load", new Integer(SqlParserSymbols.KW_LOAD));
keywordMap.put("local", new Integer(SqlParserSymbols.KW_LOCAL));
keywordMap.put("location", new Integer(SqlParserSymbols.KW_LOCATION));
+ keywordMap.put("lock", new Integer(SqlParserSymbols.KW_LOCK));
+ keywordMap.put("low_priority", new Integer(SqlParserSymbols.KW_LOW_PRIORITY));
keywordMap.put("map", new Integer(SqlParserSymbols.KW_MAP));
keywordMap.put("materialized", new Integer(SqlParserSymbols.KW_MATERIALIZED));
keywordMap.put("max", new Integer(SqlParserSymbols.KW_MAX));
@@ -394,6 +399,7 @@ import org.apache.doris.qe.SqlModeHelper;
keywordMap.put("user", new Integer(SqlParserSymbols.KW_USER));
keywordMap.put("using", new Integer(SqlParserSymbols.KW_USING));
keywordMap.put("uninstall", new Integer(SqlParserSymbols.KW_UNINSTALL));
+ keywordMap.put("unlock", new Integer(SqlParserSymbols.KW_UNLOCK));
keywordMap.put("update", new Integer(SqlParserSymbols.KW_UPDATE));
keywordMap.put("value", new Integer(SqlParserSymbols.KW_VALUE));
keywordMap.put("values", new Integer(SqlParserSymbols.KW_VALUES));
diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableAsSelectStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableAsSelectStmtTest.java
index 28b72bc..7804f6c 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableAsSelectStmtTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateTableAsSelectStmtTest.java
@@ -63,7 +63,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");";
+ ")";
String decimalTable = "CREATE TABLE `test`.`decimal_table`\n" +
"(\n" +
" `userId` varchar(255) NOT NULL COMMENT '',\n" +
@@ -75,7 +75,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");";
+ ")";
String joinTable = "CREATE TABLE `test`.`join_table`\n" +
"(\n" +
" `userId` varchar(255) NOT NULL COMMENT '',\n" +
@@ -87,7 +87,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");";
+ ")";
MetricRepo.init();
createTable(varcharTable);
createTable(decimalTable);
@@ -142,7 +142,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet.getResultRows().get(0).get(1));
+ ")", showResultSet.getResultRows().get(0).get(1));
}
@Test
@@ -161,7 +161,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet1.getResultRows().get(0).get(1));
+ ")", showResultSet1.getResultRows().get(0).get(1));
String selectFromFunction2 = "create table `test`.`select_function_2` PROPERTIES(\"replication_num\" = \"1\") as select sum(status), sum(status), sum(status), count(status), count(status) from `test`.`join_table`";
createTableAsSelect(selectFromFunction2);
@@ -180,7 +180,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet2.getResultRows().get(0).get(1));
+ ")", showResultSet2.getResultRows().get(0).get(1));
}
@Test
@@ -198,7 +198,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet1.getResultRows().get(0).get(1));
+ ")", showResultSet1.getResultRows().get(0).get(1));
String selectAlias2 = "create table `test`.`select_alias_2` PROPERTIES(\"replication_num\" = \"1\") as select userId as alias_name, username from `test`.`varchar_table`";
createTableAsSelect(selectAlias2);
ShowResultSet showResultSet2 = showCreateTable("select_alias_2");
@@ -213,7 +213,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet2.getResultRows().get(0).get(1));
+ ")", showResultSet2.getResultRows().get(0).get(1));
}
@Test
@@ -234,7 +234,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet.getResultRows().get(0).get(1));
+ ")", showResultSet.getResultRows().get(0).get(1));
}
@Test
@@ -255,7 +255,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet.getResultRows().get(0).get(1));
+ ")", showResultSet.getResultRows().get(0).get(1));
}
@Test
@@ -274,7 +274,7 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet.getResultRows().get(0).get(1));
+ ")", showResultSet.getResultRows().get(0).get(1));
}
@Test
@@ -293,6 +293,6 @@ public class CreateTableAsSelectStmtTest {
"\"replication_allocation\" = \"tag.location.default: 1\",\n" +
"\"in_memory\" = \"false\",\n" +
"\"storage_format\" = \"V2\"\n" +
- ");", showResultSet.getResultRows().get(0).get(1));
+ ")", showResultSet.getResultRows().get(0).get(1));
}
}
diff --git a/fe/pom.xml b/fe/pom.xml
index 253c095..be836f1 100644
--- a/fe/pom.xml
+++ b/fe/pom.xml
@@ -266,7 +266,7 @@ under the License.
<dependency>
<groupId>org.jmockit</groupId>
<artifactId>jmockit</artifactId>
- <version>1.48</version>
+ <version>1.49</version>
<scope>test</scope>
</dependency>
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org