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

説明を見る。

package org.objectweb.cjdbc.console.jmx;

import java.io.DataInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.util.ArrayList;

import javax.management.MBeanException;

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

public class ControllerJmxClient extends JmxClient
{

  public void connect(String host, String port, Object credentials)
      throws JmxException
  {
    mbean = JmxConstants.getControllerObjectName();
    super.connect(host, port, credentials);
    // validate MBean
    if (!this.validateTarget())
    {
      throw new JmxException("Invalid MBean target");
    }
  }

  public boolean isDistributedVirtualDatabase(String databaseName)
      throws JmxException, MBeanException
  {
    return ((Boolean) invoke("isDistributedVirtualDatabase",
        new Object[]{databaseName}, new String[]{"java.lang.String"}))
        .booleanValue();
  }

  public void connect(String controllerName) throws JmxException
  {
    int index = controllerName.indexOf(":");
    String ip = controllerName.substring(0, index);
    String port = controllerName.substring(index + 1);
    this.connect(ip, port, credentials);
  }

  public String getInfo() throws JmxException, MBeanException
  {
    StringBuffer info = new StringBuffer();
    info.append((String) (invoke("viewConfiguration", null)));
    info.append((String) (invoke("viewDatabases", null)));
    return info.toString();
  }

  public String getXml() throws JmxException, MBeanException
  {
    return (String) (invoke("viewInfo", null, null));
  }

  public String viewDatabasesXml() throws JmxException, MBeanException
  {
    return (String) (invoke("viewDatabasesXml", null, null));
  }

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

  public void refreshLogConfiguration() throws JmxException, MBeanException
  {
    invoke("refreshLogConfiguration", null, null);

  }

  public void addVirtualDatabase(String xmlConfig) throws JmxException,
      MBeanException
  {
    invoke("addVirtualDatabases", new Object[]{xmlConfig},
        new String[]{"java.lang.String"});
  }

  private void addDriver(byte[] bytes) throws JmxException, MBeanException
  {
    invoke("addDriver", new Object[]{bytes}, new String[]{"[B"});
  }

  public void addDriver(String filename) throws FileNotFoundException,
      IOException, JmxException, MBeanException
  {
    File file;
    FileInputStream fileInput = null;
    file = new File(filename);
    fileInput = new FileInputStream(file);

    // Read the file into an array of bytes
    long size = file.length();
    if (size > Integer.MAX_VALUE)
    {
      // File is too large
      throw new IOException("File is too large");
    }
    byte[] bytes = new byte[(int) size];

    int nb = fileInput.read(bytes);
    fileInput.close();
    if (nb != size)
    {
      throw new IOException("Failed to read the file");
    }
    addDriver(bytes);
  }

  public void addVirtualDatabases(String xml, String virtualName,
      boolean autoEnable, String checkPoint) throws JmxException,
      MBeanException
  {

    invoke("addVirtualDatabase", new Object[]{xml, virtualName,
        new Boolean(autoEnable), checkPoint}, new String[]{"java.lang.String",
        "java.lang.String", "boolean", "java.lang.String"});
  }

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

  public ArrayList listVirtualDatabases() throws JmxException, MBeanException
  {
    return (ArrayList) invoke("listVirtualDatabases", null, null);
  }

  public ArrayList listBackends(String virtualDbName) throws JmxException,
      MBeanException
  {
    return (ArrayList) invoke("listBackends", new Object[]{virtualDbName},
        new String[]{"java.lang.String"});
  }

  public String loadXML(String filename) throws IOException, JmxException,
      MBeanException
  {
    FileInputStream fis = new FileInputStream(filename);
    DataInputStream dis = new DataInputStream(fis);
    StringBuffer sb = new StringBuffer();
    String concat = "";
    while ((concat = DataInputStream.readUTF(dis)) != null)
      sb.append(concat);
    return (String) invoke("loadXML", new Object[]{sb.toString()},
        new String[]{"java.lang.String"});
  }

  public String loadXmlConfiguration(String filename, String virtualName,
      boolean autoEnable, String checkPoint) throws Exception
  {
    FileInputStream fis = new FileInputStream(filename);
    DataInputStream dis = new DataInputStream(fis);
    StringBuffer sb = new StringBuffer();
    String concat = "";
    while ((concat = DataInputStream.readUTF(dis)) != null)
      sb.append(concat);
    return (String) invoke("loadXML", new Object[]{sb.toString(), virtualName,
        new Boolean(autoEnable), checkPoint}, new String[]{"java.lang.String",
        "java.lang.String", "boolean", "java.lang.String"});
  }

  public String removeVirtualDatabase(String virtualname) throws Exception
  {
    return (String) invoke("removeVirtualDatabase", new Object[]{virtualname},
        new String[]{"java.lang.String"});
  }

  public String saveConfiguration() throws Exception
  {
    return (String) server.invoke(mbean, "saveConfiguration", null, null);
  }

  public void shutdown(int level) throws Exception
  {
    invoke("shutdown", new Object[]{new Integer(level)}, new String[]{"int"});
  }

  public void shutdownDatabase(String databaseName, int level)
      throws JmxException, MBeanException
  {
    invoke("shutdownDatabase", new Object[]{databaseName, new Integer(level)},
        new String[]{"java.lang.String", "int"});
  }

  public String generateReport() throws JmxException, MBeanException
  {
    return (String) invoke("generateReport", null, null);
  }

  public String generateLogReport() throws JmxException, MBeanException
  {
    return (String) invoke("generateLogReport", null, null);
  }

  public ArrayList listDatabaseClients(String virtualDbName)
      throws JmxException, MBeanException
  {
    return (ArrayList) invoke("listDatabaseClients",
        new Object[]{virtualDbName}, new String[]{"java.lang.String"});
  }

  public boolean isCacheEnableForDatabase(String virtualDbName)
      throws JmxException, MBeanException
  {
    return ((Boolean) invoke("isCacheEnableForDatabase",
        new Object[]{virtualDbName}, new String[]{"java.lang.String"}))
        .booleanValue();
  }

  public File[] listAvailableDumpFiles() throws JmxException, MBeanException
  {
    return (File[]) invoke("listAvailableDumpFiles", null, null);
  }

  public boolean removeDumpFile(File dumpFile) throws JmxException,
      MBeanException
  {
    return ((Boolean) invoke("removeDumpFile", new Object[]{dumpFile},
        new String[]{"java.io.File"})).booleanValue();
  }

  public String viewLogConfigurationFile() throws JmxException, MBeanException
  {
    return (String) invoke("viewLogConfigurationFile", null, null);
  }

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

  }

}

---