Java上でpostgreSQLで保存されているデータを取得する方法について知りたい

Question

前提・実現したいこと

JavaのEclipseのspringbootで勤怠管理システムを作成しているのですが、 pgAdminと繋いで入力した時の日付がDB内になければDBに日付(ymd)と出勤時間(start_time)、退勤時間(end_time)をinsert、入力した日付が既にDB内にあるのなら出勤時間(start_time)、退勤時間(end_time)をupdateするようにしたいです。
いろいろ試したのですがなかなか上手くいかなくて、もしよろしければどのようにすれば良いのか教えていただきたいです。

package com.example.demo;

import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import org.springframework.stereotype.Controller;
//import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RequestMapping;
//import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.servlet.ModelAndView;
//import org.springframework.stereotype.Controller;


@Controller
public class HelloController {

	@RequestMapping(value = "/", method = RequestMethod.GET)

	public ModelAndView index(ModelAndView mav) {

		mav.setViewName("index");
		mav.addObject("msg", "勤怠開始時間を入力してください。");


		return mav;
	}

	@RequestMapping(value = "/", method = RequestMethod.POST)
	public ModelAndView send(@RequestParam("start") String start, @RequestParam("end") String end, ModelAndView mav) {

		Connection conn;
		java.util.Date d1 = new java.util.Date();
		Date date = new Date(d1.getTime());
		ResultSet rs = null;



		try {
//この辺りでDB内の日付を取得しようとしているが自信なし
			conn = DriverManager.getConnection("jdbc:postgresql://localhost:5432/postgres", "postgres", "パスワード");
			PreparedStatement pstmt2 = conn.prepareStatement("select * from kintai_daily_todoke where ymd = ?");
			pstmt2.setDate(1, date);
		    rs = pstmt2.executeQuery();

			rs.next();　
             

			System.out.println(rs.getDate(1));
			System.out.println(date);



         　 // 現在の日付 = DB内の日付
			if(date == rs.getDate(1)) {

			PreparedStatement pstmt = conn.prepareStatement("update kintai_daily_todoke set start_time = ?, end_time = ? where ymd = ?");
			
			pstmt.setString(1, start);
			pstmt.setString(2, end);
			pstmt.setDate(3, date);
			pstmt.executeUpdate();





			mav.addObject("msg", "更新しました");



			}
			else {

;
			PreparedStatement pstmt = conn.prepareStatement("insert into kintai_daily_todoke values(?,?,?)");
			pstmt.setDate(1, date);
			pstmt.setString(2, start);
			pstmt.setString(3, end);
			pstmt.executeUpdate();


			mav.addObject("msg", "データを保存しました！");

			} 



		}catch(SQLException e) {

			e.printStackTrace();
			mav.addObject("msg", "エラーが発生しました！" + e);



		}


		mav.setViewName("index");

		return mav;

	}


}

試したこと

select文を使って、DB内の情報を取得すれば良いと思ったのですが、現在の日付を取得し、DBの中にその日付のデータがあるのかを比べるコードが自信がない。

補足情報（FW/ツールのバージョンなど）

・DBイメージ

テーブル名:kintai_daily_todoke

ymd	start_time	end_time

・ツール、アプリ
Eclipse spring boot
pgadmin4

Comments

[Orlofsky]

コードは https://teratail.com/help/question-tips#questionTips3-7 の [コード] に修正してください。
他のMarkdownの機能も確認しておいてください。

[sossy]

修正しました。
ご指摘ありがとうございます。

[hoshi-takanori]

上手くいかないというのは、具体的に何がどううまくいかないのでしょうか？ エラーが出ますか？
また、ymd, start_time, end_time の型はどうなってますか？ ymd は primary key でしょうか？
ちなみに、データがなければ insert、あれば update という処理は俗に upsert と言われていて、PostgreSQL 9.5 以降では INSERT 〜 ON CONFLICT 〜 という構文があるようです。
https://qiita.com/bluesDD/items/fdebbccd5ba8a6aaa565

[javahack]

パッと見、動かないだろうなとは思いますが、一応テーブルのカラムの定義がわかるようにCREATE TABLEの情報を追記してください。

[jimbe]

ymd で探して得たレコードの ymd と比較しても意味はないと思いますけど...
自信が有っても無くても, プログラムは書いたようにしか動きません.
select でレコードが無かった時にどうなるのかをお調べになったり動かしてみたりされたのでしょうか.

Answer 1

try{}の部分を同じ様な動きで書いてみました。　ご参考程度にお願いします。
SELECTで有ったらUPDATE、無ければINSERTとしております。

import java.sql.Date;

        try{

            Connection conn;
            Date date = Date.valueOf("2020-03-15");

            conn = DriverManager.getConnection("jdbc:postgresql://127.0.0.1:5432/testdb", "user", "passwd");

            PreparedStatement pstmt2 = conn.prepareStatement("select * from kintai_daily_todoke where ymd = ?");
            pstmt2.setDate(1, date);

            ResultSet rs = pstmt2.executeQuery();

            if (rs.next()){
                PreparedStatement pstmt = conn.prepareStatement("update kintai_daily_todoke set start_time = ?, end_time = ? where ymd = ?");

                pstmt.setString(1, start);
                pstmt.setString(2, end);
                pstmt.setDate(3, date);
                pstmt.executeUpdate();

                System.out.println("更新しました");
            }else{
                PreparedStatement pstmt = conn.prepareStatement("insert into kintai_daily_todoke values(?,?,?)");
                pstmt.setDate(1, date);
                pstmt.setString(2, start);
                pstmt.setString(3, end);
                pstmt.executeUpdate();

                System.out.println("データを保存しました！");
            }

        }catch(SQLException e) {
            System.out.println("エラーが発生しました！");
        }

Comments

[sossy]

ありがとうございます。
上手く動きました。
next()の動きを理解していないまま使っていましたので、また調べて理解した上で理解を深めていきます。