[Commits] d6feda205af: Merge tag 'mariadb-10.0.38' into 10.0-galera

1 Feb 2019

--- a/storage/innobase/handler/ha_innodb.cc
+++ b/storage/innobase/handler/ha_innodb.cc
@@@ -9825,446 -9041,6 +9822,435 @@@ next_record
  	return(HA_ERR_END_OF_FILE);
  }
  
- /*************************************************************************
- */
- 
- void
- ha_innobase::ft_end()
- {
- 	fprintf(stderr, "ft_end()\n");
- 
- 	rnd_end();
- }
 +#ifdef WITH_WSREP
 +extern dict_index_t*
 +wsrep_dict_foreign_find_index(
 +	dict_table_t*	table,
 +	const char**	col_names,
 +	const char**	columns,
 +	ulint		n_cols,
 +	dict_index_t*	types_idx,
 +	ibool		check_charsets,
 +	ulint		check_null);
 +
 +inline
 +const char*
 +wsrep_key_type_to_str(wsrep_key_type type)
 +{
 +	switch (type) {
 +	case WSREP_KEY_SHARED:
 +		return "shared";
 +	case WSREP_KEY_SEMI:
 +		return "semi";
 +	case WSREP_KEY_EXCLUSIVE:
 +		return "exclusive";
 +	};
 +	return "unknown";
 +}
 +
 +ulint
 +wsrep_append_foreign_key(
 +/*===========================*/
 +	trx_t*		trx,		/*!< in: trx */
 +	dict_foreign_t*	foreign,	/*!< in: foreign key constraint */
 +	const rec_t*	rec,		/*!<in: clustered index record */
 +	dict_index_t*	index,		/*!<in: clustered index */
 +	ibool		referenced,	/*!<in: is check for referenced table */
 +	wsrep_key_type	key_type)	/*!< in: access type of this key
 +					(shared, exclusive, semi...) */
 +{
 +	ut_a(trx);
 +	THD*  thd = (THD*)trx->mysql_thd;
 +	ulint rcode = DB_SUCCESS;
 +	char  cache_key[513] = {'\0'};
 +	int   cache_key_len;
 +    bool const copy = true;
 +
 +	if (!wsrep_on(trx->mysql_thd) ||
 +	    wsrep_thd_exec_mode(thd) != LOCAL_STATE)
 +		return DB_SUCCESS;
 +
 +	if (!thd || !foreign ||
 +	    (!foreign->referenced_table && !foreign->foreign_table))
 +	{
 +		WSREP_INFO("FK: %s missing in: %s",
 +			(!thd)      ?  "thread"     :
 +			((!foreign) ?  "constraint" :
 +			((!foreign->referenced_table) ?
 +			     "referenced table" : "foreign table")),
 +			   (thd && wsrep_thd_query(thd)) ?
 +			   wsrep_thd_query(thd) : "void");
 +		return DB_ERROR;
 +	}
 +
 +	if ( !((referenced) ?
 +		foreign->referenced_table : foreign->foreign_table))
 +	{
 +		WSREP_DEBUG("pulling %s table into cache",
 +			    (referenced) ? "referenced" : "foreign");
 +		mutex_enter(&(dict_sys->mutex));
 +		if (referenced)
 +		{
 +			foreign->referenced_table =
 +				dict_table_get_low(
 +					foreign->referenced_table_name_lookup);
 +			if (foreign->referenced_table)
 +			{
 +				foreign->referenced_index =
 +					wsrep_dict_foreign_find_index(
 +						foreign->referenced_table, NULL,
 +						foreign->referenced_col_names,
 +						foreign->n_fields, 
 +						foreign->foreign_index,
 +						TRUE, FALSE);
 +			}
 +		}
 +		else
 +		{
 +	  		foreign->foreign_table =
 +				dict_table_get_low(
 +					foreign->foreign_table_name_lookup);
 +			if (foreign->foreign_table)
 +			{
 +				foreign->foreign_index =
 +					wsrep_dict_foreign_find_index(
 +						foreign->foreign_table, NULL,
 +						foreign->foreign_col_names,
 +						foreign->n_fields,
 +						foreign->referenced_index, 
 +						TRUE, FALSE);
 +			}
 +		}
 +		mutex_exit(&(dict_sys->mutex));
 +	}
 +
 +	if ( !((referenced) ?
 +		foreign->referenced_table : foreign->foreign_table))
 +	{
 +		WSREP_WARN("FK: %s missing in query: %s",
 +			   (!foreign->referenced_table) ?
 +			   "referenced table" : "foreign table",
 +			   (wsrep_thd_query(thd)) ?
 +			   wsrep_thd_query(thd) : "void");
 +		return DB_ERROR;
 +	}
 +	byte  key[WSREP_MAX_SUPPORTED_KEY_LENGTH+1] = {'\0'};
 +	ulint len = WSREP_MAX_SUPPORTED_KEY_LENGTH;
 +
 +	dict_index_t *idx_target = (referenced) ?
 +		foreign->referenced_index : index;
 +	dict_index_t *idx = (referenced) ?
 +		UT_LIST_GET_FIRST(foreign->referenced_table->indexes) :
 +		UT_LIST_GET_FIRST(foreign->foreign_table->indexes);
 +	int i = 0;
 +	while (idx != NULL && idx != idx_target) {
 +		if (innobase_strcasecmp (idx->name, innobase_index_reserve_name) != 0) {
 +			i++;
 +		}
 +		idx = UT_LIST_GET_NEXT(indexes, idx);
 +	}
 +	ut_a(idx);
 +	key[0] = (char)i;
 +
 +	rcode = wsrep_rec_get_foreign_key(
 +		&key[1], &len, rec, index, idx,
 +		wsrep_protocol_version > 1);
 +
 +	if (rcode != DB_SUCCESS) {
 +		WSREP_ERROR(
 +			"FK key set failed: %lu (%lu %s), index: %s %s, %s",
 +			rcode, referenced, wsrep_key_type_to_str(key_type),
 +			(index && index->name)       ? index->name :
 +				"void index",
 +			(index && index->table_name) ? index->table_name :
 +				"void table",
 +			wsrep_thd_query(thd));
 +		return DB_ERROR;
 +	}
 +
 +	strncpy(cache_key,
 +		(wsrep_protocol_version > 1) ?
 +		((referenced) ?
 +			foreign->referenced_table->name :
 +			foreign->foreign_table->name) :
 +		foreign->foreign_table->name, sizeof(cache_key) - 1);
 +	cache_key_len = strlen(cache_key);
 +#ifdef WSREP_DEBUG_PRINT
 +	ulint j;
 +	fprintf(stderr, "FK parent key, table: %s %s len: %lu ",
 +		cache_key, (shared) ? "shared" : "exclusive", len+1);
 +	for (j=0; j<len+1; j++) {
 +		fprintf(stderr, " %hhX, ", key[j]);
 +	}
 +	fprintf(stderr, "\n");
 +#endif
 +	char *p = strchr(cache_key, '/');
 +	if (p) {
 +		*p = '\0';
 +	} else {
 +		WSREP_WARN("unexpected foreign key table %s %s",
 +			   foreign->referenced_table->name,
 +			   foreign->foreign_table->name);
 +	}
 +
 +	wsrep_buf_t wkey_part[3];
 +        wsrep_key_t wkey = {wkey_part, 3};
 +	if (!wsrep_prepare_key_for_innodb(
 +		(const uchar*)cache_key,
 +		cache_key_len +  1,
 +		(const uchar*)key, len+1,
 +		wkey_part,
 +		(size_t*)&wkey.key_parts_num)) {
 +		WSREP_WARN("key prepare failed for cascaded FK: %s",
 +			   (wsrep_thd_query(thd)) ?
 +			    wsrep_thd_query(thd) : "void");
 +		return DB_ERROR;
 +	}
 +	rcode = (int)wsrep->append_key(
 +		wsrep,
 +		wsrep_ws_handle(thd, trx),
 +		&wkey,
 +		1,
 +		key_type,
 +                copy);
 +	if (rcode) {
 +		DBUG_PRINT("wsrep", ("row key failed: %lu", rcode));
 +		WSREP_ERROR("Appending cascaded fk row key failed: %s, %lu",
 +			    (wsrep_thd_query(thd)) ?
 +			    wsrep_thd_query(thd) : "void", rcode);
 +		return DB_ERROR;
 +	}
 +
 +	return DB_SUCCESS;
 +}
 +
 +static int
 +wsrep_append_key(
 +/*==================*/
 +	THD		*thd,
 +	trx_t 		*trx,
 +	TABLE_SHARE 	*table_share,
 +	TABLE 		*table,
 +	const char*	key,
 +	uint16_t        key_len,
 +	wsrep_key_type	key_type	/*!< in: access type of this key
 +					(shared, exclusive, semi...) */
 +)
 +{
 +	DBUG_ENTER("wsrep_append_key");
 +	bool const copy = true;
 +#ifdef WSREP_DEBUG_PRINT
 +	fprintf(stderr, "%s conn %ld, trx %llu, keylen %d, table %s\n Query: %s ",
 +		wsrep_key_type_to_str(key_type),
 +		wsrep_thd_thread_id(thd), trx->id, key_len,
 +		table_share->table_name.str, wsrep_thd_query(thd));
 +	for (int i=0; i<key_len; i++) {
 +		fprintf(stderr, "%hhX, ", key[i]);
 +	}
 +	fprintf(stderr, "\n");
 +#endif
 +	wsrep_buf_t wkey_part[3];
 +        wsrep_key_t wkey = {wkey_part, 3};
 +	if (!wsrep_prepare_key_for_innodb(
 +			(const uchar*)table_share->table_cache_key.str,
 +			table_share->table_cache_key.length,
 +			(const uchar*)key, key_len,
 +			wkey_part,
 +			(size_t*)&wkey.key_parts_num)) {
 +		WSREP_WARN("key prepare failed for: %s",
 +			   (wsrep_thd_query(thd)) ?
 +			   wsrep_thd_query(thd) : "void");
 +		DBUG_RETURN(HA_ERR_INTERNAL_ERROR);
 +	}
 +
 +	int rcode = (int)wsrep->append_key(
 +			       wsrep,
 +			       wsrep_ws_handle(thd, trx),
 +			       &wkey,
 +			       1,
 +			       key_type,
 +                               copy);
 +	if (rcode) {
 +		DBUG_PRINT("wsrep", ("row key failed: %d", rcode));
 +		WSREP_WARN("Appending row key failed: %s, %d",
 +			   (wsrep_thd_query(thd)) ?
 +			   wsrep_thd_query(thd) : "void", rcode);
 +		DBUG_RETURN(HA_ERR_INTERNAL_ERROR);
 +	}
 +	DBUG_RETURN(0);
 +}
 +
 +extern void compute_md5_hash(char *digest, const char *buf, int len);
 +#define MD5_HASH compute_md5_hash
 +
 +static bool
 +referenced_by_foreign_key2(dict_table_t* table,
 +	                   dict_index_t* index) {
 +	ut_ad(table != NULL);
 +	ut_ad(index != NULL);
 +
 +	const dict_foreign_set* fks = &table->referenced_set;
 +	for (dict_foreign_set::const_iterator it = fks->begin();
 +	     it != fks->end();
 +	     ++it)
 +	{
 +		dict_foreign_t* foreign = *it;
 +		if (foreign->referenced_index != index) {
 +			continue;
 +		}
 +		ut_ad(table == foreign->referenced_table);
 +		return true;
 +	}
 +	return false;
 +}
 +
 +int
 +ha_innobase::wsrep_append_keys(
 +/*==================*/
 +	THD 		*thd,
 +	wsrep_key_type	key_type,	/*!< in: access type of this key
 +					(shared, exclusive, semi...) */
 +	const uchar*	record0,	/* in: row in MySQL format */
 +	const uchar*	record1)	/* in: row in MySQL format */
 +{
 +	int rcode;
 +	DBUG_ENTER("wsrep_append_keys");
 +
 +	bool key_appended = false;
 +	trx_t *trx = thd_to_trx(thd);
 +
 +	if (table_share && table_share->tmp_table  != NO_TMP_TABLE) {
 +		WSREP_DEBUG("skipping tmp table DML: THD: %lu tmp: %d SQL: %s", 
 +			    wsrep_thd_thread_id(thd),
 +			    table_share->tmp_table,
 +			    (wsrep_thd_query(thd)) ? 
 +			    wsrep_thd_query(thd) : "void");
 +		DBUG_RETURN(0);
 +	}
 +
 +	if (wsrep_protocol_version == 0) {
 +		uint	len;
 +		char 	keyval[WSREP_MAX_SUPPORTED_KEY_LENGTH+1] = {'\0'};
 +		char 	*key 		= &keyval[0];
 +		ibool    is_null;
 +
 +		len = wsrep_store_key_val_for_row(
 +			thd, table, 0, key, WSREP_MAX_SUPPORTED_KEY_LENGTH,
 +			record0, &is_null);
 +
 +		if (!is_null) {
 +			rcode = wsrep_append_key(
 +				thd, trx, table_share, table, keyval, 
 +				len, key_type);
 +			if (rcode) DBUG_RETURN(rcode);
 +		}
 +		else
 +		{
 +			WSREP_DEBUG("NULL key skipped (proto 0): %s", 
 +				    wsrep_thd_query(thd));
 +		}
 +	} else {
 +		ut_a(table->s->keys <= 256);
 +		uint i;
 +                bool hasPK= false;
 +
 +		for (i=0; i<table->s->keys; ++i) {
 +			KEY*  key_info	= table->key_info + i;
 +			if (key_info->flags & HA_NOSAME) {
 +				hasPK = true;
 +			}
 +		}
 +
 +		for (i=0; i<table->s->keys; ++i) {
 +			uint  len;
 +			char  keyval0[WSREP_MAX_SUPPORTED_KEY_LENGTH+1] = {'\0'};
 +			char  keyval1[WSREP_MAX_SUPPORTED_KEY_LENGTH+1] = {'\0'};
 +			char* key0 		= &keyval0[1];
 +			char* key1 		= &keyval1[1];
 +			KEY*  key_info	= table->key_info + i;
 +			ibool is_null;
 +
 +			dict_index_t* idx  = innobase_get_index(i);
 +			dict_table_t* tab  = (idx) ? idx->table : NULL;
 +
 +			keyval0[0] = (char)i;
 +			keyval1[0] = (char)i;
 +
 +			if (!tab) {
 +				WSREP_WARN("MySQL-InnoDB key mismatch %s %s",
 +					   table->s->table_name.str, 
 +					   key_info->name);
 +			}
 +			/* !hasPK == table with no PK, must append all non-unique keys */
 +			if (!hasPK || key_info->flags & HA_NOSAME ||
 +			    ((tab &&
 +			      referenced_by_foreign_key2(tab, idx)) ||
 +			     (!tab && referenced_by_foreign_key()))) {
 +
 +				len = wsrep_store_key_val_for_row(
 +					thd, table, i, key0, 
 +					WSREP_MAX_SUPPORTED_KEY_LENGTH, 
 +					record0, &is_null);
 +				if (!is_null) {
 +					rcode = wsrep_append_key(
 +						thd, trx, table_share, table, 
 +						keyval0, len+1, key_type);
 +					if (rcode) DBUG_RETURN(rcode);
 +
 +					if (key_info->flags & HA_NOSAME ||
 +					    key_type == WSREP_KEY_SHARED)
 +			  		key_appended = true;
 +				}
 +				else
 +				{
 +					WSREP_DEBUG("NULL key skipped: %s", 
 +						    wsrep_thd_query(thd));
 +				}
 +				if (record1) {
 +					len = wsrep_store_key_val_for_row(
 +						thd, table, i, key1, 
 +						WSREP_MAX_SUPPORTED_KEY_LENGTH,
 +						record1, &is_null);
 +					if (!is_null && memcmp(key0, key1, len)) {
 +						rcode = wsrep_append_key(
 +							thd, trx, table_share, 
 +							table, 
 +							keyval1, len+1, key_type);
 +						if (rcode) DBUG_RETURN(rcode);
 +					}
 +				}
 +			}
 +		}
 +	}
 +
 +	/* if no PK, calculate hash of full row, to be the key value */
 +	if (!key_appended && wsrep_certify_nonPK) {
 +		uchar digest[16];
 +		int rcode;
 +
 +		wsrep_calc_row_hash(digest, record0, table, prebuilt, thd);
 +		if ((rcode = wsrep_append_key(thd, trx, table_share, table, 
 +					      (const char*) digest, 16, 
 +					      key_type))) {
 +			DBUG_RETURN(rcode);
 +		}
 +
 +		if (record1) {
 +			wsrep_calc_row_hash(
 +				digest, record1, table, prebuilt, thd);
 +			if ((rcode = wsrep_append_key(thd, trx, table_share, 
 +						      table,
 +						      (const char*) digest, 
 +						      16, key_type))) {
 +				DBUG_RETURN(rcode);
 +			}
 +		}
 +		DBUG_RETURN(0);
 +	}
 +
 +	DBUG_RETURN(0);
 +}
 +#endif /* WITH_WSREP */
