一つのNode.jsファイルで２つのフォームからPOSTしたい

Question

前提・実現したいこと

現在Node.jsを用いてMysqlと連携したフォームを作っています。
一つのjsファイルで二つのフォームを操作できるようにしたいと考えています。
ミドルウェアにはExpressを使用しています。

ファイルの構成は次の通りです

[sensor_management]
   index.js
   [views]
      index.pug
      list.pug
      register.html
      p-list.pug
      p-register.html
   [routes]
      index.js

list.pugとp-list.pugはmysqlに登録してある情報を表示します。
それぞれ同じDatabase[facility]のfacility_listとusersから引っ張ります。

register.htmlとp-register.htmlはそれぞれfacility_listとusersに情報を書き込みます。

現在で来ていること

list.pugとp-list.pugの情報の表示
register.html(facility_list)の情報の書き込み

発生している問題・エラーメッセージ

現在p-register.html側の情報を書き込む際になぜかregister.htmlで動作しているsql文が実行されているようで、情報が登録できません。
ページごとに分岐をさせたいのですが、いまいちやり方がわからず詰まってしまいました。

C:\node_modules\mysql\lib\protocol\Parser.js:437
      throw err; // Rethrow non-MySQL errors
      ^

Error: ER_BAD_FIELD_ERROR: Unknown column 'name' in 'field list'
    at Query.Sequence._packetToError (C:node_modules\mysql\lib\protocol\sequences\Sequence.js:47:14)
    at Query.ErrorPacket (C:node_modules\mysql\lib\protocol\sequences\Query.js:79:18)
    at Protocol._parsePacket (C:node_modules\mysql\lib\protocol\Protocol.js:291:23)
    at Parser._parsePacket (C:node_modules\mysql\lib\protocol\Parser.js:433:10)
    at Parser.write (C:node_modules\mysql\lib\protocol\Parser.js:43:10)
    at Protocol.write (C:node_modules\mysql\lib\protocol\Protocol.js:38:16)
    at Socket.<anonymous> (C:node_modules\mysql\lib\Connection.js:88:28)
    at Socket.<anonymous> (C:node_modules\mysql\lib\Connection.js:526:10)
    at Socket.emit (events.js:315:20)
    at addChunk (internal/streams/readable.js:309:12)
    --------------------
    at Protocol._enqueue (C:node_modules\mysql\lib\protocol\Protocol.js:144:48)
    at Connection.query (C:node_modules\mysql\lib\Connection.js:198:25)
    at C:sensor_management\index.js:69:13    
    at Layer.handle [as handle_request] (C:node_modules\express\lib\router\layer.js:95:5)
    at next (C:node_modules\express\lib\router\route.js:137:13)
    at Route.dispatch (C:node_modules\express\lib\router\route.js:112:3)
    at Layer.handle [as handle_request] (C:node_modules\express\lib\router\layer.js:95:5)
    at C:node_modules\express\lib\router\index.js:281:22
    at Function.process_params (C:node_modules\express\lib\router\index.js:335:12)
    at next (C:node_modules\express\lib\router\index.js:275:10) {
  code: 'ER_BAD_FIELD_ERROR',
  errno: 1054,
  sqlMessage: "Unknown column 'name' in 'field list'",
  sqlState: '42S22',
  index: 0,
  sql: "INSERT INTO facility_list SET `id` = '406E8B22', `name` = '太郎', `family_name` = '二郎', `related_name` = '三郎', `mail` = '[e-mail]', `address` = '市', `family_number` = '0000-00-0000', `related_number` = '9999-99-9999', `flag` = '0'"
}

該当のソースコード

const hostname = 'localhost';
const port = 8080;

const http = require('http');
const fs = require('fs');
const url = require('url');

const express = require('express');
const app = express();
const mysql = require('mysql');

const router = express.Router();

const connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: 'p/W',
    database: 'facility'
});

app.set('view engine', 'pug');
app.use(express.static('views'));

// localhost:8080にアクセスできたとき
const recordLog = function (req, res, next) {
    console.log('localhost:8080にアクセスしました');
    next();
};

app.use(recordLog);

