一、Python连接MySQL数据库
1、导入模块#导入模块
importpymysql
2、打开数据库连接#打开数据库连接
#注意:这里已经假定存在数据库testdb,db指定了连接的数据库,当然这个参数也可以没有
db=pymysql.connect(host='127.0.0.1',port=3306,user='root',passwd='1234',db='testdb',charset='utf8')
3、创建游标对象cursor#使用cursor方法创建一个游标
cursor=db.cursor()
二、数据库基本操作
使用execute()方法来实现对数据库的基本操作。
1、查询数据库版本#查询数据库版本
cursor.execute("selectversion()")
data=cursor.fetchone()
print("DatabaseVersion:%s"%data)
2、创建数据库#创建数据库test
cursor.execute("dropdatabaseifexiststest")#如果数据库已经存在,那么删除后重新创建
sql="createdatabasetest"
cursor.execute(sql)
3、创建数据表#创建数据库表
cursor.execute("droptableifexistsemployee")#如果数据表已经存在,那么删除后重新创建
sql="""
CREATETABLEEMPLOYEE(
FIRST_NAMECHAR(20)NOTNULL,
LAST_NAMECHAR(20),
AGEINT,
SEXCHAR(1),
INCOMEFLOAT)
"""
cursor.execute(sql)
4、查询操作#查询数据表数据
sql="select*fromemployee"
cursor.execute(sql)
data=cursor.fetchone()
print(data)
5、插入操作#插入数据
sql="insertintoemployeevalues('李','梅',20,'W',5000)"
cursor.execute(sql)
mit()
#查看插入后的结果
sql="select*fromemployee"
cursor.execute(sql)
data=cursor.fetchone()
print(data)
6、指定条件查询数据#指定条件查询数据表数据
sql="select*fromemployeewhereincome>'%d'"%(1000)
cursor.execute(sql)
data=cursor.fetchone()
print(data)
7、更新操作#更新数据库
sql="updateemployeesetage=age+1wheresex='%c'"%('W')
cursor.execute(sql)
mit()
#查看更新后的结果
sql="select*fromemployee"
cursor.execute(sql)
data=cursor.fetchone()
print(data)
8、删除操作#删除数据
sql="deletefromemployeewhereage>'%d'"%(30)
cursor.execute(sql)
mit()
#查看更新后的结果
sql="select*fromemployee"
cursor.execute(sql)
data=cursor.fetchone()
print(data)
三、关闭数据库连接db.close()
四、其他
1、说明
·上例中"sql=..."语句,是经典的MySQL语句的形式,将数据库语句写在双引号内,形成类似字符串的形式;
·使用cursor对象的execute()方法具体执行数据库的操作;
·对于插入、更新、删除等操作,需要使用mit()来提交到数据库执行,对于查询、创建数据库和数据表的操作不需要此语句。
2、为有效避免因为错误导致的后果,使用以下方式来执行数据库的操作:try:
#执行SQL语句
cursor.execute(sql)
#提交修改
mit()
except:
#发生错误时回滚
db.rollback()
如果觉得《pyhon如何连接mysql_python如何连mysql数据库》对你有帮助,请点赞、收藏,并留下你的观点哦!