database.java~24~

来自「很好的Java绘图程序源代码」· JAVA~24~ 代码 · 共 121 行

package project;

import java.sql.*;
import java.io.File;
import javax.swing.JOptionPane;
/**
 * <p>Title: </p>
 *
 * <p>Description: </p>
 *
 * <p>Copyright: Copyright (c) 2006</p>
 *
 * <p>Company: </p>
 *
 * @author not attributable
 * @version 1.0
 */
public class DataBase {
  private Connection conn = null;
  private Statement sta = null;
  private ResultSet rs = null;


public DataBase() {
    try {

     // Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
          Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
    }
    catch (ClassNotFoundException ex) {
      ex.printStackTrace();
    }


  }

private Connection getConn(){
  Connection conn = null;
  //String conStr = "jdbc:microsoft:sqlserver://localhost:1433;DatabaseName=HRM";
 String conStr = "jdbc:odbc:test";
  try {
    conn = DriverManager.getConnection(conStr, "sa", "");
  }
  catch (SQLException ex) {
    ex.printStackTrace();
  }
  finally{
    return conn;
  }
}

public int executeUpdate(String sql){
  int res = -1;
  conn = this.getConn();
  try {
    sta = conn.createStatement();
    res = sta.executeUpdate(sql);
  }
  catch (SQLException ex) {
    ex.printStackTrace();
  }
  finally{
    return res;
  }

}

public ResultSet executeQuery(String sql){
  ResultSet rs = null;
  conn = this.getConn();
  try {
    sta = conn.createStatement();
    rs = sta.executeQuery(sql);
  }
  catch (SQLException ex) {
    ex.printStackTrace();
  }
  finally{
    return rs;
  }

}

public void close(){
  if(conn == null){
    return;
  }
  if(sta == null){
    return;
  }
  try {
    sta.close();
    conn.close();
  }
  catch (SQLException ex) {
    ex.printStackTrace();
  }
  sta = null;
  conn = null;
}
public void DateBackUp()
{
  String backFile = "HRM";
       File f = new File("");
       String sql = "BACKUP DATABASE HRM TO disk='" +
                    f.getAbsoluteFile().getAbsolutePath() + "\\backup\\" +
                    backFile + "'";

  try {
    JOptionPane.showMessageDialog(null,"开始备份。。。。。");
    conn = this.getConn();
    sta = conn.createStatement();
    sta.execute(sql);
  }
  catch (SQLException ex) {
  }


}
}