package pop;
import tool.*;
public class pro {
String[] data=new String[50000];
int s,sx,datanumber,tx;
String[] sex=new String[5000];
String[] credit=new String[5000];
String[] month=new String[5000];
String[] year=new String[5000];
String[] v=new String[50000];
int number_month;
int number_credit;
int number_pref,number_bus;
String[] dic_pref=new String[500];
String[] dic_credit=new String[500];
String[] dic_work=new String[500];
String[] dic_bus=new String[500];
int number;
String[] code_credit=new String[5000];
String[] code_pref=new String[5000];
int creditnumber;
String[] creditp=new String[50];
String[] style=new String[50];
int[] strlong=new int[50];
public static void main(String[] args) {
pro te=new pro();
}
pro(){
creditnumber=4;
creditp[1]="year";
creditp[2]="month";
creditp[3]="credit";
creditp[4]="value";
style[1]="INTEGER";
style[2]="INTEGER";
style[3]="VARCHAR";
style[4]="VARCHAR";
strlong[5]=20;
strlong[4]=20;
strlong[3]=5;
strlong[2]=5;
String db,tab;
db="kenr";
tab="kenr";
System.out.println(creditnumber);
table sub7=new table();
sub7.credit=creditp;
sub7.creditnumber=creditnumber;
sub7.style=style;
sub7.strlong=strlong;
sub7.makedata(db,tab);
int tr;
number_credit=0;
number_pref=0;
readfile sub=new readfile();
sub.makedata("ren.txt","UTF-8");
data=sub.data;
datanumber=sub.datanumber;
for(s=1;s<datanumber+1;s++){
catchword sub52=new catchword();
year[s]=sub52.makedata(data[s],"year");
credit[s]=sub52.makedata(data[s],"credit");
month[s]=sub52.makedata(data[s],"month");
v[s]=sub52.makedata(data[s],"value");
}
int h;
for(s=1;s<datanumber+1;s++){
h=0;
for(sx=1;sx<number_credit+1;sx++){
if(dic_credit[sx].equals(credit[s]))h=100;
}
if(h<50)number_credit=number_credit+1;
if(h<50)dic_credit[number_credit]=credit[s];
}
System.out.println(number_credit);
for(s=1;s<datanumber+1;s++){
for(sx=1;sx<number_credit+1;sx++){
if(dic_credit[sx].equals(credit[s]))code_credit[s]="c"+sx;
}
}
String[][] datax=new String[50000][10];
int s1,s2,s3;
int tx=0;
for(s=1;s<datanumber+1;s++){
datax[s][1]=year[s];
datax[s][2]=""+month[s];
datax[s][3]=""+code_credit[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<number_credit+1;s++){
System.out.println("c"+s+","+dic_credit[s]);
}
}}
package pop;
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+")";
System.out.println(sql);
int num = stx.executeUpdate(sql);
stx.close();
} catch (Exception ex) { ex.printStackTrace();}
}
}
String change(String str){
String str1;
str1="'"+str+"'";
return str1;
}
}
package pop;
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();}
}
}
最終更新:2015年08月19日 09:51