Unbekannter, generaler PDO Fehler

Diese Seite verwendet Cookies. Durch die Nutzung unserer Seite erklären Sie sich damit einverstanden, dass wir Cookies setzen. Weitere Informationen

  • Unbekannter, generaler PDO Fehler

    Guten Tag,
    ich habe foglendes Problem:
    Ich bin dabei eine eigene Sitzungsverwaltung zu schreiben und möchte dies über PDO ermöglichen.
    Dazu habe ich einmal eine Verbindung über die Abstraktionsschnittstelle PDO bereitgestellt:

    Quellcode

    1. <?php//Namespace der Klassenamespace inc\classes;
    2. /** * Abstraktionsschicht für die Datenbank * * Verbindet zur Datenbank und kapselt alle Anfragen an die * Datenbank. Nutzbar mit diversen Datenbanken (MySQL, SQLite, Oracle, etc.) * */
    3. class PDO{ //Datenbankverbindungsobjekt public $PDO = null; //aktuelles preparedStatement public $preparedStatement = null;
    4. /** * Verbindet zur Datenbank und gibt ggf. eine * Fehlermeldung zurück. * */ public function __construct($dsn, $user, $password) { try { //Neues PDO-Objekt $this->PDO = new \PDO($dsn,$user,$password); //Fehlermeldungen sollen "geworfen" werden $this->PDO->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION); } catch (PDOException $e) { //Fehlerbehandlung (bspw. E-Mail an Admin) die('<div style="color:red;">'.$e->getMessage().'</div>'); } }
    5. /** * Führt eine SQL-Anfrage durch. * * @param text Die SQL-Anfrage * * @return Array Gibt eine Ergebnismenge zurück */ public function query($sql) { try { //PDO-Anfrage durchführen $pdoStmt = $this->PDO->query($sql); //Liegt eine leere Ergebnismenge vor? ($pdoStmt->rowCount()==0)? $return = array(): //Array mit den Daten $stmt = $pdoStmt->fetchAll(); //Statement schließen $pdoStmt->closeCursor(); return $stmt; } catch(PDOException $e) { //Fehlerbehandlung (bspw. E-Mail an Admin) echo '<div style="color:red;">'.$e->getMessage().'</div>'; return false; } } /** * Legt ein "prepared Statement" an * * @param String Statement mit Platzhalter-Parametern */ public function prepareStatement($statement) { //Prepared Statement vorbereiten $this->preparedStatement = $this->PDO->prepare($statement); if($this->preparedStatement===false) { //Fehlerbehandlung (bspw. E-Mail an Admin) echo '<div style="color:red;">Prepared Statement konnte nicht vorbereitet werden.</div>'; } } /** * Führt ein zuvor angelegtes preparedStatement aus * * @param Array Die Parameter für das prepared Statement. * * @return Array Ergebnis der Anfrage */ public function execute($params = array()) { //Wenn noch kein Statement angelegt ist, wird hier abgebrochen. if($this->preparedStatement==null)return false; try { //PDO-Anfrage durchführen $this->preparedStatement->execute($params); //Wenn keine Daten zurück kamen if($this->preparedStatement->columnCount()==0)return array(); //Andernfalls die Daten als Array zurückgeben return $this->preparedStatement->fetchAll(); } catch(PDOException $e) { //Fehlerbehandlung (bspw. E-Mail an Admin) echo '<div style="color:red;">'.$e->getMessage().'</div>'; return false; } }}?>


    Soweit so gut, nun wollte ich einen eigene Sessionhandler erstellen:

    Quellcode

    1. <?php//Namespace der Klassenamespace inc\classes;
    2. /** * SessionHandler * */class SessionHandler {
    3. private $DB = null;
    4. /** * Konstruktor */ public function __construct($DB) { $this->DB = $DB;
    5. // Den SessionHandler auf die Methoden // dieser Klasse setzen session_set_save_handler(array ($this, '_open'), array ($this, '_close'), array ($this, '_read'), array ($this, '_write'), array ($this, '_destroy'), array ($this, '_gc'));
    6. // Session starten session_start(); //session_write_close(); register_shutdown_function('session_write_close'); }
    7. /** * Öffnen der Session * * @return boolean Gibt immer true zurück */ public function _open($path, $name) { return true; }
    8. /** * Session schließen * * @return boolean Gibt immer true zurück */ public function _close() { //Ruft den Garbage-Collector auf. $this->_gc(0); return true; }
    9. /** * Session-Daten aus der Datenbank auslesen * * @return varchar Gibt entweder die Sitzungswerte oder einen leeren String zurück */ public function _read($sesID) { $sessionStatement = "SELECT * FROM " . DB_TABLEPREFIX . "sessions"." WHERE id = '$sesID'"; $result = $this->DB->query($sessionStatement); if ($result === false) { return ''; }
    10. if (count($result) > 0) {
    11. return $result[0]["value"]; } else { return ''; } }
    12. /** * Neue Daten in die Datenbank schreiben * * @param varchar eindeutige Sessionid * @param Array Alle Daten der Session * * @return boolean Gibt den Status des Schreibens zurück */ public function _write($sesID, $data) { //Nur schreiben, wenn Daten übergeben werden if($data == null) { return true; } //Statement um eine bestehende Session "upzudaten" $sessionStatement = "UPDATE " . DB_TABLEPREFIX . "sessions "." SET lastUpdated='".time()."', value='$data' WHERE id='$sesID'"; $update = $this->DB->query($sessionStatement);
    14. //Ergebnis prüfen if ($update === false) { //Fehler in der Datenbank return false; } if ($this->DB->MySQLiObj->affected_rows) { //bestehende Session "upgedated" return true; } //Ansonsten muss eine neue Session erstellt werden $sessionStatement = "INSERT INTO " . DB_TABLEPREFIX . "sessions "." (id, lastUpdated, start, value)"." VALUES ('$sesID', '".time()."', '".time()."', '$data')"; $update = $this->DB->query($sessionStatement);
    15. //Ergebnis zurückgeben return $update; }
    16. /** * Session aus der Datenbank löschen * * @param varchar eindeutige Session-Nr. * * @return boolean Gibt den Status des Zerstörens zurück */ public function _destroy($sesID) { $sessionStatement = "DELETE FROM " . DB_TABLEPREFIX . "sessions "." WHERE id = '$sesID'"; $result = $this->DB->query($sessionStatement); //Ergebnis zurückgeben (true|false) return $result; }
    17. /** * Müll-Sammler ;-) * * Löscht abgelaufene Sessions aus der Datenbank * * @return boolean Gibt den Status des Bereinigens zurück */ public function _gc($life) { //Zeitpunkt, zu dem die Session als abgelaufen gilt. //Hier 15 min $sessionLife = strtotime("-15 minutes");
    18. $sessionStatement = "DELETE FROM " . DB_TABLEPREFIX . "sessions "." WHERE lastUpdated < $sessionLife"; $result = $this->DB->query($sessionStatement); //Ergebnis zurückgeben return $result; }}?>
    Alles anzeigen


    Ohne PreparedStatements und nur über Query taucht bereits dieser Fehler auf:

    Quellcode

    1. Fatal error: Uncaught exception 'PDOException' with message 'SQLSTATE[HY000]: General error' in C:\xampp\htdocs\smartPHP\inc\classes\class.PDO.php:58 Stack trace: #0 C:\xampp\htdocs\smartPHP\inc\classes\class.PDO.php(xx): PDOStatement->fetchAll() #1 C:\xampp\htdocs\smartPHP\inc\classes\class.SessionHandler.php(xx): inc\classes\PDO->query('UPDATE sp_sessi...') #2 [internal function]: inc\classes\SessionHandler->_write('u4vdetqkru9bsv9...', 'username|s:5:"A...') #3 [internal function]: session_write_close() #4 {main} thrown inC:\xampp\htdocs\smartPHP\inc\classes\class.PDO.php on line xx



    Die Zeilenangabe habe ich weggelassen, da aufgrund der Codeformatierung die Zeilen hier nicht mehr stimmen werden.
    Obwohl ich mehrere Versuche, wie $this->PDO->closeCursor(); und andere Möglichkeiten durch bin finde ich keine passende Lösung.


    Dieser Fehler behebt sich ( ohne, das ich es erklären kann), sobald ich es durch preparedStatements ersetzen, jedoch gibt bei mir die $tstmt->execute nie einen Wert zurück, daher ist die Methode in der Session _write dabei und erledigt sowohl den Update-Befehl, als auch den Insert.
    Auch wenn hier noch das alte $this->MySQLiObj->affected_rows steht, so geben auch alle anderen Funktionen array(0){} zurück und keinen Inhalt.

    Ich weiß leider nicht weiter und hoffe auf Hilfe.

    Vielen Dank.
    Rhythmbeat

    PS: Ich kann mich seltsamerweise nicht registrieren, da als Fehler "fehlende Rechte" auftaucht. :)

  • Hallo Szabo,
    danke für deien Antwort, also die Punkte, die du erwähntest sind aufgrund von Copy und Paste-Fehler entstanden und die formatierung ist im Original sauber und strukturiert, nur wurde in diesem Beispiel die Formatierung aufgehoben.
    Und den ertsen Beitrag kann ich leider nicht bearbeiten, da ich nur Besucher bin, wiederum registrieren ist nicht möglich, da ich "keine zugriffsrechte" auf die Seite habe nach dem "Absenden"-Button. Tut mir Leid.

    Ein erneuter Versuch ohne [code] oder Syntax, da sonst eigenständig formartiert wird:
    SessionHandler:

    Quellcode

    1. <?php
    2. //Namespace der Klasse
    3. namespace inc\classes;
    5. /**
    6. * SessionHandler
    7. *
    8. */
    9. class SessionHandler {
    11. private $DB = null;
    13. /**
    14. * Konstruktor
    15. */
    16. public function __construct($DB)
    17. {
    18. $this->DB = $DB;
    20. // Den SessionHandler auf die Methoden
    21. // dieser Klasse setzen
    22. session_set_save_handler(array ($this, '_open'),
    23. array ($this, '_close'),
    24. array ($this, '_read'),
    25. array ($this, '_write'),
    26. array ($this, '_destroy'),
    27. array ($this, '_gc'));
    30. // Session starten
    31. session_start();
    32. //session_write_close();
    33. register_shutdown_function('session_write_close');
    34. }
    36. /**
    37. * Öffnen der Session
    38. *
    39. * @return boolean Gibt immer true zurück
    40. */
    41. public function _open($path, $name) {
    43. return true;
    44. }
    46. /**
    47. * Session schließen
    48. *
    49. * @return boolean Gibt immer true zurück
    50. */
    51. public function _close() {
    53. //Ruft den Garbage-Collector auf.
    54. $this->_gc(0);
    55. return true;
    56. }
    58. /**
    59. * Session-Daten aus der Datenbank auslesen
    60. *
    61. * @return varchar Gibt entweder die Sitzungswerte oder einen leeren String zurück
    62. */
    63. public function _read($sesID) {
    65. $sessionStatement = "SELECT * FROM " . DB_TABLEPREFIX . "sessions WHERE id = '$sesID'";
    66. $result = $this->DB->query($sessionStatement);
    68. if ($result === false) {
    69. return '';
    70. }
    72. if (count($result) > 0) {
    74. return $result[0]["value"];
    75. } else {
    76. return '';
    77. }
    78. }
    80. /**
    81. * Neue Daten in die Datenbank schreiben
    82. *
    83. * @param varchar eindeutige Sessionid
    84. * @param Array Alle Daten der Session
    85. *
    86. * @return boolean Gibt den Status des Schreibens zurück
    87. */
    88. public function _write($sesID, $data) {
    89. //Nur schreiben, wenn Daten übergeben werden
    90. if($data == null)
    91. {
    92. return true;
    93. }
    95. //Statement um eine bestehende Session "upzudaten"
    96. $sessionStatement = "UPDATE " . DB_TABLEPREFIX . "sessions SET lastUpdated='".time()."', value='$data' WHERE id='$sesID'";
    97. $update = $this->DB->query($sessionStatement);
    100. //Ergebnis prüfen
    101. if ($update === false) {
    102. //Fehler in der Datenbank
    103. return false;
    104. }
    105. if ($this->DB->MySQLiObj->affected_rows) {
    106. //bestehende Session "upgedated"
    107. return true;
    108. }
    110. //Ansonsten muss eine neue Session erstellt werden
    111. $sessionStatement = "INSERT INTO " . DB_TABLEPREFIX . "sessions (id, lastUpdated, start, value) VALUES ('$sesID', '".time()."', '".time()."', '$data')";
    112. $update = $this->DB->query($sessionStatement);
    114. //Ergebnis zurückgeben
    115. return $update;
    116. }
    118. /**
    119. * Session aus der Datenbank löschen
    120. *
    121. * @param varchar eindeutige Session-Nr.
    122. *
    123. * @return boolean Gibt den Status des Zerstörens zurück
    124. */
    125. public function _destroy($sesID) {
    127. $sessionStatement = "DELETE FROM " . DB_TABLEPREFIX . "sessions "." WHERE id = '$sesID'";
    129. $result = $this->DB->query($sessionStatement);
    130. //Ergebnis zurückgeben (true|false)
    131. return $result;
    132. }
    134. /**
    135. * Müll-Sammler ;-)
    136. *
    137. * Löscht abgelaufene Sessions aus der Datenbank
    138. *
    139. * @return boolean Gibt den Status des Bereinigens zurück
    140. */
    141. public function _gc($life) {
    143. //Zeitpunkt, zu dem die Session als abgelaufen gilt.
    144. //Hier 15 min
    145. $sessionLife = strtotime("-15 minutes");
    147. $sessionStatement = "DELETE FROM " . DB_TABLEPREFIX . "sessions "." WHERE lastUpdated < $sessionLife";
    148. $result = $this->DB->query($sessionStatement);
    149. //Ergebnis zurückgeben
    150. return $result;
    151. }
    152. }
    153. ?>
    Alles anzeigen



    PDO-Klasse:

    Quellcode

    1. <?php
    2. //Namespace der Klasse
    3. namespace inc\classes;
    5. /**
    6. * Abstraktionsschicht für die Datenbank
    7. *
    8. * Verbindet zur Datenbank und kapselt alle Anfragen an die
    9. * Datenbank. Nutzbar mit diversen Datenbanken (MySQL, SQLite, Oracle, etc.)
    10. *
    11. */
    13. class PDO
    14. {
    15. //Datenbankverbindungsobjekt
    16. public $PDO = null;
    17. //aktuelles preparedStatement
    18. public $preparedStatement = null;
    20. /**
    21. * Verbindet zur Datenbank und gibt ggf. eine
    22. * Fehlermeldung zurück.
    23. *
    24. */
    25. public function __construct($dsn, $user, $password)
    26. {
    27. try
    28. {
    29. //Neues PDO-Objekt
    30. $this->PDO = new \PDO($dsn,$user,$password);
    31. //Fehlermeldungen sollen "geworfen" werden
    32. $this->PDO->setAttribute(\PDO::ATTR_ERRMODE, \PDO::ERRMODE_EXCEPTION);
    33. }
    34. catch (PDOException $e)
    35. {
    36. //Fehlerbehandlung (bspw. E-Mail an Admin)
    37. die('<div style="color:red;">'.$e->getMessage().'</div>');
    38. }
    40. }
    42. /**
    43. * Führt eine SQL-Anfrage durch.
    44. *
    45. * @param text Die SQL-Anfrage
    46. *
    47. * @return Array Gibt eine Ergebnismenge zurück
    48. */
    49. public function query($sql)
    50. {
    51. try
    52. {
    53. //PDO-Anfrage durchführen
    54. $pdoStmt = $this->PDO->query($sql);
    55. //Liegt eine leere Ergebnismenge vor?
    56. ($pdoStmt->rowCount()==0)? $return = array():
    57. //Array mit den Daten
    58. $stmt = $pdoStmt->fetchAll();
    59. //Statement schließen
    60. $pdoStmt->closeCursor();
    61. return $stmt;
    63. }
    64. catch(PDOException $e)
    65. {
    66. //Fehlerbehandlung (bspw. E-Mail an Admin)
    67. echo '<div style="color:red;">'.$e->getMessage().'</div>';
    68. return false;
    69. }
    71. }
    73. /**
    74. * Legt ein "prepared Statement" an
    75. *
    76. * @param String Statement mit Platzhalter-Parametern
    77. */
    78. public function prepareStatement($statement)
    79. {
    80. //Prepared Statement vorbereiten
    81. $this->preparedStatement = $this->PDO->prepare($statement);
    82. if($this->preparedStatement===false)
    83. {
    84. //Fehlerbehandlung (bspw. E-Mail an Admin)
    85. echo '<div style="color:red;">Prepared Statement konnte nicht vorbereitet werden.</div>';
    86. }
    87. }
    89. /**
    90. * Führt ein zuvor angelegtes preparedStatement aus
    91. *
    92. * @param Array Die Parameter für das prepared Statement.
    93. *
    94. * @return Array Ergebnis der Anfrage
    95. */
    96. public function execute($params = array())
    97. {
    98. //Wenn noch kein Statement angelegt ist, wird hier abgebrochen.
    99. if($this->preparedStatement==null)return false;
    101. try
    102. {
    103. //PDO-Anfrage durchführen
    104. $this->preparedStatement->execute($params);
    105. //Wenn keine Daten zurück kamen
    106. if($this->preparedStatement->columnCount()==0)return array();
    107. //Andernfalls die Daten als Array zurückgeben
    108. return $this->preparedStatement->fetchAll();
    109. }
    110. catch(PDOException $e)
    111. {
    112. //Fehlerbehandlung (bspw. E-Mail an Admin)
    113. echo '<div style="color:red;">'.$e->getMessage().'</div>';
    114. return false;
    115. }
    116. }
    117. }
    118. ?>
    Alles anzeigen