Problem z zapytaniem SQL Message System

Question

Witam, mam troszkę mały problem, tworzę tzw. message system, czyli coś podobnego co można zobaczyć na facebooku w postaci wysyłania wiadomości do znajomych przy użyciu np. messengera. Mam problem z sformułowaniem zapytania do bazy danych. 

Tak wygląda mój kod:

public function showMessages($idToSent)
    {
        $sql = "SELECT u.name, u.surname, m.text, m.data, m.fromUser, m.toUser FROM messages as m, users as u WHERE ((m.fromUser=:id AND m.toUser=:idToSent) OR (m.toUser=:idToSent AND m.fromUser=:id)) AND u.id=(m.toUser OR m.fromUser)";
        $question = \Connect\Connect::connect()->prepare($sql);
        $question->bindValue(':id', $_SESSION['iduser'], PDO::PARAM_STR);
        $question->bindValue(':idToSent', $idToSent, PDO::PARAM_STR);
        $question->execute();
        foreach ($question as $value) {
            $name = $value['name'];
            $text = $value['text'];
            $data = $value['data'];
            if($value['toUser'] == $_SESSION['iduser']) {
                echo '<div class="alert alert-success">
                        '.$text.'
                    </div>';
            } else {
                echo '<div class="alert alert-info">
                        <strong>'.$name.': </strong>'.$text.'
                    </div>';
            }
        }
    }

Dla lepszego zrozumienia oznaczmy sobie :id 1 czyli usera zalogowanego(wysyła wiadomość), :idToSent czyli usera(otrzymuje wiadomość). Gdy wysyła user wiadomość wszystko jest okej. Gdy user który odbiera wiadomość to jej nie widzi. Działa to wzajemnie

Users as u - tabela usery z której wyciągam id usera, imie i nazwisko.

fromUser - to osoba która wysyła

toUser - osoba która dostaje wiadomość

W razie wyjaśnienia proszę pytać! Z góry dzięki za pomoc

Comments

Widzę, że dalej namespace są niepoprawione.

Zwróć wynik, a nie używasz echo, bo inaczej mieszasz warstwy aplikacji. Polecam instrukcje yield.

Zaraz zobacze, co z tym problemem.

Answer 1

Wysłanie wiadomości:

1. User wysyła formularz z tytulem oraz wiadomoscia do odpowiedniego usera
2. Dodajesz ten formularz do bazy z aktualnym czasem (tabela messages) (szyfrowanie?)
3. Wyciągasz id usera, który wysłał tę wiadomość, id usera, który jest odbiorca
4. Dodajesz do bazy id wiadomosci, id nadawcy, id odbiorcy + ewentualne is_read (tabela do przechowywania adresacji wiadomosci)
5. informujesz, ze dzialanie zostalo zakonczone (alert?)

Odebranie wiadomości:

1. Wyciągasz z bazy wszystkie wiadomosci, ktore zostaly nadane i odebrane przez danego usera (SELECT z JOIN tabeli z wiadomosiciami i adresacją), oczywiscie orderujesz je po dacie
2. Wyświetlasz te wiadomości w sformatowany sposób

Odebranie ostatniej wiadomości:

1. Wyciągasz z bazy wszystkie wiadomosci, ktore zostaly nadane i odebrane przez danego usera (SELECT z JOIN tabeli z wiadomosiciami i adresacją), oczywiscie orderujesz je po dacie i ustawiasz limit 1

Do realtime radzę użyć socketów oraz kassandry, a nie SQLa

Comments

nadal nie wiem jak sformułować zapytanie

---

Insert, czy select?

---

select

---

SELECT * 
FROM messages_users 
INNER JOIN  messages ON messages_users.message_id = message.id
WHERE messages_users.recipient_id = :id OR messages_users.sender_id = :id
ORDER BY messages.created_at ASC;

Mogłem się gdzieś pomylić. Pisałem z pamięci.