course CRUD complete

main.py

@@ -21,7 +21,7 @@ app.add_middleware(
 )
 
 
-db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/cmm_test?charset=utf8mb4')
+db = dataset.connect('mysql://choozmo:pAssw0rd@db.ptt.cx:3306/openTalk?charset=utf8mb4')
 
 ##########TAG CRUD################TAG CRUD##################TAG CRUD###########TAG CRUD##################
 class Tag(BaseModel):
@@ -51,7 +51,7 @@ async def delete_tags(tag_id:int):
     db.query(sqls)
     sqls = 'DELETE FROM course_tag WHERE tag_id = '+str(tag_id)
     db.query(sqls)
-    return result
+    return 'success'
 	
 @app.put("/tags/{tag_id}")
 async def update_tags(tag_id,tag:Tag):
@@ -74,13 +74,15 @@ async def get_tags(tag_id):
 ###########COURSE CRUD###########COURSE CRUD###########COURSE CRUD###########COURSE CRUD###########
 class Course(BaseModel):
     id: int
-    name: str
-    cover_src: str   #image src url
-    content_des: str #course description
-    watch_times: int
+    title: str
+    url: str #course website location url
+    img: str #img url form
+    teacher_name: str
+    teacher_img: str #teacher user image url form
     price: int
-    period: int  #times a week
-
+    hours: int
+    units: int
+    
 @app.get("/courses")
 async def get_courses(tag_string):
     
@@ -93,17 +95,20 @@ async def get_courses(tag_string):
     course_id_string=course_id_string[:-1]
     course_id_string = course_id_string+')'
 
-    statement = 'SELECT id,name from course_table where id IN'+course_id_string    
+    statement = 'SELECT * from course_table where id IN'+course_id_string    
     for row in db.query(statement):
-        courses.append({'id':row['id'],'name':row['name']})
+        courses.append({'id':row['id'],'title':row['title'],'url':row['url'],'img':row['img']
+        ,'teacher_name':['teacher_name'],'teacher_img':row['teacher_img'],'price':row['price']
+        ,'hours':row['hours'],'units':row['units']})
     return courses
 
 @app.post("/courses")
 async def create_courses(Tag_IDs: list,course:Course):
     course_table = db['course_table']
     course_tag_table = db['course_tag']
-    pkey = course_table.insert({'name':course.name,'content_des':course.content_des,
-    'price':course.price,'period':course.period})
+    pkey = course_table.insert({'title':course.title,'url':course.url,'img':course.img
+    ,'teacher_name':course.teacher_name, 'teacher_img': course.teacher_img,'units':course.units
+    ,'price':course.price,'hours':course.hours})
     sqls = 'INSERT INTO course_tag (course_id, tag_id)VALUES'
     for tid in Tag_IDs:
         sqls = sqls + '('+str(pkey)+','+str(tid)+'),'
@@ -117,10 +122,37 @@ async def course_cover_change(course_id, uploaded_file: UploadFile = File(...)):
     with open(file_location, "wb+") as file_object:
         file_object.write(uploaded_file.file.read())
     sqls = 'UPDATE course_table\
-    SET cover_img="'+file_location+'"\
+    SET img="'+file_location+'"\
+    WHERE id='+course_id+';'
+    db.query(sqls)
+    return '{"file_loc":'+file_location+'}'
+
+@app.post("/teacher_img_change/{course_id}")
+async def teacher_img_change(course_id, uploaded_file: UploadFile = File(...)):
+    file_location = f"teacher_img/{course_id}"
+    with open(file_location, "wb+") as file_object:
+        file_object.write(uploaded_file.file.read())
+    sqls = 'UPDATE course_table\
+    SET teacher_img="'+file_location+'"\
     WHERE id='+course_id+';'
     db.query(sqls)
     return '{"file_loc":'+file_location+'}'
     
+@app.delete("/courses/{course_id}")
+async def delete_course(course_id:int):
+    sqls = 'DELETE FROM course_table WHERE id = '+str(course_id)
+    db.query(sqls)
+    sqls = 'DELETE FROM course_tag WHERE course_id = '+str(course_id)
+    db.query(sqls)
+    return "success"
     
+@app.put("/courses/{course_id}")
+async def update_course(course_id,course:Course):
+    sqls = 'UPDATE course_table\
+    SET title="'+course.title+'", url="'+course.url+'", hours='+str(course.hours)+',\
+    teacher_name="'+course.teacher_name+'", price='+str(course.price)+', units='+str(course.units)+'\
+    WHERE id='+str(course_id)+';'
+    db.query(sqls)
+    course.id=course_id
+    return course