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.Ndb;
  22 import com.mysql.cluster.ndbj.NdbApiException;
  23 import com.mysql.clusterj.ClusterJDatastoreException;
  24 import com.mysql.clusterj.core.store.ClusterTransaction;
  25 import com.mysql.clusterj.core.util.I18NHelper;
  26 import com.mysql.clusterj.core.util.Logger;
  27 import com.mysql.clusterj.core.util.LoggerFactoryService;
  28
  29 /**
  30  *
  31  */
  32 class DbImpl implements com.mysql.clusterj.core.store.Db {
  33
  34     /** My message translator */
  35     static final I18NHelper local = I18NHelper.getInstance(DbImpl.class);
  36
  37     /** My logger */
  38     static final Logger logger = LoggerFactoryService.getFactory()
  39             .getInstance(com.mysql.clusterj.core.store.ClusterConnection.class);
  40
  41     protected Ndb ndb;
  42
  43     public DbImpl(Ndb ndb) {
  44         this.ndb = ndb;
  45     }
  46
  47     public void close() {
  48         ndb.close();
  49     }
  50
  51     public com.mysql.clusterj.core.store.Dictionary getDictionary() {
  52         try {
  53             return new DictionaryImpl(ndb.getDictionary());
  54         } catch (NdbApiException ndbApiException) {
  55             throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
  56                     ndbApiException);
  57         }
  58     }
  59
  60     public ClusterTransaction startTransaction() {
  61         try {
  62             return new ClusterTransactionImpl(ndb.startTransaction());
  63         } catch (NdbApiException ndbApiException) {
  64             throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
  65                     ndbApiException);
  66         }
  67     }
  68
  69     public boolean isRetriable(ClusterJDatastoreException ex) {
  70         return false;
  71     }
  72
  73 }