sqltest.java

使用JDBC测试access

import java.sql.*;

public class SQLTEST {
	String driver = "sun.jdbc.odbc.JdbcOdbcDriver";
// 不用设置系统DNS加载 access数据库的url
	String url = "jdbc:odbc:Driver={Microsoft Access Driver (*.mdb)};DBQ=d:\\P4.mdb";
//	设置了系统DNS的加载url；test为系统
//	String url = "jdbc:odbc:test";
	String user = "";
	String pwd = "";
	Connection conn;
	Statement stmt;
	ResultSet rs;
	public static void main(String[] args){
		SQLTEST test = new SQLTEST();
		test.connect();
		String sql = "select * from people;";
	    ResultSet rs = test.executeQuery(sql);
	  try{
	    while(rs.next()){
	    	System.out.println(rs.getString("Name")+rs.getString("Address"));
	    }
	  }catch(Exception e){
		  
	  }
	}
	public SQLTEST() {
		try {
			Class.forName(driver);
		} catch (Exception e) {
			System.out.println(e);
		}
	}

//	　　　//创建不可滚动的连接
	public void connect() {
		try {
			conn = DriverManager.getConnection(url,user,pwd);
			stmt = conn.createStatement();
		} catch (Exception e) {
			System.out.println(e);
		}
	}
//	　　　//创建可以滚动的连接
	public void connect2() {
		try {
			conn = DriverManager.getConnection(url,user,pwd);
			stmt = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_READ_ONLY);
		} catch (Exception e) {
			System.out.println(e);
		}
	}

//	　　　//关闭连接
	public void close() {
		try {
			if (stmt != null) {
				stmt.close();
			}
			if (conn != null) {
				conn.close();
			}
		} catch (Exception e) {
				System.out.println(e);
		}
	}
//	　　　//查询语句
	public ResultSet executeQuery(String sql) {
		try {
			if (stmt == null) {
				connect();
			}
			rs = stmt.executeQuery(sql);
		} catch (Exception e) {
			System.out.println(e);
		}
		return rs;
	}
}