java访问数据库

    技术2022-05-11  80

    import java.sql.*; import javax.sql.RowSet; public class AccessData {         /** Creates a new instance of AccessData */     public AccessData() {     }     public static void main(String []Args){         AccessData database=new AccessData();         database.setConnectString("jdbc:odbc:padoo");         database.setDriverString("sun.jdbc.odbc.JdbcOdbcDriver");         database.setQueryString("select * from product");         database.Access();         database.HandleData();         database.closeDatabase();     }     private String connect_string=null;     private String DriverString=null;     private String query_string=null;     private RowSet rsa=null;     private ResultSet rs=null;     private Connection cn=null;     private PreparedStatement ps=null;     public void Access(){                       try {             Class.forName(DriverString);         } catch (ClassNotFoundException ex) {             ex.printStackTrace();         }         try {             cn=DriverManager.getConnection(connect_string);             ps=cn.prepareStatement(query_string,ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_READ_ONLY);             rs=ps.executeQuery();                   } catch (SQLException ex) {             ex.printStackTrace();         }             }     public void setConnectString(String connection){         this.connect_string=connection;     }     public void setQueryString(String query){         this.query_string=query;     }     public void setDriverString(String DriverString){         this.DriverString=DriverString;     }     public RowSet getRowset(){         return rsa;     }     public void HandleData(){         try {             while(rs.next()){                 System.out.println(rs.getString(6));             }            System.out.println(this.getRows());         } catch (SQLException ex) {             ex.printStackTrace();         }     }     public void closeDatabase(){         try {             rs.close();             ps.close();             cn.close();         } catch (SQLException ex) {             ex.printStackTrace();         }           }     public int getRows(){         int result_number=0;         try {             result_number=rs.getRow();             if(!rs.absolute(1)){                 System.out.println(result_number+" is available");             }             else{                 rs.last();                 result_number=rs.getRow();                 rs.absolute(result_number);             }         } catch (SQLException ex) {             ex.printStackTrace();                     }finally{             return result_number;         }            } } 

    最新回复(0)