1.连接数据库
import pymysql
#连接数据库
connection = pymysql.connect(host = 'localhost', #访问地址
port=3306, #访问端口
user = 'root' , #登录名
password = 'root', #访问密码
db = 'test' #库名
)
#创建游标
cur=connection.cursor()
#查询库中某表的数据
cur.execute("select * from ttt")
#fetch_ 获取数据
#fetchone获取一行数据 fetchall() 获取表中所有数据
ret1=cur.fetchmany(3)
print(ret1)
#查询数据库版本
cur.execute("select version()")
data = cur.fetchone()
print(" Database Version:%s" % data)
#关闭指针对象
cur.close()
#关闭连接的数据库
connection.close()
2.查询操作
import pymysql
#连接数据库
db = pymysql.connect(host = 'localhost', #访问地址
port=3306, #访问端口
user = 'root' , #登录名
password = 'root', #访问密码
db = 'test' #库名
)
#创建游标
cur=db.cursor()
#查询库中某表的数据
sql="select * from ttt"
try:
cur.execute(sql) #执行sql语句
results=cur.fetchmany(10)
print("id","date","password") #设置字段名
#遍历结果
for row in results :
id =row[0]
date =row[1]
password =row[2]
print(id,date,password)
except exception as e:
raise e
finally:
db.close
3.数据库表的新建、插入、更新、删除 操作
import pymysql
#连接数据库
db = pymysql.connect(host = 'localhost', #访问地址
port=3306, #访问端口
user = 'root' , #登录名
password = 'root', #访问密码
db = 'test' #库名
)
#使用cursor()方法创建游标对象cur
cur=db.cursor()
#------------1.创建数据库表------------
#使用execute()方法执行SQL，如果表存在，则删除
cur.execute("DROP TABLE IF EXISTS YUBG")
#使用预处理语句创建表
sql="""create table yubg(name char(20) not null,nickname char(20),age int,sex char(1),income float)"""
cur.execute(sql)
# 关闭数据库连接
db.close
#------------2.数据库表插入记录------------
sql_insert="insert into yubg(name,nickname,age,sex,income) values('张三','小张',16,'男2',300)"
try:
cur.execute(sql_insert)
db.commit() #提交数据库执行
except Exception as e:
db.rollback() #如果发生错误，进行回滚
finally:
db.close()
#------------3.数据库表更新数据------------
sql_update="update yubg set income=%d where name= '%s' "
try:
cur.execute(sql_update % (600,"张三")) #向sql语句传递参数
db.commit() #提交数据库执行
except Exception as e:
db.rollback()
finally:
db.close()
#------------4.数据库表删除记录------------
sql_delete="delete from yubg where name='%s'"
try:
cur.execute(sql_delete % ("张三"))
db.commit()
except Exception as e:
db.rollback()
finally:
db.close()
