operatdatabase.java

JSP开发的学生信息管理系统

package operator;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.io.*;

public class OperatDatabase 
{
	String sDBDriver = "com.microsoft.sqlserver.jdbc.SQLServerDriver";
	String sConnStr = "jdbc:sqlserver://localhost:1433;DatabaseName=";
	String id="sa";
	String password="";
	Connection con = null;
	ResultSet rs = null;
	Statement stmt=null;
	

	public OperatDatabase() {
		try {
		Class.forName(sDBDriver);
	}
	catch(java.lang.ClassNotFoundException e) {
		System.err.println("conn(): " + e.getMessage());
	}
	}
	
	public int getLastChar(String strrecv,char chrrecv){
	   int iRet=0;
	   int strlength = strrecv.length();
	   for( int i=0;i<strlength; i++)
	   {
		   if(strrecv.charAt(i) == chrrecv)
		      iRet = i;
	    }
	    return iRet;
	}
	
	public String IIf(boolean flag,String str1,String str2){
		if( flag )
			return str1;
		else
			return str2;
	}
	


public boolean backupDatabase(String sBackUpfileName,String sDataBaseName)
	{
		String iConcStr,iSql, iReturn;
		iConcStr = sConnStr + " master ";
		iSql = "backup database [" + sDataBaseName + "]" + "to disk='" + sBackUpfileName + "'";
		try
			{	
				con=DriverManager.getConnection(sConnStr,id,password);
				stmt=con.createStatement();
				stmt.execute(iSql);
			}
			catch(SQLException ex)
			{
				System.err.println("con.executeUpdate:"+ ex.getMessage());
				return false;
			}

		return true;
	}


public String restoreDatabase(String sBackUpfileName,String sDataBaseName,String sDataBasePath,String sBackupNumber,boolean sReplaceExist){

     String iConcStr,iSql,iReturn,iI;
     int iBeg,iEnd;
     iConcStr = sConnStr + " master ";
	 iSql="";
	 

	 try
		{
		con=DriverManager.getConnection(sConnStr,id,password);	
		stmt=con.createStatement();
		
	    if( sDataBasePath.equals("")  ){
				iSql = "select filename from master..sysfiles";
				rs = stmt.executeQuery(iSql);//iRe.Open iSql, iDb, adOpenKeyset, adLockReadOnly;
				iSql = rs.getString(0);
				rs.close();
				sDataBasePath = iSql.substring( 0, iSql.lastIndexOf("\\"));
			}

    
	    if( !sReplaceExist ){
				iSql = "select 1 from master..sysdatabases  where name='" + sDataBaseName + "'";
				rs=stmt.executeQuery(iSql);
				if( rs.next()){
						iReturn = "exist";
						rs.close();
					}else {
						iReturn = "notExist";
						rs.close();
						return iReturn;
						}
						rs = null;
			}
	
	    iSql = "select spid from master..sysprocesses where dbid=db_id('" + sDataBaseName + "')";
	    rs=stmt.executeQuery(iSql);
	    while(rs.next()){
				iSql = "kill " + String.valueOf(rs.getInt("spid"));
				stmt.execute(iSql);
			}
	    rs.close();
	 
	    iSql = "restore database [" + sDataBaseName + "]"+"from disk='" + sBackUpfileName + "'";
	    if(sReplaceExist){
	               iSql = iSql + " with REPLACE ";
			}else {
				   iSql = iSql+"";
				}
	    stmt.execute(iSql);
	    iReturn = "sucess";
	    return iReturn;
	}
	catch(SQLException sx)
	{
		System.err.println("con.executeUpdate:"+ sx.getMessage());
		iReturn="failer";
		return iReturn;
	}
}
	   

public void close()
   {
    try{
       if(con!=null)
       {
          con.close();
        }
       }
       catch(SQLException ex)
		{
			System.err.println("con.executeDelete: "+ ex.getMessage());
		}

   }
  /* 
   public static void main(String[] args)throws SQLException{
   	OperatDatabase test=new OperatDatabase();
   	ResultSet rst=test.executeQuery("select * from dbo.shujukubeifen");
   	while(rst.next()){
   		System.out.print(rst.getString("backupId"));
   		System.out.print(rst.getString("backupName"));
   		System.out.print(rst.getString("backupTime"));
   	}
   }*/
}