调用天气接口存入数据库---mysql

package util; import java.sql.PreparedStatement; import java.text.SimpleDateFormat; import java.util.Date; import db.DBHelper; import com.fasterxml.jackson.databind.JsonNode; import com.fasterxml.jackson.databind.ObjectMapper; public class DBTest { static String sql = null; static DBHelper db1 = null; public static void addWeather() { PreparedStatement pst = null; sql = "insert into weathers(city,update_time,data,humidity,pm25,pm10,quality,temperature,generalization,high,low,aqi,wind_direction,wind_power,type," + "t_data,t_high,t_low,t_aqi,t_wind_direction,t_wind_power,t_type," + "n_data,n_high,n_low,n_aqi,n_wind_direction,n_wind_power,n_type) " + "values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";//SQL语句 db1 = new DBHelper();//创建DBHelper对象 try { System.out.println("======获取天气中======"); String str = TestWeather.Test(); ObjectMapper obj = new ObjectMapper(); JsonNode node = obj.readValue(str, JsonNode.class); //city JsonNode cityNode = node.get("city"); String city = cityNode.asText(); //update_time SimpleDateFormat df = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");//设置日期格式 //data JsonNode dataNode = node.get("data"); JsonNode forecastNode = dataNode.get("forecast"); JsonNode forecastNode0_date = forecastNode.get(0); JsonNode dateNode = forecastNode0_date.get("date"); String forecast_date = dateNode.asText(); //humidity JsonNode shiduNode = dataNode.get("shidu"); String shidu = shiduNode.asText(); //pm25 JsonNode pm25Node = dataNode.get("pm25"); String pm25 = pm25Node.asText(); //pm10 JsonNode pm10Node = dataNode.get("pm10"); String pm10 = pm10Node.asText(); //quality JsonNode qualityNode = dataNode.get("quality"); String quality = qualityNode.asText(); //temperature JsonNode temperatureNode = dataNode.get("wendu"); String temperature = temperatureNode.asText(); //generalization JsonNode forecastNode_generalization = forecastNode0_date.get("notice"); String forecast_generalization = forecastNode_generalization.asText(); //high JsonNode forecastNode_high = forecastNode0_date.get("high"); String forecast_high = forecastNode_high.asText(); //low JsonNode forecastNode_low = forecastNode0_date.get("low"); String forecast_low = forecastNode_low.asText(); //aqi JsonNode forecastNode_aqi = forecastNode0_date.get("aqi"); String forecast_aqi = forecastNode_aqi.asText(); //fx JsonNode forecastNode_fx = forecastNode0_date.get("fx"); String forecast_fx = forecastNode_fx.asText(); //fl JsonNode forecastNode_fl = forecastNode0_date.get("fl"); String forecast_fl = forecastNode_fl.asText(); //type JsonNode forecastNode_type = forecastNode0_date.get("type"); String forecast_type = forecastNode_type.asText(); //t_date JsonNode forecastNode1_date = forecastNode.get(1); JsonNode dateNode1 = forecastNode1_date.get("date"); String t_date = dateNode1.asText(); //t_high JsonNode highNode1 = forecastNode1_date.get("high"); String t_high = highNode1.asText(); //t_low JsonNode lowNode1 = forecastNode1_date.get("low"); String t_low = lowNode1.asText(); //t_aqi JsonNode aqiNode1 = forecastNode1_date.get("aqi"); String t_aqi = aqiNode1.asText(); //t_fx JsonNode fxNode1 = forecastNode1_date.get("fx"); String t_fx = fxNode1.asText(); //t_fl JsonNode flNode1 = forecastNode1_date.get("fl"); String t_fl = flNode1.asText(); //t_type JsonNode typeNode1 = forecastNode1_date.get("type"); String t_type = typeNode1.asText(); //n_data JsonNode forecastNode2_date = forecastNode.get(2); JsonNode dateNode2 = forecastNode2_date.get("date"); String n_date = dateNode2.asText(); //n_high JsonNode highNode2 = forecastNode2_date.get("high"); String n_high = highNode2.asText(); //n_low JsonNode lowNode2 = forecastNode2_date.get("low"); String n_low = lowNode2.asText(); //n_aqi JsonNode aqiNode2 = forecastNode2_date.get("aqi"); String n_aqi = aqiNode2.asText(); //n_fx JsonNode fxNode2 = forecastNode2_date.get("fx"); String n_fx = fxNode2.asText(); //n_fl JsonNode flNode2 = forecastNode2_date.get("fl"); String n_fl = flNode2.asText(); //n_type JsonNode typeNode2 = forecastNode2_date.get("type"); String n_type = typeNode2.asText(); try { pst = db1.conn.prepareStatement(sql); pst.setString(1, city); pst.setString(2, df.format(new Date())); pst.setString(3, forecast_date); pst.setString(4, shidu); pst.setString(5, pm25); pst.setString(6, pm10); pst.setString(7, quality); pst.setString(8, temperature); pst.setString(9, forecast_generalization); pst.setString(10, forecast_high); pst.setString(11, forecast_low); pst.setString(12, forecast_aqi); pst.setString(13, forecast_fx); pst.setString(14, forecast_fl); pst.setString(15, forecast_type); pst.setString(16, t_date); pst.setString(17, t_high); pst.setString(18, t_low); pst.setString(19, t_aqi); pst.setString(20, t_fx); pst.setString(21, t_fl); pst.setString(22, t_type); pst.setString(23, n_date); pst.setString(24, n_high); pst.setString(25, n_low); pst.setString(26, n_aqi); pst.setString(27, n_fx); pst.setString(28, n_fl); pst.setString(29, n_type); pst.executeUpdate(); System.out.println("======天气入库成功======"); } catch (Exception e) { e.printStackTrace(); System.out.println("======天气入库失败======"); } } catch (Exception e) { e.printStackTrace(); } finally{ if(db1 != null) { try { db1.close();//关闭连接 } catch (Exception e) { e.printStackTrace(); } } } } }