中国气象局接口城市代码及抓取源码

import java.io.BufferedReader; import java.io.InputStreamReader; import java.net.URL; import java.sql.Connection; import java.sql.DriverManager; import java.sql.SQLException; import java.sql.Statement; public class T { static String regex = "^\\d*$"; /** * @param args */ public static void main(String[] args) { try { Class.forName("org.sqlite.JDBC"); Connection conn = DriverManager.getConnection("jdbc:sqlite:H:\\sqllite\\city.db"); conn.setAutoCommit(false); try { insert(conn, "-1"); } catch (SQLException e) { e.printStackTrace(); conn.rollback(); }finally{ conn.close(); } } catch (Exception e) { e.printStackTrace(); } } public static String getData(String code){ try{ URL url = new URL("http://m.weather.com.cn/data5/city"+code+".xml"); // URL url = new URL("http://m.weather.com.cn/data/101010100.html"); BufferedReader br = new BufferedReader(new InputStreamReader(url .openStream(),"UTF-8")); String s = ""; StringBuffer sb = new StringBuffer(""); while ((s = br.readLine()) != null) { sb.append(s); } br.close(); return sb.toString(); } catch (Exception e) { e.printStackTrace(); } return null; } public static void insert(Connection conn,String code) throws SQLException{ String str = getData(code.equals("-1")?"":code); if(str!=null){ String[] ss = str.split(","); for(String s : ss){ String[] vs = s.split("\\|"); String citycode = vs[0]; String cityname = vs[1]; Statement stat = conn.createStatement(); if(cityname.matches(regex)){ stat.executeUpdate("update citys set weathercode='"+cityname+"' where citycode = '"+code+"'"); conn.commit(); stat.close(); }else{ stat.executeUpdate("INSERT INTO citys (citycode,cityname,parentcode) VALUES('"+citycode+"','"+cityname+"','"+code+"')"); conn.commit(); stat.close(); insert(conn, citycode); } } } } }