下面是我如何设置以下文件:index.js
const express = require('express')
const app = express()
const port = 8000
const expense_model = require('./expense_model')
app.use(express.json());
app.use(function (req, res, next) {
res.setHeader('Access-Control-Allow-Origin', 'http://localhost:8000');
res.setHeader('Access-Control-Allow-Methods', 'GET,POST,PUT,DELETE,OPTIONS');
res.setHeader('Access-Control-Allow-Headers', 'Content-Type, Access-Control-Allow-Headers');
next();
});
app.get('/', (req, res) => {
expense_model.getExpenses()
.then(expenses => {
res.status(200).json(expenses);
})
.catch(error => {
console.error('Failed to retrieve expenses:', error);
res.status(500).json({ error: 'Failed to retrieve expenses' });
});
});
app.post('/expenses', (req, res) => {
expense_model.createExpense(req.body)
.then(response => {
res.status(200).send(response);
})
.catch(error => {
res.status(500).send(error);
})
})
app.delete('/expenses/:id', (req, res) => {
expense_model.deleteExpense(req.params.id)
.then(response => {
res.status(200).send(response);
})
.catch(error => {
res.status(500).send(error);
})
})
app.listen(port, () => console.log(`Example app listening on port ${port}!`))
以及expense_model. js
const Pool = require('pg').Pool
const pool = new Pool({
user: 'my_user',
host: 'localhost',
database: 'my_database',
password: 'root',
port: 5432,
});
async function getExpenses(req, res) {
try {
const query = 'SELECT * FROM expenses';
const result = await pool.query(query);
const expenses = result.rows;
res.status(200).json(expenses);
console.log('Response:', res);
} catch (err) {
console.error('Failed to retrieve expenses:', err);
res.status(500).json({ error: 'Failed to retrieve expenses' });
}
}
async function createExpense(req, res) {
const { expense, amount, description, tag } = req.body;
const query = 'INSERT INTO expenses (expense, amount, description, tag) VALUES ($1, $2, $3, $4) RETURNING *';
const values = [expense, amount, description, tag];
try {
const result = await pool.query(query, values);
res.status(201).json(result.rows[0]);
} catch (err) {
console.error('Failed to create an expense:', err);
res.status(500).json({ error: 'Failed to create an expense' });
}
}
async function updateExpense(req, res) {
const id = parseInt(req.params.id);
const { expense, amount, description, tag } = req.body;
const query = 'UPDATE expenses SET expense = $1, amount = $2, description = $3, tag = $4 WHERE id = $5';
const values = [expense, amount, description, tag, id];
try {
const result = await pool.query(query, values);
if (result.rowCount === 0) {
res.status(404).json({ error: 'Expense not found' });
} else {
res.json({ message: 'Expense updated successfully' });
}
} catch (err) {
console.error('Failed to update an expense:', err);
res.status(500).json({ error: 'Failed to update an expense' });
}
}
async function deleteExpense(req, res) {
const id = parseInt(req.params.id);
const query = 'DELETE FROM expenses WHERE id = $1';
const values = [id];
try {
const result = await pool.query(query, values);
if (result.rowCount === 0) {
res.status(404).json({ error: 'Expense not found' });
} else {
res.json({ message: 'Expense deleted successfully' });
}
} catch (err) {
console.error('Failed to delete an expense:', err);
res.status(500).json({ error: 'Failed to delete an expense' });
}
}
module.exports = {
getExpenses,
createExpense,
deleteExpense,
updateExpense
}
我收到错误:无法检索费用:TypeError:Cannot read properties of undefined(阅读'json')at Object.getExpenses,on submit the form in frontend too,I'm getting axios error.问题可能出在Postgres的连接方式上。这是我第一次使用postreSQL,所以我对它不是很熟悉。
2条答案
按热度按时间ykejflvf1#
您应该从
getExpenses
返回result.rows
:而且,您还应该使用相同的逻辑重构
expense_model
中的所有其他函数。1cklez4t2#
好吧,我没有正确调用函数,它应该是这样的:
app.get('/', expense_model.getExpenses);
在我的原始代码中,我调用了一个没有传递参数的函数,而它需要同时调用res和req。