@@ -101,8 +101,9 @@ ngs::Error_code Crud_command_handler::execute_crud_insert(
101101 ngs::Error_code error = id_agg.configue (&m_session->data_context ());
102102 if (error) return error;
103103
104+ const auto is_relational = is_table_data_model (msg);
104105 Expression_generator gen (&m_qb, msg.args (), msg.collection ().schema (),
105- is_table_data_model (msg) );
106+ is_relational );
106107 Empty_resultset rset;
107108 return execute (Insert_statement_builder (gen, &id_agg), msg, rset,
108109 &ngs::Common_status_variables::m_crud_insert,
@@ -155,8 +156,9 @@ void Crud_command_handler::notice_handling(
155156// -- Update
156157ngs::Error_code Crud_command_handler::execute_crud_update (
157158 const Mysqlx::Crud::Update &msg) {
159+ const auto is_relational = is_table_data_model (msg);
158160 Expression_generator gen (&m_qb, msg.args (), msg.collection ().schema (),
159- is_table_data_model (msg) );
161+ is_relational );
160162 Empty_resultset rset;
161163 return execute (Update_statement_builder (gen), msg, rset,
162164 &ngs::Common_status_variables::m_crud_update,
@@ -196,8 +198,9 @@ void Crud_command_handler::notice_handling(
196198// -- Delete
197199ngs::Error_code Crud_command_handler::execute_crud_delete (
198200 const Mysqlx::Crud::Delete &msg) {
201+ const auto is_relational = is_table_data_model (msg);
199202 Expression_generator gen (&m_qb, msg.args (), msg.collection ().schema (),
200- is_table_data_model (msg) );
203+ is_relational );
201204 Empty_resultset rset;
202205 return execute (Delete_statement_builder (gen), msg, rset,
203206 &ngs::Common_status_variables::m_crud_delete,
@@ -216,8 +219,9 @@ void Crud_command_handler::notice_handling(
216219// -- Find
217220ngs::Error_code Crud_command_handler::execute_crud_find (
218221 const Mysqlx::Crud::Find &msg) {
222+ const auto is_relational = is_table_data_model (msg);
219223 Expression_generator gen (&m_qb, msg.args (), msg.collection ().schema (),
220- is_table_data_model (msg) );
224+ is_relational );
221225 Streaming_resultset<Crud_command_delegate> rset (m_session, false );
222226 return execute (Find_statement_builder (gen), msg, rset,
223227 &ngs::Common_status_variables::m_crud_find, nullptr );
0 commit comments