create database

songyi/database.py

@@ -0,0 +1,27 @@
+import sqlite3
+
+conn = sqlite3.connect('courses.db')
+print ("数据库打开成功")
+c = conn.cursor()
+
+# c.execute('''CREATE TABLE COURSE_LIST
+#        (ID INT PRIMARY KEY     NOT NULL,
+#        TITLE           VARCHAR(50)    NOT NULL,
+#        DESCRIPTION     TEXT NOT NULL);''')
+
+c.execute('''CREATE TABLE COURSE_DATA
+       (MESSAGE_ID      VARCHAR(50) PRIMARY KEY     NOT NULL,
+        COURSE_ID       INT                         NOT NULL,
+        CATEGORY        VARCHAR(20)                 NOT NULL,
+        CREATED_AT      TIMESTAMP                   NOT NULL,
+        ATTACHMENT_ID   VARCHAR(50)                 NOT NULL);''')
+
+c.execute('''CREATE TABLE COURSE_ATTACHMENT
+       (ID              VARCHAR(50) PRIMARY KEY     NOT NULL,
+        ATTACHMENT_NAME VARCHAR(20)                 NOT NULL,
+        ATTACHMENT_URL  TEXT                        NOT NULL,
+        ATTACHMENT_TEXT TEXT                        NOT NULL);''')
+
+print ("数据表创建成功")
+conn.commit()
+conn.close()

songyi/parse-course-message.py

@@ -20,8 +20,8 @@ headers = {
 }
 
 class_id = '80000002'
-course_id = '6770'
+course_id = '7940'
 
 response = requests.get('https://bandu-api.songy.info/v1/communities/'+ class_id +'/courses/' + course_id + '/messages', headers=headers)
 
-print(response.json())
+print(response.text)

songyi/read_list.py

@@ -1,16 +1,35 @@
 # 获取课程列表中的id以及描述信息
 
 import json
+import sqlite3
 
+courses_list = []
 with open('courses.json', encoding="UTF-8") as file:
-    str_data = file.readline()
-    courses = json.loads(str_data)
-    # print(type(courses))
+    str_datas = file.readlines()
+    for str_data in str_datas:
+        if str_data.strip() == '':
+            break
+        courses = json.loads(str_data)
+        # print(type(courses))
 
-    # 获取课程序号及名称存入list中
-    courses_list = []
-    for item in courses['data']['items']:
-        courses_dict = {'id': item['id'], 'title': item['title'], 'description': item['description']}
-        courses_list.append(courses_dict)
+        # 获取课程序号及名称存入list中
+        for item in courses['data']['items']:
+            courses_dict = {'id': item['id'], 'title': item['title'], 'description': item['description']}
+            print(courses_dict)
+            courses_list.append(courses_dict)
 
-    print(courses_list)
+conn = sqlite3.connect('courses.db')
+c = conn.cursor()
+print ("数据库打开成功")
+
+
+
+for course_info in courses_list:
+    course_id = course_info['id']
+    print(type(course_id))
+    c.execute("INSERT INTO COURSE_LIST (ID,TITLE,DESCRIPTION) \
+    VALUES ( " + str(course_id) + ", '" + course_info['title'] + "', '" + course_info['description'] +"')")
+
+conn.commit()
+print("数据插入成功")
+conn.close()