我是 NodeJS 的新手，我在尝试将某些数据保存/保存在数据库中时遇到问题。

让我们从头开始，这样您会更容易理解。我有一个运动列表，可以选择选中或不选中，这就是我需要坚持的，选中的。

前端:

controller.js

$scope.toggleSportSelection = function(sport) {
  var params = {};
  params.user = $scope.customer.customer;
  sport.checked = !sport.checked;
  SportsFactory.setSportChecked(params);
};

service.js

  setSportChecked: function(params) {
    var defer = $q.defer();
    $http.post(CONSTANT_VARS.BACKEND_URL + '/sports/checked', params)
    .success(function(sportChecked) {
        LocalForageFactory.remove(CONSTANT_VARS.LOCALFORAGE_SPORTS_CHECKED, params);
        defer.resolve(sportChecked);
      })
      .error(function(err) {
        console.log(err);
        defer.reject(err);
      });
    return defer.promise;
  }

我一直在调试这个前端部分，一切似乎都正常......

现在后端:

setSportCtrl.js

module.exports = {

  setCheck: function(req, res) {
    var checkedSportParams = req.body;

    SportSelectionService.sportChecked(checkedSportParams).then(function() {
      res.json(200, {msg: 'OK'});
    }, function(err) {
      res.json(400, err);
    });
  }
}

SportSelection.js(模型)

module.exports = {
  connection: 'RedisServer',
  attributes: {
    sport: {
      type: 'array',
      required: false
    },

    user: {
      type: 'string',
      required: true
    }
  }
};

在这部分我可以看到 console 是如何在终端打印的，但是如果我做 console.log(sportChecked) 或 console.log( newSport) 我得到的只是一个数组，其中到处都是 null...

SportSelectionService.js

