Requêtes SQL et AJAX¶

exports.pool = function(mysql) {
  // informations pour se connecter à la base de données
  var pool = mysql.createPool({
    host     : 'localhost',
    user     : 'root',
    // mettre '' comme mot de passe sur Windows
    password : 'root',
    database : 'hello_world',
    charset  : 'UTF8_UNICODE_CI',
    multipleStatements: true
  });

  // à l'appel de cette fonction, ces informations sont retournées
  return pool;
}

exports.requete = function(mysql, sql, requete_sql, callback) {
  // nous récupérons les données de la fonction pool() écrite plus haut
  // nous utilisons getConnection() pour avoir une connection pool
  sql.pool(mysql).getConnection(function(err, connection) {
    /* lorsque nous avons les informations sur cette connection,
    nous exécutons la requête */
    connection.query(requete_sql, function(err, results) {
      // nous affichons les erreurs, s'il y en a,  à l'aide d'une autre fonction
      sql.query_error(err);
      /* nous testons l'existence du paramètre callback, qui est facultatif si nous
      ne voulons pas obtenir le résultat de la requête (par exemple pour les UPDATE) */
      if(typeof(callback) !== 'undefined') {
        // s'il existe, nous renvoyons les résultats dans une fonction de callback
        callback(results);
      }
      // nous libérons la connection pour éviter de surcharger le pool
      connection.destroy();
    });
  });
}

// cette fonction permet d'afficher une erreur dans la requête SQL
exports.query_error = function(erreur) {
  if (erreur) {
    console.log('query error : ' + erreur.stack);
  }
}

exports.f = function(io, mysql, sql) {
  // ...
}

var http = require('http');
var path = require('path');
var express = require('express');
// récupération du module node-mysql
var mysql = require('mysql');

var app = express();
var server = http.Server(app);
var io = require('socket.io')(server);

var routes = require('./serveur/routes.js');
var socket = require('./serveur/socket.js');
// récupération des fonctions du fichier sql.js
var sql = require('./serveur/sql.js');

routes.f(app, __dirname, mysql, sql);
socket.f(io, mysql, sql);

server.listen(8888);

// à placer juste après console.log('Le client a cliqué sur le bouton !')
var requete_sql = 'INSERT INTO clics(date) VALUES(NOW())';
sql.requete(mysql, sql, requete_sql);

exports.date = function(mysql, sql, callback, derniere_date) {
  // teste si l'attribut derniere_date est true ou false
  if (!derniere_date) {
    var requete_sql = 'SELECT * FROM clics ORDER BY id';
  } else {
    // nous demandons de choisir le premier élément dans
    // l'ordre décroissant, c'est-à-dire le dernier élément
    var requete_sql = 'SELECT * FROM clics ORDER BY id DESC LIMIT 0,1'
  }
  sql.requete(mysql, sql, requete_sql, function(results) {
    callback(results);
  });
}

app.get('/derniere_date', function(req, res) {
  sql.date(mysql, sql, function(results) {
    res.render('derniere_date.ejs', {
      results : results
    });
  }, true);
});

socket.on('charger_derniere_date', function() {
  var xhr = new XMLHttpRequest();
  xhr.open('GET', 'derniere_date');
  xhr.addEventListener('readystatechange', function() {
    if (xhr.readyState === 4 && xhr.status === 200) {
      // on ajoute le contenu de derniere_date.ejs aux dates existantes
      byId('dates').innerHTML += xhr.responseText;
      // rappel : byId() = document.getElementById()
    }
  });
  xhr.send(null);
});

socket.on('bouton_client', function() {
  console.log('Le client a cliqué sur le bouton !')
  var requete_sql = 'INSERT INTO clics(date) VALUES(NOW())';
  sql.requete(mysql, sql, requete_sql);

  // avec la fonction socket.emit le client actuel charge la nouvelle date
  socket.emit('charger_derniere_date');
  /* avec la fonction socket.broadcast.emit,
  la nouvelle date est également envoyée aux autres clients */
  socket.broadcast.emit('charger_derniere_date');
});