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 """