- 
  /*********************************************************************//**
  Stores a reference to the current row to 'ref' field of the handle. Note
  that in the case where we have generated the clustered index for the
diff --cc storage/xtradb/handler/ha_innodb.cc
index 89539bfeed2,3a7b5b493a2..8c0db0231ed
--- a/storage/xtradb/handler/ha_innodb.cc
+++ b/storage/xtradb/handler/ha_innodb.cc
@@@ -10591,446 -9812,6 +10593,435 @@@ next_record
  	return(HA_ERR_END_OF_FILE);
  }
  
- /*************************************************************************
- */
- 
- void
- ha_innobase::ft_end()
- {
- 	fprintf(stderr, "ft_end()\n");
- 
- 	rnd_end();
- }
 +#ifdef WITH_WSREP
 +extern dict_index_t*
 +wsrep_dict_foreign_find_index(
 +	dict_table_t*	table,
 +	const char**	col_names,
 +	const char**	columns,
 +	ulint		n_cols,
 +	dict_index_t*	types_idx,
 +	ibool		check_charsets,
 +	ulint		check_null);
 +
 +inline
 +const char*
 +wsrep_key_type_to_str(wsrep_key_type type)
 +{
 +	switch (type) {
 +	case WSREP_KEY_SHARED:
 +		return "shared";
 +	case WSREP_KEY_SEMI:
 +		return "semi";
 +	case WSREP_KEY_EXCLUSIVE:
 +		return "exclusive";
 +	};
 +	return "unknown";
 +}
 +
 +ulint
 +wsrep_append_foreign_key(
 +/*===========================*/
 +	trx_t*		trx,		/*!< in: trx */
 +	dict_foreign_t*	foreign,	/*!< in: foreign key constraint */
 +	const rec_t*	rec,		/*!<in: clustered index record */
 +	dict_index_t*	index,		/*!<in: clustered index */
 +	ibool		referenced,	/*!<in: is check for referenced table */
 +	wsrep_key_type	key_type)	/*!< in: access type of this key
 +					(shared, exclusive, semi...) */
 +{
 +	ut_a(trx);
 +	THD*  thd = (THD*)trx->mysql_thd;
 +	ulint rcode = DB_SUCCESS;
 +	char  cache_key[513] = {'\0'};
 +	int   cache_key_len;
 +    bool const copy = true;
 +
 +	if (!wsrep_on(trx->mysql_thd) ||
 +	    wsrep_thd_exec_mode(thd) != LOCAL_STATE)
 +		return DB_SUCCESS;
 +
 +	if (!thd || !foreign ||
 +	    (!foreign->referenced_table && !foreign->foreign_table))
 +	{
 +		WSREP_INFO("FK: %s missing in: %s",
 +			(!thd)      ?  "thread"     :
 +			((!foreign) ?  "constraint" :
 +			((!foreign->referenced_table) ?
 +			     "referenced table" : "foreign table")),
 +			   (thd && wsrep_thd_query(thd)) ?
 +			   wsrep_thd_query(thd) : "void");
 +		return DB_ERROR;
 +	}
 +
 +	if ( !((referenced) ?
 +		foreign->referenced_table : foreign->foreign_table))
 +	{
 +		WSREP_DEBUG("pulling %s table into cache",
 +			    (referenced) ? "referenced" : "foreign");
 +		mutex_enter(&(dict_sys->mutex));
 +		if (referenced)
 +		{
 +			foreign->referenced_table =
 +				dict_table_get_low(
 +					foreign->referenced_table_name_lookup);
 +			if (foreign->referenced_table)
 +			{
 +				foreign->referenced_index =
 +					wsrep_dict_foreign_find_index(
 +						foreign->referenced_table, NULL,
 +						foreign->referenced_col_names,
 +						foreign->n_fields, 
 +						foreign->foreign_index,
 +						TRUE, FALSE);
 +			}
 +		}
 +		else
 +		{
 +	  		foreign->foreign_table =
 +				dict_table_get_low(
 +					foreign->foreign_table_name_lookup);
 +			if (foreign->foreign_table)
 +			{
 +				foreign->foreign_index =
 +					wsrep_dict_foreign_find_index(
 +						foreign->foreign_table, NULL,
 +						foreign->foreign_col_names,
 +						foreign->n_fields,
 +						foreign->referenced_index, 
 +						TRUE, FALSE);
 +			}
 +		}
 +		mutex_exit(&(dict_sys->mutex));
 +	}
 +
 +	if ( !((referenced) ?
 +		foreign->referenced_table : foreign->foreign_table))
 +	{
 +		WSREP_WARN("FK: %s missing in query: %s",
 +			   (!foreign->referenced_table) ?
 +			   "referenced table" : "foreign table",
 +			   (wsrep_thd_query(thd)) ?
 +			   wsrep_thd_query(thd) : "void");
 +		return DB_ERROR;
 +	}
 +	byte  key[WSREP_MAX_SUPPORTED_KEY_LENGTH+1] = {'\0'};
 +	ulint len = WSREP_MAX_SUPPORTED_KEY_LENGTH;
 +
 +	dict_index_t *idx_target = (referenced) ?
 +		foreign->referenced_index : index;
 +	dict_index_t *idx = (referenced) ?
 +		UT_LIST_GET_FIRST(foreign->referenced_table->indexes) :
 +		UT_LIST_GET_FIRST(foreign->foreign_table->indexes);
 +	int i = 0;
 +	while (idx != NULL && idx != idx_target) {
 +		if (innobase_strcasecmp (idx->name, innobase_index_reserve_name) != 0) {
 +			i++;
 +		}
 +		idx = UT_LIST_GET_NEXT(indexes, idx);
 +	}
 +	ut_a(idx);
 +	key[0] = (char)i;
 +
 +	rcode = wsrep_rec_get_foreign_key(
 +		&key[1], &len, rec, index, idx,
 +		wsrep_protocol_version > 1);
 +
 +	if (rcode != DB_SUCCESS) {
 +		WSREP_ERROR(
 +			"FK key set failed: %lu (%lu %s), index: %s %s, %s",
 +			rcode, referenced, wsrep_key_type_to_str(key_type),
 +			(index && index->name)       ? index->name :
 +				"void index",
 +			(index && index->table_name) ? index->table_name :
 +				"void table",
 +			wsrep_thd_query(thd));
 +		return DB_ERROR;
 +	}
 +
 +	strncpy(cache_key,
 +		(wsrep_protocol_version > 1) ?
 +		((referenced) ?
 +			foreign->referenced_table->name :
 +			foreign->foreign_table->name) :
 +		foreign->foreign_table->name, sizeof(cache_key) - 1);
 +	cache_key_len = strlen(cache_key);
 +#ifdef WSREP_DEBUG_PRINT
 +	ulint j;
 +	fprintf(stderr, "FK parent key, table: %s %s len: %lu ",
 +		cache_key, (shared) ? "shared" : "exclusive", len+1);
 +	for (j=0; j<len+1; j++) {
 +		fprintf(stderr, " %hhX, ", key[j]);
 +	}
 +	fprintf(stderr, "\n");
 +#endif
 +	char *p = strchr(cache_key, '/');
 +	if (p) {
 +		*p = '\0';
 +	} else {
 +		WSREP_WARN("unexpected foreign key table %s %s",
 +			   foreign->referenced_table->name,
 +			   foreign->foreign_table->name);
 +	}
 +
 +	wsrep_buf_t wkey_part[3];
 +        wsrep_key_t wkey = {wkey_part, 3};
 +	if (!wsrep_prepare_key_for_innodb(
 +		(const uchar*)cache_key,
 +		cache_key_len +  1,
 +		(const uchar*)key, len+1,
 +		wkey_part,
 +		(size_t*)&wkey.key_parts_num)) {
 +		WSREP_WARN("key prepare failed for cascaded FK: %s",
 +			   (wsrep_thd_query(thd)) ?
 +			    wsrep_thd_query(thd) : "void");
 +		return DB_ERROR;
 +	}
 +	rcode = (int)wsrep->append_key(
 +		wsrep,
 +		wsrep_ws_handle(thd, trx),
 +		&wkey,
 +		1,
 +		key_type,
 +                copy);
 +	if (rcode) {
 +		DBUG_PRINT("wsrep", ("row key failed: %lu", rcode));
 +		WSREP_ERROR("Appending cascaded fk row key failed: %s, %lu",
 +			    (wsrep_thd_query(thd)) ?
 +			    wsrep_thd_query(thd) : "void", rcode);
 +		return DB_ERROR;
 +	}
 +
 +	return DB_SUCCESS;
 +}
 +
 +static int
 +wsrep_append_key(
 +/*==================*/
 +	THD		*thd,
 +	trx_t 		*trx,
 +	TABLE_SHARE 	*table_share,
 +	TABLE 		*table,
 +	const char*	key,
 +	uint16_t        key_len,
 +	wsrep_key_type	key_type	/*!< in: access type of this key
 +					(shared, exclusive, semi...) */
 +)
 +{
 +	DBUG_ENTER("wsrep_append_key");
 +	bool const copy = true;
 +#ifdef WSREP_DEBUG_PRINT
 +	fprintf(stderr, "%s conn %ld, trx %llu, keylen %d, table %s\n Query: %s ",
 +		wsrep_key_type_to_str(key_type),
 +		wsrep_thd_thread_id(thd), trx->id, key_len,
 +		table_share->table_name.str, wsrep_thd_query(thd));
 +	for (int i=0; i<key_len; i++) {
 +		fprintf(stderr, "%hhX, ", key[i]);
 +	}
 +	fprintf(stderr, "\n");
 +#endif
 +	wsrep_buf_t wkey_part[3];
 +        wsrep_key_t wkey = {wkey_part, 3};
 +	if (!wsrep_prepare_key_for_innodb(
 +			(const uchar*)table_share->table_cache_key.str,
 +			table_share->table_cache_key.length,
 +			(const uchar*)key, key_len,
 +			wkey_part,
 +			(size_t*)&wkey.key_parts_num)) {
 +		WSREP_WARN("key prepare failed for: %s",
 +			   (wsrep_thd_query(thd)) ?
 +			   wsrep_thd_query(thd) : "void");
 +		DBUG_RETURN(HA_ERR_INTERNAL_ERROR);
 +	}
 +
 +	int rcode = (int)wsrep->append_key(
 +			       wsrep,
 +			       wsrep_ws_handle(thd, trx),
 +			       &wkey,
 +			       1,
 +			       key_type,
 +                               copy);
 +	if (rcode) {
 +		DBUG_PRINT("wsrep", ("row key failed: %d", rcode));
 +		WSREP_WARN("Appending row key failed: %s, %d",
 +			   (wsrep_thd_query(thd)) ?
 +			   wsrep_thd_query(thd) : "void", rcode);
 +		DBUG_RETURN(HA_ERR_INTERNAL_ERROR);
 +	}
 +	DBUG_RETURN(0);
 +}
 +
 +extern void compute_md5_hash(char *digest, const char *buf, int len);
 +#define MD5_HASH compute_md5_hash
 +
 +static bool
 +referenced_by_foreign_key2(dict_table_t* table,
 +	                   dict_index_t* index) {
 +	ut_ad(table != NULL);
 +	ut_ad(index != NULL);
 +
 +	const dict_foreign_set* fks = &table->referenced_set;
 +	for (dict_foreign_set::const_iterator it = fks->begin();
 +	     it != fks->end();
 +	     ++it)
 +	{
 +		dict_foreign_t* foreign = *it;
 +		if (foreign->referenced_index != index) {
 +			continue;
 +		}
 +		ut_ad(table == foreign->referenced_table);
 +		return true;
 +	}
 +	return false;
 +}
 +
 +int
 +ha_innobase::wsrep_append_keys(
 +/*==================*/
 +	THD 		*thd,
 +	wsrep_key_type	key_type,	/*!< in: access type of this key
 +					(shared, exclusive, semi...) */
 +	const uchar*	record0,	/* in: row in MySQL format */
 +	const uchar*	record1)	/* in: row in MySQL format */
 +{
 +	int rcode;
 +	DBUG_ENTER("wsrep_append_keys");
 +
 +	bool key_appended = false;
 +	trx_t *trx = thd_to_trx(thd);
 +
 +	if (table_share && table_share->tmp_table  != NO_TMP_TABLE) {
 +		WSREP_DEBUG("skipping tmp table DML: THD: %lu tmp: %d SQL: %s", 
 +			    wsrep_thd_thread_id(thd),
 +			    table_share->tmp_table,
 +			    (wsrep_thd_query(thd)) ? 
 +			    wsrep_thd_query(thd) : "void");
 +		DBUG_RETURN(0);
 +	}
 +
 +	if (wsrep_protocol_version == 0) {
 +		uint	len;
 +		char 	keyval[WSREP_MAX_SUPPORTED_KEY_LENGTH+1] = {'\0'};
 +		char 	*key 		= &keyval[0];
 +		ibool    is_null;
 +
 +		len = wsrep_store_key_val_for_row(
 +			thd, table, 0, key, WSREP_MAX_SUPPORTED_KEY_LENGTH,
 +			record0, prebuilt, &is_null);
 +
 +		if (!is_null) {
 +			rcode = wsrep_append_key(
 +				thd, trx, table_share, table, keyval, 
 +				len, key_type);
 +			if (rcode) DBUG_RETURN(rcode);
 +		}
 +		else
 +		{
 +			WSREP_DEBUG("NULL key skipped (proto 0): %s", 
 +				    wsrep_thd_query(thd));
 +		}
 +	} else {
 +		ut_a(table->s->keys <= 256);
 +		uint i;
 +                bool hasPK= false;
 +
 +		for (i=0; i<table->s->keys; ++i) {
 +			KEY*  key_info	= table->key_info + i;
 +			if (key_info->flags & HA_NOSAME) {
 +				hasPK = true;
 +			}
 +		}
 +
 +		for (i=0; i<table->s->keys; ++i) {
 +			uint  len;
 +			char  keyval0[WSREP_MAX_SUPPORTED_KEY_LENGTH+1] = {'\0'};
 +			char  keyval1[WSREP_MAX_SUPPORTED_KEY_LENGTH+1] = {'\0'};
 +			char* key0 		= &keyval0[1];
 +			char* key1 		= &keyval1[1];
 +			KEY*  key_info	= table->key_info + i;
 +			ibool is_null;
 +
 +			dict_index_t* idx  = innobase_get_index(i);
 +			dict_table_t* tab  = (idx) ? idx->table : NULL;
 +
 +			keyval0[0] = (char)i;
 +			keyval1[0] = (char)i;
 +
 +			if (!tab) {
 +				WSREP_WARN("MySQL-InnoDB key mismatch %s %s",
 +					   table->s->table_name.str, 
 +					   key_info->name);
 +			}
 +			/* !hasPK == table with no PK, must append all non-unique keys */
 +			if (!hasPK || key_info->flags & HA_NOSAME ||
 +			    ((tab &&
 +			      referenced_by_foreign_key2(tab, idx)) ||
 +			     (!tab && referenced_by_foreign_key()))) {
 +
 +				len = wsrep_store_key_val_for_row(
 +					thd, table, i, key0, 
 +					WSREP_MAX_SUPPORTED_KEY_LENGTH, 
 +					record0, prebuilt, &is_null);
 +				if (!is_null) {
 +					rcode = wsrep_append_key(
 +						thd, trx, table_share, table, 
 +						keyval0, len+1, key_type);
 +					if (rcode) DBUG_RETURN(rcode);
 +
 +					if (key_info->flags & HA_NOSAME ||
 +					    key_type == WSREP_KEY_SHARED)
 +			  		key_appended = true;
 +				}
 +				else
 +				{
 +					WSREP_DEBUG("NULL key skipped: %s", 
 +						    wsrep_thd_query(thd));
 +				}
 +				if (record1) {
 +					len = wsrep_store_key_val_for_row(
 +						thd, table, i, key1, 
 +						WSREP_MAX_SUPPORTED_KEY_LENGTH,
 +						record1, prebuilt, &is_null);
 +					if (!is_null && memcmp(key0, key1, len)) {
 +						rcode = wsrep_append_key(
 +							thd, trx, table_share, 
 +							table, 
 +							keyval1, len+1, key_type);
 +						if (rcode) DBUG_RETURN(rcode);
 +					}
 +				}
 +			}
 +		}
 +	}
 +
 +	/* if no PK, calculate hash of full row, to be the key value */
 +	if (!key_appended && wsrep_certify_nonPK) {
 +		uchar digest[16];
 +		int rcode;
 +
 +		wsrep_calc_row_hash(digest, record0, table, prebuilt, thd);
 +		if ((rcode = wsrep_append_key(thd, trx, table_share, table, 
 +					      (const char*) digest, 16, 
 +					      key_type))) {
 +			DBUG_RETURN(rcode);
 +		}
 +
 +		if (record1) {
 +			wsrep_calc_row_hash(
 +				digest, record1, table, prebuilt, thd);
 +			if ((rcode = wsrep_append_key(thd, trx, table_share, 
 +						      table,
 +						      (const char*) digest, 
 +						      16, key_type))) {
 +				DBUG_RETURN(rcode);
 +			}
 +		}
 +		DBUG_RETURN(0);
 +	}
 +
 +	DBUG_RETURN(0);
 +}
 +#endif /* WITH_WSREP */
- 
  /*********************************************************************//**
  Stores a reference to the current row to 'ref' field of the handle. Note
  that in the case where we have generated the clustered index for the

    

jan

tags

participants (1)