import java.sql.*; import java.util.*; public class Example14_9 { public static void main(String args[]) { SequencePrepareQuery query=new SequencePrepareQuery(); String datasorce="star"; String tableName="employee"; query.setDatasourceName(datasorce); query.setTableName(tableName); ArrayList result=query.getQueryResult(); for(StringBuffer str:result) { System.out.println(str); } } } import java.sql.*; import java.util.*; public class PreparedQuery { String datasourceName=""; //数据源名 String tableName=""; //表名 String SQL; //SQL语句 ArrayList queryResult; //查询结果 public PreparedQuery() { try{ Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); } catch(ClassNotFoundException e) { System.out.print(e); } } public void setDatasourceName(String s) { datasourceName=s.trim(); } public void setTableName(String s) { tableName=s.trim(); } public void setSQL(String SQL) { this.SQL=SQL; } public ArrayList getQueryResult() { queryResult=new ArrayList(); Connection con; Statement sql; ResultSet rs; try { String uri="jdbc:odbc:"+datasourceName; String id=""; String password=""; con=DriverManager.getConnection(uri,id,password); DatabaseMetaData metadata=con.getMetaData(); ResultSet rs1=metadata.getColumns(null,null,tableName,null); int 字段个数=0; while(rs1.next()) { 字段个数++; } sql=con.prepareStatemen(SQL); rs=sql.executeQuery(); while(rs.next()) { StringBuffer record=new StringBuffer(); for(int k=1;k<=字段个数;k++) { record.append(" "+rs.getString(k)+" "); } queryResult.add(record); } con.close(); } catch(SQLException e) { System.out.println("请输入正确的表名"+e); } return queryResult; } } import java.sql.*; import java.util.*; public class PrepareQuery { String datasourceName=""; //数据源名 String tableName=""; //表名 String SQL; //SQL语句 ArrayList queryResult; //查询结果 public PrepareQuery() { try{ Class.forName("sun.jdbc.odbc.JdbcOdbcDriver"); } catch(ClassNotFoundException e) { System.out.print(e); } } public void setDatasourceName(String s) { datasourceName=s.trim(); } public void setTableName(String s) { tableName=s.trim(); } public void setSQL(String SQL) { this.SQL=SQL; } public ArrayList getQueryResult() { queryResult=new ArrayList(); Connection con; PreparedStatement sql; ResultSet rs; try { String uri="jdbc:odbc:"+datasourceName; String id=""; String password=""; con=DriverManager.getConnection(uri,id,password); DatabaseMetaData metadata=con.getMetaData(); ResultSet rs1=metadata.getColumns(null,null,tableName,null); int 字段个数=0; while(rs1.next()) { 字段个数++; } sql=con.prepareStatement(SQL); rs=sql.executeQuery(); while(rs.next()) { StringBuffer record=new StringBuffer(); for(int k=1;k<=字段个数;k++) { record.append(" "+rs.getString(k)+" "); } queryResult.add(record); } con.close(); } catch(SQLException e) { System.out.println("请输入正确的表名"+e); } return queryResult; } } import java.sql.*; import java.util.*; public class SequencePrepareQuery extends PrepareQuery { public ArrayList getQueryResult() { setSQL("SELECT * FROM "+tableName); return super.getQueryResult(); } }