ThreadDAO.java

package dao;

import dto.User;

import java.sql.*;

public class ThreadDAO {
    private Connection con;

    public ThreadDAO(){
        this.con = new BDConnection().getConnection();
    }

    public String getAllMessages(){
        StringBuilder txt = new StringBuilder();
        try{
            Statement stmt = this.con.createStatement();
            ResultSet rs = stmt.executeQuery("SELECT * FROM userAccount;");

            while(rs.next()){
                int userId = rs.getInt(1);
                String username = rs.getString(2);
                String pwd = rs.getString(3);

                txt.append("Id : ").append(userId).append(" Username : ").append(username).append(" Password : ").append(pwd).append('\n');
            }
        } catch (SQLException sqle) {
            sqle.getStackTrace();
        }

        return txt.toString();
    }
//
//    public String getUserById(int id){
//        StringBuilder txt = new StringBuilder();
//        try{
//            PreparedStatement stmt = this.con.prepareStatement("SELECT * FROM userAccount WHERE id=?");
//            stmt.setInt(1, id);
//            ResultSet rs = stmt.executeQuery();
//
//            if(rs.next()){
//                int userId = rs.getInt(1);
//                String username = rs.getString(2);
//                String pwd = rs.getString(3);
//
//                txt.append("Id : ").append(userId).append(" Username : ").append(username).append(" Password : ").append(pwd).append('\n');
//            }
//        } catch (SQLException sqle) {
//            sqle.getStackTrace();
//        }
//
//        return txt.toString();
//    }
//
//    public void addUser(User nUser){
//        try{
//            PreparedStatement stmt = this.con.prepareStatement("INSERT INTO userAccount VALUES (?,?,?)");
//            stmt.setInt(1, nUser.getID());
//            stmt.setString(2, nUser.getUserName());
//            stmt.setString(3, nUser.getPwd());
//
//            stmt.executeUpdate();
//
//        } catch (SQLException sqle) {
//            sqle.getStackTrace();
//        }
//    }
}