Node.js查询MySQL并返回结果集给客户端
// 引入必要的模块
const express = require('express');
const mysql = require('mysql');
// 配置MySQL连接
const connection = mysql.createConnection({
host : 'localhost',
user : 'your_username',
password : 'your_password',
database : 'your_database'
});
// 连接MySQL
connection.connect();
// 创建Express应用
const app = express();
const port = 3000;
// 定义路由处理查询请求
app.get('/api/items', (req, res) => {
// 执行SQL查询
connection.query('SELECT * FROM items', (error, results, fields) => {
if (error) throw error;
// 将查询结果返回给客户端
res.json(results);
});
});
// 监听3000端口
app.listen(port, () => {
console.log(`服务器运行在 http://localhost:${port}`);
});
这段代码首先引入了Express和MySQL模块,并创建了一个MySQL连接。然后,定义了一个Express应用和一个API路由,该路由处理对/api/items
的GET请求,并执行一个查询来获取所有的items。查询结果通过JSON的形式返回给客户端。最后,应用开始监听3000端口。
评论已关闭