p082107 - 経済統計練習帳

package air3;
 
import tool.*;
 
import java.util.HashMap;
 
public class pro {
 
    int creditnumber;
String[] creditp=new String[50]; 
String[] style=new String[50]; 
int[] strlong=new int[50];
    String[][] datax=new String[500000][10];
 
 
 
   HashMap<String,Integer> map = new HashMap<String,Integer>();
   int s,datanumber;
 String[] data=new String[5000];
 String yy,mm;
     String[] v=new String[5000];
     String[] route=new String[5000];
      String[] year=new String[5000];
      String[] month=new String[5000];
      int[] code=new int[5000];
        int h,fastline;
  int dicnumber; 
   String[] dic=new String[5000];
 
   public static void main(String[] args) {
       pro te=new pro();
   }
   pro(){
 
       creditnumber=4;
       creditp[1]="year";
       creditp[2]="month";
       creditp[3]="route";
       creditp[4]="value"; 
       style[1]="INTEGER";
       style[2]="INTEGER";
       style[3]="VARCHAR";
       style[4]="VARCHAR";
 
       strlong[3]=20;
       strlong[4]=20;
 
       String db,tab;
 
       db="air";
       tab="air6";
 
 
       table sub7=new table();
       sub7.credit=creditp;
       sub7.creditnumber=creditnumber;
       sub7.style=style;
       sub7.strlong=strlong;
       sub7.makedata(db,tab);
 
 
 
 
       int tr;
 
            dicnumber=0;
 
       for(tr=0;tr<98;tr++){
       readfile sub77=new readfile();
       sub77.makedata("air/"+tr+".txt","UTF-8");
       data=sub77.data;
       datanumber=sub77.datanumber;  
 
        for(s=1;s<datanumber+1;s++){
 
     catchword sub=new catchword();
     year[s]=sub.makedata(data[s],"year");   
     month[s]=sub.makedata(data[s],"month");  
    route[s]=sub.makedata(data[s],"code_route");   
     v[s]=sub.makedata(data[s],"value"); 
        }
 
        for(s=1;s<datanumber+1;s++){ 
        route[s]=route[s].replace("  ","");   
        route[s]=route[s].replace(" ","");  
         route[s]=route[s].replace("　",""); 
        }
 
 
for(s=1;s<datanumber+1;s++){ 
h=0;
if(map.containsKey(route[s]))h=100;
if(h<50)dicnumber=dicnumber+1;
if(h<50)dic[dicnumber]=route[s];
if(h<50)map.put(route[s],dicnumber);
}   
 
int sx;
 
for(s=1;s<datanumber+1;s++){ 
code[s]=map.get(route[s]); 
}
 
 
 
 
 
        for(s=1;s<datanumber+1;s++){
 
       datax[s][1]=year[s];
       datax[s][3]="r"+code[s];
       datax[s][2]=month[s];
       datax[s][4]=v[s];
 
       }
 
 
       insert sub5=new insert();
       sub5.creditnumber=creditnumber;
       sub5.style=style;
       sub5.data=datax;
       sub5.datanumber=datanumber;
       sub5.makedata(db,tab);
 
 
 
 
 
 
 
}
 
 
 
for(s=1;s<dicnumber+1;s++){ 
System.out.println("r"+s+","+dic[s]); 
}
 
 
 
 
 
 
} 
}
 
 
 
package air3;
 
 
import java.sql.*;
 
public class table{
 
   Connection dbx;   
Statement stx; 
String sqx; 
ResultSet rsx; 
int creditnumber; 
String[] credit=new String[50]; 
String[] style=new String[50]; 
int[] strlong=new int[50];
 
 
 
 
   void makedata(String db,String tab){
 
 
 
       String str;
 
       str="";
       int s;
       for(s=1;s<creditnumber;s++){
       if(style[s].equals("INTEGER"))str=str+credit[s]+" "+style[s]+",";
       if(style[s].equals("VARCHAR"))str=str+credit[s]+" "+style[s]+"("+strlong[s]+"),";
       }
       s=creditnumber;
       if(style[s].equals("INTEGER"))str=str+credit[s]+" "+style[s];
       if(style[s].equals("VARCHAR"))str=str+credit[s]+" "+style[s]+"("+strlong[s]+")";
 
 
 
 
   String url = "jdbc:h2:"+db+";create=true";   
String usr = ""; 
String pwd = "";
 
 
try{
Class.forName("org.h2.Driver");
 
dbx = DriverManager.getConnection(url, usr, pwd);
 
 
     stx = dbx.createStatement();
 
     String sqx = "CREATE TABLE " +tab+"("+str+")"; 
 
 
     stx.executeUpdate(sqx);
 
} catch (Exception ex) { ex.printStackTrace();} 
 
 
 
 
 
 
   }
}
 
 
 
package air3;
 
import java.sql.*; 
import java.io.*;
 
class insert {
 
   Connection dbx;   
Statement stx; 
String sqx; 
ResultSet rsx;
 
String[] style=new String[50]; 
int creditnumber;
 String[][] data=new String[5000][50];  
int datanumber;
 
int p;
 
   void makedata(String db,String tab) {
 
       String str;
 
       int s,sx;
 
       for(p=1;p<datanumber+1;p++){
 
 
      str="";
 
       for(sx=1;sx<creditnumber;sx++){
       if(style[sx].equals("VARCHAR"))str=str+change(data[p][sx])+",";
       if(style[sx].equals("INTEGER"))str=str+data[p][sx]+",";
       }
       sx=creditnumber;
       if(style[sx].equals("VARCHAR"))str=str+change(data[p][sx]);
       if(style[sx].equals("INTEGER"))str=str+data[p][sx];
 
   String url = "jdbc:h2:"+db+";create=true";   
String usr = ""; 
String pwd = "";
 
 
try{
Class.forName("org.h2.Driver");
 
dbx = DriverManager.getConnection(url, usr, pwd);
 
 
     stx = dbx.createStatement();
 
     String sql = "INSERT INTO "+tab+" VALUES("+str+")";
 
   int num = stx.executeUpdate(sql);
 
   stx.close();
} catch (Exception ex) { ex.printStackTrace();} 
 
       }
 
 
 }
String change(String str){ 
String str1; 
str1="'"+str+"'"; 
return str1; 
} 
}