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()