src/org/objectweb/cjdbc/console/jmx/VirtualDatabaseJmxClient.java

説明を見る。

package org.objectweb.cjdbc.console.jmx;

import java.util.ArrayList;
import java.util.Map;

import javax.management.MBeanException;

import org.objectweb.cjdbc.common.exceptions.ExceptionTypes;
import org.objectweb.cjdbc.common.jmx.JmxConstants;
import org.objectweb.cjdbc.common.jmx.JmxException;

public class VirtualDatabaseJmxClient extends JmxClient
{
  private String virtualDbName;
  private String username;
  private String password;

  public VirtualDatabaseJmxClient(String name, String username,
      String password, String host, String port, Object credentials)
      throws JmxException, MBeanException
  {
    super.connect(host, port, credentials);
    connect(name, username, password);
  }

  private void connect(String name, String username, String password)
      throws JmxException, MBeanException
  {
    mbean = JmxConstants.getVirtualDbObjectName(name);
    this.virtualDbName = name;
    this.username = username;
    this.password = password;
    boolean ok = checkAdminAuthentication(username, password);
    if (!ok)
    {
      mbean = null;
      throw new JmxException(ExceptionTypes.AUTHENTICATION_FAILED);
    }
  }

  public String[] getBackendInformation(String backendName)
      throws JmxException, MBeanException
  {
    return (String[]) invoke("viewBackendInformation", new Object[]{username,
        password, backendName}, new String[]{"java.lang.String",
        "java.lang.String", "java.lang.String"});
  }

  public boolean checkAdminAuthentication(String adminLogin,
      String adminPassword) throws JmxException, MBeanException
  {
    Object o = invoke("checkAdminAuthentication", new Object[]{adminLogin,
        adminPassword}, new String[]{"java.lang.String", "java.lang.String"});
    return new Boolean(o.toString()).booleanValue();
  }

  public boolean hasRecoveryLog() throws JmxException, MBeanException
  {
    Object o = invoke("hasRecoveryLog", new Object[]{username, password},
        new String[]{"java.lang.String", "java.lang.String"});
    return new Boolean(o.toString()).booleanValue();
  }

  public boolean isDistributed() throws JmxException, MBeanException
  {
    Object o = invoke("isDistributed", new Object[]{username, password},
        new String[]{"java.lang.String", "java.lang.String"});
    return new Boolean(o.toString()).booleanValue();
  }

  public void disableBackend(String databaseBackendName) throws JmxException,
      MBeanException
  {
    invoke("disableBackend", new Object[]{username, password,
        databaseBackendName}, new String[]{"java.lang.String",
        "java.lang.String", "java.lang.String"});
  }

  public void disableBackendForCheckpoint(String databaseBackendName,
      String checkpointName) throws JmxException, MBeanException
  {
    invoke("disableBackendForCheckpoint", new Object[]{username, password,
        databaseBackendName, checkpointName}, new String[]{"java.lang.String",
        "java.lang.String", "java.lang.String", "java.lang.String"});
  }

  public void enableBackend(String databaseBackendName) throws JmxException,
      MBeanException
  {
    invoke("enableBackend", new Object[]{username, password,
        databaseBackendName}, new String[]{"java.lang.String",
        "java.lang.String", "java.lang.String"});
  }

  public void enableBackendFromCheckpoint(String databaseBackendName,
      String checkpointName) throws JmxException, MBeanException
  {
    invoke("enableBackendFromCheckpoint", new Object[]{username, password,
        databaseBackendName, checkpointName}, new String[]{"java.lang.String",
        "java.lang.String", "java.lang.String", "java.lang.String"});
  }

  public ArrayList getAllBackendNames() throws JmxException, MBeanException
  {
    return (ArrayList) invoke("viewAllBackendNames", new Object[]{username,
        password}, new String[]{"java.lang.String", "java.lang.String"});
  }

  public ArrayList getCheckpointNames() throws JmxException, MBeanException
  {
    return (ArrayList) invoke("viewCheckpointNames", new Object[]{username,
        password}, new String[]{"java.lang.String", "java.lang.String"});
  }

  public String getName()
  {
    if (JmxConstants.DEBUG)
      System.out.println("#DEBUG#getName for:" + virtualDbName);
    return virtualDbName;
  }

  public void enableAllBackend() throws JmxException, MBeanException
  {
    invoke("enableAllBackend", new Object[]{username, password}, new String[]{
        "java.lang.String", "java.lang.String"});
  }

  public void enableAllBackend(String checkpoint) throws JmxException,
      MBeanException
  {
    if (checkpoint == null)
    {
      this.enableAllBackend();
      return;
    }
    invoke(
        "enableAllBackend",
        new Object[]{username, password, checkpoint},
        new String[]{"java.lang.String", "java.lang.String", "java.lang.String"});
  }

  public void disableAllBackend() throws JmxException, MBeanException
  {
    invoke("disableAllBackend", new Object[]{username, password}, new String[]{
        "java.lang.String", "java.lang.String"});
  }

  public void disableAllBackendForCheckpoint(String checkpoint)
      throws JmxException, MBeanException
  {
    invoke("disableAllBackendForCheckpoint", new Object[]{username, password,
        checkpoint}, new String[]{"java.lang.String", "java.lang.String",
        "java.lang.String"});
  }

  public void backupBackendWithCheckpoint(String backendName,
      String checkpointName, ArrayList tables) throws JmxException,
      MBeanException
  {
    invoke("backupBackendWithCheckpoint", new Object[]{username, password,
        backendName, checkpointName, tables}, new String[]{"java.lang.String",
        "java.lang.String", "java.lang.String", "java.lang.String",
        "java.util.ArrayList"});
  }

  public void removeCheckpoint(String checkpointName) throws JmxException,
      MBeanException
  {
    invoke("removeCheckpoint",
        new Object[]{username, password, checkpointName}, new String[]{
            "java.lang.String", "java.lang.String", "java.lang.String"});
  }

  public String getBackendState(String backendName) throws JmxException,
      MBeanException
  {
    return (String) invoke("getBackendState", new Object[]{username, password,
        backendName}, new String[]{"java.lang.String", "java.lang.String",
        "java.lang.String"});
  }

  public void shutdown() throws JmxException, MBeanException
  {
    invoke("shutdown", new Object[]{username, password}, new String[]{
        "java.lang.String", "java.lang.String"});
  }

  public String getOwningController() throws JmxException, MBeanException
  {
    return (String) invoke("viewOwningController", new Object[]{username,
        password}, new String[]{"java.lang.String", "java.lang.String"});
  }

  public void restoreBackendFromBackupCheckpoint(String databaseBackendName,
      String checkpointName) throws JmxException, MBeanException
  {
    invoke("restoreBackendFromBackupCheckpoint", new Object[]{username,
        password, databaseBackendName, checkpointName}, new String[]{
        "java.lang.String", "java.lang.String", "java.lang.String",
        "java.lang.String"});
  }

  public void replicateBackend(String backendName, String newBackendName,
      Map parameters) throws JmxException, MBeanException
  {
    invoke("replicateBackend", new Object[]{username, password, backendName,
        newBackendName, parameters}, new String[]{"java.lang.String",
        "java.lang.String", "java.lang.String", "java.lang.String",
        "java.util.Map"});
  }

  public String[] viewControllerList() throws JmxException, MBeanException
  {
    return (String[]) invoke("viewControllerList", new Object[]{username,
        password}, new String[]{"java.lang.String", "java.lang.String"});
  }
}

---