wsrep_consistency_check only handled on SQLCOM_INSERT_SELECT

[Ben Mildren]

pt-table-checksum uses REPLACE ... SELECT to create a checksum of chunks of data, I believe the wsrep_consistency_check was introduced to ensure the isolation would support this process, however it looks like the wsrep_consistency_check is only handled on SQLCOM_INSERT_SELECT and not SQLCOM_REPLACE_SELECT.
In order for pt-table-checksum to be re-runnable it makes sense for it to use SQLCOM_REPLACE_SELECT as opposed to SQLCOM_INSERT_SELECT, so it looks like the wsrep_consistency_check should also/alternatively be applied to the SQLCOM_REPLACE_SELECT.

----------------------
modified sql_parse.cc:
----------------------
#ifdef WITH_WSREP
    if (lex->sql_command == SQLCOM_INSERT_SELECT &&
 thd->wsrep_consistency_check == CONSISTENCY_CHECK_DECLARED)
    {
      thd->wsrep_consistency_check = CONSISTENCY_CHECK_RUNNING;
      WSREP_TO_ISOLATION_BEGIN(first_table->db, first_table->table_name, NULL);
    }

....

    if (lex->sql_command == SQLCOM_REPLACE_SELECT)
      lex->set_stmt_unsafe(LEX::BINLOG_STMT_UNSAFE_REPLACE_SELECT);

-----------------------
pt-table-checksum code:
-----------------------
   my $checksum_dml = "REPLACE INTO $repl_table "
                    . "(db, tbl, chunk, chunk_index,"
                    . " lower_boundary, upper_boundary, this_cnt, this_crc) "
                    . "SELECT"
                    . ($cluster->is_cluster_node($master_cxn) ? ' /*!99997*/' : '')
                    . " ?, ?, ?, ?, ?, ?,";

[Alex Yurchenko (ayurchen)]

yes, it looks like removing SQLCOM_INSERT_SELECT check from the if() statement could fix it.

[Nilnandan Joshi (nilnandan-joshi)]

Verified with PXC 5.5 and 5.6

----------------------
sql_parse.cc:
----------------------

#ifdef WITH_WSREP
    if (lex->sql_command == SQLCOM_INSERT_SELECT &&
 thd->wsrep_consistency_check == CONSISTENCY_CHECK_DECLARED)
    {
      thd->wsrep_consistency_check = CONSISTENCY_CHECK_RUNNING;
      WSREP_TO_ISOLATION_BEGIN(first_table->db, first_table->table_name, NULL);
    }

-----------------------
pt-table-checksum code:
-----------------------

# ########################################################################
   # Checksum args and the DMS part of the checksum query for each table.
   # ########################################################################
   my %crc_args = $rc->get_crc_args(dbh => $master_dbh);
   my $checksum_dml = "REPLACE INTO $repl_table "
                    . "(db, tbl, chunk, chunk_index,"
                    . " lower_boundary, upper_boundary, this_cnt, this_crc) "
                    . "SELECT"
                    . ($cluster->is_cluster_node($master_cxn) ? ' /*!99997*/' : '')
                    . " ?, ?, ?, ?, ?, ?,";
   my $past_cols = " COUNT(*), '0'";

[Seppo Jaakola (seppo-jaakola)]

Pushed the fixes in revisions:
wsrep-5.5: http://bazaar.launchpad.net/~codership/codership-mysql/wsrep-5.5/revision/4012
wsrep-5.6: http://bazaar.launchpad.net/~codership/codership-mysql/5.6/revision/4119

[Shahriyar Rzayev (rzayev-sehriyar)]

Percona now uses JIRA for bug reports so this bug report is migrated to: https://jira.percona.com/browse/PXC-1702