flask+mongodb追加削除を実現
3481 ワード
flask+mongodb追加削除を実現
manage.py import json
from flask import Flask, request
from flask_cors import CORS
#flask_cor
from flask_script import Manager
from app import app
from models import User
manager = Manager(app)
CORS(app, supports_credentials=True)
@app.route('/test', methods=['GET', 'POST'])
@manager.command
def save():
datas = request.get_data()
print(datas)
user = User('diaodiao',datas)
user.save()
return datas
@app.route('/getdata', methods=['GET', 'POST'])
@manager.command
def query_users():
users = User.query_users()
# str(users['ObjectId'])
list = []
for user in users:
# print(user)
# user.get('_id').tostring
# str(user['_id'])
# str(user)
del user['_id']
print(user)
list.append(user)
# json.dumps(user)
print(list)
jsondata = json.dumps(list)
# print(user)
# return user
# print(jsondata)
return jsondata
# return user
@app.route('/delete', methods=['GET', 'POST'])
@manager.command
def delete():
datas = request.get_data()
print(datas)
print("------")
# print(datas['name'])
name = "DiaoDiao"
users = User.delete(name)
if name:
# return "Remove " + datas.name["name"] + " Ok!"
return "Remove " + ["name"] + " Ok!"
else:
return " , !"
@app.route('/update', methods=['GET', 'POST'])
@manager.command
def update():
datas = request.get_data()
print(datas)
print("------")
# print(datas['name'])
name = "DiaoDiao"
email = "[email protected]"
users = User.update(name,email)
if name:
return "update " + name + " Ok!"
else:
return " , !"
if __name__=='__main__':
# app.run()
manager.run(debug=True)
manage.py import pymongo def get_coll():
client = pymongo.MongoClient('localhost', 27017)
db = client.jikexueyuan
user = db.user_collection
return user
class User(object):
def __init__(self, name, datas):
self.name = name
self.datas = datas
def save(self):
user = {"name": self.name, "email": self.datas}
coll = get_coll()
id = coll.insert(user)
print(id)
@staticmethod
def query_users():
users = get_coll().find()
return users
@staticmethod
def delete(name):
users = get_coll().find({"name": name})
print(name)
print(users)
coll = get_coll()
coll.remove({"name": name})
# userusername = users.find_one({"name": name})
# users.remove(userusername)
# users.delete(name)
return name
@staticmethod
def update(name,email):
users = get_coll().find({"name": name})
print(name)
print(users)
coll = get_coll()
# coll.deleteOne({"name": name})
coll.find({"name": name})
coll.update({"name":name},{"$set":{"email":email}})
# userusername = users.find_one({"name": name})
# users.remove(userusername)
# users.delete(name)
return name
作者:jianpeng.diao版権声明:本文はブロガーのオリジナル文章で、転載はブロガーのリンクを添付してください!
import json
from flask import Flask, request
from flask_cors import CORS
#flask_cor
from flask_script import Manager
from app import app
from models import User
manager = Manager(app)
CORS(app, supports_credentials=True)
@app.route('/test', methods=['GET', 'POST'])
@manager.command
def save():
datas = request.get_data()
print(datas)
user = User('diaodiao',datas)
user.save()
return datas
@app.route('/getdata', methods=['GET', 'POST'])
@manager.command
def query_users():
users = User.query_users()
# str(users['ObjectId'])
list = []
for user in users:
# print(user)
# user.get('_id').tostring
# str(user['_id'])
# str(user)
del user['_id']
print(user)
list.append(user)
# json.dumps(user)
print(list)
jsondata = json.dumps(list)
# print(user)
# return user
# print(jsondata)
return jsondata
# return user
@app.route('/delete', methods=['GET', 'POST'])
@manager.command
def delete():
datas = request.get_data()
print(datas)
print("------")
# print(datas['name'])
name = "DiaoDiao"
users = User.delete(name)
if name:
# return "Remove " + datas.name["name"] + " Ok!"
return "Remove " + ["name"] + " Ok!"
else:
return " , !"
@app.route('/update', methods=['GET', 'POST'])
@manager.command
def update():
datas = request.get_data()
print(datas)
print("------")
# print(datas['name'])
name = "DiaoDiao"
email = "[email protected]"
users = User.update(name,email)
if name:
return "update " + name + " Ok!"
else:
return " , !"
if __name__=='__main__':
# app.run()
manager.run(debug=True)
def get_coll():
client = pymongo.MongoClient('localhost', 27017)
db = client.jikexueyuan
user = db.user_collection
return user
class User(object):
def __init__(self, name, datas):
self.name = name
self.datas = datas
def save(self):
user = {"name": self.name, "email": self.datas}
coll = get_coll()
id = coll.insert(user)
print(id)
@staticmethod
def query_users():
users = get_coll().find()
return users
@staticmethod
def delete(name):
users = get_coll().find({"name": name})
print(name)
print(users)
coll = get_coll()
coll.remove({"name": name})
# userusername = users.find_one({"name": name})
# users.remove(userusername)
# users.delete(name)
return name
@staticmethod
def update(name,email):
users = get_coll().find({"name": name})
print(name)
print(users)
coll = get_coll()
# coll.deleteOne({"name": name})
coll.find({"name": name})
coll.update({"name":name},{"$set":{"email":email}})
# userusername = users.find_one({"name": name})
# users.remove(userusername)
# users.delete(name)
return name