review.fuel-infra Code Review - packages/trusty/mysql-wsrep-5.6.git/blob

   1 /*
   2  *  Copyright 2010 Sun Microsystems, Inc.
   3  *  All rights reserved. Use is subject to license terms.
   4  *
   5  *  This program is free software; you can redistribute it and/or modify
   6  *  it under the terms of the GNU General Public License as published by
   7  *  the Free Software Foundation; version 2 of the License.
   8  *
   9  *  This program is distributed in the hope that it will be useful,
  10  *  but WITHOUT ANY WARRANTY; without even the implied warranty of
  11  *  MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  12  *  GNU General Public License for more details.
  13  *
  14  *  You should have received a copy of the GNU General Public License
  15  *  along with this program; if not, write to the Free Software
  16  *  Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301  USA
  17  */
  18
  19 package com.mysql.clusterj.bindings;
  20
  21 import com.mysql.cluster.ndbj.NdbApiException;
  22 import com.mysql.cluster.ndbj.NdbScanOperation;
  23 import com.mysql.clusterj.ClusterJDatastoreException;
  24 import com.mysql.clusterj.core.store.ScanFilter;
  25 import com.mysql.clusterj.core.store.ScanOperation;
  26
  27 /**
  28  *
  29  */
  30 class ScanOperationImpl extends OperationImpl implements ScanOperation {
  31
  32     private NdbScanOperation scanOperation;
  33
  34     ScanOperationImpl(NdbScanOperation operation, ClusterTransactionImpl transaction) {
  35         super(operation, transaction);
  36         this.scanOperation = operation;
  37     }
  38
  39     public void close() {
  40         scanOperation.close();
  41     }
  42
  43     public void deleteCurrentTuple() {
  44         try {
  45             scanOperation.deleteCurrentTuple();
  46         } catch (NdbApiException ndbApiException) {
  47             throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
  48                     ndbApiException);
  49         }
  50     }
  51
  52     public ScanFilter getScanFilter() {
  53         try {
  54             return new ScanFilterImpl(scanOperation.getNdbScanFilter());
  55         } catch (NdbApiException ndbApiException) {
  56             throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
  57                     ndbApiException);
  58         }
  59     }
  60
  61     public int nextResult(boolean fetch) {
  62         try {
  63             return scanOperation.nextResult(fetch);
  64         } catch (NdbApiException ndbApiException) {
  65             throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
  66                     ndbApiException);
  67         }
  68     }
  69
  70 }