如何使用Python来连接MySQL数据库
前言
MySQL是应用最广泛的开源的数据库管理系统,LAMP
与LNMP
都是常见的使用组合,MySQL在里面充当了相当重要的角色,所以MySQL是我们非常有必要学习使用的一种数据库。
而Python是强力的胶水语言,那么如何使用Python来连接MySQL数据库呢?这就是我们今天的学习内容。
环境
- MySQL
- Python
- Python的第三方库:pymysql
pip install pymysql
使用
-
创建MySQL测试用的表
CREATE TABLE `student` ( `sid` int, `sname` varchar(20) NOT NULL, `sage` varchar(20) NOT NULL, `sno` varchar(100) NOT NULL, `saddress` varchar(100) NOT NULL, PRIMARY KEY (`sid`) USING BTREE )
-
我们这里使用的是pymysql这个Python的第三方库,我们打开JUPYTER NOTEBOOK来测试Python代码
-
导入所需的第三方库
-
创建数据库连接对象
param host:数据库服务器所在的主机地址 param user:登录的用户名 param password:要使用的密码。 param database:要使用的数据库,None不使用特定的数据库。 param port:要使用的MySQL端口,默认通常都可以。 (默认值:3306) param bind_address:当客户端有多个网络接口时,请指定从哪个接口连接到主机。可以用主机名或IP地址。 param unix_socket:您可以选择使用unix套接字而不是TCP / IP。 param read_timeout:以秒为单位从读取连接的超时(默认值:无 - 无超时) param write_timeout:以秒为单位连接写入的超时(默认值:无 - 无超时) param charset:你要使用的编码集。
更多相关参数请查看源码或者官方文档
-
创建游标对象
-
然后我们来写个完整的简单的插入数据的案例
-
到Navicat for MySQL里面查看插入的数据
-
我写的模板
import pymysql db = pymysql.connect("localhost","root","a","cs",charset="utf8") def connect_mysql(sql,data): cursor = db.cursor() try: result=None if data: if isinstance(data[0],list): cursor.executemany(sql,data) else: cursor.execute(sql,data) else: cursor.execute(sql) result=cursor.fetchall() except Exception as e: print(e) db.rollback(); finally: cursor.close() db.commit(); #提交操作 return result sql="select * from nowcoder_info where flag='0'" results=self.connect_mysql(sql,None) sql="insert into KuGo_singer (class_name,sindex,singername,singerid,imgurl) values (%s,%s,%s,%s,%s)" connect_mysql(sql,data)