databasemanager.java

采用java+sql实现图书管理系统

import java.sql.*;

public class DataBaseManager {
  Connection con;//声明con
  ResultSet rs;//声明rs结果集
  Statement stmt;
  //getConnection() 得到连接数据库的属性文件内容，并返回连接结果集 
  //声明drivers，得到数据库的驱动程序 
  //声明url，得到连接远程数据库的URL 
  //声明username，得到连接远程数据库的用户名 
  //声明password，得到连接远程数据库的密码 
  public DataBaseManager() {
    try{
        Class.forName("com.microsoft.sqlserver.jdbc.SQLServerDriver");}
       catch(ClassNotFoundException e){System.out.println(""+e);}
 try{
   String uri="jdbc:sqlserver://127.0.0.1:1433;DatabaseName=LibraryManagement";
  String user="sa";
 String password="sa";
 con=DriverManager.getConnection(uri,user,password);
      stmt = con.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,
                                 ResultSet.CONCUR_UPDATABLE);
    }
    catch (SQLException sqle) {//无法连接数据库
      System.out.println(sqle.toString());
    }
   // catch (ClassNotFoundException cnfex) {
     // cnfex.printStackTrace();//装载 JDBC/ODBC 驱动程序失败
    //}
  }

  public ResultSet getResult(String strSQL) {//strSQL为传入的查询的sql语
    try {
      rs = stmt.executeQuery(strSQL);//rs为返回查询的单个结果集
      return rs;
    }
    catch (SQLException sqle) {
      System.out.println(sqle.toString());//连接数据库失败
      return null;
    }

  }

  public int updateSql(String strSQL) {
    try {
      int i=stmt.executeUpdate(strSQL);//修改数据库记录操作，返回影响行数
      con.commit();//进行数据库操作后必须事物提交
      return i;
    }
    catch (SQLException sqle) {
      System.out.println(sqle.toString());
      return -1;
    }
  }

  public void closeConnection() {
    try {
      con.close();//断开数据库的连接
    }
    catch (SQLException sqle) {
      System.out.println(sqle.toString());
    }
  }

}