// DBの中身を取得しに行く
// 施設一覧
app.get('/page/list', function (req, res) {
    var sql = 'select * from facility.facility_list';
    connection.query(sql, (err, rows, fields) => {
        if (err) throw err;
        res.render('list', {
            title: 'Facility List',
            f_data: rows
        });
    });
});

// 利用者一覧
app.get('/page/p-list', function (req, res) {
    var sql = 'select * from facility.users';
    connection.query(sql, (err, rows, fields) => {
        if (err) throw err;
        res.render('p-list', {
            title: 'Users List',
            f_data: rows
        });
    });
});

// DBに情報を登録する
const path = require('path');
const bodyParser = require('body-parser');

// 施設登録
app.get('/page/register.html', (req, res) => res.sendFile(path.join(__dirname, '/register.html')));
app.use(bodyParser.urlencoded({ extended: true }));

app.post('/', (req, res) => {
	var sql = "INSERT INTO facility_list SET ?";

	connection.query(sql,req.body,function(err, result, fields){
		if (err) throw err;
        console.log(result);
        res.redirect("/page/list");
        //登録が完了したら一覧ページに飛ぶ

	});
});

// 利用者登録
app.get('/page/p-register.html', (req, res) => res.sendFile(path.join(__dirname, '/p-register.html')));
app.use(bodyParser.urlencoded({ extended: true }));

app.post('/', (req, res) => {
	var sql = "INSERT INTO users SET ?";

	connection.query(sql,req.body,function(err, result, fields){
		if (err) throw err;
        console.log(result);
        res.redirect("/page/p-list");
        //登録が完了したら一覧ページに飛ぶ

	});
});

//ルーティング
var index = require('./routes/index');
//var page = require('./routes/page');

// ルーティングの設定(./routes/index.jsなどに飛ばす)
app.use('/', index);
//app.use('/page', page);

// 上のルーティングに当てはまらなかった場合、404を設定
app.use(function(req, res, next) {
  var err = new Error('Not Found');
  err.status = 404;
  next(err);
});

app.listen(8080);

試したこと

アロー関数を通常のfunctionなどにしてみましたがNot found 404になったりしてよくわからなかったです。

伝わりにくいかと思いますが、どなたか救いの手を差し伸べていただけると助かります。

Comments

[退会済みユーザー]

app.post('/', (req, res) が2つあるからじゃない？

[Kumampet]

ご指摘ありがとうございます

/register.htmlからPostしたときはvar sql = "INSERT INTO facility_list SET ?";を発火させ、/p-register.htmlからPostしたときはvar sql = "INSERT INTO users SET ?";を発火させたいのですが、app.post('/',(req, res))を一つにする方法がよくわかりません。

Answer 1

強引だけどフォームのURLで処理を分けた

①ページのURLをgetで取得し、グローバル変数に格納しておく

var fulUrl; // Global

//--略
// デバイス登録ページか利用者登録ページか取得する
app.get('/page/p-register.html', (req, res) => {
    fullUrl = req.protocol + '://' + req.get('Host') + req.originalUrl;
    res.sendFile(__dirname + '/views/p-register.html');
    console.log(fullUrl);
});
app.get('/page/register.html', (req, res) => {
    fullUrl = req.protocol + '://' + req.get('Host') + req.originalUrl;
    res.sendFile(__dirname + '/views/register.html');
    console.log(fullUrl);
});

②取得したURLに応じて書き込み先を変更し、DBのクエリを書き換える

app.use(bodyParser.urlencoded({ extended: true }));
app.post('/', (req, res) => {
    if (fullUrl == "http://localhost:8080/page/p-register.html") {

        const sql = "INSERT INTO users SET ?";

        connection.query(sql, req.body, function (err, result, fields) {
            if (err) throw err;
            console.log(result);
            res.redirect("/page/p-list");
            //登録が完了したら一覧ページに飛ぶ
        });
    } else if (fullUrl == "http://localhost:8080/page/register.html") {

        const sql = "INSERT INTO devices SET ?";

        connection.query(sql, req.body, function (err, result, fields) {
            if (err) throw err;
            console.log(result);
            res.redirect("/page/list");
            //登録が完了したら一覧ページに飛ぶ
        });
    }
});

Comments

[Kumampet]

もっといい方法があったら、教えてください・・・