database.java~2~

Java+MySQL开发员工管理系统

package com.source;

import java.sql.*;

public class Database{
  public static Connection cn;
  public static Statement st;
  public static ResultSet rs;

  public static boolean joinDB() {
  	boolean joinFlag;
  	try {
  	  joinFlag = true;
//      Class.forName("com.microsoft.jdbc.sqlserver.SQLServerDriver");
//      String url = "jdbc:microsoft:sqlserver://127.0.0.1:1433";

	  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
	  String url="jdbc:odbc:EmployeeInformationMS";


      String Username = "sa";
      String Password = "";
      cn = DriverManager.getConnection(url,Username,Password);

      cn.setCatalog("EmployeeInformationMS");
      System.out.println("数据库连接成功");
      st = cn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);
      return joinFlag;

    }catch(SQLException sqlEx) {
      System.out.println(sqlEx.getMessage());

      joinFlag = false;
      return joinFlag;

    }catch(ClassNotFoundException notfoundEX) {
      System.out.println(notfoundEX.getMessage());

      joinFlag = false;
      return joinFlag;
    }
  }

  public static boolean executeSQL(String sqlString) {
    boolean executeFlag;
    try {
      st.execute(sqlString);
      executeFlag = true;
    }catch(Exception e) {
      executeFlag = false;
      System.out.println("sql exception:" + e.getMessage());
    }
    return executeFlag;
  }


  public static boolean query(String sqlString) {

    try {
      rs=null;
      //System.out.println(sqlString);
      rs = st.executeQuery(sqlString);
    }catch(Exception Ex) {
      System.out.println("sql exception:"+Ex);
      return false;
    }
    return true;
  }
}