操作access

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

public class MsAccessDBUtils {
    private static MsAccessDBUtils instance = null;
    public static MsAccessDBUtils getInstance() {
        if (instance == null) {
            instance = new MsAccessDBUtils();
        }
        return instance;
    }

    private MsAccessDBUtils() {}

    //最先被调用 mdbFile=d:\xxx.mdb
    public void loadConfig(String mdbFile,String user,String psw) throws Exception{
        mdb_file = mdbFile;
        user = user;
        pwd = psw;
        loadDriver();
    }
    
    public void loadConfig(String mdbFile) throws Exception{
        mdb_file = mdbFile;
        loadDriver();
    }
    private static String dirverClass = "sun.jdbc.odbc.JdbcOdbcDriver";
    private static String url = "jdbc:odbc:Driver={Microsoft Access Driver (*.mdb)}; DBQ=";
    private static String mdb_file = null;//access 文件[这里要绝对路径]
    private static String user = "";
    private static String pwd = "";
    private static Connection conn;
    private static Statement stmt;
    private static ResultSet rs;

    private void loadDriver() throws Exception{
        try {
            Class.forName(dirverClass);
        } catch (Exception e) {
            throw e;
        }
    }

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

    //关闭连接
    public static void close() throws Exception{
        try {
            if (rs != null) {
                rs.close();
                rs=null;
            }
            if (stmt != null) {
                stmt.close();
                stmt=null;
            }
            if (conn != null) {
                conn.close();
                conn=null;
            }
        } catch (Exception e) {
            throw e;
        }
    }

    //查询语句
    public static List executeQuery(String sql) throws Exception{
        List l = new ArrayList();
        try {
            if (stmt == null) {
                connect();
            }
            rs = stmt.executeQuery(sql);
            l = orgResultSet4List(rs);
            //close();
        } catch (Exception e) {
            throw e;
        }
        return l;
    }

    public static int executeUpdate(String sql) throws Exception{
        try {
            if (stmt == null) {
                connect();
            }
            int res = stmt.executeUpdate(sql);
            //close();
            return res;
        } catch (Exception e) {
            throw e;
        }
    }
    public static int[] executeUpdate(String[] sql)  throws Exception{
        try {
            if (stmt == null) {
                connect(false);
            }
            for (int i = 0; i < sql.length; i++) {
                stmt.addBatch(sql[i]);
            }
            int[] res = stmt.executeBatch();
            conn.commit();
            //close();
            return res;
        } catch (Exception e) {
            throw e;
        }
    }
    private static List orgResultSet4List(ResultSet rs)throws Exception{
        try {
            ResultSetMetaData rsmd = rs.getMetaData();
            int cols = rsmd.getColumnCount();
            List l = new ArrayList();
            Map recordMap = null;
            while (rs.next()) {
                recordMap = new HashMap();
                for (int i = 0; i < cols; i++) {
                    recordMap.put((String)(rsmd.getColumnName(i+1)).toLowerCase(),rs.getObject(i+1));
                }
                l.add(recordMap);
            }
            return l;
        }
        catch (Exception ex) {
            //ex.printStackTrace();
            throw ex;
        }
    }

    public static void main(String[] args) {
        

        
    }
}