koa_使用数据库

梗概

• 因为koa是轻量的，没有复杂的架构，所以只需简单的使用数据库的第三方库即可（如ORM）

示例

const Koa = require('koa');
const Router = require('koa-router');
const mysql = require('mysql');
 
const app = new Koa();
const router = new Router();
 
// 创建数据库连接
const connection = mysql.createConnection({
  host: 'localhost',
  user: 'root',
  password: 'password',
  database: 'my_database'
});
 
// 连接数据库
connection.connect((err) => {
  if (err) {
    console.error('Error connecting to database: ' + err.stack);
    return;
  }
  console.log('Connected to database as ID ' + connection.threadId);
});
 
// 查询数据
router.get('/users', async (ctx) => {
  connection.query('SELECT * FROM users', (error, results, fields) => {
    if (error) throw error;
    ctx.body = results;
  });
});
 
app.use(router.routes()).use(router.allowedMethods());
 
app.listen(3000, () => {
  console.log('Server running on port 3000');
});

在这个示例中，我们使用了koa和koa-router来创建一个简单的服务器，并通过mysql模块连接到数据库。我们创建了一个GET路由来查询users表中的所有数据，并将结果返回给客户端。在实际应用中，您可以根据自己的需求进行进一步的开发和定制。