hcq/oceanbase
1
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

fix create mview with null value

Browse Source
This commit is contained in:
hy-guo
2024-06-20 09:50:18 +00:00
committed by ob-robot
parent 6dc5a3f6cb
commit 1820122dd8
2 changed files with 19 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
src/sql/resolver/ddl/ob_create_view_resolver.cpp
View File

@ -321,7 +321,8 @@ int ObCreateViewResolver::resolve(const ParseNode &parse_tree)
*allocator_, *allocator_,
*session_info_, *session_info_,
column_list, column_list,
comment_list))) { comment_list,
params_.is_from_create_mview_))) {
LOG_WARN("failed to add column infos", K(ret)); LOG_WARN("failed to add column infos", K(ret));
} else if ((!resolve_succ || add_undefined_columns) } else if ((!resolve_succ || add_undefined_columns)
&& is_force_view && lib::is_oracle_mode() && is_force_view && lib::is_oracle_mode()
@ -1652,7 +1653,8 @@ int ObCreateViewResolver::add_column_infos(const uint64_t tenant_id,
ObIAllocator &alloc, ObIAllocator &alloc,
ObSQLSessionInfo &session_info, ObSQLSessionInfo &session_info,
const ObIArray<ObString> &column_list, const ObIArray<ObString> &column_list,
const ObIArray<ObString> &comment_list) const ObIArray<ObString> &comment_list,
bool is_from_create_mview /* =false */)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObIArray<SelectItem> &select_items = select_stmt.get_select_items(); ObIArray<SelectItem> &select_items = select_stmt.get_select_items();
@ -1694,7 +1696,8 @@ int ObCreateViewResolver::add_column_infos(const uint64_t tenant_id,
} else if (OB_FAIL(fill_column_meta_infos(*expr, } else if (OB_FAIL(fill_column_meta_infos(*expr,
table_schema.get_charset_type(), table_schema.get_charset_type(),
table_schema.get_table_id(), table_schema.get_table_id(),
column))) { column,
is_from_create_mview))) {
LOG_WARN("failed to fill column meta infos", K(ret), K(column)); LOG_WARN("failed to fill column meta infos", K(ret), K(column));
} else if (lib::is_mysql_mode() && } else if (lib::is_mysql_mode() &&
OB_FAIL(resolve_column_default_value(&select_stmt, select_item, column, alloc, session_info))) { OB_FAIL(resolve_column_default_value(&select_stmt, select_item, column, alloc, session_info))) {
@ -1713,7 +1716,8 @@ int ObCreateViewResolver::add_column_infos(const uint64_t tenant_id,
int ObCreateViewResolver::fill_column_meta_infos(const ObRawExpr &expr, int ObCreateViewResolver::fill_column_meta_infos(const ObRawExpr &expr,
const ObCharsetType charset_type, const ObCharsetType charset_type,
const uint64_t table_id, const uint64_t table_id,
ObColumnSchemaV2 &column) ObColumnSchemaV2 &column,
bool is_from_create_mview /* =false */)
{ {
int ret = OB_SUCCESS; int ret = OB_SUCCESS;
ObObjMeta column_meta = expr.get_result_type().get_obj_meta(); ObObjMeta column_meta = expr.get_result_type().get_obj_meta();
@ -1728,7 +1732,13 @@ int ObCreateViewResolver::fill_column_meta_infos(const ObRawExpr &expr,
column.set_collation_type(expr.get_collation_type()); column.set_collation_type(expr.get_collation_type());
column.set_accuracy(expr.get_accuracy()); column.set_accuracy(expr.get_accuracy());
column.set_zero_fill(expr.get_result_type().has_result_flag(ZEROFILL_FLAG)); column.set_zero_fill(expr.get_result_type().has_result_flag(ZEROFILL_FLAG));
column.set_nullable(expr.get_result_type().is_not_null_for_read() ? false : true); if (is_from_create_mview) {
// bug fix for
// mview should not set not null
column.set_nullable(true);
} else {
column.set_nullable(expr.get_result_type().is_not_null_for_read() ? false : true);
}
if (OB_FAIL(ret)) { if (OB_FAIL(ret)) {
} else if (column.is_enum_or_set() && OB_FAIL(column.set_extended_type_info(expr.get_enum_set_values()))) { } else if (column.is_enum_or_set() && OB_FAIL(column.set_extended_type_info(expr.get_enum_set_values()))) {
LOG_WARN("set enum or set info failed", K(ret), K(expr)); LOG_WARN("set enum or set info failed", K(ret), K(expr));

6
src/sql/resolver/ddl/ob_create_view_resolver.h
View File

@ -71,11 +71,13 @@ public:
common::ObIAllocator &alloc, common::ObIAllocator &alloc,
sql::ObSQLSessionInfo &session_info, sql::ObSQLSessionInfo &session_info,
const common::ObIArray<ObString> &column_list, const common::ObIArray<ObString> &column_list,
const common::ObIArray<ObString> &comment_list); const common::ObIArray<ObString> &comment_list,
bool is_from_create_mview = false);
static int fill_column_meta_infos(const ObRawExpr &expr, static int fill_column_meta_infos(const ObRawExpr &expr,
const ObCharsetType charset_type, const ObCharsetType charset_type,
const uint64_t table_id, const uint64_t table_id,
ObColumnSchemaV2 &column); ObColumnSchemaV2 &column,
bool is_from_create_mview = false);
static int resolve_column_default_value(const sql::ObSelectStmt *select_stmt, static int resolve_column_default_value(const sql::ObSelectStmt *select_stmt,
const sql::SelectItem &select_item, const sql::SelectItem &select_item,
schema::ObColumnSchemaV2 &column_schema, schema::ObColumnSchemaV2 &column_schema,