備份:backup database 數(shù)據(jù)庫(kù)名字 to disk='備份到的位置' with init
還原:restore database 數(shù)據(jù)庫(kù)名字 from disk='備份到的位置' with replace
數(shù)據(jù)庫(kù)連接類(lèi)
------------------------------------------------------------
package com;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.apache.log4j.Logger;
/**
* 數(shù)據(jù)庫(kù)備份與還原
* @author Stream
*
*/
public class DateBakDao {
/**
* 1
*/
private static String driver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
private static String url = "jdbc:sqlserver://localhost:1413;databaseName=stream";
private static String urlrevert = "jdbc:sqlserver://localhost:1413;databaseName=master"; //還原不能用自己的數(shù)據(jù)庫(kù),不能自己還原自己吧^_^
private static String username = "sa";
private static String password = "stream1990";
/**
* 2
*/
static {
try {
Class.forName(driver);
} catch (Exception e) {
// TODO: handle exception
}
}
/**
* 3
*/
public static Connection getCon(String type) {
Connection con = null;
try {
if(type.equals("bak")){ //因?yàn)閷?xiě)一個(gè)類(lèi)中,
con=DriverManager.getConnection(url,username,password);
}else{
con=DriverManager.getConnection(urlrevert,username,password);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
return con;
}
}
/**
* 4
*/
public static void closeCon(ResultSet rs,PreparedStatement ps,Connection con){
try {
if(rs!=null){
rs.close();
}
if(ps!=null){
ps.close();
}
if(con!=null){
con.close();
}
} catch (Exception e) {
// TODO: handle exception
}
}
public static void main(String[] args) {
System.out.println(getCon("bak"));
}
}
備份處理JSP
------------------------------------------------------------
<%@ page language="java" import="java.util.*,com.*,org.apache.log4j.Logger" pageEncoding="UTF-8"%>
<%@page import="java.sql.*;"%>
<%
boolean flag=true;
Connection con=null;
ResultSet rs=null;
String filePath="";
Logger logger=Logger.getLogger("doDataBak.jsp");
String value = request.getParameter("bakname");
if(value==null || value.trim().equals("")){
//為它取個(gè)名字
java.util.Date now = new java.util.Date();
java.text.SimpleDateFormat formatter = new java.text.SimpleDateFormat("yyyyMMddHHmmss");
value = formatter.format(now);
}
try{
con=new DateBakDao().getCon("bak");
filePath=this.getServletConfig().getServletContext().getRealPath("/")+"admin\\bak\\"+value+".dat";
String sql="backup database stream to disk='"+filePath+"'"+" with init";
//out.print(sql);
Statement st=con.createStatement(); //這句和注意咯,別習(xí)慣成自然寫(xiě)成另一句了
st.execute(sql);
logger.info("成功備份數(shù)據(jù)庫(kù)到"+filePath);
st.close();
}catch(Exception e){
flag=false;
e.printStackTrace();
logger.info("備份數(shù)據(jù)庫(kù)時(shí)出現(xiàn)錯(cuò)誤");
}finally{
new DateBakDao().closeCon(rs,null,con);
}
if(flag==true && new java.io.File(filePath).isFile()){
out.print("<script>alert('備份成功')</script>");
out.print("數(shù)據(jù)備份在"+filePath);
}else{
out.print("<script>alert('備份失敗')</script>");
}
%>
數(shù)據(jù)庫(kù)還原處理 JSP
------------------------------------------------------------
<%@ page language="java" import="java.util.*,com.*,org.apache.log4j.Logger" pageEncoding="UTF-8"%>
<%@page import="java.sql.*;"%>
<%
String filePath=request.getParameter("path");
boolean flag=true;
Connection con=null;
ResultSet rs=null;
Logger logger=Logger.getLogger("doDataRevert.jsp");
try{
//關(guān)閉這個(gè)數(shù)據(jù)庫(kù)的所有連接
con=new DateBakDao().getCon("revert");
String killconnsql = "exec killspid 'stream' "; //這里是執(zhí)行一個(gè)存儲(chǔ)過(guò)程,存儲(chǔ)過(guò)程在下面貼出
CallableStatement stt = con.prepareCall(killconnsql);
stt.execute();
stt.close();
//執(zhí)行數(shù)據(jù)庫(kù)還原
//filePath=this.getServletConfig().getServletContext().getRealPath("/")+"bak\\magic.dat";
String sql="restore database stream from disk='"+filePath+"'"+" with replace";
//out.print(sql);
Statement st=con.createStatement(); //同備份
st.execute(sql);
st.close();
}catch(Exception e){
flag=false;
e.printStackTrace();
logger.info("還原數(shù)據(jù)庫(kù)出現(xiàn)錯(cuò)誤");
}finally{
new DateBakDao().closeCon(rs,null,con);
}
if(flag==true){
logger.info("還原了一次數(shù)據(jù)庫(kù)");
out.print("還原成功");
}else{
out.print("<script>alert('還原失敗')</script>");
}
%>
關(guān)閉指定數(shù)據(jù)庫(kù)所有連接的存儲(chǔ)過(guò)程
------------------------------------------------------------
create proc killspid (@dbname varchar(20))
as
begin
declare @sql nvarchar(500)
declare @spid int
set @sql='declare getspid cursor for
select spid from sysprocesses where dbid=db_id('''+@dbname+''')'
exec (@sql)
open getspid
fetch next from getspid into @spid
while @@fetch_status < >-1
begin
exec('kill '+@spid)
fetch next from getspid into @spid
end
close getspid
deallocate getspid
end
--用法
use master
exec killspid '數(shù)據(jù)庫(kù)名'
定時(shí)備份數(shù)據(jù)庫(kù)
ContextListener類(lèi)
package serverbean;
import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.http.HttpServlet;
public class ContextListener extends HttpServlet implements
ServletContextListener {
/**
*
*/
private static final long serialVersionUID = 1L;
public ContextListener() {
}
private java.util.Timer timer = null;
public void contextInitialized(ServletContextEvent event) {
timer = new java.util.Timer(true);
event.getServletContext().log("定時(shí)器已啟動(dòng)");
//timer.schedule(new DatabaseTask(event.getServletContext()), 0,
// 60 * 60 * 1000); // 后邊最后一個(gè)參數(shù)代表監(jiān)視器的監(jiān)視周期,現(xiàn)在為一小時(shí)
timer.schedule(new DatabaseTask(event.getServletContext()), 0, 1000); // 后邊最后一個(gè)參數(shù)代表監(jiān)視器的監(jiān)視周期,現(xiàn)在為一秒
event.getServletContext().log("已經(jīng)添加任務(wù)調(diào)度表");
}
public void contextDestroyed(ServletContextEvent event) {
timer.cancel();
System.out.println("定時(shí)器銷(xiāo)毀");
event.getServletContext().log("定時(shí)器銷(xiāo)毀");
}
}
MyTask類(lèi)
package serverbean;
import java.util.Calendar;
import java.util.TimerTask;
import javax.servlet.ServletContext;
import javax.servlet.ServletException;
import java.sql.SQLException;
import java.text.SimpleDateFormat;
import dbconn.DBResult;
public class DatabaseTask extends TimerTask {
/**
* Constructor of the object.
*/
public DatabaseTask() {
super();
}
// private static final int C_SCHEDULE_HOUR = 3;//這個(gè)代表3點(diǎn)鐘的時(shí)候執(zhí)行任務(wù)
private static final int C_SCHEDULE_SECOND = 3;// 這個(gè)代表3秒鐘的時(shí)候執(zhí)行任務(wù)
private static boolean isRunning = false;
private ServletContext context = null;
public DatabaseTask(ServletContext context) {
this.context = context;
}
public void run() {
Calendar cal = Calendar.getInstance();
if (!isRunning) {
// if (C_SCHEDULE_HOUR == cal.get(Calendar.HOUR_OF_DAY)) {
if (C_SCHEDULE_SECOND == cal.get(Calendar.SECOND)) {
isRunning = true;
context.log("開(kāi)始執(zhí)行指定任務(wù)");
String filePath = this.context.getRealPath("/database_bak");
SimpleDateFormat tempDate = new SimpleDateFormat(
"yyyy-MM-dd" + "_" + "HH-mm-ss"); // HH表示24小時(shí)制，hh表示12小時(shí)制
String datetime = tempDate.format(new java.util.Date());
filePath = filePath + "\\FIOM_bak_" + datetime;
String sql = "backup database FIOM to disk= '" + filePath
+ "'";
DBResult conn=new DBResult();
try {
conn.executeUpdate(sql);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
// System.out.println(this.context.getRealPath("/database_bak"));
// 對(duì)table空值進(jìn)行修改,并更改編碼標(biāo)記.
// 由于在查詢(xún)時(shí)就進(jìn)行了鎖定,防止查詢(xún)后沒(méi)有錄入數(shù)據(jù)
// new CodeDAO().changeState();//此處寫(xiě)執(zhí)行任務(wù)代碼
isRunning = false;
context.log("指定任務(wù)執(zhí)行結(jié)束");
}
} else {
context.log("上一次任務(wù)執(zhí)行還未結(jié)束");
}
}
public void init() throws ServletException {
// Put your code here
}
}
最后需要在"web.xml"加上這樣一句話(huà)，這樣才能在服務(wù)器啟動(dòng)的時(shí)候就執(zhí)行監(jiān)視器。
<listener>
<listener-class>serverbean.ContextListener </listener-class>
</listener>
posted on 2011-11-04 22:32
飛翔天使 閱讀(899)
評(píng)論(0) 編輯 收藏 所屬分類(lèi):
JSP