Skip to content
Snippets Groups Projects
Select Git revision
  • c7dc6934ccaebd9abc6829e8ed202eec78d355a6
  • master default protected
2 results

edit_ue.py

Blame
  • Forked from Jean-Marie Place / SCODOC_R6A06
    Source project has a limited visibility.
    ThreadDAO.java 3.18 KiB
    package dao;
    
    import dto.Message;
    import dto.User;
    
    import java.sql.*;
    import java.util.ArrayList;
    import java.util.List;
    
    public class ThreadDAO {
        private Connection con;
    
        public ThreadDAO(){
            this.con = new BDConnection().getConnection();
        }
    
        public List<Message> getAllMessages(){
            ArrayList<Message> messages = new ArrayList<>();
            try{
                Statement stmt = this.con.createStatement();
                ResultSet rs = stmt.executeQuery("SELECT * FROM msg;");
    
                while(rs.next()){
                    int msgId = rs.getInt(1);
                    int userIdMsg = rs.getInt(2);
                    int threadId = rs.getInt(3);
                    String msg = rs.getString(4);
    
                    messages.add(new Message(msgId,userIdMsg,threadId,msg));
                }
            } catch (SQLException sqle) {
                sqle.getStackTrace();
            }
    
            return messages;
        }
    
        public List<Message> getAllMessagesFromThread(int threadId){
            ArrayList<Message> messages = new ArrayList<>();
            try{
                PreparedStatement ps = this.con.prepareStatement("SELECT msg FROM msg WHERE thread_id=?;");
                ps.setInt(1, threadId);
                ResultSet rs = ps.executeQuery();
    
                while(rs.next()){
                    int msgId = rs.getInt(1);
                    int userIdMsg = rs.getInt(2);
                    String msg = rs.getString(3);
    
                    messages.add(new Message(msgId,userIdMsg,threadId,msg));
                }
            } catch (SQLException sqle) {
                sqle.getStackTrace();
            }
    
            return messages;
        }
    
        // Créer un thread
        public void createThread(User user, String threadName) throws SQLException {
            PreparedStatement ps = this.con.prepareStatement("INSERT INTO thread (userID_thread, threadName) VALUES(?, ?)");
            try {
                ps.setString(1, ""+user.getId());
                ps.setString(2, threadName);
            }
            catch (SQLException sqle) {
                sqle.getStackTrace();
            }
        }
    
    
    //
    //    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();
    //        }
    //    }
    }