Как получить конкретные данные из MySQL в REST API NodeJs

Question

Вот моя база данных:

Вот мой код

//Read by jenis_kelamin
router.get('/:table/jk/:jenis_kelamin', function(req, res) {
	sequelize.query("SHOW KEYS FROM `"+TABLE_PREFIX+req.params.table+"` WHERE Key_name = 'PRIMARY'", { type: sequelize.QueryTypes.SELECT})
	.then(function(keys) {
		var jenis_kelamin =req.params.jenis_kelamin;
		sequelize.query("SELECT * FROM `"+TABLE_PREFIX+req.params.table+"` WHERE jenis_kelamin = `"+jenis_kelamin+"` ", { type: sequelize.QueryTypes.SELECT})
		.then(function(rows) {
			if(!rows.length) {
				res.status(404);
				res.json({
					"success" : 0,
					"data" : "No rows found"
				});
			}
			res.status(200);
			res.json({
				"success" : 1,
				"data" : rows
			});
		})
		.catch( function(err) {
			res.status(404);
			res.send({
				"success" : 0,
				"message" : err.message
			});
		});
	})
	.catch( function(err) {
		res.status(404);
		res.send({
			"success" : 0,
			"message" : err.message
		});
	});
});

Я хочу получить поля в таблице 'siswa', где 'jenis_kelamin' = 'starfish'. Используйте код выше, но я получаю эту ошибку:

{
    "success": 0,
    "message": "ER_BAD_FIELD_ERROR: Unknown column 'starfish' in 'where clause'"
}

Кто-нибудь может мне помочь?

Answer 1

ПОПРОБУЙТЕ

//Read by jenis_kelamin
router.get('/:table/jk/:jenis_kelamin', function(req, res) {
    sequelize.query("SHOW KEYS FROM '"+TABLE_PREFIX+req.params.table+"' WHERE Key_name = 'PRIMARY'", { type: sequelize.QueryTypes.SELECT})
    .then(function(keys) {
        var jenis_kelamin =req.params.jenis_kelamin;
        sequelize.query("SELECT * FROM '"+TABLE_PREFIX+req.params.table+"' WHERE jenis_kelamin = '"+jenis_kelamin+"' ", { type: sequelize.QueryTypes.SELECT})
        .then(function(rows) {
            if(!rows.length) {
                res.status(404);
                res.json({
                    "success" : 0,
                    "data" : "No rows found"
                });
            }
            res.status(200);
            res.json({
                "success" : 1,
                "data" : rows
            });
        })
        .catch( function(err) {
            res.status(404);
            res.send({
                "success" : 0,
                "message" : err.message
            });
        });
    })
    .catch( function(err) {
        res.status(404);
        res.send({
            "success" : 0,
            "message" : err.message
        });
    });
});

ЭТО тоже должно работать

//Read by jenis_kelamin
router.get('/:table/jk/:jenis_kelamin', function(req, res) {
    sequelize.query("SHOW KEYS FROM '"+TABLE_PREFIX+req.params.table+"' WHERE Key_name = 'PRIMARY'", { type: sequelize.QueryTypes.SELECT})
    .then(function(keys) {
        var jenis_kelamin =req.params.jenis_kelamin;
        return sequelize.query("SELECT * FROM '"+TABLE_PREFIX+req.params.table+"' WHERE jenis_kelamin = '"+jenis_kelamin+"' ", { type: sequelize.QueryTypes.SELECT})
    })
    .then(function(rows) {
        if(!rows.length) {
            res.status(404);
            res.json({
                "success" : 0,
                "data" : "No rows found"
            });
        }
        res.status(200);
        res.json({
            "success" : 1,
            "data" : rows
        });
    })
    .catch( function(err) {
        res.status(404);
        res.send({
            "success" : 0,
            "message" : err.message
        });
    });
});

И наконец

router.get('/:table/jk/:jenis_kelamin', function(req, res) {

    const myTableName = sanitizeTableName(req.params.table) 
    const myFieldValue = santizeValue(req.params.jenis_kelamin)

    sequelize.query("SHOW KEYS FROM '"+ TABLE_PREFIX + myTableName +"' WHERE Key_name = 'PRIMARY'", { type: sequelize.QueryTypes.SELECT})
    .then(function(keys) {
        var jenis_kelamin =req.params.jenis_kelamin;
        return sequelize.query("SELECT * FROM '"+TABLE_PREFIX+myTableName+"' WHERE jenis_kelamin = '"+myFieldValue+"' ", { type: sequelize.QueryTypes.SELECT})
    })
    .then(function(rows) {
        if(!rows.length) {
            res.status(404);
            res.json({
                "success" : 0,
                "data" : "No rows found"
            });
        }
        res.status(200);
        res.json({
            "success" : 1,
            "data" : rows
        });
    })
    .catch( function(err) {
        res.status(404);
        res.send({
            "success" : 0,
            "message" : err.message
        });
    });
});

где функции sanitize следят за тем, чтобы входные данные из запроса не подвергали вас инъекционным атакам или другим неприятным неожиданностям.