1 import pymysql
 2 
 3 class ReadDB:
 4     #获取对象方法封装
 5     conn=None
 6     def get_conn(self):
 7         if self.conn is None:
 8             self.conn=pymysql.connect(host="10.135.1.100",
 9                                       port=31308,user="ota",
10                                       password="Defaultota",
11                                       database="ota_base_data",
12                                       charset='utf8')
13         return self.conn
14     #获取游标对象方法以及封装
15     def get_cursor(self):
16         return self.get_conn().cursor()
17     #关闭游标对象
18     def close_curson(self,cursor):
19         if cursor:
20             cursor.close()
21     #关闭连接
22     def close_coon(self):
23         if self.conn:
24             self.conn.close()
25             self.conn=None
26     #主方法进行查询
27     def get_sql_one(self,sql):
28         #定义游标对象以及数据变量
29         surson=None
30         data=None
31         try:
32             surson=self.get_cursor()
33             surson.execute(sql)
34             #获取结果
35             data=surson.fetchone()
36         except Exception as e:
37             print("get_sql_one error",e)
38         finally:
39             self.close_curson(surson)
40             self.close_coon()
41             #返回执行结果
42             return  data
43 if __name__ == '__main__':
44     ReadDB().get_conn()