~hartmut-php/mysql-server/cluster-7.2-showdbs

« back to all changes in this revision

Viewing changes to storage/ndb/src/ndbapi/NdbQueryOperation.cpp

  • Committer: Jan Wedvik
  • Date: 2012-03-30 12:25:43 UTC
  • Revision ID: jan.wedvik@oracle.com-20120330122543-bks4vpvrvl80e2tc
This commit is a refactoring. NdbQueryBuilderImpl::m_id, NdbQueryBuilderImpl::m_ix are
renamed to m_opNo and m_internalOpNo. Associated methods are renamed in the same way.

Show diffs side-by-side

added added

removed removed

Lines of Context:
273
273
  NdbResultStream& getResultStream(Uint32 operationNo) const;
274
274
 
275
275
  NdbResultStream& getResultStream(const NdbQueryOperationImpl& op) const
276
 
  { return getResultStream(op.getQueryOperationDef().getQueryOperationIx()); }
 
276
  { return getResultStream(op.getQueryOperationDef().getOpNo()); }
277
277
 
278
278
  Uint32 getReceiverId() const;
279
279
  Uint32 getReceiverTcPtrI() const;
508
508
     * operation will have two distincts nodes in the tree used by the
509
509
     * SPJ block, this number may be different from 'opNo'.
510
510
     */
511
 
    const Uint32 internalOpNo = m_operation.getQueryOperationDef().getQueryOperationId();
 
511
    const Uint32 internalOpNo = m_operation.getInternalOpNo();
512
512
 
513
513
    const bool complete = !((remainingScans >> internalOpNo) & 1);
514
514
    return complete; 
1004
1004
    NdbResultStream& childStream = m_rootFrag.getResultStream(child);
1005
1005
    const bool allSubScansComplete = childStream.prepareResultSet(remainingScans);
1006
1006
 
1007
 
    Uint32 childId = child.getQueryOperationDef().getQueryOperationIx();
 
1007
    Uint32 childId = child.getQueryOperationDef().getOpNo();
1008
1008
 
1009
1009
    /* Condition 1) & 2) calc'ed outside loop, see comments further below: */
1010
1010
    const bool skipNonMatches = !allSubScansComplete ||      // 1)
3788
3788
  m_ordering(NdbQueryOptions::ScanOrdering_unordered),
3789
3789
  m_interpretedCode(NULL),
3790
3790
  m_diskInUserProjection(false),
3791
 
  m_parallelism(def.getQueryOperationIx() == 0
 
3791
  m_parallelism(def.getOpNo() == 0
3792
3792
                ? Parallelism_max : Parallelism_adaptive),
3793
3793
  m_rowSize(0xffffffff)
3794
3794
3802
3802
  const NdbQueryOperationDefImpl* parent = def.getParentOperation();
3803
3803
  if (parent != NULL)
3804
3804
  { 
3805
 
    const Uint32 ix = parent->getQueryOperationIx();
 
3805
    const Uint32 ix = parent->getOpNo();
3806
3806
    assert (ix < m_queryImpl.getNoOfOperations());
3807
3807
    m_parent = &m_queryImpl.getQueryOperation(ix);
3808
3808
    const int res = m_parent->m_children.push_back(this);
4475
4475
 
4476
4476
#ifdef __TRACE_SERIALIZATION
4477
4477
    ndbout << "Serialized params for index node " 
4478
 
           << m_operationDef.getQueryOperationId()-1 << " : ";
 
4478
           << getInternalOpNo()-1 << " : ";
4479
4479
    for(Uint32 i = startPos; i < attrInfo.getSize(); i++){
4480
4480
      char buf[12];
4481
4481
      sprintf(buf, "%.8x", attrInfo.get(i));
4489
4489
  // 'length' and 'requestInfo' has been calculated.
4490
4490
  Uint32 startPos = attrInfo.getSize();
4491
4491
  Uint32 requestInfo = 0;
4492
 
  bool isRoot = (def.getQueryOperationIx()==0);
 
4492
  bool isRoot = (def.getOpNo()==0);
4493
4493
 
4494
4494
  QueryNodeParameters::OpType paramType =
4495
4495
       !def.isScanOperation() ? QueryNodeParameters::QN_LOOKUP
4609
4609
 
4610
4610
#ifdef __TRACE_SERIALIZATION
4611
4611
  ndbout << "Serialized params for node " 
4612
 
         << m_operationDef.getQueryOperationId() << " : ";
 
4612
         << getInternalOpNo() << " : ";
4613
4613
  for(Uint32 i = startPos; i < attrInfo.getSize(); i++){
4614
4614
    char buf[12];
4615
4615
    sprintf(buf, "%.8x", attrInfo.get(i));
4935
4935
  if (traceSignals) {
4936
4936
    ndbout << "NdbQueryOperationImpl::execTRANSID_AI()" 
4937
4937
           << ", fragment no: " << rootFrag->getFragNo()
4938
 
           << ", operation no: " << getQueryOperationDef().getQueryOperationIx()
 
4938
           << ", operation no: " << getQueryOperationDef().getOpNo()
4939
4939
           << endl;
4940
4940
  }
4941
4941
 
5182
5182
    getQuery().setErrorCode(QRY_SEQUENTIAL_SCAN_SORTED);
5183
5183
    return -1;
5184
5184
  }
5185
 
  else if (getQueryOperationDef().getQueryOperationIx() > 0)
 
5185
  else if (getQueryOperationDef().getOpNo() > 0)
5186
5186
  {
5187
5187
    getQuery().setErrorCode(Err_FunctionNotImplemented);
5188
5188
    return -1;
5212
5212
    getQuery().setErrorCode(QRY_WRONG_OPERATION_TYPE);
5213
5213
    return -1;
5214
5214
  }
5215
 
  else if (getQueryOperationDef().getQueryOperationIx() == 0)
 
5215
  else if (getQueryOperationDef().getOpNo() == 0)
5216
5216
  {
5217
5217
    getQuery().setErrorCode(Err_FunctionNotImplemented);
5218
5218
    return -1;
5296
5296
NdbOut& operator<<(NdbOut& out, const NdbQueryOperationImpl& op){
5297
5297
  out << "[ this: " << &op
5298
5298
      << "  m_magic: " << op.m_magic;
5299
 
  out << " op.operationDef.getQueryOperationIx()" 
5300
 
      << op.m_operationDef.getQueryOperationIx();
 
5299
  out << " op.operationDef.getOpNo()"
 
5300
      << op.m_operationDef.getOpNo();
5301
5301
  if (op.getParentOperation()){
5302
5302
    out << "  m_parent: " << op.getParentOperation(); 
5303
5303
  }