Pastebin.vip

Database usage preprocessing

From , 5 Years ago, written in Java, viewed 210 times.
URL https://pastebin.vip/view/aa169b49
  1. import java.sql.*;
  2. import java.util.*;
  3. public class Example14_9 {
  4.    public static void main(String args[]) {
  5.      SequencePrepareQuery query=new SequencePrepareQuery();
  6.      String datasorce="star";
  7.      String tableName="employee";
  8.      query.setDatasourceName(datasorce);
  9.      query.setTableName(tableName);
  10.      ArrayList<StringBuffer> result=query.getQueryResult();
  11.      for(StringBuffer str:result) {
  12.         System.out.println(str);  
  13.      }
  14.   }
  15. }
  16.  
  17. import java.sql.*;
  18. import java.util.*;
  19. public class PreparedQuery {
  20.    String datasourceName="";        //数据源名
  21.    String tableName="";            //表名
  22.    String SQL;                     //SQL语句
  23.    ArrayList <StringBuffer> queryResult;  //查询结果
  24.    public PreparedQuery() {
  25.       try{  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
  26.       }
  27.       catch(ClassNotFoundException e) {
  28.          System.out.print(e);
  29.       }
  30.    }
  31.    public void setDatasourceName(String s) {
  32.       datasourceName=s.trim();
  33.    }
  34.    public void setTableName(String s) {
  35.       tableName=s.trim();
  36.    }
  37.    public void setSQL(String SQL) {
  38.       this.SQL=SQL;
  39.    }
  40.    public ArrayList <StringBuffer> getQueryResult() {
  41.       queryResult=new ArrayList<StringBuffer>();
  42.       Connection con;
  43.       Statement sql;
  44.       ResultSet rs;
  45.       try {
  46.            String uri="jdbc:odbc:"+datasourceName;
  47.            String id="";
  48.            String password="";
  49.            con=DriverManager.getConnection(uri,id,password);
  50.            DatabaseMetaData metadata=con.getMetaData();
  51.            ResultSet rs1=metadata.getColumns(null,null,tableName,null);
  52.            int 字段个数=0;
  53.            while(rs1.next()) {
  54.               字段个数++;
  55.            }
  56.            sql=con.prepareStatemen(SQL);
  57.            rs=sql.executeQuery();
  58.            while(rs.next()) {
  59.              StringBuffer record=new StringBuffer();
  60.              for(int k=1;k<=字段个数;k++) {
  61.                  record.append(" "+rs.getString(k)+" ");
  62.              }
  63.              queryResult.add(record);
  64.            }
  65.            con.close();
  66.        }
  67.        catch(SQLException e) {
  68.            System.out.println("请输入正确的表名"+e);
  69.        }
  70.        return queryResult;
  71.    }    
  72. }
  73.  
  74. import java.sql.*;
  75. import java.util.*;
  76. public class PrepareQuery {
  77.    String datasourceName="";        //数据源名
  78.    String tableName="";            //表名
  79.    String SQL;                     //SQL语句
  80.    ArrayList <StringBuffer> queryResult;  //查询结果
  81.    public PrepareQuery() {
  82.       try{  Class.forName("sun.jdbc.odbc.JdbcOdbcDriver");
  83.       }
  84.       catch(ClassNotFoundException e) {
  85.          System.out.print(e);
  86.       }
  87.    }
  88.    public void setDatasourceName(String s) {
  89.       datasourceName=s.trim();
  90.    }
  91.    public void setTableName(String s) {
  92.       tableName=s.trim();
  93.    }
  94.    public void setSQL(String SQL) {
  95.       this.SQL=SQL;
  96.    }
  97.    public ArrayList <StringBuffer> getQueryResult() {
  98.       queryResult=new ArrayList<StringBuffer>();
  99.       Connection con;
  100.       PreparedStatement sql;
  101.       ResultSet rs;
  102.       try {
  103.            String uri="jdbc:odbc:"+datasourceName;
  104.            String id="";
  105.            String password="";
  106.            con=DriverManager.getConnection(uri,id,password);
  107.            DatabaseMetaData metadata=con.getMetaData();
  108.            ResultSet rs1=metadata.getColumns(null,null,tableName,null);
  109.            int 字段个数=0;
  110.            while(rs1.next()) {
  111.               字段个数++;
  112.            }
  113.            sql=con.prepareStatement(SQL);
  114.            rs=sql.executeQuery();
  115.            while(rs.next()) {
  116.              StringBuffer record=new StringBuffer();
  117.              for(int k=1;k<=字段个数;k++) {
  118.                  record.append(" "+rs.getString(k)+" ");
  119.              }
  120.              queryResult.add(record);
  121.            }
  122.            con.close();
  123.        }
  124.        catch(SQLException e) {
  125.            System.out.println("请输入正确的表名"+e);
  126.        }
  127.        return queryResult;
  128.    }    
  129. }
  130.  
  131. import java.sql.*;
  132. import java.util.*;
  133. public class SequencePrepareQuery extends PrepareQuery {
  134.    public ArrayList <StringBuffer> getQueryResult() {
  135.        setSQL("SELECT * FROM "+tableName);
  136.        return super.getQueryResult();
  137.    }    
  138. }
  139.  
  140.  
  141.  

Reply to "Database usage preprocessing"

Here you can reply to the paste above

captcha

https://burned.cc - Burn After Reading Website
Powered by Pastebin.vip paste tool since 2022!