[pen2010]

hallo zusammen,

ich hab zur zeit ein kleines prob und komme irgendwie nicht wirklich weiter. ich bastle gerade an einer streaming-funktion für ein chatsystem.

kurzbeschreibung:
eine tabelle wird ständig ausgelesen (in einer while(!connection_aborted)-schleife.

zeitgleich sollen von anderen webinterfaces einträge in die gleiche tabelle gemacht werden (chat-inputs).

solange der stream läuft werden die inputs aber nicht der tabelle hinzugefügt. erst nach verlassen des streams und erneutem aufruf sind die bisher (scheinbar gepufferten) inserts sichtbar.

kann ich dieses gepufferte inserten irgendwie umgehen? edit: es liegt nicht am insert query (also mysql_query_unbuffered hat keine auswirkung)

hier ein codesnip vom stream und vom input:

PHP-Code:

function Stream(){
    $db = new db_local;
    $query0 = sprintf("SELECT msg_id FROM chat_roommessage WHERE room_id = %d ORDER BY msg_id DESC LIMIT 1", $_SESSION['user']['room']);
    $db->query($query0);
    $lastpos = $db->result();
    while(!connection_aborted()){
        $db->query($query0);
        $pos = $db->result();
        if($lastpos < $pos){
            $db->query(sprintf("SELECT message FROM chat_roommessage WHERE room_id = %d AND msg_id > %d", $_SESSION['user']['room'], $lastpos));
            while($db->next_record()){
                $text = stripslashes($db->record['message']);
                echo $text."<br>";
                $lastpos = $pos;
            }
        }else{
            echo " ";
        }
        usleep(250000);
    }
}

---

input (andere datei) :
$db2 = new db_local;
$db2->query(sprintf("INSERT INTO chat_roommessage (room_id, user_id, date, message) VALUES (%d, %d, NOW(), '%s')", $_SESSION['user']['room'], $_user['aid'], $msg));
$db2->close(); 


[Bleistift]

Ich gehe jetzt einfach mal davon aus, dass du von PHP redest. Dann könnte nämlich ein Blick in das PHP-Manual nicht schaden:
http://ch2.php.net/manual/en/functio...ered-query.php
(Womöglich hab ich dich aber auch falsch verstanden, denn Queries werden immer sofort an die DB gesendet )

[pen2010]

sry hatte mich wohl falsch ausgedrückt - nein am insert-query (oder der art) kanns eigentlich nicht liegen da beide varianten gleichsam warten bis das streaming beendet wird...

[mepeisen]

mögliche Ursache 1. Die Insert.
Wie hast du das verifiziert? Beispielsweise parallel per Kommandozeile oder phpMyAdmin oder oder oder ebenfalls mal einen Query abgesetzt?

mögliche Ursache 2. Das Auslesen klappt nicht.
Wie hast du das verifiziert (siehe 1.)?

Lange Rede kurzer Sinn: Mit einer normalen Datenbank klappt das problemlos (normal deswegen um Klugscheißern wg. Transaktionsverhalten u.ä. vorzubeugen *g*).
Ich gucke mal in meine Kristallkugel und sage, dass alles korrekt funktioniert, es aber ein HTTP-typisches Problem gibt, entweder aufgrund eines vorzeitigen Abbruchs deines Scriptes (das ja potentiell endlos laufen soll) oder durch Puffer-Verhalten (PHP-Manual, Methode flush).

P.S.: Lerne die Verwendung von MIN() bzw. MAX() in Hinblick auf deinen ersten Query ($query0)

[Jann Hendrik]

mysql_error
Man sollte beo kritischen Anwendungen immer mysql_error() verwenden. Manchmal ist es ggf. besser darauf zu verzichten, beim debuggen aber sollte es imho dabei sein! Etwa so:

PHP-Code:

<?php
  $sql = "SELECT
              `feldname`, `nocheinfeldname`, `undnochfeldname`
          FROM
              `tabellenname`
          WHERE
              `feldname` LIKE '%suchwort%'
            AND
              `nocheinfeldname` = 'wert'
          ORDER BY
              `undnochfeldname` ASC
          LIMIT
              0 , 30";
  $result = mysql_query($sql) or exit('<h2>Fehler</h2>sql-querry: '$sql.'<br />error: '.mysql_error());
  // ...
?>

exit
mysql_error

Voteilhaft ist auch, wenn man reservierte Bezeichnungen für Felder nutzt, wie zB date, dass man diese dann in ´ setzt (s. Beispiel).

[mepeisen]

OK, ich gebe mich geschlagen, hätte mir das doch genauer angucken sollen

Jann hat Recht. Da der Insert aber so nicht funktionieren kann, ist folgende Aussage bischen merkwürdig:

solange der stream läuft werden die inputs aber nicht der tabelle hinzugefügt. erst nach verlassen des streams und erneutem aufruf sind die bisher (scheinbar gepufferten) inserts sichtbar.

Sprich, das ist mit dem Code-Fragment von dir aufgrund eines SQL-Fehlers gar nitt möglich. Und daher war meine Nachfrage, wie du denn verifiziert hast, dass es tatsächlich geinsertet wird, ja nicht sooo schlecht

Rest ist Transferleistung aus Janns Post und meinem.

[Jann Hendrik]

puh, ich habe schon gedacht mich möglicherweise zu weit aus dem Fenster gelehnt zu haben...

traute mich schon fast nicht zu posten nach dem ich das hier:

Zitat von mepeisen

(normal deswegen um Klugscheißern wg. Transaktionsverhalten u.ä. vorzubeugen *g*).

gelesen habe...

Dabei scheiße ich doch so gerne klug - wenn ich denn auch mal was weiß

und nein - das soll hier nicht weiter thematisiert werden - in diesem thread geht es um was anderes!