basedao.java

Jsf写的增删改查 Jsf写的增删改查

package com.accp;

import java.sql.*;

public class BaseDao {
    private Connection conn = null;
    private Statement stmt = null;
    private ResultSet rs = null;
    public BaseDao() {
        try {
            Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
            conn = DriverManager.getConnection("jdbc:odbc:Driver={MicroSoft Access Driver (*.mdb)};DBQ=E:\\Sjsf\\accp.mdb","","");
            stmt =  conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE);
        } catch (Exception ex) {
        }
    }

    public static void main(String[] args) throws SQLException {
        BaseDao db = new BaseDao();
        String sql  = "select * from noteinfo";
        int pageSize = 3;
        int pageNow = 3;
        ResultSet rs = db.executeQuery(sql);
        rs.absolute((pageNow-1)*pageSize+1);
        for(int i =0;i<pageSize;i++)
        {
            System.out.println(rs.getString("userName"));
            if(!rs.next()) break;
        }
    }

    public void executeUpdate(String sql) throws SQLException {
        System.out.println(sql);
        stmt.executeUpdate(sql);
    }

    public ResultSet executeQuery(String sql) throws SQLException {
        rs = stmt.executeQuery(sql);
        return rs;
    }

    public void close()
    {
        try
        {
            if(rs!=null) rs.close();
        }catch(Exception ex){}
        try
        {
            if(stmt!=null) stmt.close();
        }catch(Exception ex){}
        try
        {
            if(conn!=null) conn.close();
        }catch(Exception ex){}


    }
}