在module.export函数中使用回调进行MySQL查询的方法如下:
npm install mysql express
const mysql = require('mysql');
const express = require('express');
const app = express();
const pool = mysql.createPool({
host: 'localhost',
user: 'your_username',
password: 'your_password',
database: 'your_database'
});
module.exports = {
query: function(sql, callback) {
pool.getConnection(function(err, connection) {
if (err) {
callback(err, null);
} else {
connection.query(sql, function(err, results) {
connection.release();
callback(err, results);
});
}
});
}
};
const db = require('./db'); // 假设查询函数定义在名为db.js的文件中
app.get('/users', function(req, res) {
const sql = 'SELECT * FROM users';
db.query(sql, function(err, results) {
if (err) {
res.status(500).send('Error retrieving users');
} else {
res.json(results);
}
});
});
app.listen(3000, function() {
console.log('Server is running on port 3000');
});
在上述代码中,我们首先创建了一个MySQL连接池,然后定义了一个查询函数,该函数接受SQL查询语句和回调函数作为参数。在查询函数中,我们从连接池中获取一个连接,执行查询,然后释放连接并调用回调函数返回结果或错误。
在Express应用程序中,我们使用该查询函数来处理GET请求,并在回调函数中处理查询结果或错误。如果查询成功,我们将结果作为JSON数据发送回客户端;如果查询失败,我们发送一个500错误响应。
请注意,上述代码仅为示例,实际应用中可能需要根据具体情况进行适当的修改和错误处理。
领取专属 10元无门槛券
手把手带您无忧上云