python中如何连接MySQL服务器的一个库

小编给大家分享一下 python中如何连接MySQL服务器的一个库，希望大家阅读完这篇文章之后都有所收获，下面让我们一起去探讨吧！

创新互联是专业的涪陵网站建设公司，涪陵接单;提供成都网站设计、成都做网站,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行涪陵网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!

PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库。

安装：

pip install PyMySQL

数据库增删改查流程差不多，主要在于sql语句。

#!/usr/bin/env python3
#-*- coding:utf-8 -*-
import pymysql
#创建一个数据库链接
db = pymysql.connect("localhost",'root','drcom','TESTDB')
#创建一个游标对象
#游标是系统为用户开设的一个数据缓冲区，存放sql语句的执行结果
cursor = db.cursor()
#执行sql查询，返回值是查询到的数据条目数
cursor.execute("select version()")
#获取查询数据
#fetchone每次只返回一行，也就是结果集的下一行
#fetchall() 得到结果集中剩下的所有行
data = cursor.fetchone()
print("database version:%s"%data)
#执行sql。如果表存在就删除
cursor.execute("drop table if exists EMPLOYEE")
#使用预处理语句创建表
sql = '''CREATE TABLE EMPLOYEE(
	FIRST_NAME CHAR(20) NOT NULL,
	LAST_NAME CHAR(20),
	AGE INT,
	SEX CHAR(1),
	INCOME FLOAT)'''
cursor.execute(sql)
#sql插入语句
insert_db = '''INSERT INTO EMPLOYEE(FIRST_NAME,
		LAST_NAME,AGE,SEX,INCOME)
		VALUES('Mac','Mohan',20,'M',2000)'''
try:
	cursor.execute(insert_db)
#提交到数据库执行，不执行这一步，数据是不会被真正的写入到数据库的
	db.commit()
except:
#如果发生错误则回滚
	db.rollback()

cursor.execute("SELECT * FROM TESTDB.EMPLOYEE")
result = cursor.fetchall()
print(result)
#关闭数据库

db.close()

看完了这篇文章，相信你对“ python中如何连接MySQL服务器的一个库”有了一定的了解，如果想了解更多相关知识，欢迎关注创新互联行业资讯频道，感谢各位的阅读！