Maison  >  Article  >  interface Web  >  Connexion à MySQL dans nodejs (tutoriel détaillé)

Connexion à MySQL dans nodejs (tutoriel détaillé)

亚连
亚连original
2018-06-09 14:40:022632parcourir

Cet article présente principalement la fonction de connexion à la base de données MySQL implémentée par nodejs, et analyse les étapes de fonctionnement associées et les techniques de mise en œuvre de la connexion nodejs et de l'interrogation des données mysql sous forme d'exemples. Les amis dans le besoin peuvent se référer aux exemples de. cet article

Décrit la fonction de connexion à la base de données MySQL implémentée par nodejs. Partagez-le avec tout le monde pour votre référence, les détails sont les suivants :

1. Exécutez npm install mysql dans le répertoire du projet pour installer le module mysql pour nodejs ;

2. db.jsLe module est utilisé pour se connecter à MySQL et définir des méthodes de requête

var mysql = require('mysql');
// 创建一个数据库连接池
var pool = mysql.createPool({
 connectionLimit: 50,
 host: 'localhost',
 user: 'admin',
 password: '123456',
 database: 'rp-test'
});
// SELECT * FROM users
// 让我们的方法支持两种模式
// 一种是只传入SQL语句和回调函数
// 一种是传入SQL语句、参数数据、回调函数
exports.query = function (sql, P, C) {
 var params = [];
 var callback;
 // 如果用户传入了两个参数,就是SQL和callback
 if (arguments.length == 2 && typeof arguments[1] == 'function') {
  callback = P;
 } else if (arguments.length == 3 && Array.isArray(arguments[1]) && typeof arguments[2] == 'function') {
  params = P;
  callback = C;
 } else {
  throw new Error('对不起,参数个数不匹配或者参数类型错误');
 }
 // 如果用户传入了三个参数,那么就是SQL和参数数组、回调函数
 // 从池子里面拿一个可以使用的连接
 pool.getConnection(function (err, connection) {
  // Use the connection
  connection.query(sql, params, function () {
   // 使用完毕之后,将该连接释放回连接池
   connection.release();
   callback.apply(null, arguments);
  });
 });
};
3 Exemples de requête

var express = require('express');
var db = require('./db');
var router = express.Router();
router.get('/',function(req, res, next){
  db.query("select * from app",function(err,result){
     //console.log(result);
    res.send(JSON.stringify (result));
  });
});
module.exports=router;
Ce qui précède est ce que j'ai compilé pour tout le monde ; . J'espère que cela sera utile à tout le monde à l'avenir.

Articles associés :

Comment utiliser le plug-in de progression du chargement avec Pace.js et NProgress.js (tutoriel détaillé)

Dans l'applet WeChat À propos du cycle de vie de l'application (tutoriel détaillé)

À propos de l'utilisation du plug-in de progression de chargement de NProgress.js dans jQuery

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration:
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn