データーベースの情報を削除する機能を作りたい

Question

社員データベースに入っているデータを削除する機能を作成したいです。

・ResultSet rs =pStmt.executeQuery();のところがエラーになり調べたところ、executeUpdate()を使用するべきだとわかったのですが、これを入れると「int から ResultSet には変換できません」と出てきて、結局どうしたらいいのかわかりません。

・★①のところ。なんと書けば、削除該当の社員番号が出力されるのでしょうか。

・★②のところ。YかNをキーボード入力させて、inputにとりこみたいのですが、自分なりに書いてみてもエラーになってしまい、よくわかりませんでした。

まだ勉強したばかりである上に、理解が浅いまま元々ある検索機能やログイン機能を見ながら書いたということもあり、頑張ってみたけど多分いろいろ間違えているんだろうな・・・と思っています。
よろしくお願いいたします。

public class MainSystem{
	public static void main(String[] args) {
		// TODO 自動生成されたメソッド・スタブ

		String jdbcUrl="jdbc:mysql://localhost/eimsdb?serverTimezone=JST";//データベースに接続するためのURL
		String user="eimsuser";//データベースに接続するためのユーザ名
		String passwd="eimspass";//データベースに接続するためパスワード

		//接続メソッド
		try(Connection con = DriverManager.getConnection(jdbcUrl,user,passwd)){

			boolean fact=true; //true = ログインが完了していない
			while(fact) {
				ArrayList<String> inf = LoginGamen.getLoginInfo(); //ログイン入力情報の入れ子
				int empno = Integer.parseInt(inf.get(0));
				String password = inf.get(1);

				fact = Login.doLogin(con, empno, password);
			}

			fact = true;
			String function;
			String input = null;

			if(Login.getDeptname().equals("人事部")){
				JinjiDAO jinji =new JinjiDAO(con);
				while(fact) {
					function = JinjiDAO.showFunctions();
					if(function.equals("検索")) {
						ArrayList<Syain> syain =jinji.doKensaku();

						for(Syain s : syain) {
							System.out.println(s);
						}

					}else if(function.equals("追加")) {

					}else if(function.equals("削除")) {
						ArrayList<Syain> syain =jinji.doSakuzyo();
						System.out.println("以下の社員を削除しますか？");//確認画面
						System.out.println("社員番号：" + ★①該当の社員番号);
						System.out.println("氏：");
						System.out.println("名");
						System.out.println("氏（カナ）：");
						System.out.println("名（カナ）：");
						System.out.println("パスワード：");
						System.out.println("性別：");
						System.out.println("部署コード：");
						★②YかNをキーボード入力させて、inputにとりこみたい
						System.out.println("(YorN):");
						if(input.equals("Y")||input.equals("N")) {
							break;
						}else {
							System.out.println("YまたはNを入力してください");
						}
					}
				}

					}else if(function.equals("変更")) {

					}
					input = LogoutGamen.doLogout();
					if(input.equals("Y")) {
						break;
			}else {
				SyainDAO syain = new SyainDAO(con);
				while(fact) {
					function=FunctionListSyain.showFunctions();
					if(function.equals("検索")) {
						ArrayList<Syain> sList =syain.doKensaku();

						for(Syain s : sList) {
							System.out.println(s);
						}
					}
					input= LogoutGamen.doLogout();
					if(input.equals("Y")){
						break;
					}


				}
			}
		}catch(SQLException e) {
			e.printStackTrace();
		}
	}
}

public class Sakuzyo {

	public static String createSql() {
	 StringBuilder sql = new StringBuilder();
	 sql.append("delete from employee whele emp = ");
	 try {
			BufferedReader br = new BufferedReader(new InputStreamReader(System.in));

			System.out.print("削除したい社員番号を入力してください");
			System.out.println("->");
			String empno = br.readLine();
			sql.append(empno);
	 }catch(IOException e) {
			e.printStackTrace();
	 }
	 return sql.toString();
	}
}

public class SyainDAO {
	private Connection con = null;

	public SyainDAO(Connection con) {
		this.con = con;
	}
	public ArrayList<Syain> doSakuzyo() {
		ArrayList<Syain> syainList = new ArrayList<>();
		String sql = Sakuzyo.createSql();

	try {
		PreparedStatement pStmt = con.prepareStatement(sql);
		ResultSet rs =pStmt.executeQuery(); //sqlを実行し、rsに格納
			while (rs.next()) {
				int empno = rs.getInt("empno");
				String lname = rs.getString("lname");
				String fname = rs.getString("fname");
				String lkana = rs.getString("lkana");
				String fkana = rs.getString("fkana");
				String password = rs.getString("password");
				int gender = rs.getInt("gender");
				int deptno = rs.getInt("deptno");
				String deptname = rs.getString("deptname");

				Busyo busyo = new Busyo(deptno, deptname);
				syainList.add(new Syain(empno, lname, fname, lkana, fkana, password, gender, deptno, busyo));

			}
	} catch (SQLException e) {
		e.printStackTrace();
	}
	return syainList;
	}
}

Answer 1

エラー原因はリファレンス読んでみればわかります。

