sqlで自分のツイートだけを表示したい

Question

MutterDAO.java

package dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

import model.Mutter;
import util.JDBCUtils;

public class MutterDAO {

	  //全レコードを取得
	public List<Mutter> findAll(String userName) {
		List<Mutter> mutterList = new ArrayList<Mutter>();

		try(Connection conn = JDBCUtils.getConnection()){

			      	// TWEETテーブルにUSERテーブルを結合してTWEET_IDの大きい順に並び替え    ; SELECT 列名 FROM テーブル名 ORDER BY 列名 並び順  (検索結果をTWEET_IDの大きい順DESCに並び替える)
			String sql = "SELECT * FROM (SELECT "
						+ "TWEET_ID AS TWEET_ID,"
						+ "USER_NAME AS USER_NAME,"
						+ "TWEET.TEXT AS TEXT "  //  AS は別名的な
						+ "FROM TWEET INNER JOIN USER ON TWEET.USER_ID = USER.USER_ID " //結合；選択列リスト FROM テーブルA JOIN テーブルB ON 両テーブルの結合条件
						+ "ORDER BY TWEET_ID DESC) "
						+ "WHERE USER_NAME=?";

			try(PreparedStatement pStmt = conn.prepareStatement(sql)){
				pStmt.setString(1, userName);  //postで送られたuserNameがデータベース上にあるか検索

				// SELECTを実行
				try(ResultSet rs = pStmt.executeQuery()){
					// SELECT文の結果をArrayListに格納
					while (rs.next()) {
						int tweetId = rs.getInt("TWEET_ID");
						String Name = rs.getString("USER_NAME");
						String te = rs.getString("TEXT");
						Mutter mutter = new Mutter(tweetId, Name, te);
						mutterList.add(mutter);
					}
				}
			}
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
		return mutterList;
	}




//つぶやきを追加
	public boolean create(Mutter mutter) {
		try(Connection conn = JDBCUtils.getConnection()){

			// INSERT文の準備(idは自動連番なので指定しなくてよい）
			String sql = "INSERT INTO TWEET (USER_ID,TEXT) VALUES(?, ?)";
			try(PreparedStatement pStmt = conn.prepareStatement(sql)){
				// INSERT文中の「?」に使用する値を設定しSQLを完成
				pStmt.setString(1, mutter.getUserId());
				pStmt.setString(2, mutter.getText());
				// INSERT文を実行
				int result = pStmt.executeUpdate();
				if (result != 1) {
					return false;
				}
			}
		} catch (Exception e) {
			throw new RuntimeException(e);
		}
		return true;
	}


}

GetMutterListLogic.java

//MutterDAOを使用してMUTTERテーブルの全レコードを取得し、それを返す

package model;

import java.util.List;

import dao.MutterDAO;


public class GetMutterListLogic {

	public List<Mutter> execute(String userName){
		MutterDAO dao = new MutterDAO();
		List<Mutter> mutterList = dao.findAll(userName);
		return mutterList;
	}
}

Main.java

//つぶやきに関するリクエストを処理するコントローラ

package servlet;

import java.io.IOException;
import java.util.List;

import javax.servlet.RequestDispatcher;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import javax.servlet.http.HttpSession;

import model.GetMutterListLogic;
import model.Mutter;
import model.PostMutterLogic;
import model.User;

@WebServlet("/Main")
public class Main extends HttpServlet {
	private static final long serialVersionUID = 1L;

	protected void doGet(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {

		// ログインしているか確認するため、セッションスコープからユーザー情報を取得
		HttpSession session = request.getSession();
		User loginUser = (User) session.getAttribute("loginUser");

		if (loginUser == null) { // ログインしていない場合
			// リダイレクト
			response.sendRedirect(request.getServletContext().getContextPath()); // トップ画面へ
		} else { // ログイン済みの場合

			// つぶやきリストを取得して、リクエストスコープに保存
			GetMutterListLogic getMutterListLogic = new GetMutterListLogic();

			List<Mutter> mutterList = getMutterListLogic.execute("userName");
			request.setAttribute("mutterList", mutterList);

			// フォワード
			RequestDispatcher dispatcher = request.getRequestDispatcher("WEB-INF/jsp/myPage.jsp");
			dispatcher.forward(request, response);
		}

	}

	protected void doPost(HttpServletRequest request, HttpServletResponse response)
			throws ServletException, IOException {

		// ログインしているか確認するため、セッションスコープからユーザー情報を取得
		HttpSession session = request.getSession();
		User loginUser = (User) session.getAttribute("loginUser");

		if (loginUser == null) { // ログインしていない場合
			// リダイレクト
			response.sendRedirect(request.getServletContext().getContextPath()); // トップ画面へ
		} else {

			// リクエストパラメータの取得
			request.setCharacterEncoding("UTF-8");
			String text = request.getParameter("text");

			// 入力値チェック
			if (text != null && text.length() != 0) {

				// つぶやきをつぶやきリストに追加
				Mutter mutter = new Mutter(loginUser.getUserId(), text);
				PostMutterLogic postMutterLogic = new PostMutterLogic();
				postMutterLogic.execute(mutter);

			} else {
				// エラーメッセージをリクエストスコープに保存
				request.setAttribute("errorMsg", "つぶやきが入力されていません。");
			}

			// つぶやきリストを取得して、リクエストスコープに保存
			GetMutterListLogic getMutterListLogic = new GetMutterListLogic();
			List<Mutter> mutterList = getMutterListLogic.execute("userName");
			request.setAttribute("mutterList", mutterList);

			// メイン画像にフォワード
			RequestDispatcher dispatcher = request.getRequestDispatcher("WEB-INF/jsp/myPage.jsp");
			dispatcher.forward(request, response);
		}
	}
}

やりたいことは自分のつぶやきだけを表示したいです
データベース上はエラーはないのですが
実行したときにつぶやきが表示されません
どこがおかしいのでしょうか？？

Answer 1

            // つぶやきリストを取得して、リクエストスコープに保存
            GetMutterListLogic getMutterListLogic = new GetMutterListLogic();
            List<Mutter> mutterList = getMutterListLogic.execute("userName"); // ここ

"userName" ではなく loginUser.getUserId()では？

Comments

[Yoshi--]

ありがとうございました！！！！！