module.exports = {

  sportChecked: function(params) {
    var Promise = require('bluebird');
    return new Promise(function(fullfill, reject) {
      console.time('sportChecked_findOne');
      SportSelection.findOne({
        user: params.user
      }).exec(function(err, sportChecked) {
        console.timeEnd('sportChecked_findOne');
        var newSport;
        if (err) {
          reject(new Error('Error finding user'));
          console.error(err);
        }else if (sportChecked) {
          newSport =  sportChecked.sport;
          console.time('sportChecked_update');
          SportSelection.update({
            user: params.user
          },
          {
            sport: newSport
          }).exec(function(err, sportCheckedUpdated) {
            console.timeEnd('sportChecked_update');
            if (err) {
              reject(new Error('Error on sportChecked'));
            }else {
              fullfill(sportCheckedUpdated);
            }
          });
          if (sportChecked.sport) {
            sportChecked.sport.push(params.sport);
            console.log('New sport added');
          }else {
            sportChecked.sport = [params.sport];
          }
        }else {
          console.time('sportChecked_create');
          SportSelection.create({
            sport: [params.sport],
            user: params.user
          }).exec(function(err, created) {
              console.timeEnd('sportChecked_create');
              if (err) {
                reject(new Error('Error on sportChecked'));
              }else {
                fullfill(created);
              }
            });
        }
      });
    });
  }

那么你认为我的问题是什么？我做错了什么？

最佳答案

这是我做的方法，我会从头到尾教你怎么做

从 Node.js 部分开始，我使用的是 Sails.js 和 lodash

SetSportsController.js

'use strict';

module.exports = {

  setCheck: function(req, res) {
    var checkedSportParams = req.body;
    SportSelectionService.sportChecked(checkedSportParams).then(function() {
      res.json(200, {msg: 'OK'});
    }, function(err) {
      res.json(400, err);
    });
  },

  retrieveSetCheck: function(req, res) {
    if (req.params) {
      SportSelectionService.getSportChecked(req.params).then(function(sportChecked) {
        res.json(200, sportChecked);
      }, function(err) {
        res.json(400, err);
      });
    }else {
      res.json(400, {error: 'Error retrieving Sports'});
    }
  }
};

比起我们使用 SportSelectionService.js

'use strict';

var _ = require('lodash');

module.exports = {

  sportChecked: function(params) {
    var Promise = require('bluebird');
    return new Promise(function(fullfill, reject) {
      SportSelection.findOne({
        user: params.user
      }).exec(function(err, sportChecked) {//this array comes with duplicates
        var newSport,
            sportCheckedUniq = _.uniq(sportChecked.sport);//prevents duplicates
        if (err) {
          reject(new Error('Error finding user'));
          console.error(err);
        }else if (sportChecked) {
          newSport = sportCheckedUniq || [];
          if (_.includes(sportCheckedUniq, params.sport)) {
            sportCheckedUniq = _.pull(newSport, params.sport);
            sportCheckedUniq = _.difference(newSport, params.sport);
          }else {
            newSport.push(params.sport);
            sportCheckedUniq = newSport;
          }
          SportSelection.update({
            user: params.user
          },
          {
            sport: newSport
          }).exec(function(err, sportCheckedUpdated) {
            if (err) {
              reject(new Error('Error on sportChecked'));
            }else {
              fullfill(sportCheckedUpdated);
            }
          });
          if (sportCheckedUniq) {
            sportCheckedUniq.push(params.sport);
          }else {
            sportCheckedUniq = [params.sport];
          }
        }else {
          SportSelection.create({
            sport: [params.sport],
            user: params.user
          }).exec(function(err, created) {
              if (err) {
                reject(new Error('Error on sportChecked'));
              }else {
                fullfill(created);
              }
            });
        }
      });
    });
  },

  getSportChecked: function(params) {
    var Promise = require('bluebird');
    return new Promise(function(fullfill, reject) {
      console.time('sportChecked_findOne');
      SportSelection.findOne({
        user: params.user
      }).exec(function(err, sportChecked) {
        console.timeEnd('sportChecked_findOne');
        if (err) {
          reject(new Error('Error finding sportChecked'));
          console.error(err);
        }else {
          if (sportChecked) {
            fullfill(sportChecked);
          }else {
            SportSelection.create({
              // 10 is the ID for soccer, which must unchecked by default on every single user.
              sport: [10],
              user: params.user
            }).exec(function(err, created) {
              console.log(err);
              console.log(created);
              if (err) {
                reject(new Error('Error on sportChecked'));
              }else {
                fullfill(created);
              }
            });
          }
        }
      });
    });
  }
};

如你所见，我们只有两种方法，第一种

sportChecked() 是在用户选中或取消选中任何项目时触发的函数。

然后我们有 getSportChecked()，这是每次用户再次登录时调用的方法。

我没有任何删除方法，因为我们没有删除任何东西，我们只是在观察语句的变化。

我也在使用 Redis 服务器

不要忘记创建模型，我给它们起了个名字 SportSelection.js

'use strict';

module.exports = {
  connection: 'RedisServer',
  attributes: {
    sport: {
      type: 'array',
      required: false
    },

    user: {
      type: 'string',
      required: true
    }
  }
};

此外，在配置文件夹中我们有 policies.js，我无法告诉您如何使用它，因为这是您的配置，但我的是:

  SetSportsController: {
    setCheck: ['jwtAuth', 'sanitizerPolicy', 'headersPolicy'],
    retrieveSetCheck: ['jwtAuth', 'sanitizerPolicy']
  },...

然后，我们转到前端部分(记住:AngularJS)

我有一个 Controller ，controller.js

$scope.toggleSportSelection = function(sport) {
  SportsFactory.setSportChecked({
    user: $scope.customer.customer,
    sport: sport.id
  }).then(function() {
    sport.checked = !sport.checked;
    $ionicScrollDelegate.resize();
  }, function() {
    $ionicScrollDelegate.resize();
  });
};

正在按照这个模板工作

  <ion-item ng-repeat="sport in sportsFilter track by $index"
            ng-click="toggleSportSelection(sport)">
    {{:: sport.name}}
  </ion-item>

然后，service.js

注意 AngularJS

这里是我发布帖子的地方，你看

  .factory('SportsFactory', function($http, $q, AuthFactory, LocalForageFactory,
                                     LeaguesFactory, ImageFactory, CONSTANT_VARS) {

  getSports: function(customer) {
    var defer = $q.defer(),
    _this = this;

    LocalForageFactory.retrieve(CONSTANT_VARS.LOCALFORAGE_SPORTS)
      .then(function(sports) {
        if (!_.isNull(sports)) {
          defer.resolve(sports);
        }else {
          $http.get(CONSTANT_VARS.BACKEND_URL + '/lines/sports/' + customer.agent)
            .success(function(sports) {
              sports = _.sortBy(sports, function(sport) {
                return sport.priority;
              });
              _this.getSportChecked(customer).then(function(sportChecked) {
                var sportIds = _.pluck(sports, 'id'),
                    intersectedSports = _.intersection(sportIds, sportChecked.sport);
                if (sports.length) {
                  sports = _.map(sports, function(sport) {
                    sport.checked = !_.includes(intersectedSports, sport.id);
                    return sport;
                  });
                }else {
                  AuthFactory.logout();
                }
              });
              _.each(sports, function(sport) {
                var sportImg = ImageFactory.sportImages(sport);
                if (sportImg.length) {
                  sport.img = sportImg[0];
                }else {
                  sport.img = 'https://placehold.it/40x40';
                }
              });
              defer.resolve(sports);
            })
          .error(function(err) {
            defer.reject(err);
          });
        }
      });
    return defer.promise;
  },

  setSportChecked: function(params) {
    var defer = $q.defer();
    $http.post(CONSTANT_VARS.BACKEND_URL + '/sports/checked', params)
    .success(function(sportChecked) {
        LocalForageFactory.remove(CONSTANT_VARS.LOCALFORAGE_SPORTS_CHECKED, params);
        defer.resolve(sportChecked);
      })
      .error(function(err) {
        console.log(err);
        defer.reject(err);
      });
    return defer.promise;
  },

  getSportChecked: function(customer) {
    var defer = $q.defer(),
        user,
        rejection = function(err) {
          defer.reject(err);
        };

    LocalForageFactory.retrieve(CONSTANT_VARS.LOCALFORAGE_SPORTS_CHECKED)
      .then(function(sportChecked) {
        user = customer.customer;
        if (!_.isNull(sportChecked)) {
          defer.resolve(sportChecked);
        }else {
          $http.get(CONSTANT_VARS.BACKEND_URL + '/sports/getChecked/' + user)
          .success(function(sportChecked) {
            LocalForageFactory.set(CONSTANT_VARS.LOCALFORAGE_SPORTS_CHECKED, sportChecked);
            defer.resolve(sportChecked);
          })
          .error(rejection);
        }
      }, rejection);
    return defer.promise;
  }
});

首先，将注意力集中在 setSportChecked() 和 getSportChecked() 上，这是该服务的神奇之处，然后是函数 getSports() 调用如下所示的 getSportChecked()

          _this.getSportChecked(customer).then(function(sportChecked) {
            var sportIds = _.pluck(sports, 'id'),
                intersectedSports = _.intersection(sportIds, sportChecked.sport);
            if (sports.length) {
              sports = _.map(sports, function(sport) {
                sport.checked = !_.includes(intersectedSports, sport.id);
                return sport;
              });
            }else {
              AuthFactory.logout();
            }
          });

所以，如果这个长项目，这是最终版本，你必须接触大量文件才能完成这个，将数据保存/保存在数据库中，所以，请看这段代码，因为这是我到目前为止的方式并且工作得很好而且速度很快，我还没有错误，从这里离开，问你需要知道的问题，我会在白天回答。希望这有帮助

关于javascript - 将数据保存在数据库问题中，在控制台上收到 NULL，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/28904730/