MySQL转数据到Oracle(五)

while (rst.next()) {
Vector vec = new Vector();
String column_name = NulltoSpace(rst.getString("COLUMN_NAME"));// 列名
String is_nullable = NulltoSpace(rst.getString("IS_NULLABLE"));// 是否為空，如果不允許NO,允許為YES
String data_type = NulltoSpace(rst.getString("DATA_TYPE"));// int,varchar,text,timestamp,date
String character_maximun_length = NulltoSpace(rst
.getString("CHARACTER_MAXIMUM_LENGTH"));// 長度大小
String column_key = NulltoSpace(rst.getString("COLUMN_KEY"));// 是否主鍵
// 是的話為PRI
// MUL(index)
// 有兩個PRI說明是複合index
String extra = NulltoSpace(rst.getString("EXTRA")); // 是否自動增長列
// 是的話
// auto_increment
String column_default = NulltoSpace(rst
.getString("COLUMN_DEFAULT"));// 是否有默認值
vec.add(column_name);
vec.add(is_nullable);
vec.add(data_type);
vec.add(character_maximun_length);
vec.add(column_key);
vec.add(extra);
vec.add(column_default);
arg.add(vec);
}
rst.close();
} catch (SQLException e) {
e.printStackTrace();
}

return arg;
}

public boolean judge_china(String tablename, String columnname) {
try {
String querysql = "select count(1) row from " + tablename
+ " where length(" + columnname + ")!=char_length("
+ columnname + ")";
// System.out.println("sql= "+querysql);
ResultSet rst = statement.executeQuery(querysql);
if (rst.next()) {
if (NulltoSpace(rst.getString("row")).equals("0")) {
return false;
} else {
return true;
}
}
rst.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
}
return true;
}

public int get_maxId(String tablename, String columnname) {
String maxValue = "0";
try {
String querysql = "select max(" + columnname + ") maxid from "
+ tablename;
// System.out.println("sql= "+querysql);
ResultSet rst = statement.executeQuery(querysql);
if (rst.next()) {
maxValue = NulltoSpace(rst.getString("maxid"));
}
rst.close();
} catch (SQLException e) {
}
return Integer.parseInt(maxValue + 1);
}

public Vector queryAllTable(String table_schema) {
Vector tableName = new Vector();
try {
String queryTable = "SELECT `TABLES`.`TABLE_NAME` "
+ "FROM `information_schema`.`TABLES` "
+ "WHERE `TABLES`.`TABLE_TYPE` = 'base table' "
+ "and `TABLES`.`TABLE_SCHEMA` ='" + table_schema + "'";
// System.out.println("sql= "+queryTable);
ResultSet rst = statement.executeQuery(queryTable);
while (rst.next()) {
tableName.add(NulltoSpace(rst.getString("TABLE_NAME")));
}
} catch (SQLException e) {
// TODO Auto-generated catch block
}
return tableName;
}

public boolean connectionMethod() {
try {
Class.forName(DBdriver).newInstance();
conn = DriverManager.getConnection(DBURL);
statement = conn.createStatement();
return true;
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
return false;
}
}

public static String NulltoSpace(Object o) {
if (o == null)
return "";
else if (o.equals("null")) {
return "";
} else {
return o.toString().trim();
}
}

public static void dele