Nodejs uses connection pooling to connect to the database
Create OptPool.js
Var mysql = require ('mysql')
Function OptPool () {
This.flag = true
This.pool = mysql.createPool ({
Host:'localhost'
User:'root'
Password:''
Database:'mtc'
Port:'3306'
});
This.getPool = function () {
If (this.flag) {
This.pool.on ('connection',function (connection) {
Connection.query ('SET SESSION auto_increment_increment=1')
This.flag = false
});
}
Return this.pool
}
}
Module.exports = OptPool
Create mysqlPool.js
Var OptPool = require ('. / models/OptPool')
Var optPool = new OptPool ()
Var pool = optPool.getPool ()
Pool.getConnection (function (err,conn) {
/ / Delete
Var deleteSql = "DELETE FROM mtc_users WHERE user_id =?"
Var deleteParams = ['3']
Conn.query (deleteSql,deleteParams,function (err,rs) {
If (err) {
Console.log (err)
Return
}
Console.log ('delete success')
Conn.release ()
})
/ modify
/ / var updateSql = "UPDATE mtc_users SET user_pass =? WHERE user_id =?"
/ / var updateParams = ['7891012]
/ / conn.query (updateSql,updateParams,function (err,rs) {
/ / if (err) {
/ / console.log (err)
/ / return
/ /}
/ / console.log ('update success')
/ / conn.release ()
/ /})
/ query
/ / var selectSql = "SELECT * FROM mtc_users"
/ / var selectParams = []
/ / conn.query (selectSql,selectParams,function (err,rs) {
/ / if (err) {
/ / console.log (err)
/ / return
/ /}
/ / for (var I = 0bot I
