1 import pymysql 2 def get_conn(): 3 """
4 :return: 連接，游標 5 """
6 # 創建連接
7 conn = pymysql.connect(host="hadoop102", 8 user="root", 9 password="000429", 10 db="company", 11 charset="utf8") 12 # 創建游標
13 cursor = conn.cursor() # 執行完畢返回的結果集默認以元組顯示
14 return conn, cursor 15
16 def close_conn(conn, cursor): 17 if cursor: 18 cursor.close() 19 if conn: 20 conn.close() 21 """
22 ------------------------------------------------------------------------------------ 23 """
24 def query(sql,*args): 25 """
26 通用封裝查詢 27 :param sql: 28 :param args: 29 :return:返回查詢結果 （（），（）） 30 """
31 conn , cursor= get_conn() 32 print(sql) 33 cursor.execute(sql) 34 res = cursor.fetchall() 35 close_conn(conn , cursor) 36 return res 37 """
38 ------------------------------------------------------------------------------------ 39 """
