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<StringBuffer> 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 <StringBuffer> 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 <StringBuffer> getQueryResult() { |
queryResult= new ArrayList<StringBuffer>(); |
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 <StringBuffer> 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 <StringBuffer> getQueryResult() { |
queryResult= new ArrayList<StringBuffer>(); |
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 <StringBuffer> getQueryResult() { |
setSQL( "SELECT * FROM " +tableName); |
return super .getQueryResult(); |
} |
} |