PreparedStatement#executeUpdate

戻り値:
(1) SQLデータ操作言語(DML)文の場合は行数、(2)何も返さないSQL文の場合は0

返却値がintなのでResultSetでは受け取れません。

---

ただ、そもそもロジックおかしいです。

    PreparedStatement pStmt = con.prepareStatement(sql);

    ResultSet rs =pStmt.executeQuery(); //sqlを実行し、rsに格納

SyainDAO.doSakuzyo()で削除してしまってます。（executeUpdateは直接関係ない）
「以下の社員を削除しますか？」と出ているときには該当のデータ削除は終わっています。
そうではなく、キー（DELETEと同じ検索条件）でSELECTしてきた結果を表示させたうえで「Y」→削除実行とすべきです。

Comments

[lemon1027]

遅くなり申し訳ありません。考えていたら時間がかかってしまいました。

＞返却値がintなのでResultSetでは受け取れません。
ResultSetがexecuteUpdateでは使えないことは理解できました。
となると、ResultSet rs =pStmt.executeQuery();の部分は
int del =pStmt.executeUpdate();
などに変える必要があるのでしょうか？
もしそうならば、この続きがわからず手が止まってしまいました。

＞キー（DELETEと同じ検索条件）
Sakuzyoでは
ssql.append("delete from employee whele emp = ");
sql.append("select * from employee whele emp = ");
と、上記二種類のSQLが必要になるということでしょうか？

[m.ts10806]

リンクのリファレンスは読まれましたか？
該当箇所も引用したのですけど。

そもそもの問題点として「確認メッセージを出す前に削除実行している」ことなので、
・SELECTで対象のデータを取得
・「削除しますか？」で対象データをprintで表示
・Y　でDELETE実行

と現在のロジックを大幅に書き換える必要があります。
「上記二種類のSQLが必要になる」については「YES」が返答ですが、
それぞれ独立して実行されるものですし、「N」が選択されればDELETEは実行されません。

[dodox86]

＞@質問者さん

executeQueryでどんなSQLを対象に実行するのかというとSELECT文なので、0個以上の結果（行）が返ります。なので返り値はResultSetで受けるのです。対してexecuteUpdateではどんなSQLかというとDELETEやUPDATE、INSERT文です。これらの実行結果は処理された行数で返るので、返り値がintなのです。どういうSQLを実行し、それによって何を得るのか。その後に何をしたいのか良く考えましょう。

[lemon1027]

＞リンクのリファレンスは読まれましたか？
リファレンスは読ませていただきました。ただ、私の読解力と経験不足では今回のコードexecuteUpdateをどのように活用するのか、少々難しかったです。

＞「確認メッセージを出す前に削除実行している」
MainSystemの削除部分はこのような感じでしょうか。
（★はどう書いていいかわからない箇所です）
的外れなことを言っていたら申し訳ありません。

}else if(function.equals("削除")) {
ArrayList<Syain> syain =jinji.doSakuzyo();
String sql = Sakuzyo.createSql();
try {
PreparedStatement pStmt = con.prepareStatement(sql);
ResultSet rs =pStmt.executeQuery();

while (rs.next()) {
System.out.println("以下の社員を削除しますか？");//確認画面
System.out.println("社員番号：" + ★ ); System.out.println("氏：");
System.out.println("名");
System.out.println("氏（カナ）：");
System.out.println("名（カナ）：");
System.out.println("パスワード："); System.out.println("性別："); System.out.println("部署コード："); System.out.println("(YorN):");

if(input.equals("Y")) {
String ssql = Sakuzyo.createSql();
★

}else if(input.equals("N")) {
break;

}else {
System.out.println("YまたはNを入力してください");
}

}
} catch (SQLException e) {
e.printStackTrace();
}

[m.ts10806]

１個ずつやりませんか。
まず「削除対象のデータを取得するSELECT」だけ。

[lemon1027]

dodox86さん
ご回答ありがとうございます。
SQL文に該当した行数が返ってきたとして、そのあとその行数をどのように活用するのかわからず、混乱してしまいました。

[lemon1027]

m.ts10806さん
わかりました。
現在、「削除対象のデータを取得するSELECT」は
sql.append("select * from employee whele emp = ");
ここにsql.append(empno);でキーボード入力した社員番号をSELECTしている、という流れです。

[m.ts10806]

>SQL文に該当した行数が返ってきたとして、そのあとその行数をどのように活用するのかわからず

「削除された行数」なので、０かそれ以上かで分岐できます。

>sql.append(empno);で

エスケープされてないのとか、「キーボード入力した社員番号」と言いつつ入力された情報を受け取っているコードなかったりとか、色々と疑問に思う部分はありますが、
ロジックの整理のためにフローチャート一度書かれては。
現状のコードからなんとかしようとすると手法にしか目に行かないので
「実現したい要件は何か」からフローを書いて、その通りに実装する。
すると無駄な実装や使うべき機能が見えてきます。
書きながら考えるのではなく、考えてから書く。

[lemon1027]

理解と経験不足なので、フローチャートで整理してみたいと思います。
ご回答ありがとうございました。