【query.py】连接数据库函数的编写

2024-07-02 16:46:33 +08:00
parent 7235f7a22b
commit ef5fd5bea4
1 changed files with 13 additions and 0 deletions
@@ -0,0 +1,13 @@
+from pymysql import *
+conn = connect(host='10.92.35.13',port=3306,user='XiaoXueQi',password='XiaoXueQi',database='Weibo_PublicOpinion_AnalysisSystem')
+cursor = conn.cursor()
+def query(sql,params,type="no_select"):
+    params = tuple(params)
+    cursor.execute(sql,params)
+    conn.ping(reconnect=True)
+    if type != 'no_select':
+        data_list = cursor.fetchall()
+        conn.commit()
+        return data_list
+    else:
+        conn.commit()