2016-04-14 72 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

回答