【问题标题】:How do I pass mysql database content to a different page?如何将 mysql 数据库内容传递到不同的页面?
【发布时间】:2018-12-28 06:11:21
【问题描述】:

我正在尝试将我的数据库内容显示到 ejs 网页。但是,在尝试在页面之间传递内容时遇到了问题。

我有一个 JavaScript 页面 "store.js" 正在运行服务器:

store.js-

var express = require('express');
var dbcon = require('./app/db/databaseconnection');
//var path = require('path');
//dbcon.connection;

var app = express();
var router = express.Router();

dbcon.connect();
console.log(dbcon.getproducts());

//var filepath = path.join(__dirname, '../../views/')
var filepath = __dirname + '/views/';
app.set('view engine', 'ejs');
app.use(express.static(__dirname + '/public'));
app.use('/', router);

router.get('/', (request, response) => response.render(filepath + 'index', { page_name: 'home' }));
router.get('/store', (request, response) => response.render(filepath + 'store', { page_name: 'store' }));
router.get('/about', (request, response) => response.render(filepath + 'about', { page_name: 'about' }));
router.get('/contact', (request, response) => response.render(filepath + 'contact', { page_name: 'contact' }));
router.get('/build', (request, response) => response.render(filepath + 'build/build'));
router.get('/learn', (request, response) => response.render(filepath + 'learn/learn'));
app.use('*', (request, response) => response.render(filepath + '404', { page_name: '404' }));
app.listen(3000, () => console.log("Server running at Port 3000"));

然后我有一个包含数据库连接的 JavaScript 页面:

databaseconnection.js-

var mysql = require('mysql');
var connection = mysql.createConnection(conObject = {
    host: "localhost",
    user: "root",
    password: "LOTOS123l",
    database: "dbComputerStore"
});


module.exports = {
    connect: () => 
    { 
        connection.connect((error) => {
            if (error) throw error;
            console.log(conObject.database + " connected!");
        });
    },
    // The display method prints the returned result to the console.
    // Change this to return the result. Maybe a toString() ?
    getproducts: () => {
        /*var result = */connection.query('SELECT * FROM products', (error, result) => { 
            return result;
            //return result;
            // console.log(result);
            // How to get certain properties
            // console.log(result[0].brand);
            // console.log(result[0].series);
            // console.log(result[0].model);
        });
        //return result.result;
    },
    createdb: () => {

    },
    createtable: () => {

    },
    populatetable: () => {

    }
}

所以在store.js 页面上,我有console.log(dbcon.getproducts());,我希望它会显示"products" 表的数据库内容。但是我一直不确定。基本上,我无法将它从数据库连接页面传递到 store.js 页面。

如果我让它工作,我的下一步是找到一种方法将产品表显示到 ejs 页面。我一直在尝试解决这个问题一段时间,所以任何帮助将不胜感激!谢谢!

【问题讨论】:

  • connection.query 是一个异步函数,你要么需要通过回调(由调用者提供)将结果传递给调用者,要么修改getproducts 以返回一个Promise 并等待promise 解决在 store.js 中,然后显示输出
  • 你会推荐哪种方式?
  • 两种方法都可以正常工作。另请注意,连接到数据库是异步操作。在查询数据库之前,您必须等待(使用回调或 Promise)连接准备好。我建议你创建一个连接池,每次你想查询数据库时(即在 getproducts 方法中),从池中获取一个连接,使用该连接查询数据库并返回结果(通过调用回调或解析一个承诺)

标签: mysql node.js express ejs


【解决方案1】:

按照我的 cmets,以下是如何修改 databaseconnection.js 模块以使用 connection pool 并通过 Promises 返回查询结果:

注意:代码大部分未经测试

const mysql = require("mysql");

const pool = mysql.createPool({
  connectionLimit: 10, // adjust this according to your needs
  host: "localhost",
  user: "root",
  password: "LOTOS123l",
  database: "dbComputerStore"
});

module.exports = {
  // you don't need the connect method anymore

  getProducts: () => new Promise((resolve, reject) => {
    pool.query("SELECT * FROM products", (error, results, fields) => {
      if (error) {
        reject(error);
      } else {
        resolve(results);
      }
    });
  }),
  // ...
};

然后在 store.js 中,你可以这样做:

const dbcon = require('./app/db/databaseconnection');

dbcon.getProducts()
  .then(results => {
    console.log(results);
  })
  .catch(err => {
    console.error(err);
  });

// or you could use async/await syntax:

const asyncFn = async () => {
  try {
    const results = await dbcon.getProducts();
    console.log(results);
  } catch (ex) {
    console.error(err);
  }
};
asyncFn();

【讨论】:

  • 我收到了弃用警告: timers.enroll() 已弃用。请改用 setTimeout。
  • mysql module repository on GitHub 中搜索完全相同的警告字符串会将您带到this (currently resolved) issue。所以基本上你需要将mysql模块升级到最新版本(2.16.0截至目前)。
  • 好的,谢谢,最后一件事,结果显示为 Array(1) [RowDataPacket],如何获取 Array 中的内容?
  • 没关系,我让它工作了,我只是使用了一个 for 循环,它显示了所有的内容。非常感谢!
猜你喜欢
  • 2015-03-16
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
  • 1970-01-01
相关资源
最近更新 更多