连接数据库

• 连接时需要额外指定参数db
• cursor.execute(' ') 操作SQL语句
• SELECT VERSION() 获得当前版本
• CREATE DATABASE spiders DEFAULT CHARACTER SET utf8 创建数据库

import pymysql
db = pymysql.connect(host='localhost',user=' ',password=' ',port=3306)#IP，用户名，密码，端口号
cursor = db.cursor()    #获得操作游标，利用游标执行SQL语句
cursor.execute('SELECT VERSION()') #获得当前版本
data = cursor.fetchone() #获得第一条数据 ?
print('Database version:',data)
cursor.execute('CREATE DATABASE spiders DEFAULT CHARACTER SET utf8')//创建sriders数据库，默认编码utf-8
db.close()

创建表

• PRIMARY KEY 主键，创建表时主要指定主键
• 创建表：CREATE TABLE IF NOT EXISTS musicspider(指定字段)

import pymysql
db = pymysql.connect(host='localhost',user='root',password='密码',port=3306,db='spiders')#连接数据库，指定参数db
cursor = db.cursor()
sql = 'CREATE TABLE IF NOT EXISTS musicspider(songName VARCHAR(225) NOT NULL,singerName VAECHAR(225) NOT NULL,musicUrl VARCHAR(255) NOT NULL,PRIMARY KEY (songName))'
#创建表，‘字段名’‘字段类型’（大小）
#VERCHAR 变长字符串
cursor.execute(sql)
db.close()

插入数据

• INSERT INTO table(colum1,colum2...) values(格式符1，格式符2...)

import pymysql
db = pymysql.connect(host='localhost',user='root',password='密码',port=3306,db='spiders')#连接数据库
cursor = db.cursor()
songName = '当年情'
singerName = '张国荣'
musicURL = 'https://i.y.qq.com/v8/playsong.html?songid=102349891&source=yqq#wechat_redirect'
sql = 'INSERT INTO musicspider(songName,singerName,musicURL) values(%s,%s,%s)'
# 异常处理，执行失败时调用rollback执行数据回滚，相当于什么都没发生
try:cursor.execute(sql,(songName,singerName,musicURL))db.commit() # 提交后才能实现数据插入
except:db.rollback() # 执行数据回滚
db.close()

• 事务
  • 原子性：要么发生要么不发生，不存在进行一半的情况
  • 一致性：从一个一致性状态到另一个一致性状态
  • 隔离性：事务与其他并发的事务隔离，互不干扰
  • 持久性：永久性
• 插入更新删除操作都是对数据库进行更改的操作，而更改操作必须是一个事务，所以操作的标准写法：

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

• 动态构造字典（传入一个字典插入数据

data = {'songName':'当年情''singerName':'张国荣''musicURL':'https://i.y.qq.com/v8/playsong.html?songid=102349891&source=yqq#wechat_redirect'
}
table = 'musicspider'
keys = ','.join(data.keys()) #字段名，用逗号分隔开
values = ','.join(['%s']*len(data)） # 占位符
sql = 'INSERT INTO {table}({keys}) VALUES ({values})'.format(table = table,keys = keys,values = values)
try:if cursor.execute(sql,tuple(data.values())): # sql构造占位符，调用execute需要字典键值作参数print("successful")db.commit()
except:print('failed')db.rollback()
db.close()

更新数据

• 构造SQL语句,执行execute()方法，传入元组形式的参数，执行commit提交操作

sql = 'UPDATE musicspider SET musicURL = %s WHERE songName = %s'
try:cursor.execute(sql,('*****','***'))db.commit
except:db.rollback()
db.close()

• 字典传值，存在时更新数据，不存在时插入数据

data = {,,}table = 
keys = 
values = sql = 'INSTRT INTO {table}({keys}) VALUES ({values}) ON DUPLICATE KEY UPDATE'.format(table = table,keys = keys,values = values)
update = ','.join(['{key}:%s'.format(key = key) for key in data])
sql += updatetry:if cursor.execute(sql,tuple(data.values())*2):print("Successful")db.commit()
except:print("Failed")db.rollback()db.close()

删除数据

• 使用DELETE语句

table = #删除目标表明
condition = #删除条件sql = 'DELETE FROM {table} WHERE {condition}'.format{table = table,condition = condition}try:cursor.execute(sql)db.commit()
except:db.rollback()db.close()

查询数据

• SELECT语句
• sql = 'SELECT * FROM {table} WHERE {condition}'
• fetchall()和fetchone() 返回结果内部有一个偏移指针用来指向查询结果，最开始偏移指针指向第一条数据，取出之后指针偏移到下一条数据，再取时会取到下一跳数据

sql = 'SELECT *FROM {} WHERE {}'try:cursor.execute(sql)print('count:'cursor.rowcount)row = cursor.fetchone()while row:print('row:'row)row = cursor.fetchone()
except:print('Error')

navicat连接mysql报错1251

解决方式：更改加密方式

1. 登录mysql
2. 更改加密方式

mysql> ALTER USER 'root'@'localhost' IDENTIFIED BY 'password' PASSWORD EXPIRE NEVER;
Query OK, 0 rows affected (0.10 sec)

3. 更新密码

mysql> ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY '新密码';
Query OK, 0 rows affected (0.35 sec)

4. 刷新

mysql> FLUSH PRIVILEGES;
Query OK, 0 rows affected (0.28 sec)

5. 重新连接