"req.getConnection is not function"Node.js

Question

Node.js 응용 프로그램과 sql 데이터베이스를 연결하는 데 문제가 있습니다. "req.getConnection is not function"오류가 발생합니다. 특정 페이지 (eg.users)를 클릭하는 순간 데이터베이스에서 데이터를 가져 오려고합니다.

var express = require('express'); 
var path = require('path'); 
var favicon = require('serve-favicon'); 
var logger = require('morgan'); 
var cookieParser = require('cookie-parser'); 
var bodyParser = require('body-parser'); 
var flash = require('express-flash'); 
var session = require('express-session'); 
var expressValidator = require('express-validator'); 
var methodOverride = require('method-override'); 

var connection = require('express-myconnection'); 
var mysql = require('mysql'); 

var routes = require('./routes/index'); 
var users = require('./routes/users'); 

var app = express(); 

// view engine setup 
app.set('views', path.join(__dirname, 'views')); 
app.set('view engine', 'jade'); 

// uncomment after placing your favicon in /public 
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico'))); 
app.use(logger('dev')); 
app.use(bodyParser.json()); 
app.use(bodyParser.urlencoded({ extended: false })); 
app.use(session({secret:"mysecretpass"})); 
app.use(flash()); 
app.use(expressValidator()); 
app.use(cookieParser()); 
app.use(require('less-middleware')(path.join(__dirname, 'public'))); 
app.use(express.static(path.join(__dirname, 'public'))); 

app.use('/', routes); 
app.use('/users', users); 

app.use(methodOverride(function(req, res){ 
if (req.body && typeof req.body === 'object' && '_method' in req.body) 
    { 
     var method = req.body._method; 
     delete req.body._method; 
     return method; 
    } 
    })); 

/*----------------------------------------- 
* Connection peer, register as middleware 
* type koneksi:single,pool and request 
-----------------------------------------*/ 
app.use(
    connection(mysql,{ 
     host:'localhost', 
     user:'root', 
     password:'', 
     port:3306, 
     database:'stores' 
    },'single') 
    ); 


// catch 404 and forward to error handler 
app.use(function(req, res, next) { 
    var err = new Error('Not Found'); 
    err.status = 404; 
    next(err); 
}); 

// error handlers 

// development error handler 
// will print stacktrace 
if (app.get('env') === 'development') { 
    app.use(function(err, req, res, next) { 
    res.status(err.status || 500); 
    res.render('error', { 
     message: err.message, 
     error: err 
    }); 
    }); 
} 

// production error handler 
// no stacktraces leaked to user 
app.use(function(err, req, res, next) { 
    res.status(err.status || 500); 
    res.render('error', { 
    message: err.message, 
    error: {} 
    }); 
}); 
module.exports = app; 

루트 /하는 index.js

var express = require('express'); 
var router = express.Router(); 

/* GET home page. */ 
router.get('/', function(req, res, next) { 
    res.render('dashboard', { title: 'Dashboard' }); 
}); 

router.get('/admin_users', function(req, res, next) { 
    req.getConnection(function(err,connection){ 
     var query = connection.query('SELECT * FROM users',function(err,rows) 
     { 
      if(err) 
       var errornya = ("Error Selecting : %s ",err); 
      req.flash('msg_error', errornya); 
      res.render('admin_users',{title:"Admin Users",data:rows}); 
     }); 
     //console.log(query.sql); 
    }); 
}); 

module.exports = router; 

Answer 1

당신은 당신의 routes 미들웨어 후 express-myconnection 미들웨어 를 추가를 app.js

다음과 같이

내 코드입니다. 미들웨어는 추가 된 순서대로 실행되므로 express-myconnection 미들웨어가 실행 된 후 req 개체에 getConnection 함수가 정의되어 있지 않습니다.

경로 사용법 위에 연결 미들웨어를 이동하기 만하면됩니다.

app.use(
    connection(mysql,{ 
     host:'localhost', 
     user:'root', 
     password:'', 
     port:3306, 
     database:'stores' 
    },'single') 
); 

app.use('/', routes); 
app.use('/users', users);