src/org/objectweb/cjdbc/controller/backup/BackupManager.java

説明を見る。

package org.objectweb.cjdbc.controller.backup;

import java.io.File;
import java.io.FilenameFilter;
import java.util.ArrayList;
import java.util.Hashtable;

import org.objectweb.cjdbc.common.exceptions.BackupException;
import org.objectweb.cjdbc.common.exceptions.OctopusException;
import org.objectweb.cjdbc.common.i18n.Translate;
import org.objectweb.cjdbc.common.log.Trace;
import org.objectweb.cjdbc.common.shared.BackupListener;
import org.objectweb.cjdbc.common.util.ZipMe;
import org.objectweb.cjdbc.common.xml.DatabasesXmlTags;
import org.objectweb.cjdbc.common.xml.XmlComponent;
import org.objectweb.cjdbc.controller.backend.DatabaseBackend;
import org.objectweb.cjdbc.controller.core.ControllerConstants;

public class BackupManager implements XmlComponent
{
  static Trace      logger           = Trace.getLogger(BackupManager.class
                                         .getName());
  private String    backupDir        = ControllerConstants.DEFAULT_BACKUP_DIR;
  private boolean   cleanBackupFiles = true;
  private boolean   zipBackupFiles   = true;
  private int       numberOfBackups  = -1;

  private Hashtable threads;

  public BackupManager(String backupDir, boolean cleanBackupFiles,
      boolean zipBackupFiles, int numberOfBackups)
  {
    this();
    this.backupDir = backupDir;
    this.cleanBackupFiles = cleanBackupFiles;
    this.zipBackupFiles = zipBackupFiles;
    this.numberOfBackups = numberOfBackups;

  }

  public BackupManager()
  {
    threads = new Hashtable();
  }

  public void backup(DatabaseBackend backend, String checkpoint,
      ArrayList tables,BackupListener listener) throws BackupException
  {
    logger.info(Translate.get("backup.manager.backuping.backend", new String[]{
        backend.getName(), checkpoint}));
    Octopus octopus = new Octopus(backend, checkpoint, tables);
    octopus.setZipOctopus(zipBackupFiles);
    octopus.setCleanOctopus(cleanBackupFiles);
    octopus.setOctopusMode(true);
    if(listener!=null)
      octopus.setListener(listener);
    threads.put(backend, octopus);
    octopus.start();
  }

  public synchronized void getResult(DatabaseBackend backend, long waitTime)
      throws BackupException, OctopusException
  {
    logger.info(Translate.get("backup.manager.waiting.backend.result",
        new String[]{backend.getName(), "" + (waitTime / 1000)}));
    Octopus backup = (Octopus) threads.get(backend);
    try
    {
      backup.join(waitTime);
    }
    catch (InterruptedException e)
    {
      logger.error("Interrupted while joining on backend:"+backend.getName(),e);
    }
    Exception e = backup.getRunException();
    if (e != null)
    {
      if (e instanceof BackupException)
        throw (BackupException) e;
      else if (e instanceof OctopusException)
        throw (OctopusException) e;
    }
      
  }

  public void restore(DatabaseBackend backend, String checkpoint,
      ArrayList tables,BackupListener listener) throws BackupException
  {
    logger.info(Translate.get("backup.manager.restoring.backend", new String[]{
        backend.getName(), checkpoint}));
    Octopus octopus = new Octopus(backend, checkpoint, tables);
    octopus.setZipOctopus(zipBackupFiles);
    octopus.setCleanOctopus(cleanBackupFiles);
    if(listener!=null)
      octopus.setListener(listener);
    octopus.setOctopusMode(false);
    threads.put(backend, octopus);
    octopus.start();
  }

  public File[] listAvailableDumpFiles()
  {
    File f = new File(backupDir);
    if (f.exists())
    {
      return f.listFiles(new FilenameFilter()
      {
        public boolean accept(File dir, String name)
        {
          if (name.endsWith(ZipMe.ZIP_EXT))
            return true;
          else
            return false;
        }
      });
    }
    else
      return new File[0];
  }

  public String getBackupDir()
  {
    return backupDir;
  }

  public void setBackupDir(String backupDir)
  {
    this.backupDir = backupDir;
  }

  public boolean isCleanBackupFiles()
  {
    return cleanBackupFiles;
  }

  public void setCleanBackupFiles(boolean cleanBackupFiles)
  {
    this.cleanBackupFiles = cleanBackupFiles;
  }

  public int getNumberOfBackups()
  {
    return numberOfBackups;
  }

  public void setNumberOfBackups(int numberOfBackups)
  {
    this.numberOfBackups = numberOfBackups;
  }

  public boolean isZipBackupFiles()
  {
    return zipBackupFiles;
  }

  public void setZipBackupFiles(boolean zipBackupFiles)
  {
    this.zipBackupFiles = zipBackupFiles;
  }

  public String getXml()
  {
    return "<" + DatabasesXmlTags.ELT_BACKUP + " "
        + DatabasesXmlTags.ATT_BACKUP_DIR + "=\"" + backupDir + "\" "
        + DatabasesXmlTags.ATT_BACKUP_CLEAN + "=\"" + cleanBackupFiles + "\" "
        + DatabasesXmlTags.ATT_BACKUP_ZIP + "=\"" + zipBackupFiles + "\" "
        + "/>";
  }
}

---