如何使用python连接mysql数据库
如何使用python连接mysql数据库
1.要想让python能够连接到mysql,首先就是要先下载安装pymysql的模块:
Win+R 进入命令行,使用pip install pymysql安装模块。我这里使用的是清华镜像源。
2.导入pymysql模块,创建一个连接mysql的类对象,并定义初始化需要的变量。
#导入pymsql模块
import pymysql
#创建连接MYSQL的类
class TestMysql:
#初始化变量
def __init__(self,username,host,passwd,database):
self.username = username
self.host = host
self.passwd = passwd
self.database = database
3.创建一个连接mysql的connection函数。
#创建数据库连接
def conn_mysql(self):
conn = pymysql.connect(user=self.username,host=self.host,password=self.passwd,db=self.database)
return conn
4.创建一个mysql退出是的提示信息(个人觉得可以看心情选择)。
#关闭数据库的提示信息
def close_mysql(self):
print("MySQL is Closed")
5.最后在创建一个查询数据的函数,我这里偷懒了,加了一个while循环,每循环一次的时候就询问一次是否继续?这样就可以不用再创建诸如delete,update,insert等等的函数了。
#查询数据
def get_data(self):
self.conn = self.conn_mysql()
cur = self.conn.cursor()
#
while True:
sql = input('输入SQL语句:')
cur.execute(sql)
results = cur.fetchall()
for i in results:
print(str(i))
yn = input('按N断开连接,任意键继续:').strip()
if yn == 'N':
break
#
cur.close()
self.close_mysql()
6.最最最后,为了以后可以在其他程序中调用这个类对象,还可以加上if name == “main”:
下面就是定义变量,创建类的实例,调用实例了。这里我还用了try/except做报错自动处理,当定义的变量有问题出现报错时,会自动将错误信息输出到终端。
if __name__ == "__main__":
#定义变量
username = input('用户名:').strip()
host = input('主机名:').strip()
passwd = input('密码:').strip()
database = input('库名:').strip()
#使用try--except
try:
#创建TestMysql的实例
mysql = TestMysql(username,host,passwd,database)
mysql.conn_mysql()
mysql.get_data()
except pymysql.err.ProgrammingError as e:
print("Exception Error is %s"%(e))
except pymysql.err.OperationalError as e:
print("Exception Error is %s"%(e))
以下是部分运行的效果:
来源:藝海☜☞朝阳