Python连接Mysql

通过python操作mysql,面向对象的编程思想

导入包

1
from pymysql import *

面向对象封装

init初始化方法

创建连接,建立游标对象

1
2
3
4
5
6
7
class JD(object):
def __init__(self):
#  1创建链接对象
self.conn = connect(host='主机名', port=3306, database='数据库名', user='账户名', password='密码',charset='utf8')

# 2 创建游标对象
self.cs = self.conn.cursor()

del方法

关闭游标,关闭连接

1
2
3
4
def __del__(self):
# 5 关闭
self.cs.close()
self.conn.close()

sql语句执行方法

1
2
3
4
5
6
def my_execute_sql(self,sql):
"""执行sql语句"""
self.cs.execute(sql)

# 4 获取数据
content = self.cs.fetchall()

写sql语句

例:

1
2
3
4
5
def show_all_goods(self):
"""显示所有的商品信息"""
sql = "select * from goods;"

self.my_execute_sql(sql)

运行

1
2
def run(self):
self.show_all_goods()