19 package com.mysql.clusterj.bindings;
21 import com.mysql.cluster.ndbj.Ndb;
22 import com.mysql.cluster.ndbj.NdbApiException;
23 import com.mysql.cluster.ndbj.NdbClusterConnection;
24 import com.mysql.clusterj.ClusterJDatastoreException;
25 import com.mysql.clusterj.core.store.Db;
26 import com.mysql.clusterj.core.util.I18NHelper;
27 import com.mysql.clusterj.core.util.Logger;
28 import com.mysql.clusterj.core.util.LoggerFactoryService;
41 .
getInstance(com.mysql.clusterj.core.store.ClusterConnection.class);
49 }
catch (NdbApiException ndbApiException) {
55 public void connect(
int connectRetries,
int connectDelay,
boolean verbose) {
58 }
catch (NdbApiException ndbApiException) {
64 public Db createDb(
String database,
int maxTransactions) {
67 return new DbImpl(ndb);
68 }
catch (NdbApiException ndbApiException) {
69 throw new ClusterJDatastoreException(local.
message(
"ERR_Datastore"),
74 public void waitUntilReady(
int connectTimeoutBefore,
int connectTimeoutAfter) {
77 }
catch (NdbApiException ndbApiException) {
78 throw new ClusterJDatastoreException(local.
message(
"ERR_Datastore"),