Probleme mit DB-Abstraktion

Einklappen
X
 
  • Filter
  • Zeit
  • Anzeigen
Alles löschen
neue Beiträge

  • Probleme mit DB-Abstraktion

    Also..ich bekomme folgenden Fehler:
    PHP-Code:
    Fatal errorUncaught exception 'MysqlException' with message 'You have an error in your SQL syntax;
    check the manual that corresponds to your MySQL server version for the right syntax to use near 
    '
    email' at line 1' in D:\\Programme\\Zend\\Apache2\\htdocs\\lib\\database\\mysql\\test\\class.mysql_test.php:58 Stack trace:#0
    D:\\Programme\\Zend\\Apache2\\htdocs\\lib\\authentication\\class.authenticate.php(6):
    DB_MySQL_Test->execute('email''looser'#1
    D:\\Programme\\Zend\\Apache2\\htdocs\\index.php(20): Authentication::check_credentials('email''looser'#2 {main} thrown in
    D:\\Programme\\Zend\\Apache2\\htdocs\\lib\\database\\mysql\\test\\class.mysql_test.php on line 58 
    Ich kann mir das ganze auch erklären und zuordnen...
    Die Methode DB_MySQL_Test->execute($query) sollte nicht aufgerufen werden, sondern die Methode DB_MySQL_Test_Statement->execute()..

    Also der Code sieht folgendermaßen aus:
    class.authenticate.php
    PHP-Code:
    <?php
    class Authentication {
        static function 
    check_credentials($name$password) {
            
    $dbh = new DB_MySQL_Test;
            
    $query "SELECT user_id FROM cm_users WHERE user_mail = :1 AND user_pass = :2";
                
    $cur $dbh->prepare($query)->execute($name$password);
                
    $row $cur->fetch_assoc();
                if(
    $row) {
                    
    $userid $row['user_id'];
                }
                else {
                    throw new 
    AuthException("User is not authorized!");
                }
                return 
    $userid;
        }

    }
    ?>
    dieser wird von index.php aufgerufen, dieser Code spielt aber keine Rolle, hier die beiden Klassen in einer Datei:
    PHP-Code:
    <?php

    class DB_MySQL_Test {
        protected 
    $db_user;
        protected 
    $db_pass;
        protected 
    $db_host;
        protected 
    $db_name;
        protected 
    $dbh;


        public function 
    __construct(){
            
    $this->user DB_USER;
            
    $this->pass DB_PASS;
            
    $this->host DB_HOST;
            
    $this->name DB_NAME;
        }

        protected function 
    connect(){
            
    $this->dbh mysql_connect($this->host$this->user$this->pass);
            if(!
    is_resource($this->dbh)){
                require_once(
    FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                throw new 
    MysqlException;
            }
            if(!
    mysql_select_db($this->name$this->dbh)){
                require_once(
    FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                throw new 
    MysqlException;
            }
        }

        public function 
    execute($query){
            if(!
    $this->dbh){
                
    $this->connect();
            }
            
    $ret mysql_query($query$this->dbh);
            if(!
    $ret){
                require_once(
    FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                throw new 
    MysqlException;
            }
            elseif(!
    is_resource($ret)){
                return 
    TRUE;
            }
            else {
                
    $stmt = new DB_MySQL_Test_Statement($this->dbh$query);
                
    $stmt->result $ret;
                return 
    $stmt;
            }
        }

        public function 
    prepare($query){
            if(!
    $this->dbh){
                
    $this->connect();
            }
            return new 
    DB_MySQL_Test_Statement($this->dbh$query);
        }
    }
    class 
    DB_MySQL_Test_Statement {
        protected 
    $result;
        protected 
    $binds;
        public 
    $query;
        protected 
    $dbh;

        public function 
    __construct($dbh$query){
            
    $this->query $query;
            
    $this->dbh $dbh;
            if(!
    is_resource($dbh)){
                require_once(
    FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                throw new 
    MysqlException("Not a valid database connection");
            }
        }
       
        public function 
    bind_param($ph$pv){
            
    $this->binds[$ph] = $pv;
        }
      
        public function 
    execute($query){
            
    $binds func_get_args();
            foreach (
    $binds as $index => $name){
                
    $this->binds[$index 1] = $name;
            }
            
    $cnt count($binds);
            
    $query $this->query;
            foreach (
    $this->binds as $ph => $pv){
                
    $query str_replace(":$ph""'".mysql_escape_string($pv)."'"$query);
            }
            
    $this->result mysql_query($query$this->dbh);
            if(!
    $this->result){
                require_once(
    FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                throw new 
    MysqlException;
            }
        }
      
        public function 
    fetch_row(){
            if(!
    $this->result){
                require_once(
    FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                throw new 
    MysqlException("Query not executed");
            }
            return 
    mysql_fetch_row($this->result);
        }
       
        public function 
    fetch_assoc(){
            return 
    mysql_fetch_assoc($this->result);
        }
       
        public function 
    fetchall_assoc(){
            
    $retval = array();
            while(
    $row $this->fetch_assoc()){
                
    $retval[] = $row;
            }
            return 
    $retval;
        }
    }
    ?>
    Die anderen eingebundenen Dateien sind halt nur die Exception-Handler...
    Der sollte doch eigentlich aufgrund der Funktion DB_MySQL_Test->prepare($query) in DB_MySQL_Test_Statement springen und dann die execute-Methode ausführen... aber, ne...er zeigt mir lieber nen Query-String-Fehler an
    Vllt findet ja jemand den Fehler...
    Danke im Vorraus, Dennis
    P.S.: Falls jemand den ganzen Code haben möchte...schreiben...falls sich jemand über die komischen require_once-Aufrufe wundert... wir verwenden eine zentrale Datei, wo Passwörter, Pfade und Einstellungen gespeichert sind und die auch dort als Konstanten definiert werden...
    EDIT:
    Das Forum schluckt ja die Backslashes... ... egal...hab's korrigiert ... oder eben auch nicht
    auch die Breite angepasst

    Zuletzt geändert von Bersi667; 08.11.2007, 07:02.
    Musik beflügelt unseren Geist

  • #2
    Habe gerade was geändert..und zwar:
    PHP-Code:
        public function prepare($query){
            if(!
    $this->dbh){
                
    $this->connect();
            }
            
    $stmt = new DB_MySQL_Test_Statement($this->dbh$query);
            
    $stmt->execute($query);
        } 
    in der Klasse DB_MySQL_Test...jetzt ruft der die Methode DB_MySQL_Test_Statement::execute($query) auf...bekomme da aber den gleichen Fehler, der erzählt mir wieder einen von falsche Synthax usw. ... dabei sollte das doch ausgewertet sein...

    Such mal weiter...
    Musik beflügelt unseren Geist

    Kommentar


    • #3
      Ich hab nicht allse genau angeschaut, aber der Konstuktor der Klasse DB_MySQL_Test_Statement gibt ja nichts zurück, und diese Nichts gibst du dann in DB_MySQL_Test->prepare() weiter.
      Gruss
      H2O

      Kommentar


      • #4
        Original geschrieben von H2O
        Ich hab nicht allse genau angeschaut, aber der Konstuktor der Klasse DB_MySQL_Test_Statement gibt ja nichts zurück, und diese Nichts gibst du dann in DB_MySQL_Test->prepare() weiter.
        Bullshit! New erzeugt einen neues Objekt, hier vom Typ DB_MySQL_Test_Statement! Grundlagen!

        Hast du dir die Query mal vor dem Ausführen ausgegeben? Irgendwo scheint was mit deinem ersetzen Parameter schief zu gehen! Wo genau, kann ich so leider net sagen!

        Kommentar


        • #5
          @PHP-Desaster
          Sorry, du hast natürlich völlig recht, ich glaube, ich bin noch nicht ganz wach. Also vergiss meinen Beitrag. Löschen kann ich ihn leider nicht mehr.
          Gruss
          H2O

          Kommentar


          • #6
            Hey, also...wenn ich mir die Query so ausgeben lasse, funktioniert das, der Fehler liegt iwo hier:
            PHP-Code:
            public function execute($query){
                    
            $binds func_get_args();
                    foreach (
            $binds as $index => $name){
                        
            $this->binds[$index 1] = $name;
                    }
                    
            $cnt count($binds);
                    
            $query $this->query;
                    foreach (
            $this->binds as $ph => $pv){
                        
            $query str_replace(":$ph""'".mysql_escape_string($pv)."'"$query);
                    }
                    
            $this->result mysql_query($query$this->dbh);
                    if(!
            $this->result){
                        require_once(
            FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                        throw new 
            MysqlException;
                    }
                } 
            Der Fehler wird geworfen, wenn der den Query ausführen soll...
            Moment mal, kann das sein, dass ich die Methode bind_param() garnicht abarbeite?!? ...
            PHP-Code:
            public function bind_param($ph$pv){
                    
            $this->binds[$ph] = $pv;
                } 
            Hmm...versuch das nachher mal, sobald ich wieder zuhaus bin...Grüße, Dennis
            Musik beflügelt unseren Geist

            Kommentar


            • #7
              PHP-Code:
              public function execute($query){
                      
              $binds func_get_args();
                      foreach (
              $binds as $index => $name){
                          
              $this->binds[$index 1] = $name;
                      }
                      
              // ... 
              Der Fehler ist, das in $binds imho auch der Parameter $query enthalten ist! Dein $index+1 hilft da aber auch nix! array_slice hilft!

              Kommentar


              • #8
                Der Parameter $query ist übrigens eh schon mal Quatsch, der Methode wird doch $name und $password übergeben, deswegen ja auch das func_get_args()...teste mal weiter...lass mir im Moment mal alle Werte ausgeben, iwo da werd ich den Fehler ja finden...
                Musik beflügelt unseren Geist

                Kommentar


                • #9
                  haha...nu hab ich wieder den gleichen Fehler wie eben...

                  Also, das ganze wird so aufgerufen:
                  PHP-Code:
                  static function check_credentials($name$password) {
                          
                  $dbh = new DB_MySQL_Test;
                          
                  $query "SELECT user_id FROM cm_users WHERE user_mail = :1 AND user_pass = :2";
                              
                  $cur $dbh->prepare($query);
                              
                  $cur->execute($name$password);
                              
                  $row $cur->fetch_assoc();
                              if(
                  $row) {
                                  
                  $userid $row['user_id'];
                              }
                              else {
                                  throw new 
                  AuthException("User is not authorized!");
                              }
                              return 
                  $userid;
                      } 
                  So wird doch erst die Methode prepare($query) aufgerufen...
                  in dieser findet folgendes statt:
                  PHP-Code:
                  public function prepare($query){
                          if(!
                  $this->dbh){
                              
                  $this->connect();
                          }
                          return new 
                  DB_MySQL_Test_Statement($this->dbh$query);
                      } 
                  eigentlich sollte man ja nun meinen wird eine Instanz der Klasse DB_MySQL_Test_Statement geöffnet..und dann dementsprechend diese Methode verarbeitet:
                  PHP-Code:
                  public function execute(){
                          
                  $binds func_get_args();
                          foreach (
                  $binds as $index => $name){
                              
                  $this->binds[$index 1] = $name;
                          }
                          
                  $cnt count($binds);
                          
                  $query $this->query;
                          return 
                  $query;
                          foreach (
                  $this->binds as $ph => $pv){
                              
                  $query str_replace(':$ph''\''.mysql_escape_string($pv).'\''$query);
                          }
                          
                  $this->result mysql_query($query$this->dbh);
                          if(!
                  $this->result){
                              require_once(
                  FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                              throw new 
                  MysqlException;
                          }
                      } 
                  Aber nein, der Compiler meint er müsste stattdessen:
                  PHP-Code:
                  public function execute($query){
                          if(!
                  $this->dbh){
                              
                  $this->connect();
                          }
                          
                  $ret mysql_query($query$this->dbh);
                          if(!
                  $ret){
                              require_once(
                  FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                              throw new 
                  MysqlException;
                          }
                          elseif(!
                  is_resource($ret)){
                              return 
                  TRUE;
                          }
                          else {
                              
                  $stmt = new DB_MySQL_Test_Statement($this->dbh$query);
                              
                  $stmt->result $ret;
                              return 
                  $stmt;
                          }
                      } 
                  ausführen...dies ist aber eine Methode der Klasse DB_MySQL_Test, in der die Methode prepare($query) sitzt... iwie find ich das ganz schön unlogisch......... hab's auch schon mit anderen Funktionsnamen getestet, so dass es nicht zu Überschneidungen kommen kann, aber das funktioniert auch nicht..., als ob der prepare() nicht abarbeiten würde...
                  Zuletzt geändert von Bersi667; 09.11.2007, 04:40.
                  Musik beflügelt unseren Geist

                  Kommentar


                  • #10
                    So...hab das Problem in den Griff bekommen, jetzt springt der zwar wieder in die korrekte execute() Abfrage, aber schmeisst immer noch nen Fehler, weil die Umwandlung der Platzhalter nicht korrekt funzt...
                    Langsam treibt mich der scheiss noch in den wahnsinn...
                    Musik beflügelt unseren Geist

                    Kommentar


                    • #11
                      Aaalso...es lag nicht am vermeintlich fehlenden array_slice()...hätte auch keine Ahnung, was ich damit anfangen sollte... wenn ich das Script wie folgt ändere:
                      PHP-Code:
                      public function execute(){
                              
                      $binds func_get_args();
                              foreach (
                      $binds as $index => $name){
                                  
                      $this->binds[$index 1] = $name;
                              }
                              
                      $cnt count($binds);
                              
                      $query $this->query;
                              foreach (
                      $this->binds as $ph => $pv){
                                  
                      $query str_replace(':'.$phmysql_escape_string($pv), $query);
                              }
                              
                      $this->result mysql_query($query$this->dbh);
                              if(!
                      $this->result){
                                  require_once(
                      FS_LIB_ROOT.DS.'database'.DS.'mysql'.DS.'mysql_exception.php');
                                  throw new 
                      MysqlException;
                              }
                          } 
                      Gibt der mir zwar immer noch nen Fehler aus, wieder, dass die SQL-Synthax nicht stimmen kann, allerdings ists nen Teilerfolg, da der nun die Platzhalter entfernt und der Query vollständig ist...
                      Musik beflügelt unseren Geist

                      Kommentar


                      • #12
                        Hier ist mal ein Auszug aus der Fehlermeldung...
                        Code:
                        Fatal error: Uncaught exception 'MysqlException' with message 'You have an error in your SQL syntax; check the manual
                         that corresponds to your MySQL server version for the right syntax to use near '@gmx.de AND user_pass = looser'
                        Sieht so aus, als würde der über das @ meckern...
                        Musik beflügelt unseren Geist

                        Kommentar


                        • #13
                          Du hast natürlich recht, der $query-Parameter in deiner Methode ist Käse. Hatte ich jetzt nicht richtig drauf geachtet.
                          PHP-Code:
                          $query str_replace(':'.$phmysql_escape_string($pv), $query); 
                          Wo sind die Anführungszeichen geblieben??

                          Was mir grad noch auffällt, was passiert wohl mit folgender Query:
                          Code:
                          insert into fussball
                          set ergebnis = '1:1',
                                mannschaft = :1


                          BTW: Spricht was gegen ??

                          Kommentar


                          • #14
                            Ja, das soll ja eigentlich maskiert werden...teste gerade mal ein wenig, also, wenn ich eine eMail-Adresse eintipp, kommt eben genannter Fehler, falls ich aber nur einen Namen eingebe erzählt der mir einen von "Unknown Column" -->ergo, der denkt, das ganze sei die Spalte....

                            Ich lass mir im Moment die Query ausgeben, nachdem sie abgearbeitet wurde...dabei kommt raus:
                            Code:
                            SELECT user_id FROM cm_users WHERE user_mail = [email]den-nis@bersi.de[/email] AND user_pass = nix
                            Musik beflügelt unseren Geist

                            Kommentar


                            • #15
                              Und seit wann kannst du Strings ohne Anführungszeichen an die Datenbank schicken??
                              In deinem ersten Code ist es doch noch richtig:
                              PHP-Code:
                              $query str_replace(":$ph""'".mysql_escape_string($pv)."'"$query); 

                              Kommentar

                              Lädt...
                              X