使用 NodeJS/AngularJS 创建到 MySQL 的 RESTful API 桥

Question

我是 RESTful API 的新手，我的应用程序遇到了问题。我想设置 HTTP GET 方法来从 mysql 中检索数据，并且我认为文件 app.js 已经连接到数据库（但我不太清楚路由器是如何工作的）。我知道我需要创建一个路由器，但我只是不知道如何去做，比如发布和获取等，我不确定我错过了什么。请帮忙！感谢您的宝贵时间并做出回应！

================================================ =========================== 我想我没有描述我的问题，让我重新表述一下。

1. 现在我有一个模型

   @models/Users.js

2. 我有路由器文件

   @routers/index.js & user.js`

（都是express生成的默认文件）

1. 我还有一个半定型文件（我不确定）

   @app.js

我的目标是当在 url 中输入 /whatever 时，可以从 http 获得响应，例如 json 数据或数据库中的任何内容。我知道我的文件中有很多问题（也许所有问题都没有正确编写），我只是想获得帮助以使其正确，以便我了解结构。感谢您的帮助！

app.js：

var express = require('express');
var path = require('path');
var favicon = require('serve-favicon');
var logger = require('morgan');
var cookieParser = require('cookie-parser');
var bodyParser = require('body-parser');

var routes = require('./routes/index');
var users = require('./routes/users');

var app = express();

var mysql = require('mysql');
require('./models/Users');



// view engine setup
app.set('views', path.join(__dirname, 'views'));
app.set('view engine', 'ejs');

// uncomment after placing your favicon in /public
//app.use(favicon(path.join(__dirname, 'public', 'favicon.ico')));
app.use(logger('dev'));
app.use(bodyParser.json());
app.use(bodyParser.urlencoded({ extended: false }));
app.use(cookieParser());
app.use(express.static(path.join(__dirname, 'public')));

app.use('/', routes);
app.use('/users', users);

// catch 404 and forward to error handler
app.use(function(req, res, next) {
  var err = new Error('Not Found');
  err.status = 404;
  next(err);
});

// error handlers

// development error handler
// will print stacktrace
if (app.get('env') === 'development') {
  app.use(function(err, req, res, next) {
    res.status(err.status || 500);
    res.render('error', {
      message: err.message,
      error: err
    });
  });
}

// production error handler
// no stacktraces leaked to user
app.use(function(err, req, res, next) {
  res.status(err.status || 500);
  res.render('error', {
    message: err.message,
    error: {}
  });
});


module.exports = app;

/models/User.js

var mysql      = require('mysql');
var connection = mysql.createConnection({
    connectionLimit : 100,
    host     : 'localhost',
    user     : 'root',
    password : '',
    database : 'ajs02'
});

connection.connect();

connection.query('SELECT * from post', function(err, rows, fields) {
  if (!err)
    console.log('The solution is: ', rows);
  else
    console.log('Error while performing Query.');
});

connection.end();

/routers/index.js

var express = require('express');
var router = express.Router();

var mysql = require('mysql');


/* GET home page. */

router.get('/', function(req, res, next) {
  res.render('index', { title: 'Express' });
});

router.get('/match', function(req, res) {
    mysql.query('SELECT * FROM ' + req.params.table + ' ORDER BY id DESC LIMIT 20', req.params.id, function(err, rows, fields) {
        var user = new User(req.postId);


        res.send(user)
        connection.release();
    });
});
router.get('/hw', function(req, res) {
  res.send('hello world');
});

module.exports = router;

Answer 1

RESTful API 的工作原理与您的数据库已经支持的 CRUD（创建、读取、更新、删除）操作相同。您只需要将这些 SQL 操作转换为 GET、PUT、POST 和 DELETE 等 RESTful（HTTP 请求）动词。

考虑：

// a GET request = a database READ or (a.k.a SELECT)
app.get('/path', function(req, res) {
    connection.query('SELECT * FROM ' + req.params.table + ' ORDER BY id DESC LIMIT 20', req.params.id, function(err, rows, fields) {
        res.json('.. assume you translated your database response a javascript object .. ')
        connection.release();
    });
});

// a POST request = a database CREATE (a.k.a INSERT)
app.post('/path', function(req, res) {
    connection.query('INSERT INTO ' + req.params.table + ' SOME OTHER PARTS OF YOUR SQL QUERY', req.params.id, function(err, rows, fields) {
        res.json('.. assume you translated your database response a javascript object again .. ')
        connection.release();
    });
});

// a PUT request = a database UPDATE
app.put('/path', function(req, res) {
    connection.query('UPDATE ' + req.params.id + ' SOME OTHER PARTS OF YOUR SQL QUERY', req.params.id, function(err, rows, fields) {
        res.json('.. assume you translated your database response a javascript object yet again .. ')
        connection.release();
    });
});

// a DELETE request = a database DELETE
app.delete('/path', function(req, res) {
    connection.query('DELETE FROM ' + req.params.table + ' SOME OTHER PARTS OF YOUR SQL QUERY', req.params.id, function(err, rows, fields) {
        res.json('.. assume you translated your database response a javascript object once again .. ')
        connection.release();
    });
});

至于路由，以Express Routing Guide开头。在基本级别，定义的路由（例如/path）对应于请求URI：http://yourserver.com/path）。它还支持通配符、命名参数和正则表达式，例如：/path/:id、/path/* 和 /path/id_.*$。