19 package com.mysql.clusterj.bindings;
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;
30 class ScanOperationImpl
extends OperationImpl implements ScanOperation {
34 ScanOperationImpl(
NdbScanOperation operation, ClusterTransactionImpl transaction) {
35 super(operation, transaction);
36 this.scanOperation = operation;
40 scanOperation.close();
43 public void deleteCurrentTuple() {
45 scanOperation.deleteCurrentTuple();
46 }
catch (NdbApiException ndbApiException) {
47 throw new ClusterJDatastoreException(local.message(
"ERR_Datastore"),
54 return new ScanFilterImpl(scanOperation.getNdbScanFilter());
55 }
catch (NdbApiException ndbApiException) {
56 throw new ClusterJDatastoreException(local.message(
"ERR_Datastore"),
61 public int nextResult(
boolean fetch) {
63 return scanOperation.nextResult(fetch);
64 }
catch (NdbApiException ndbApiException) {
65 throw new ClusterJDatastoreException(local.message(
"ERR_Datastore"),