VirtualDatabaseAdmin.java

/**
 * C-JDBC: Clustered JDBC.
 * Copyright (C) 2002-2005 French National Institute For Research In Computer
 * Science And Control (INRIA).
 * Contact: c-jdbc@objectweb.org
 * 
 * This library is free software; you can redistribute it and/or modify it
 * under the terms of the GNU Lesser General Public License as published by the
 * Free Software Foundation; either version 2.1 of the License, or any later
 * version.
 * 
 * This library is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License
 * for more details.
 * 
 * You should have received a copy of the GNU Lesser General Public License
 * along with this library; if not, write to the Free Software Foundation,
 * Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA.
 *
 * Initial developer(s): Emmanuel Cecchet.
 * Contributor(s): Mathieu Peltier, Nicolas Modrzyk
 */

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.GetBackendSchema;
import org.objectweb.cjdbc.console.text.commands.dbadmin.RemoveCheckpoint;
import org.objectweb.cjdbc.console.text.commands.dbadmin.RemoveDumpFile;
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.ShowBackendState;
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;
import org.objectweb.cjdbc.console.text.commands.dbadmin.ViewDumpNames;

/**
 * This is the C-JDBC controller console virtual database administration module.
 * 
 * @author <a href="mailto:Emmanuel.Cecchet@inria.fr">Emmanuel Cecchet </a>
 * @author <a href="mailto:Mathieu.Peltier@inrialpes.fr">Mathieu Peltier </a>
 * @author <a href="mailto:Nicolas.Modrzyk@inrialpes.fr">Nicolas Modrzyk </a>
 * @version 1.0
 */
public class VirtualDatabaseAdmin extends AbstractConsoleModule
{
  private String virtualDbName, login, password;

  /**
   * Returns the login value.
   * 
   * @return Returns the login.
   */
  public String getLogin()
  {
    return login;
  }

  /**
   * Returns the password value.
   * 
   * @return Returns the password.
   */
  public String getPassword()
  {
    return password;
  }

  /**
   * Returns the virtualDbName value.
   * 
   * @return Returns the virtualDbName.
   */
  public String getVirtualDbName()
  {
    return virtualDbName;
  }

  /**
   * @see org.objectweb.cjdbc.console.text.module.AbstractConsoleModule#login(java.lang.String[])
   */
  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();
    }

  }

  /**
   * @see org.objectweb.cjdbc.console.text.module.AbstractConsoleModule#getDescriptionString()
   */
  public String getDescriptionString()
  {
    return "VirtualDatabase Administration";
  }

  /**
   * @see org.objectweb.cjdbc.console.text.module.AbstractConsoleModule#getPromptString()
   */
  public String getPromptString()
  {
    return virtualDbName + "(" + login + ")";
  }

  /**
   * @see org.objectweb.cjdbc.console.text.module.AbstractConsoleModule#loadCommands()
   */
  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 GetBackendSchema(this));
    commands.add(new Native(this));
    commands.add(new RemoveCheckpoint(this));
    commands.add(new RemoveDumpFile(this));
    commands.add(new Replicate(this));
    commands.add(new Restore(this));
    commands.add(new TransferBackend(this));
    commands.add(new ShowBackends(this));
    commands.add(new ShowBackendState(this));
    commands.add(new SetCheckpoint(this));
    commands.add(new ViewCheckpointNames(this));
    commands.add(new ViewDumpNames(this));
  }

  /**
   * Creates a new <code>VirtualDatabaseAdmin</code> instance.
   * 
   * @param console console console
   */
  public VirtualDatabaseAdmin(Console console)
  {
    super(console);
  }
}

---