const mysql = require(''mysql'')

const config = require(''./../../config/config.default'')

var connection = mysql.createConnection({
  host: config.database.HOST,
  user: config.database.USERNAME,
  password: config.database.PASSWORD,
  database: config.database.DATABASE
})

connection.connect(function(err) {
  if (err) {
    console.error(''error connecting: '' + err.stack)
    return
  }
  console.log(''Database connection successful, connected as id '' + connection.threadId)
})

//查询
// connection.query(`select * from area`, function(err, results, fields) {
//   if (err) throw err
//   console.log(results[0])
//   console.log(fields[0])
// })



//关闭连接
// connection.end(function(err) {
//   if (err) {
//     console.error(''数据库关闭失败'' + err)
//   }
//   console.log(''数据库关闭'')
// })

module.exports = connection

// 分装

const mysql = require(''mysql'')

const config = require(''./../../config/config.default'')

module.exports = {
  query: function(sql, params, callback) {
    var connection = mysql.createConnection({
      host: config.database.HOST,
      user: config.database.USERNAME,
      password: config.database.PASSWORD,
      database: config.database.DATABASE
    })
    connection.connect(function(err) {
      if (err) {
        console.error(''error connecting: '' + err.stack)
        throw err
      }
      console.log(''Database connection successful, connected as id '' + connection.threadId)
      connection.query(sql, params, function(err, results, fields) {
        if (err) throw err
        callback && callback(results, fields)
        connection.end(function(err) {
          if (err) {
            console.error(''数据库关闭失败'' + err)
            throw err 
          }
          console.log(''数据库关闭'')
        })
      })    
    })
  },
  // 连接池连接
  queryPool: function(sql, params, callback) {
    var pool = mysql.createPool({
      host: config.database.HOST,
      user: config.database.USERNAME,
      password: config.database.PASSWORD,
      database: config.database.DATABASE
    })
    pool.getConnection(function(err, connection) {
      // 使用连接
      connection.query(sql, params, function(err, results, fields) {
        if (err) throw err
        callback && callback(results, fields)
        connection.release()     
        console.info(''连接完成,不再使用,返回到连接池'')
      })
    })
  }
}


// 调用
const db = require(''./index'')


db.query(`select * from area`, [], function(result, fields) {
  console.log(''查询结果：'')
  console.log(result[0].name)
})

db.queryPool(`select * from area`, [], function(result, fields) {
  console.log(''查询结果：'')
  console.log(result[0])
})

const db = require(''../db'')
const query = db.queryPoolPromise

/**
 * @author afacode
 * SQL 操作
 * @date 2018.08.15
 */
let findAllUser = (value, col = ''*'') => {
  let _sql = `select ${col} from user_login where user_id = ?;`
  return query(_sql, value)
}
// 测试
async function user() {
  let user = await findAllUser([22], [''username'', ''password''])
  
console.log(user)
}

user()

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")
 
//创建连接池
const db= mysql.createPool({  
    host : 'localhost', //连接主机
    port : 3306,   //端口号
    database : 'test',  //连接的是哪一个库
    user : 'root',   //用户名
    password : '',    //密码
    connectionLimit : 50, //用于指定连接池中最大的链接数，默认属性值为10. 
    //用于指定允许挂起的最大连接数，如果挂起的连接数超过该数值，就会立即抛出一个错误，
    //默认属性值为0.代表不允许被挂起的最大连接数。
    queueLimit:3 
})

const mysql = require("mysql")
 
//创建连接池
const db= mysql.createPool({  
    host : 'localhost', //连接主机
    port : 3306,   //端口号
    database : 'test',  //连接的是哪一个库
    user : 'root',   //用户名
    password : '',    //密码
    connectionLimit : 50, //用于指定连接池中最大的链接数，默认属性值为10. 
    //用于指定允许挂起的最大连接数，如果挂起的连接数超过该数值，就会立即抛出一个错误，
    //默认属性值为0.代表不允许被挂起的最大连接数。
    queueLimit:3 
})  
 
module.exports.query = (sql, values.callback) => {
  //err： 该参数是指操作失败时的错误对象。
  //connection: 该值为一个对象，代表获取到的连接对象。当连接失败时，该值为undefined。
  db.getConnection(function(err, connection) {
    if (err) {
      console.log(''与mysql数据库建立连接失败'');
      pool.releaseConnection(); //释放链接
    } else {
      console.log(''与mysql数据库建立连接成功'');
      connection.query(sql,values,(err, res) => {
        if (err) {
          console.log(''执行sql语句失败，查询数据失败'');
          //connection.release() 当一个连接不需要使用时，使用该方法将其归还到连接池中 release释放
          connection.release();
          callback(err,null)
        } else {
           console.log(''执行sql语句成功'');
           callback(null,res)
          //pool.end() 当一个连接池不需要使用时，可以使用该方法关闭连接池
          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('发生了错误***',err)
        return
    }
console.log('找到了',res)
})