Как отправить несколько параметров из Angular HTTP Post в серверную часть Nodejs для использования в запросе OracleDB? - PullRequest
Новая
       15

Как отправить несколько параметров из Angular HTTP Post в серверную часть Nodejs для использования в запросе OracleDB?

0 голосов
/ 26 марта 2019

Мое сообщение успешно, и я получаю данные, возвращенные мне в Angular, но по какой-то причине я не могу передать переменную "id" со значением "11". У меня есть поиск по различным учебным пособиям, и мне кажется, что я правильно их настроил.

Я что-то упустил здесь? Я новичок, поэтому заранее прошу прощения, если это легко.

Угловой компонент страницы 

import { Component, OnInit } from '@angular/core';
import { Observable } from 'rxjs';
import { DBService, Group} from '../db.service';
import { HttpClient } from '@angular/common/http';
import { NgIf } from '@angular/common/src/directives/ng_if';
import { element } from 'protractor';
import { ActivatedRoute } from '@angular/router';
import { Router } from '@angular/router';


@Component({
  selector: 'app-flow',
  templateUrl: './flow.component.html',
  styleUrls: ['../css.css']
})
export class FlowComponent implements OnInit {

  groups: Group[];

  constructor(
    private auth: AuthenticationService,
    private dbService: DBService,
    private route: ActivatedRoute,
    private router: Router
  ) {}



  ngOnInit() {
   const id = 11;
    this.dbService.getGroup2(id).subscribe(groups => this.groups = groups);
  }

}

Сервисный код БД 

getGroup2(id): Observable<Group[]> {
 const url = 'http://localhost:4200/api/' + 'employees';
 const params = ({
id: id
 });
 return this._http.post(url, params)
 .pipe(
  map((res) => {
     console.log(res);
    return <Group[]> res;
  })
 );
 }

Backend

услуги / router.js 

const express = require('express');
const router = new express.Router();
const employees = require('../controllers/employees.js');

router.route('/employees/:id?')
  .post(employees.post);

module.exports = router;

услуги / database.js 

const oracledb = require('oracledb');
const dbConfig = require('../config/database.js');

async function initialize() {
  const pool = await oracledb.createPool(dbConfig.hrPool);
}

module.exports.initialize = initialize;

// close the function

async function close() {
    await oracledb.getPool().close();
  }
  
  module.exports.close = close;

// simple executre function

function simpleExecute(statement, binds = [], opts = {}) {
    return new Promise(async (resolve, reject) => {
      let conn;
  
      opts.outFormat = oracledb.OBJECT;
      opts.autoCommit = true;
  
      try {
        conn = await oracledb.getConnection();
  
        const result = await conn.execute(statement, binds, opts);
  
        resolve(result);
      } catch (err) {
        reject(err);
      } finally {
        if (conn) { // conn assignment worked, need to close
          try {
            await conn.close();
          } catch (err) {
            console.log(err);
          }
        }
      }
    });
  }
  
  module.exports.simpleExecute = simpleExecute;

Контроллеры / employees.js 

const employees = require('../db_apis/employees.js');

async function get(req, res, next) {
  try {
    const context = {};

  context.id = parseInt(req.params.id, 10);

    const rows = await employees.find(context);

    if (req.params.id) {
      if (rows.length === 1) {
        res.status(200).json(rows[0]);
      } else {
        res.status(404).end();
      }
    } else {
      res.status(200).json(rows);
    }
  } catch (err) {
    next(err);
  }
}

module.exports.get = get;

db_apis / employees.js 

const database = require('../services/database.js');

const baseQuery = 
 `SELECT * FROM DB.EMPLOYEES`;

async function find(context) {
  let query = baseQuery;
  const binds = {};

   if (context.id) {
   binds.employee_id = context.id;

    query += `\nwhere employee_id = :employee_id`;
  }

  const result = await database.simpleExecute(baseQuery);
  
  console.log(result.rows);
  return result.rows;

}

module.exports.find = find;

Примечание. Я просто пытаюсь заставить это работать для 1 переменной в моем коде выше для ID. В будущем мне нужно будет передать несколько переменных, таких как даты, числа и строки varchar.

Любая помощь будет принята с благодарностью.

1 Ответ

0 голосов
/ 26 марта 2019

Вместо использования: 

req.params.id

Попробуйте использовать: 

req.body['id']

req.params используется для получения параметров из маршрута

...