POST 上的 SQLalchemy 检查记录是否已存在并发回现有记录

Sqlalchemy on POST check if record already exists and send back the existing record

我有几个端点遇到了相同类型的问题。检查记录是否已经存在。在这个特定的实例中,我正在验证是否已经将 url 具有相同值的记录添加到数据库中。

端点

api.add_resource(EventEntries, '/events/<int:event_id>/entries')

加载器

class Entry (Resource):
    #RETURNS A SINGLE EVENT
    def get(self, entry_id):
        schema = EntrySchema()
        result = db.session.query(EntryModel).filter(EntryModel.id == entry_id)
        return schema.dump(result, many=True), 200

    #PUTS A SINGLE EVENT
    def put(self, entry_id):
        event_id = event_id
        title = request.json['title']
        description = request.json['description']
        type = request.json['type']
        domain = request.json['domain']
        language = request.json['language']
        publishdate = request.json['publishdate']
        url = request.json['url']

        entry = EntryModel(event_id=event_id,title=title,description=description,type=type,domain=domain,language=language,publishdate=publishdate,url=url)

        db.session.add(event)
        db.session.commit()

        data = ({'id' :entry.id,
                        'title': entry.title,
                        'description': entry.description,
                        'type': entry.type,
                        'domain': entry.domain,
                        'language': entry.language,
                        'publishdate': entry.publishdate,
                        'url': entry.url})

        response = jsonify(data)
        response.status_code = 200 # or 400 or whatever
        return response

修改

我修改了上面的文件以包含以下行,这些行检查记录是否存在并尝试 return 该记录。这会导致即使条目不存在也会发回空数组。

    # If record already exists
    schema = EntrySchema()
    result = db.session.query(EntryModel).filter(EntryModel.url == request.json['url'])
    print(result)
    print(request.json['url'])

    if  result is not None:
        print("Record Already exists")
        return schema.dump(result, many=True), 200

    else:

已修复:

我添加了这个而不是上面的建议。

    # If record already exists
    schema = EntrySchema()
    result = db.session.query(EntryModel).filter(EntryModel.url == request.json['url']).first()
    print(result)

    if not result is None:
        print("Record Already exists")
        return schema.dump(result, many=False), 200