Python操作MySQL

Posted 2021-01-31 huanggaoyu

1.连接数据库

import pymysql # 引入 pymysql对象

‘‘‘
连接数据库 
参数1:数据库的ip地址 
参数2:用户名 
参数3:密码
参数4:连接的数据库名称
‘‘‘
db = pymysql.connect("127.0.0.1","root","123456","python1806")

#创建一个对象 cursor
cursor = db.cursor()
#准备sql语句
sql = "show tables"

#执行sql语句
cursor.execute(sql)

#获取返回的信息

#data=cursor.fetchone()
data=cursor.fetchall()
print(data)

cursor.close()

db.close()

　　

2.创建数据表

import pymysql

db = pymysql.connect("localhost","root","123456","python1806")
cursor = db.cursor()

#检测表是否存在 存在先删除 
sql1 = "drop table if exists haha"

cursor.execute(sql1)

sql2= "create table haha(id int(11) unsigned not null primary key auto_increment,username varchar(64) not null default ‘shuaige‘)engine=myisam default charset=utf8"

cursor.execute(sql2)


cursor.close()
db.close()

　　

3.插入数据

import pymysql # 引入 pymysql对象


‘‘‘
连接数据库 
参数1:数据库的ip地址 
参数2:用户名 
参数3:密码
参数4:连接的数据库名称
‘‘‘
db = pymysql.connect("127.0.0.1","root","123456","python1806")

#创建一个对象 cursor
cursor = db.cursor()
#准备sql语句
sql = "insert into haha(username) values(‘123‘),(‘456‘),(‘789‘)"

try:
cursor.execute(sql)
db.commit()
except:
db.rollback()

cursor.close()

db.close()

　　

4.更新数据

import pymysql # 引入 pymysql对象


‘‘‘
连接数据库 
参数1:数据库的ip地址 
参数2:用户名 
参数3:密码
参数4:连接的数据库名称
‘‘‘
db = pymysql.connect("127.0.0.1","root","123456","python1806")

#创建一个对象 cursor
cursor = db.cursor()
#准备sql语句
#sql = "insert into haha(username) values(‘123‘),(‘456‘),(‘789‘)"
sql = "update haha set username=‘东方不败‘ where id=2"

try:
cursor.execute(sql)
db.commit()
except:
db.rollback()

cursor.close()

db.close()

　　

5.删除数据

import pymysql # 引入 pymysql对象


‘‘‘
连接数据库 
参数1:数据库的ip地址 
参数2:用户名 
参数3:密码
参数4:连接的数据库名称
‘‘‘
db = pymysql.connect("127.0.0.1","root","123456","python1806")

#创建一个对象 cursor
cursor = db.cursor()
#准备sql语句
sql = "delete from haha where id=1"
try:
cursor.execute(sql)
db.commit()
except:
db.rollback()

cursor.close()

db.close()

　　

6.查询数据

import pymysql # 引入 pymysql对象


‘‘‘
连接数据库 
参数1:数据库的ip地址 
参数2:用户名 
参数3:密码
参数4:连接的数据库名称
‘‘‘
db = pymysql.connect("127.0.0.1","root","123456","python1806")

#创建一个对象 cursor
cursor = db.cursor()
#准备sql语句
sql = "select * from haha"

try:
cursor.execute(sql) #执行sql语句
result = cursor.fetchall() #取出所有的结果
for row in result:
print("%d--%s" % (row[0],row[1]))

except:
db.rollback()
cursor.close()

db.close()