수정

app.py

@@ -7,6 +7,8 @@ from tornado.wsgi import WSGIContainer
 from tornado.httpserver import HTTPServer
 from tornado.ioloop import IOLoop
 
+from sqlite3worker import Sqlite3Worker
+
 import platform
 import bcrypt
 import difflib
@@ -47,7 +49,7 @@ except:
             pass
 
 # 디비 연결
-conn = sqlite3.connect(set_data['db'] + '.db', check_same_thread = False)
+conn = sqlite3.connect(set_data['db'] + '.db')
 curs = conn.cursor()
 
 # 기타 설정 변경

back_reset.py

@@ -12,12 +12,12 @@ json_data = open('set.json').read()
 set_data = json.loads(json_data)
 
 # 디비 연결
-conn = sqlite3.connect(set_data['db'] + '.db', check_same_thread = False)
+conn = sqlite3.connect(set_data['db'] + '.db')
 curs = conn.cursor()
 
 # 파싱 해주는 함수
 def parser(data):
-    namumark(conn, data[0], data[1], 1, 0, 0)
+    namumark(conn, data[0], data[1], 1)
 
 # 역링크 전부 삭제
 curs.execute("delete from back")
@@ -32,10 +32,8 @@ for test in data:
     # 제목 프린트
     print(test[0])
 
-    # 스레드 기반으로 처리
-    t = threading.Thread(target = parser, args = [test])
-    t.start()
-    t.join()
+    # 파싱
+    parser(test)
 
 # 커밋
 conn.commit()

delete_recaptcha.py

@@ -6,7 +6,7 @@ json_data = open('set.json').read()
 set_data = json.loads(json_data)
 
 # 디비 연결
-conn = sqlite3.connect(set_data['db'] + '.db', check_same_thread = False)
+conn = sqlite3.connect(set_data['db'] + '.db')
 curs = conn.cursor()
 
 # 데이터 삭제

func.py

@@ -4,7 +4,6 @@ from flask import session, render_template
 from urllib import parse
 
 import json
-import sqlite3
 import hashlib
 import requests
 import re

mark.py

@@ -27,9 +27,7 @@ def namumark(conn, title, data, num):
     data = start(conn, data, title)
     if num == 1:        
         for back_data in data[2]:
-            thread_start = threading.Thread(target = plusing, args = [conn, back_data[0], back_data[1], back_data[2]])
-            thread_start.start()
-            thread_start.join()
+            plusing(conn, back_data[0], back_data[1], back_data[2])
 
         conn.commit()