-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathcrud.py
More file actions
104 lines (86 loc) · 3.41 KB
/
crud.py
File metadata and controls
104 lines (86 loc) · 3.41 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
from flask import Flask, request, make_response,jsonify
from flask_cors import CORS
from functools import wraps
import pymysql
app = Flask(__name__)
cors = CORS(app)
@app.route('/users', methods=['GET'])
def get():
conn = pymysql.connect(host="localhost", user="root", password="", db="group1")
cur = conn.cursor(pymysql.cursors.DictCursor)
cur.execute("select * from student")
output = cur.fetchall()
for x in output:
print(x);
conn.close()
return jsonify(output);
@app.route('/specificuser', methods=['GET'])
def getSpecific():
conn = pymysql.connect(host="localhost", user="root", password="", db="group1")
cur = conn.cursor(pymysql.cursors.DictCursor)
rollno = int(str(request.args.get('rollno')))
sql = f"SELECT * FROM student where RollNo={rollno}";
cur.execute(sql)
output = cur.fetchall()
for x in output:
print(x);
conn.close()
return jsonify(output);
@app.route('/users', methods=['DELETE'])
def delete():
conn = pymysql.connect(host="localhost", user="root", password="", db="group1")
cur = conn.cursor(pymysql.cursors.DictCursor)
rollno = int(str(request.args.get('rollno')))
sql = f"DELETE FROM student where RollNo={rollno}";
cur.execute(sql)
output = cur.fetchall()
conn.commit()
print(cur.rowcount,"record deleted")
return jsonify("RECORD DELETED SUCCESSFULLY");
@app.route('/users', methods=['PUT'])
def insert_user():
conn = pymysql.connect(host="localhost", user="root", password="", db="group1")
raw_json = request.get_json();
RollNo = raw_json['RollNo'];
FirstName = raw_json['FirstName'];
LastName = raw_json['LastName'];
City = raw_json['City'];
Age = raw_json['Age'];
ItemList = raw_json['ItemList'];
sql = f"INSERT INTO student(RollNo,FirstName,LastName,City,Age,ItemList) VALUES ('"+str(RollNo)+"','"+FirstName+"','"+LastName+"','"+City+"','"+str(Age)+"','"+ItemList+"')";
cur = conn.cursor()
cur.execute(sql)
conn.commit()
return jsonify("RECORD INSERTED SUCCESSFULLY");
@app.route('/insertmarks', methods=['GET'])
def insert_marks():
conn = pymysql.connect(host="localhost", user="root", password="", db="group1")
raw_json = request.get_json();
RollNo = raw_json['RollNo'];
CN = raw_json['CN'];
Python = raw_json['Python'];
COA = raw_json['COA'];
Pcom = raw_json['Pcom'];
Maths = raw_json['Maths'];
sql = f"INSERT INTO ise_marks(RollNo,CN,Python,COA,Pcom,Maths) VALUES ('"+str(RollNo)+"','"+str(CN)+"','"+str(Python)+"','"+str(COA)+"','"+str(Pcom)+"','"+str(Maths)+"')";
cur = conn.cursor()
cur.execute(sql)
conn.commit()
return jsonify("MARKS INSERTED SUCCESSFULLY");
@app.route('/users', methods=['POST'])
def update():
conn = pymysql.connect(host="localhost", user="root", password="", db="group1")
raw_json = request.get_json()
RollNo = raw_json['RollNo'];
FirstName = raw_json['FirstName'];
LastName = raw_json['LastName'];
City = raw_json['City'];
Age = raw_json['Age'];
ItemList = raw_json['ItemList'];
sql = f"UPDATE student SET RollNo = '{RollNo}', FirstName = '{FirstName}', LastName = '{LastName}', City = '{City}', Age = '{Age}', ItemList = '{ItemList}' WHERE RollNo = {RollNo}"
cur = conn.cursor()
cur.execute(sql)
conn.commit()
return jsonify("RECORD UPDATED SUCCESSFULLY")
if __name__=="__main__":
app.run(host="0.0.0.0", port=int("1234"), debug=True)