Python操作MySQL - 努力吧阿团

link之家

链接快照平台

输入网页链接，自动生成快照
标签化管理网页链接

相关文章推荐

风度翩翩的排球 · Java应用在docker环境配置容器健康检 ...· 1 年前 ·

睿智的柠檬 · JPA与EntityManager批量新增、 ...· 1 年前 ·

千杯不醉的西装 · js/ts ...· 1 年前 ·

冷冷的棒棒糖 · Spring Data Jpa ...· 1 年前 ·

宽容的黑框眼镜 · python - ...· 1 年前 ·

import pymysql
#调用pymysql模块的connect()函数创建connection连接对象
#必备参数有’连接名称‘，’用户名‘，’密码‘，’数据库名‘,注意参数顺序
db = pymysql.connect('localhost','root','root','test')
#调用游标cursor()方法，创建cursor对象
cursor = db.cursor()
#执行sql语句查询数据库版本
cursor.execute('select version()')
data = cursor.fetchone()
print(data) #
cursor.close()
db.close()
#out: ('5.7.31-log',)
将connect传入参数改为关键字参数,传入的时候可以不再注意参数顺序。

上述部分代码修改如下
db = pymysql.connect(host='localhost',user='root',database='test',password='root')
使用create table 表名创建表。
import pymysql
db = pymysql.connect('localhost','root','root','test')
cursor = db.cursor()
#如果books表存在就删除它，这样防止创建失败
cursor.execute('drop table if exists books')
sql = '''
CREATE TABLE books(
    id int(8) NOT NULL AUTO_INCREMENT,
    name varchar(50) NOT NULL,
    category varchar(50) NOT NULL,
    price decimal(10,2) DEFAULT NULL,
    publish_time date DEFAULT NULL,
    PRIMARY KEY (id)
) ENGINE=MyISAM AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
cursor.execute(sql)
cursor.close()
db.close()
AUTO_INCREMENT表示自增
PRIMARY KEY 主键
decimal(10,2) 保持两位小数点
1.插入一条数据。

注意：mysql的占位符为%s，跟SQLite的?不一样。
import pymysql
db = pymysql.connect('localhost','root','root','test',charset='utf8')
cursor = db.cursor()
#定义data元组存放要写入表中的数据
data = ('Python从入门到放弃','计算机类','56.99','2020-10-11')
#Mysql中使用%s作为占位符
sql = "insert into books(name,category,price,publish_time) value (%s,%s,%s,%s)"
cursor.execute(sql,data)
cursor.close()
db.close()
2.插入多条数据；
import pymysql
db = pymysql.connect('localhost','root','root','test',charset='utf8')
cursor = db.cursor()
#定义data列表存放要写入表中的多条数据
data = [
('Python从入门到放弃','计算机类','56.99','2020-10-11'),
('Linux从入门到放弃','计算机类','58.99','2020-10-11'),
('吃饭从入门到放弃','生活类','23.69','2020-10-11'),
('睡觉从入门到放弃','生活类','15.59','2020-10-11')
sql = "insert into books(name,category,price,publish_time) value (%s,%s,%s,%s)"
#使用executemany()插入多条数据
cursor.executemany(sql,data)
cursor.close()
db.close()
3.使用try:except:发生错误时回滚数据；
import pymysql
db = pymysql.connect('localhost','root','root','test',charset='utf8')
cursor = db.cursor()
#定义data列表存放要写入表中的多条数据
data = [
('Python从入门到放弃','计算机类','56.99','2020-10-11'),
('Linux从入门到放弃','计算机类','58.99','2020-10-11'),
('吃饭从入门到放弃','生活类','23.69','2020-10-11'),
('睡觉从入门到放弃','生活类','15.59','2020-10-11')
    sql = "insert into books(name,category,price,publish_time) value (%s,%s,%s,%s)"
    #使用executemany()插入多条数据
    cursor.executemany(sql,data)
    db.commit()
except:
    db.rollback()
cursor.close()
db.close()
修改删除查询
跟操作SQLite一样，点此转送
学习来自：《python从入门到项目实践》明日科技 第十五章