기상청 날씨 api 받아와서 db에 저장하기 (DAO)2 (1시간 간격으로 저장하기)

기상청 api는 3시간 간격으로 날씨정보가 저장되어 있어요.

그거를 1시간 간격으로 데이터를 저장할 수 있도록 짜본 코드입니다.

 

//프로젝트 통으로 올려둔 깃허브 주소입니다.

다른 내용이 궁금하시다면 확인 해 주세요.

github.com/Joowon0220/weather.git

package com.weather03.mvc;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.List;

import static com.weather03.db.JDBCTemplate.*;

public class VillageWeatherDAO {

	public int insertVillageWeather(List<VillageWeather> vw) throws ClassNotFoundException {

		
		Connection con = null;
		
		ResultSet rs = null;
		
		PreparedStatement insert_pstm = null;
		PreparedStatement insert_pstm2 = null;
		PreparedStatement insert_pstm3 = null;
		int res = 0;

		con = getConnection();

		

		String query = "INSERT INTO WEATHER03" + " VALUES(getdate(),?,?,?,?)";
		String query2 = "INSERT INTO WEATHER03" + " VALUES(getdate(),?,?,?,?)";
		String query3 = "INSERT INTO WEATHER03" + " VALUES(getdate(),?,?,?,?)";

		try {
			for (int i = 0; i < vw.size(); i++) {
				VillageWeather str = vw.get(i);

				insert_pstm = con.prepareStatement(query);
				insert_pstm.setString(1, str.getBaseDate());
				insert_pstm.setString(2, str.getBaseTime());
				insert_pstm.setString(3, str.getT3h());
				insert_pstm.setString(4, str.getReh());

				System.out.println("3.query ready");
				res = insert_pstm.executeUpdate();

				if (res > 0) {
					commit(con);
					System.out.println("인서트 성공");
				}

				
				
				System.out.println("4.return");
			}
			for (int i = 0; i < vw.size(); i++) {
				VillageWeather str = vw.get(i);
				int baseTime2 = Integer.parseInt(str.getBaseTime())+100;
				String new_baseTime2 = String.format("%04d", baseTime2);
				insert_pstm2 = con.prepareStatement(query2);
				insert_pstm2.setString(1, str.getBaseDate());
				insert_pstm2.setString(2, new_baseTime2);
				insert_pstm2.setString(3, str.getT3h());
				insert_pstm2.setString(4, str.getReh());

				System.out.println("3.query ready");
				res = insert_pstm2.executeUpdate();

				if (res > 0) {
					commit(con);
					System.out.println("인서트 성공");
				}

				
				
				System.out.println("4.return");
			}
			for (int i = 0; i < vw.size(); i++) {
				VillageWeather str = vw.get(i);
				int baseTime3 = Integer.parseInt(str.getBaseTime())+200;
				String new_baseTime3 = String.format("%04d", baseTime3);
				insert_pstm3 = con.prepareStatement(query3);
				insert_pstm3.setString(1, str.getBaseDate());
				insert_pstm3.setString(2, new_baseTime3);
				insert_pstm3.setString(3, str.getT3h());
				insert_pstm3.setString(4, str.getReh());

				System.out.println("3.query ready");
				res = insert_pstm3.executeUpdate();

				if (res > 0) {
					commit(con);
					System.out.println("인서트 성공");
				}

				
				
				System.out.println("4.return");
			}
			
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			System.out.println("3 or 4 error");
			e.printStackTrace();
		} finally {
			close(insert_pstm, con);
		}
		return res;
		
		

		// else 끝

	}
}