db.getConnection 不是函数

Question

我正在尝试向我的第一个应用程序发出发帖请求，但每次我发帖时，都会出现以下错误：

TypeError: db.getConnection is not a function

我已经尝试了所有堆栈溢出建议，但在过去两天搞乱了代码后，我似乎仍然无法让它工作。我是初学者，所以请原谅我，但这就是我的代码的样子......

我的 db.js 看起来像这样......

var mysql = require('mysql');

var mainDb = mysql.createPool({
  host     : process.env.mysql_host,
  user     : process.env.mysql_user,
  password : process.env.mysql_pwd,
  database : process.env.mysql_db
});

exports.getConnection = function(callback) {
  mainDb.getConnection(function(err, connection) {
    if (err) {
      console.error('error connecting: ' + err.stack);
      return;
    }
      callback(err, connection);
  });
};

我的 register.js 代码看起来像这样......

var express = require('express');
var router = express.Router();
var db = require(__dirname, 'models/db');
var bodyParser = require('body-parser');

app.use(bodyParser.urlencoded({
   extended: false
}));

app.use(bodyParser.json());


router.get('/register', function(req, res, next) {
  res.render('register', { title: 'Register for a free account' });
});

router.post('/register', function(req, res) {
  var input = JSON.parse(JSON.stringify(req.body));
  var today = new Date();
  var users = {
    "username": req.body.username,
    "email":req.body.email,
    "password":req.body.password,
    "created":today,
    "modified":today
  };
  db.getConnection(function(err, connection) {
    connection.query('INSERT INTO users SET ? ', users, function(err, result) {
    connection.release();
    if (err) { return console.error(err); }
    });
  });
  res.redirect('/index');
});
module.exports = router;

我不知道我的 app.js 是否与这个问题相关，但它看起来像这样......

const express = require('express');
      http = require('http');
      path = require('path');
      session = require('express-session');
      app = express();
      mysql      = require('mysql');
      bodyParser = require('body-parser');
      db = require(__dirname, 'models/db')

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

app.use('/', index);
app.use('/', register);

var engine = require('ejs-mate');
app.engine('ejs', engine);
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');

app.use(bodyParser.json());
app.use(bodyParser.urlencoded({extended: false}));
app.use(express.static(path.join(__dirname, 'public')));


var server = http.createServer(app);

var port = 8995;
server.listen(port);

module.exports = app;

当我启动 app.js 时，我没有收到任何错误，只有当我从表单发出发布请求时，错误才会显示在我的浏览器中。请帮忙！

Answer 1

在 db.js 中，您仅导出一个函数。但在 register.js 中，您尝试像使用对象一样使用

db

。

要解决您的问题，在 db.js 中，只需导出一个对象，而不是函数：

function getConnection(callback) {
   mainDb.getConnection(function(err, connection) {
   if (err) {
       console.error('error connecting: ' + err.stack);
       return;
   }
   callback(err, connection);
}

module.exports = { getConnection };

Answer 2

您需要根据需要使用mysql2然后使用

mysql.createPool

。

简单代码：

const db = mysql.createPool({
    host: "localhost",
    user: "root",
    password: "password",
    database: "databaseName"
});

db.getConnection((err, con)=>{
    if (err) {
        console.log(`Could not connect to the database ${err}`)
    }else{
        console.log("Succesfully connected to the database")
    }
});

module.exports = db;

希望这段代码对你有帮助🌹

Answer 3

根据文档，您不需要使用 getConnection 方法，只需导出池。

https://github.com/mysqljs/mysql