var mysql = require('mysql');
var connection = mysql.createConnection({
  host     : 'localhost',
  user     : 'ac',
  password : '123456',
  database : 'textPro'
});
 
connection.connect();
 
connection.query('SELECT * from1 userInfo', function (error, results, fields) {
  if (error) throw error;
  console.log('The solution is: ', results);
});
 
connection.end();

const mysql = require("mysql")
 
//創(chuàng)建連接池
const db= mysql.createPool({  
    host : 'localhost', //連接主機(jī)
    port : 3306,   //端口號(hào)
    database : 'test',  //連接的是哪一個(gè)庫(kù)
    user : 'root',   //用戶名
    password : '',    //密碼
    connectionLimit : 50, //用于指定連接池中最大的鏈接數(shù)，默認(rèn)屬性值為10. 
    //用于指定允許掛起的最大連接數(shù)，如果掛起的連接數(shù)超過(guò)該數(shù)值，就會(huì)立即拋出一個(gè)錯(cuò)誤，
    //默認(rèn)屬性值為0.代表不允許被掛起的最大連接數(shù)。
    queueLimit:3 
})  

const mysql = require("mysql")
 
//創(chuàng)建連接池
const db= mysql.createPool({  
    host : 'localhost', //連接主機(jī)
    port : 3306,   //端口號(hào)
    database : 'test',  //連接的是哪一個(gè)庫(kù)
    user : 'root',   //用戶名
    password : '',    //密碼
    connectionLimit : 50, //用于指定連接池中最大的鏈接數(shù)，默認(rèn)屬性值為10. 
    //用于指定允許掛起的最大連接數(shù)，如果掛起的連接數(shù)超過(guò)該數(shù)值，就會(huì)立即拋出一個(gè)錯(cuò)誤，
    //默認(rèn)屬性值為0.代表不允許被掛起的最大連接數(shù)。
    queueLimit:3 
})  
 
module.exports.query = (sql, values.callback) => {
  //err： 該參數(shù)是指操作失敗時(shí)的錯(cuò)誤對(duì)象。
  //connection: 該值為一個(gè)對(duì)象，代表獲取到的連接對(duì)象。當(dāng)連接失敗時(shí)，該值為undefined。
  db.getConnection(function(err, connection) {
    if (err) {
      console.log('與mysql數(shù)據(jù)庫(kù)建立連接失敗');
      pool.releaseConnection(); //釋放鏈接
    } else {
      console.log('與mysql數(shù)據(jù)庫(kù)建立連接成功');
      connection.query(sql,values,(err, res) => {
        if (err) {
          console.log('執(zhí)行sql語(yǔ)句失敗，查詢(xún)數(shù)據(jù)失敗');
          //connection.release() 當(dāng)一個(gè)連接不需要使用時(shí)，使用該方法將其歸還到連接池中 release釋放
          connection.release();
          callback(err,null)
        } else {
           console.log('執(zhí)行sql語(yǔ)句成功');
           callback(null,res)
          //pool.end() 當(dāng)一個(gè)連接池不需要使用時(shí)，可以使用該方法關(guān)閉連接池
          pool.end();
        }
      })
    }
  })
}

const query=require('./db').query;
let sql='SELECT * FROM class WHERE class_id=? AND class_name=?' 
let userId=1;
let userName='阿辰';
query(sql,[userId,userName],(err,res)=>{
    if(err){
        console.log('發(fā)生了錯(cuò)誤***',err)
        return
    }
console.log('找到了',res)
})