2016-04-14 103 views
0

在nodejs中使用mysql模塊獲得了一些問題。即使用戶存在,它會創建一個新用戶,所以有可能是一個問題在於此:節點JS中的多個查詢

if (rows[0].exist == "0") { // if not exist, create it (already authentified by wordpress) 

我已經嘗試過沒有報價,但同樣的問題,將不會更新,只需插入。

function _databaseProcess() { 
     var existUser = 'SELECT COUNT(*) as exist FROM user WHERE display_name = "?"'; 
     var insertUser = 'INSERT INTO user SET ?'; 
     var getUid = 'select uid from user where display_name = "?"'; 

     pool.getConnection(function(err, db) { // Ask for a connection 
      if (err) { 
       db.release(); 
       console.log("Erreur lors de la connexion à la base"); 
       return; 
      } 

      console.log('Connexion à la base : id ' + db.threadId); 

      db.query(existUser, [data.username], function(err, rows) { // check if user exist 
       if (err) throw err; 
       console.log("resultat : " + rows[0].exist); 
       if (rows[0].exist == "0") { // if not exist, create it (already authentified by wordpress) 
        console.log('Première connexion de ' + data.username); 
        uid = uuid.v4(); 
        var value = { 
         "display_name": data.username, 
         "uid": uid 
        }; 
        db.query(insertUser, value, function(err, rows) { 
         if (err) throw err; 
         db.release(); 
         console.log("Ajout de l'user " + rows.insertId); 

         _initiateConnection(); 
        }); 
       } else { //else, retrieve the uid 
        db.query(getUid, value, function(err, rows) { 
         if (err) throw err; 
         db.release(); 
         console.log("UID de l'user : " + rows[0].uid); 
         uid = rows[0].uid; 

         _initiateConnection(); 
        }); 
       } 
      }); 

      db.on('error', function(err) { 
       console.log("Erreur dans la base de donnée"); 
       return; 
      }); 
     }); 

編輯

其實,這裏是控制檯輸出我得到:

[/#DIM4Opuve1Ov96igAAAB]Requete obtenu, qui est-ce ? 
Connexion à la base : id 36525 
[ RowDataPacket { exist: 0 } ] 
Première connexion de polette 
Ajout de l'user 1 
[/#DIM4Opuve1Ov96igAAAB] USER: polette => bcf8ebb5-04fc-45d4-8d15-5ee7ae6ec368 
polette from socket /#DIM4Opuve1Ov96igAAAB joined the app 
Utilisateurs connectés (1) : 
bcf8ebb5-04fc-45d4-8d15-5ee7ae6ec368 (polette) sur le socket /#DIM4Opuve1Ov96igAAAB 
polette disconnected 
[/#1DIhz2yFipo9VtuzAAAC]Requete obtenu, qui est-ce ? 
Connexion à la base : id 36525 
[ RowDataPacket { exist: 0 } ] 
Première connexion de polette 
Ajout de l'user 2 
[/#1DIhz2yFipo9VtuzAAAC] USER: polette => d6a73fc1-a650-4b03-89d5-cb96b070e876 
polette from socket /#1DIhz2yFipo9VtuzAAAC joined the app 
Utilisateurs connectés (1) : 
d6a73fc1-a650-4b03-89d5-cb96b070e876 (polette) sur le socket /#1DIhz2yFipo9VtuzAAAC 

有一些輸出,你可能不知道,因爲我忽略的代碼,但事實上我們看到的是,即使polette在數據庫中,他不會搜索他的UID,並將創建一個新的,並在我的數據庫中,我會得到這個(此輸出是xml導出):

<pma_xml_export version="1.0" xmlns:pma="http://www.phpmyadmin.net/some_doc_url/"> 
    <!-- 
    - Structure schemas 
    --> 
    <pma:structure_schemas> 
     <pma:database name="node" collation="latin1_swedish_ci" charset="latin1"> 
      <pma:table name="user"> 
       CREATE TABLE `user` (
        `id` smallint(5) unsigned NOT NULL AUTO_INCREMENT, 
        `display_name` varchar(255) NOT NULL, 
        `uid` varchar(36) DEFAULT NULL, 
        PRIMARY KEY (`id`) 
       ) ENGINE=InnoDB AUTO_INCREMENT=3 DEFAULT CHARSET=utf8; 
      </pma:table> 
     </pma:database> 
    </pma:structure_schemas> 

    <!-- 
    - Base de données: 'node' 
    --> 
    <database name="node"> 
     <!-- Table user --> 
     <table name="user"> 
      <column name="id">1</column> 
      <column name="display_name">polette</column> 
      <column name="uid">bcf8ebb5-04fc-45d4-8d15-5ee7ae6ec368</column> 
     </table> 
     <table name="user"> 
      <column name="id">2</column> 
      <column name="display_name">polette</column> 
      <column name="uid">d6a73fc1-a650-4b03-89d5-cb96b070e876</column> 
     </table> 
    </database> 
</pma_xml_export> 
+0

你應該學習的承諾和[promisify(http://bluebirdjs.com/docs/api/promise.promisifyall.html)你的數據庫訪問,這個代碼幾乎沒有任何已經是一個回調地獄 –

+0

是的,下一步,但作爲nodejs的初學者,我想了解如何解決我的數據庫查詢,就像我已經作出 –

+0

你可以簡單地''console.log(行)'而不是'console.log(「resultat:」+ rows [0] .exist);' – Molda

回答