pymysql库中提供了两个常用的对象:Connection对象和Cursor对象。
1. Connection对象
Connection对象用于建立与MySQL数据库的连接,可以通过以下方法创建:
connect(参数列表)
以上方法中的常用参数及其含义如下:
·参数host,数据库所在主机的IP主机地址,若数据库位于本机,可设为localhost。
·参数port,数据库占用的端口,默认是3306。
·参数database ,表示数据库的名称。
·参数user,连入数据库时使用的用户名。
·参数password ,用户密码。
·参数charset,表示通信采用的编码方式,推荐使用utf8。
使用connect()方法向本地数据库建立连接,示例代码如下:
conn = pymysql.connect(
host='localhost',
user='root',
password ='123456',
database ='dbtest',
charset='utf8')
pymysql库为Connection对象提供了一些实现了数据库操作的常用方法,这些方法的说明如表1所示。
表1 Connection对象的常用方法
方法 说明
close() 关闭连接
commit() 提交当前事务
rollback() 回滚当前事务。
cursor() 创建并返回Cursor对象
注:事务回滚是指,事务在运行过程中因发生某种故障而不能继续执行,使得系统将事务中对数据库的所有已完成的更新操作全部撤销,将数据库返回到事务开始时的状态。
2. Cursor对象
Cursor对象即游标对象,它主要负责执行SQL语句。Cursor对象通过调用Connection对象的cursor()方法创建。使用上文创建的Connection对象conn获得游标对象,示例代码如下:
cs_obj = conn.cursor()
Cursor对象的常用属性和方法分别如表2和表3所示。
表2 Cursor对象的常用属性
属性 说明
rowcount 获取最近一次
execute() 执行后受影响的行数
connection 获得当前连接对象
表3 Cursor对象的常用方法
方法 说明
close() 关闭游标
execute(query, args=None) 执行SQL语句,返回受影响的行数
fetchall() 执行SQL查询语句,将结果集(符合SQL语句中条件的所有行集合)中的每行转化为一个元组,再将这些元组装入一个元组返回
fetchone() 执行SQL查询语句,获取下一个查询结果集
多学一招:SQL语句
SQL(全称Structure Query Language)是结构化查询语言,也是目前应用较广泛的用于访问和操作关系数据库的标准语言,具有易学易用、功能丰富的特点。下面将对基础的SQL语句进行介绍。
(1)创建数据库
创建数据库使用“create database”语句,语法格式如下:
create database 数据库名称
创建数据库dbtest的示例如下:
create database dbtest
(2)删除数据库
删除数据库使用“drop database”语句,语法格式如下:
drop database 数据库名称
删除数据库dbtest的示例如下:
drop database dbtest
(3)创建表
创建表使用“create table”语句,语法格式如下:
create table 表名称(
字段名 字段类型 [约束],
字段名 字段类型 [约束],
......
字段名 字段类型 [约束]
)
MySQL支持的字段类型很丰富,主要包括数值、日期和字符串类型。其中常见的数值类型有int、double、float等,常见的日期类型有date、time、year,常见的字符串类型有char和varchar。在设计数据表的字段时,可以为其添加约束,例如,primary key用于设置某个字段为主键,unique用于设置某个字段的值唯一,not null用于设置某个字段不能有空值。
在之前创建的数据库dbtest中创建数据表users,示例如下:
use dbtest; # 使用dbtest数据库
create table users(
UserID int primary key, # UserID字段被设置为主键
UserName varchar(20) unique, # UserName的值是惟一的,不能重复
UserPwd varchar(20) not null # UserPwd字段的值不能为空
)
(4)数据的增加
增加数据使用“insert into”语句实现,语法格式如下:
insert into table_name (字段1, 字段2,......字段n)
values (值1, 值2, ......值n);
例如,向users表里添加2行数据:
insert into users(userid,username,userpwd)
values(1,'xiaoMing','123456');
insert into users(userid,username,userpwd)
values(2,'xiaoHong','654321');
(5) 数据的删除
删除数据指从数据库中将记录彻底删除,使用“delete”语句和where子句实现,语法格式如下:
delete from 表名称 where 条件
例如,从users表中将第1条数据删除:
delete from users where UserID = 1
(6) 数据的更新
更新数据使用“update”语句和where子句实现,语法格式如下:
update 表名称
set 字段1 = 数值1,
字段2 = 数值2,
字段3 = 数值3.. ..
where 条件
例如,将表users中UserID为1的用户名称改为“小华”:
update users set UserName = "小华" where UserID = 1
(7) 数据的查询
查询数据使用“select”语句实现,语法格式如下:
select 字段1,字段2,......字段n from 表名称
还可以使用select语句和where子句实现条件查询,语法格式如下:
select 字段1,字段2,......字段n from 表名称 where 条件
例如,从users表中查询所有的数据:
use dbtest;
select * from users