提取json页面再导入mysql代码,Java代码库,德仔网

代码语言
代码分类
【Java】提取json页面再导入mysql
作者:哲滔 / 发布于2016/4/20/ 719
import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.Reader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import java.sql.ResultSet;  
import java.sql.SQLException; 
public class GetJson{
    static DBHelper db1 = null; 
    public static void main(String args[]){
        GetJson x=new GetJson();    
        try {
             handleJson(x.getJsonString("http://q.stock.sohu.com/hisHq?" +
                    "code=cn_600001&start=20000504&end=20151215&stat=1&order=D&period=d&callback=historySearchHandler&rt=jsonp&r=0.8391495715053367&0.9677250558488026"));
        } catch (Exception e) {
            e.printStackTrace();
        }  
    }
     
protected String getJsonString(String urlPath) throws Exception {
        //获取urlPath的内容
        URL url = new URL(urlPath);
        HttpURLConnection connection = (HttpURLConnection) url.openConnection();
        connection.connect();
        System.out.println("=============================");
        connection.setConnectTimeout(30000); connection.setReadTimeout(30000);
        InputStream inputStream = connection.getInputStream();
        //读取urlPath的内容
        Reader reader = new InputStreamReader(inputStream, "UTF-8");
        BufferedReader bufferedReader = new BufferedReader(reader);
        String str = null;
        StringBuffer sb = new StringBuffer();
        while ((str = bufferedReader.readLine()) != null) {
            System.out.println(str);
            sb.append(str);
        }
        reader.close();
        connection.disconnect();
        return sb.toString();
    }  
 
private static void handleJson(String br){  
    List<String> codes = null ;  
    Matcher m = Pattern.compile("\\[\\[(.*?)\\]\\]").matcher(br);
    while (m.find()) {      
        String[] a = m.group(1).toString().split("\\],\\[");
        codes = new ArrayList<String>();
        for(String s:a){
            String sql1="insert into  `user1`.`java1` values (" +s+")";
            //System.out.println(sql1);
            db1 = new DBHelper(sql1);//创建DBHelper对象   
            try {  
                db1.pst.executeUpdate();//执行语句，得到结果集  
                db1.close();//关闭连接  
            } catch (SQLException e) {  
                e.printStackTrace();  
            }  
    }    
}  
}
}


import java.sql.Connection;  
import java.sql.DriverManager;  
import java.sql.PreparedStatement;  
import java.sql.SQLException;  
   
public class DBHelper {  
    public static final String url = "jdbc:mysql://127.0.0.1/user1";  
    public static final String name = "com.mysql.jdbc.Driver";  
    public static final String user = "root";  
    public static final String password = "********";  
   
    public Connection conn = null;  
    public PreparedStatement pst = null;  
   
    public DBHelper(String sql) {  
        try {  
            Class.forName(name);//指定连接类型  
            conn = DriverManager.getConnection(url, user, password);//获取连接  
            pst = conn.prepareStatement(sql);//准备执行语句  
        } catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
   
    public void close() {  
        try {  
            this.conn.close();  
            this.pst.close();  
        } catch (SQLException e) {  
            e.printStackTrace();  
        }  
    }  
}
试试其它关键字
　json　　mysql　
同语言下
可能有用的
哲滔贡献的其它代码(8)