J2EE下的oracle数据库备份方法

简介:

 

1./**
  *   @Description :   实现数据库的备份
*   @since JDK1.5
  *   @date   (开发日期):   2009 - 06 - 10
  *   @ 注意事项 :数据库备份文件放在服务器上 , 路径在 Constant 里设置,如希望正确使用,需要导入相关 jar
  *    
  */
 
 
     public class  BackUpDataBaseAction  extends  Action {
 
    static  Logger logger = Logger.getLogger(BackUpDataBaseAction. class);
 
    public  ActionForward execute(ActionMapping actionMapping,
           ActionForm actionForm, HttpServletRequest httpServletRequest,
           HttpServletResponse httpServletResponse) {
 
       Calendar cDay = Calendar.getInstance();
       SimpleDateFormat myf =  new  SimpleDateFormat( "yyyyMMddHHmmss" );
       String day = myf.format(cDay.getTime());
        //  获得 Constant 中定义的数据库备份文件存放路径,格式如:
         // public static final String DataBaseBackUpPath = "D:\\sOADB\\";
String outputFile = Constant.DataBaseBackUpPath;
        //  如果服务器端硬盘上不存在 outputFile 目录,则创建这个目录
       File mydir =  new  File(outputFile);
        if  (!(mydir.exists())) {
           mydir.mkdir();
       }
 
        //  备份文件名
       String fileName =  "soa"  + day +  ".dmp" ;
        //  将备份好的数据库文件放在服务器端的 outputFile 目录下
      
        //  得到数据库的连接信息
 
         //  得到物理路径 , 取得 applicationContext.xml 中数据库定义,
// url,usrname,password O/R 映射文件等内容
       ServletContext m_application =  this .getServlet().getServletContext();
       String path = m_application.getRealPath( "/" );
       String filename = path +  "WEB-INF\\applicationContext.xml" ;
       WriteXMLWithDom wxf =  new  WriteXMLWithDom();
       String[] str = wxf.GetOralAddrWithDom(filename);
        if  (str[0].equalsIgnoreCase( "" )) {
            return  actionMapping.findForward( "failure" );
       }
        // str[1]  用户名   ,[2]  用户密码  ,
        //  服务器地址 ,[0]
       String command =  "exp  " +str[1]+ "/" +str[2]+ "@" +str[0].substring(str[0].lastIndexOf( ':' )+1)+ " file="  + outputFile+ fileName;
       Runtime rt = Runtime.getRuntime();
        // Process process=null;
        try  {
 
            // process=rt.exec(command);
           rt.exec(command);
            // process.waitFor();
            //  假等待一下 , 目的是让其能在文件列表中列出 , 可以 process.destroy() 得到
           Thread.sleep(5000);
        catch  (Exception e) {
             // 捕捉异常
           String errorSORT = Constant.errorBeifen;
           httpServletRequest.setAttribute( "ERRORSORT" , errorSORT);
          
           String error =  " 数据库备份操作失败,请稍候再试!  " ;
           httpServletRequest.setAttribute( "PUBLICINFERROR" , error);
            return  actionMapping.findForward( "warning" );
       }
        // p.destroy();
        logger .warn(StringUtil.getLogString(((UserInfo) httpServletRequest
              .getSession().getAttribute(Constant.USER)).getUserAccount(),
               " 执行了数据库备份操作 " ));
 
        return  actionMapping.findForward( "success" );
    }
 
}
 2.获取application中关于数据库定义的信息,包括用户名,密码,url,.hbm.xml文件等。
package com.gao.sys;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStreamWriter;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.parsers.ParserConfigurationException;
import javax.xml.transform.OutputKeys;
import javax.xml.transform.Result;
import javax.xml.transform.Source;
import javax.xml.transform.Transformer;
import javax.xml.transform.TransformerConfigurationException;
import javax.xml.transform.TransformerException;
import javax.xml.transform.TransformerFactory;
import javax.xml.transform.dom.DOMSource;
import javax.xml.transform.stream.StreamResult;
import org.w3c.dom.Document;
import org.w3c.dom.Element;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;
import org.w3c.dom.Text;
import org.xml.sax.SAXException;
public class WriteXMLWithDom {
 public WriteXMLWithDom() {
 }
 public int CallWriteXMLWithDom(String fname, String tablename) {
  int returnValue = 0;
  try {
   File file = new File(fname);
   BufferedInputStream bufferedInputStream = new BufferedInputStream(
     new FileInputStream(file));
   DocumentBuilderFactory factory = DocumentBuilderFactory
     .newInstance();
   DocumentBuilder parser = factory.newDocumentBuilder();
   InputStream instr = new FileInputStream(fname);
   Document doc = parser.parse(instr);
   // 根节点
   NodeList nodeList = doc.getElementsByTagName("beans");
   for (int b = 0; b < nodeList.getLength(); b++) {
    Node book = nodeList.item(b);
    for (Node bean = book.getFirstChild(); bean != null; bean = bean
      .getNextSibling()) {
     // bean节点
     if (bean.getNodeName().equals("bean")) {
      for (int i = 0; i < bean.getChildNodes().getLength(); i++) {
       // property节点
       Node pro = bean.getChildNodes().item(i);
       if (pro.getAttributes() != null
         && pro.getAttributes().getNamedItem("name") != null) {
        if (pro.getAttributes().getNamedItem("name")
          .getNodeValue().equals(
            "mappingResources")) {
         // list节点
         Node listn = pro.getFirstChild()
           .getNextSibling();
         Element elistn = (Element) listn;
         Element newvalue = doc
           .createElement("value");
         Text newtest = doc
           .createTextNode("com/gao/data/bean/"
             + tablename + ".hbm.xml");
         newvalue.appendChild(newtest);
         elistn.appendChild(newvalue);
        }
       }
      }
     }
    }
   }
   // }
   FileOutputStream outStream = new FileOutputStream(fname);
   OutputStreamWriter outWriter = new OutputStreamWriter(outStream,
     "UTF-8");
   try {
    // Prepare the DOM document for writing
    Source source = new DOMSource(doc);
    // Prepare the output file
    Result result = new StreamResult(outWriter);
    // Write the DOM document to the file
    Transformer xformer = TransformerFactory.newInstance()
      .newTransformer();
    xformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8");
    // xformer.setOutputProperty(OutputKeys.DOCTYPE_SYSTEM,"dtd/spring-beans.dtd");
    // xformer.setOutputProperty(OutputKeys.DOCTYPE_PUBLIC,"-//SPRING//DTD
    // BEAN//EN");
    xformer.transform(source, result);
   } catch (TransformerConfigurationException e) {
    e.printStackTrace();
   } catch (TransformerException e) {
    e.printStackTrace();
   }
   try {
    outWriter.close();
    outStream.close();
    returnValue = 1;
   } catch (IOException e) {
    // TODO 自动生成 catch 块
    e.printStackTrace();
   } finally {
    return returnValue;
   }
  } catch (ParserConfigurationException e) {
   e.printStackTrace();
  } catch (FileNotFoundException e) {
   e.printStackTrace();
  } catch (SAXException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  } finally {
   return returnValue;
  }
 }
 public int DeleteNodeFromXMLWithDom(String fname, String tablename) {
  int returnValue = 0;
  try {
   File file = new File(fname);
   BufferedInputStream bufferedInputStream = new BufferedInputStream(
     new FileInputStream(file));
   DocumentBuilderFactory factory = DocumentBuilderFactory
     .newInstance();
   DocumentBuilder parser = factory.newDocumentBuilder();
   InputStream instr = new FileInputStream(fname);
   Document doc = parser.parse(instr);
   // 根节点
   NodeList nodeList = doc.getElementsByTagName("beans");
   for (int b = 0; b < nodeList.getLength(); b++) {
    Node book = nodeList.item(b);
    for (Node bean = book.getFirstChild(); bean != null; bean = bean
      .getNextSibling()) {
     // bean节点
     if (bean.getNodeName().equals("bean")) {
      for (int i = 0; i < bean.getChildNodes().getLength(); i++) {
       // property节点
       Node pro = bean.getChildNodes().item(i);
       if (pro.getAttributes() != null
         && pro.getAttributes().getNamedItem("name") != null) {
        if (pro.getAttributes().getNamedItem("name")
          .getNodeValue().equals(
            "mappingResources")) {
         // list节点
         Node listn = pro.getFirstChild()
           .getNextSibling();
         Element elistn = (Element) listn;
         
         Node valuen = elistn.getFirstChild();
         
         int k = valuen.getChildNodes().getLength();
         for(int j=0;j<elistn.getChildNodes().getLength()-1;j++){
          valuen=valuen.getNextSibling();
          if(valuen.getTextContent().contains(
            tablename)){
           listn.removeChild(valuen);
           break;
          }
          
          
         }
        
        }
       }
      }
     }
    }
   }
   // }
   FileOutputStream outStream = new FileOutputStream(fname);
   OutputStreamWriter outWriter = new OutputStreamWriter(outStream,
     "UTF-8");
   try {
    // Prepare the DOM document for writing
    Source source = new DOMSource(doc);
    // Prepare the output file
    Result result = new StreamResult(outWriter);
    // Write the DOM document to the file
    Transformer xformer = TransformerFactory.newInstance()
      .newTransformer();
    xformer.setOutputProperty(OutputKeys.ENCODING, "UTF-8");
    xformer.transform(source, result);
   } catch (TransformerConfigurationException e) {
    e.printStackTrace();
   } catch (TransformerException e) {
    e.printStackTrace();
   }
   try {
    outWriter.close();
    outStream.close();
    returnValue = 1;
   } catch (IOException e) {
    // TODO 自动生成 catch 块
    e.printStackTrace();
   } finally {
    return returnValue;
   }
  } catch (ParserConfigurationException e) {
   e.printStackTrace();
  } catch (FileNotFoundException e) {
   e.printStackTrace();
  } catch (SAXException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  } finally {
   return returnValue;
  }
 }
 public String[] GetOralAddrWithDom(String fname) {
  String[] str = { "", "", "" };
  try {
   File file = new File(fname);
   BufferedInputStream bufferedInputStream = new BufferedInputStream(
     new FileInputStream(file));
   DocumentBuilderFactory factory = DocumentBuilderFactory
     .newInstance();
   DocumentBuilder parser = factory.newDocumentBuilder();
   InputStream instr = new FileInputStream(fname);
   Document doc = parser.parse(instr);
   // 根节点
   NodeList nodeList = doc.getElementsByTagName("beans");
   for (int b = 0; b < nodeList.getLength(); b++) {
    Node book = nodeList.item(b);
    for (Node bean = book.getFirstChild(); bean != null; bean = bean
      .getNextSibling()) {
     // bean节点
     if (bean.getNodeName().equals("bean")
       && bean.getAttributes().getNamedItem("id")
         .getNodeValue().equals("DataSource")) {
      for (int i = 0; i < bean.getChildNodes().getLength(); i++) {
       // property节点
       Node pro = bean.getChildNodes().item(i);
       if (pro.getAttributes() != null
         && pro.getAttributes().getNamedItem("name") != null) {
        if (pro.getAttributes().getNamedItem("name")
          .getNodeValue().equals("url")) {
         str[0] = pro.getAttributes().getNamedItem(
           "value").getNodeValue();
        }
        if (pro.getAttributes().getNamedItem("name")
          .getNodeValue().equals("username")) {
         str[1] = pro.getAttributes().getNamedItem(
           "value").getNodeValue();
        }
        if (pro.getAttributes().getNamedItem("name")
          .getNodeValue().equals("password")) {
         str[2] = pro.getAttributes().getNamedItem(
           "value").getNodeValue();
        }
       }
      }
     }
    }
   }
  } catch (ParserConfigurationException e) {
   e.printStackTrace();
  } catch (FileNotFoundException e) {
   e.printStackTrace();
  } catch (SAXException e) {
   e.printStackTrace();
  } catch (IOException e) {
   e.printStackTrace();
  } finally {
   return str;
  }
 }
}
 
大家可以比较阅读的文章;
 
 
      本文转自 gaochaojs 51CTO博客,原文链接:http://blog.51cto.com/jncumter/166362,如需转载请自行联系原作者


相关文章
|
15天前
|
Oracle 关系型数据库 数据库
已解决:idea 连接 oracle 数据库 避雷
已解决:idea 连接 oracle 数据库 避雷
|
5天前
|
Oracle 关系型数据库 数据库
实时计算 Flink版产品使用问题之连接到Oracle数据库但无法读取到数据,是什么导致的
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
8天前
|
SQL 关系型数据库 MySQL
MYSQL————DDL方法使用(包含在数据库,以及具体数据库表格的一些操纵)
MYSQL————DDL方法使用(包含在数据库,以及具体数据库表格的一些操纵)
|
12天前
|
SQL Oracle 关系型数据库
探索 Linux 命令 `db_archive`:Oracle 数据库归档日志的工具
探索 Linux 中的 `db_archive`,实际与 Oracle 数据库归档日志管理相关。在 Oracle 中,归档日志用于恢复,当在线重做日志满时自动归档。管理员可使用 SQL*Plus 查看归档模式,通过 `RMAN` 进行备份和恢复操作。管理归档日志需谨慎,避免数据丢失。了解归档管理对 Oracle 管理员至关重要,确保故障时能快速恢复数据库。
|
10天前
|
SQL 数据管理 关系型数据库
数据管理DMS产品使用合集之误删了数据库后,恢复方法有哪些
阿里云数据管理DMS提供了全面的数据管理、数据库运维、数据安全、数据迁移与同步等功能,助力企业高效、安全地进行数据库管理和运维工作。以下是DMS产品使用合集的详细介绍。
|
14天前
|
SQL Oracle 关系型数据库
改变Oracle数据库连接端口
改变Oracle数据库连接端口
24 4
|
5天前
|
SQL Oracle 关系型数据库
实时计算 Flink版产品使用问题之在进行Oracle数据库的全量同步时,只同步了一条数据而源表实际上包含多条数据,是什么原因
实时计算Flink版作为一种强大的流处理和批处理统一的计算框架,广泛应用于各种需要实时数据处理和分析的场景。实时计算Flink版通常结合SQL接口、DataStream API、以及与上下游数据源和存储系统的丰富连接器,提供了一套全面的解决方案,以应对各种实时计算需求。其低延迟、高吞吐、容错性强的特点,使其成为众多企业和组织实时数据处理首选的技术平台。以下是实时计算Flink版的一些典型使用合集。
|
8天前
|
存储 Oracle 关系型数据库
Oracle数据库快速入门
Oracle数据库快速入门
11 0
|
10天前
|
存储 Oracle 关系型数据库
|
16天前
|
Oracle 关系型数据库 数据库
oracle误删除数据的恢复方法
oracle误删除数据的恢复方法

热门文章

最新文章

推荐镜像

更多