从 Angular2 组件将 Json 传递给 Node.js

Question

我正在尝试从 Angular2 和 Node.js 将数据插入数据库

当我运行我的脚本时，我console.log(this.address); 以确保我传递了json，这是控制台的输出。

Address {street: "1111 NW 40TH AVE", city: "MIAMI", state: "Florida", zip: "33167"}

但是记录没有进入数据库。我知道我有联系，但我在这里遗漏了一些东西，不知道如何从这里进行故障排除。

在组件中这是http.post

 addressSubmit() { 
      this.addressSubmitted = true; 
      var headers = new Headers();
      headers.append('Content-Type', 'application/json');
      this.http
      .post('http://localhost:4200/profile/addAddress', this.address, { headers: headers })
      .map(response => response.json());
      console.log(this.address);
  }

所以有了这个函数，我知道我有一个似乎正在传递 json 的函数。

然后在带有节点的后端我收到这样的json，

addAddress: function(req, res) {
        pool.connect(function(err, client, done) {
            if (err) {
                return console.error('error fetching client from pool', err);
            } // end of error catch while creating pool connection

            var query = client.query("insert into address (street, city, state, zip) " +
            "values ('" + req.query.street + "','" + req.query.city + "','" +
            req.query.state + "','" + req.query.zip + "')"); // create the query

            query.on("end", function(result) {
                client.end();
                res.write('Success');
                res.end();
            }); // handle the query
            done(); // release the client back to the pool
        }); // end of pool connection
        pool.on('error', function(err, client) { 
                console.error('idle client error', err.message, err.stack) 
            }); // handle any error with the pool
    } // End addAddress function

像这样处理路线，

router.get('/profile/addAddress', connection.addAddress);

在 app.js 中

app.get('/profile/addAddress', function(req,res){
    db.addAddress(req,res);
});

所以在这一点上。我知道我正在传递 json。我知道我与数据库有连接。我可以通过手动输入条目并转到express route 来检索条目并将它们输出到浏览器。

我只是缺少从angular2 到node 来回传递数据。然后从node回到angular2。

现在在 echonax 答案的帮助下，我在“网络”选项卡下的查询字符串中有这个，

查询字符串参数

street:11700 NW 36TH AVE
city:MIAMI
state:Florida
zip:33167

Answer 1

我认为您没有向后端发出请求。

你的

this.http
      .post('http://localhost:4200/profile/addAddress', this.address, { headers: headers })
      .map(response => response.json());

line 返回一个 Observable，这个 observable 只有在订阅时才会被调用。

所以让你的 addressSubmit() 像这样返回这个 observable：

 addressSubmit() { 
      this.addressSubmitted = true; 
      var headers = new Headers();
      headers.append('Content-Type', 'application/json');
      return this.http
      .post('http://localhost:4200/profile/addAddress', this.address, { headers: headers })
      .map(response => response.json());
  }

然后在你的代码中这样称呼它：

this.addressSubmit().subscribe((response)=>{
    //do something with the response here
    console.log(response);
})