Commit 156bfa48 authored by pekka@mysql.com's avatar pekka@mysql.com

ha_ndbcluster.cc:

  merge
parent 56fa7bfd
...@@ -614,14 +614,14 @@ int ha_ndbcluster::get_ndb_lock_type(enum thr_lock_type type) ...@@ -614,14 +614,14 @@ int ha_ndbcluster::get_ndb_lock_type(enum thr_lock_type type)
{ {
int lm; int lm;
if (type == TL_WRITE_ALLOW_WRITE) if (type == TL_WRITE_ALLOW_WRITE)
lm = NdbScanOperation::LM_Exclusive; lm= NdbScanOperation::LM_Exclusive;
else if (uses_blob_value(retrieve_all_fields)) else if (uses_blob_value(retrieve_all_fields))
/* /*
TODO use a new scan mode to read + lock + keyinfo TODO use a new scan mode to read + lock + keyinfo
*/ */
lm = NdbScanOperation::LM_Exclusive; lm= NdbScanOperation::LM_Exclusive;
else else
lm = NdbScanOperation::LM_CommittedRead; lm= NdbScanOperation::LM_CommittedRead;
return lm; return lm;
} }
...@@ -842,7 +842,7 @@ int ha_ndbcluster::complemented_pk_read(const byte *old_data, byte *new_data) ...@@ -842,7 +842,7 @@ int ha_ndbcluster::complemented_pk_read(const byte *old_data, byte *new_data)
if (!(field->flags & PRI_KEY_FLAG) && if (!(field->flags & PRI_KEY_FLAG) &&
(thd->query_id != field->query_id)) (thd->query_id != field->query_id))
{ {
if (get_ndb_value(op, i, field->ptr)) if (get_ndb_value(op, field, i))
ERR_RETURN(trans->getNdbError()); ERR_RETURN(trans->getNdbError());
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment