accessdbconn.java

图书馆管理系统 能满足 查询

package com.jxyd.sql;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class AccessDBConn {
	private Connection conn;            //连接对象
    private Statement stmt;                //语句对象
    private ResultSet rs;                //结果集对象
    private String accessdriver;        //保存Access驱动程序字符串
    private String accessURL;             //保存Access连接字符串
    private String dbpath="C:/tomcat/webapps/BookManager/data.mdb";

    public AccessDBConn()
    {
        //Access驱动程序
        accessdriver = "sun.jdbc.odbc.JdbcOdbcDriver";        
        //连接字符串
        accessURL = "jdbc:odbc:Driver={Microsoft Access Driver (*.mdb)};DBQ=";
        conn = null;
    }

    //该方法从参数得到数据库路径，并加到连接字符串后面,然后再建立连接
    public Connection getConnToAccess(){
        try{
            accessURL=accessURL+dbpath;
            Class.forName(accessdriver);
            conn = DriverManager.getConnection(accessURL);
            System.out.println("找到数据库文件，连接成功...");
            }catch(Exception e){
                System.out.println("操作数据库出错，请仔细检查文件路径...");
                System.err.println(e.getMessage());
            }
        return conn;
    }
            
    
  //执行插入更新时的方法
	public boolean executeUpdate(String username,String mbno,String msg) {
		String sql="insert into OutBox (username,Mbno,Msg) values('"+username+"','"+mbno+"','"+msg+"')";
		boolean bupdate = false;
		try {
			// 建立数据库连接，其它参数说明同上面的一样
			Connection conn = this.getConnToAccess();
			Statement stmt = conn.createStatement();
			int rowCount = stmt.executeUpdate(sql);
			// 如果不成功，bupdate就会返回0
			if (rowCount != 0)
				bupdate = true;
			System.out.println("短信提醒已经成功发出...");
		} catch (SQLException ex) {
			// 打印出错信息
			System.err.println("db.executeUpdate: " + ex.getMessage());
		}
		return bupdate;
	}
	
	
    //执行查询时的方法
	public ResultSet executeQuery(String sql) {
		rs = null;
		try {
			Connection conn = this.getConnToAccess();
			Statement stmt = conn.createStatement();
			rs = stmt.executeQuery(sql);

		} catch (Exception e) {
			System.err.println("db.executeQuery: " + e.getMessage());

		}
		return rs;

	}
	
	//关闭数据库连接
    public void close()
    {
        try{
            rs.close();
            stmt.close();
            conn.close(); 
        }catch(SQLException sqlexception){
            sqlexception.printStackTrace();
        }
    }


}