connectaccess.java

个人之前学JAVA编的一个日程管理小系统(用界面操作ACCESS).可当初学JAVA和数据库例子.

import java.sql.*;

public class ConnectAccess {
	String drv = "sun.jdbc.odbc.JdbcOdbcDriver";
	String url = "jdbc:odbc:MS Access Database;DBQ=";
	String dbFile = "D://prog/Java/HomeDog/HomeDog.mdb"; //数据库所在的目录
	String connAction = null;
	Connection conn = null;
	boolean connType = true;
	ResultSet rs = null;
	Statement sm = null;
	RecordType rt = new RecordType();
		
	public boolean createConn_Direct () {
		try {
			if (connAction == "GET") 
				throw new SQLException("J-ODBC have connected!");
			Class.forName(drv).newInstance();
			conn = DriverManager.getConnection(url + dbFile);
			connAction = "GET";
			connType = false;
			//showConnNUM();
		}
		catch (ClassNotFoundException ec) {
			System.out.println("Connected ERROR 1; It is : " + ec);
		}
		catch (SQLException es) {
			System.out.println("Connected ERROR 2; It is : " + es);
		}
		catch (Exception ex) {
			System.out.println("Connected ERROR 3; It is : " + ex);
		}
		
		if (conn == null) return false;
		else return true;
	}
	
	public boolean exeSQL (String sql) {
		try {
			conn.setAutoCommit(true);
			sm = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
			rs = sm.executeQuery(sql); 
		}
		catch (Exception ex) {
			System.out.println("Error in exeSQL(String sql): " + ex);
			return false;
		}
		
		return true;
	}
	
	/*
	public void searchFromID(int WID) {
		try {
			conn.setAutoCommit(true);
			sm = conn.createStatement();
			rs = sm.executeQuery("select * from work where ID=WID"); 
		}
		catch (Exception ex) {
			System.out.println("Connected ERROR searchFromID : " + ex);
		}
	}
	*/
	
	public boolean searchAll() {
		try {
			conn.setAutoCommit(true);
			sm = conn.createStatement(ResultSet.TYPE_SCROLL_INSENSITIVE, ResultSet.CONCUR_READ_ONLY);
			rs = sm.executeQuery("select * from work");
			System.out.println("searchALL OK!");
		}
		catch (Exception ex) {
			System.out.println("Connected ERROR searchAll : " + ex);
		}
		
		return true;
	}
	
	public void addData(RecordType rt) {
		String name = "chying";
	    String addSQL = "insert into work(user_ID, work_date,reg_date, content, other, state) values(1,'" + 
	                     rt.getWorkDate()+"','" + rt.getRegDate()+"','" + rt.getContent() + "','" + 
	                     rt.getOther() + "',0)";
		try {
			sm = conn.createStatement();
			sm.execute(addSQL);
			System.out.println("Insert OK!");
		}
		
		catch (Exception ex) {
			System.out.println("ERROR addData() : " + ex);
		}
	}
	
	public boolean alterData(RecordType rt) {
	    String addSQL = "update work set work_date='" + rt.getWorkDate() + "', reg_date= '" + 
	    				rt.getRegDate() + "', content= '" + rt.getContent() + "',other = '" + 
	    				rt.getOther() + "', state= '" + rt.getState() +"' where ID =" + rt.getID();
		try {
			sm = conn.createStatement();
			sm.execute(addSQL);
			System.out.println("alter OK!");
		}
		
		catch (Exception ex) {
			System.out.println("ERROR alterData() : " + ex);
			return false;
		}
		return true;
	}
	
	public void closeSQL() {
		try {
			sm.close();
			//rs.close();
			conn.close();
		}
		catch (Exception ex) {
			System.out.println("Connected ERROR closeSQL()  : " + ex);
		}
		System.out.println("Conn closed. OK!");
	}
		
	public static void main(String args[]) {
		ConnectAccess CA1 = new ConnectAccess();
		RecordType rt=null;
		
		System.out.println(CA1.createConn_Direct());
		CA1.searchAll();
		CA1.closeSQL();
	}
}