src/org/objectweb/cjdbc/console/text/module/VirtualDatabaseAdmin.java

説明を見る。

package org.objectweb.cjdbc.console.text.module;

import org.objectweb.cjdbc.common.i18n.ConsoleTranslate;
import org.objectweb.cjdbc.common.jmx.mbeans.ControllerMBean;
import org.objectweb.cjdbc.common.jmx.mbeans.VirtualDatabaseMBean;
import org.objectweb.cjdbc.console.text.Console;
import org.objectweb.cjdbc.console.text.commands.Help;
import org.objectweb.cjdbc.console.text.commands.History;
import org.objectweb.cjdbc.console.text.commands.Native;
import org.objectweb.cjdbc.console.text.commands.Quit;
import org.objectweb.cjdbc.console.text.commands.dbadmin.Backup;
import org.objectweb.cjdbc.console.text.commands.dbadmin.Disable;
import org.objectweb.cjdbc.console.text.commands.dbadmin.DisableAll;
import org.objectweb.cjdbc.console.text.commands.dbadmin.DisableRead;
import org.objectweb.cjdbc.console.text.commands.dbadmin.Enable;
import org.objectweb.cjdbc.console.text.commands.dbadmin.EnableAll;
import org.objectweb.cjdbc.console.text.commands.dbadmin.EnableRead;
import org.objectweb.cjdbc.console.text.commands.dbadmin.RemoveCheckpoint;
import org.objectweb.cjdbc.console.text.commands.dbadmin.Replicate;
import org.objectweb.cjdbc.console.text.commands.dbadmin.Restore;
import org.objectweb.cjdbc.console.text.commands.dbadmin.SetCheckpoint;
import org.objectweb.cjdbc.console.text.commands.dbadmin.ShowBackends;
import org.objectweb.cjdbc.console.text.commands.dbadmin.TransferBackend;
import org.objectweb.cjdbc.console.text.commands.dbadmin.ViewCheckpointNames;

public class VirtualDatabaseAdmin extends AbstractConsoleModule
{
  private String virtualDbName, login, password;

  public String getLogin()
  {
    return login;
  }

  public String getPassword()
  {
    return password;
  }

  public String getVirtualDbName()
  {
    return virtualDbName;
  }

  public void login(String[] params)
  {
    // In case a login has failed before
    quit = false;
    String vdbName = params[0];
    try
    {
      if (vdbName == null || vdbName.trim().equals(""))
      {
        vdbName = console.readLine(ConsoleTranslate.get("admin.login.dbname"));
        if (vdbName == null)
          return;
      }

      login = console.readLine(ConsoleTranslate.get("admin.login.user"));
      if (login == null)
        return;

      password = console.readPassword(ConsoleTranslate
          .get("admin.login.password"));
      if (password == null)
        return;

      try
      {
        ControllerMBean mbean = console.getJmxClient().getControllerProxy();
        if (!mbean.hasVirtualDatabase(vdbName))
        {
          console.printError(ConsoleTranslate.get("module.database.invalid",
              vdbName));
          quit();
          return;
        }
        VirtualDatabaseMBean vdb = console.getJmxClient()
            .getVirtualDatabaseProxy(vdbName, login, password);
        if (!vdb.checkAdminAuthentication(login, password))
        {
          console.printError(ConsoleTranslate.get("module.database.login.fail",
              login));
          quit();
        }
      }
      catch (Exception e)
      {
        // does not exists: quit
        console.printError(ConsoleTranslate.get("module.database.invalid",
            vdbName), e);
        quit();
      }
      this.virtualDbName = vdbName;
      if (quit)
        return;

      // Reload commands because target has changed
      loadCommands();
      console.println(ConsoleTranslate.get("admin.login.ready", virtualDbName));
    }
    catch (Exception e)
    {
      console.printError(e.getMessage(), e);
      quit();
    }

  }

  public String getDescriptionString()
  {
    return "VirtualDatabase Administration";
  }

  public String getPromptString()
  {
    return virtualDbName + "(" + login + ")";
  }

  protected void loadCommands()
  {
    commands.clear();
    commands.add(new Help(this));
    commands.add(new History(this));
    commands.add(new Quit(this));
    commands.add(new Backup(this));
    commands.add(new Disable(this));
    commands.add(new DisableRead(this));
    commands.add(new DisableAll(this));
    commands.add(new Enable(this));
    commands.add(new EnableRead(this));
    commands.add(new EnableAll(this));
    commands.add(new Native(this));
    commands.add(new RemoveCheckpoint(this));
    commands.add(new Replicate(this));
    commands.add(new Restore(this));
    commands.add(new TransferBackend(this));
    commands.add(new ShowBackends(this));
    commands.add(new SetCheckpoint(this));
    commands.add(new ViewCheckpointNames(this));
  }

  public void quit()
  {
    quit = true;
  }

  public VirtualDatabaseAdmin(Console console)
  {
    super(console);
  }
}

---