python学习——pymql
基础
- pymql是第三方库，需要安装PYMYSQL
- 使用是要导入pymysql模块
步骤(以查询为例)
- 第一步：使用
connect()打开数据库，需要三个参数，分别为：host、user、password。host为数据库的ip地址；user为登录名；password为登录密码。database为选填参数，是数据库
- 第二步：
cursor() 方法创建一个游标对象 cursor，不需要传参
- 第三步：
execute() 方法执行 SQL 查询 ，需要传入dql语句的参数
- 第四步：使用
fetchone() 方法获取单条数据，可打印；用fetchmany()可获取多条数据，需要传入条数参数；用fetchall()可以获取全部数据
- 第五步：关闭数据库
close()
- 代码示例：
import pymysql
class DbSql:
def __init__(self,host,user,password,database):
self.host = host
self.user = user
self.password = password
self.database = database
#链接数据库
self.db = pymysql.connect(host=host,user=user,
password=password,database=database)
def do_mysql(self,sql):
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = self.db.cursor()
# 使用 execute() 方法执行 SQL 查询
cursor.execute(sql)
# 使用 fetchone() 方法获取单条数据.
data_one = cursor.fetchone()#获取一条数据
data_money = cursor.fetchmany(5)#获取多条数据，需要传入条数参数
data_all = cursor.fetchall()#获取全部数据
#打印数据
print("一条结果：",data_one)
print("==================分割线==================")
print("多条结果：",data_money)
print("==================分割线==================")
print("全部结果：",data_all)
#关闭数据库
self.db.close()
创建、插入、更新和删除
创建
- 创建的步骤和查询差不多，只是将sql语句变为创建数据库的sql即可
-
- 第一步：使用
connect()打开数据库，需要三个参数，分别为：host、user、password。host为数据库的ip地址；user为登录名；password为登录密码。database为选填参数，是数据库
- 第二步：
cursor() 方法创建一个游标对象 cursor，不需要传参
- 第三步：
execute() 方法执行 SQL 查询 ，创建喊出数据库的语句，可使用if判断，如果数据库存在就删除
- 第四步：
execute() 方法执行 SQL 查询 ，传入创建数据库的sql语句
- 第五步：关闭数据库
close()
- 代码示例：
import pymysql
class DbSql:
def __init__(self,host,user,password,database):
self.host = host
self.user = user
self.password = password
self.database = database
#链接数据库
self.db = pymysql.connect(host=host,user=user,
password=password,database=database)
def do_mysql(self,sql):
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = self.db.cursor()
# 使用 execute() 方法执行 SQL，如果表存在则删除
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
# 使用 execute() 方法执行 SQL 查询
cursor.execute(sql)#sql为创建数据库的sql
#关闭数据库
self.db.close()
插入、更新与删除
-
- 第一步：使用
connect()打开数据库，需要三个参数，分别为：host、user、password。host为数据库的ip地址；user为登录名；password为登录密码。database为选填参数，是数据库
- 第二步：
cursor() 方法创建一个游标对象 cursor，不需要传参
- 第三步：
execute() 方法执行 SQL 查询 ，sql语句其插入数据、更新数据或者删除数据的sql
- 第四步：
commit()方法，提交sql到数据库去执行，需要用到异常处理，如果发生问题就回滚（rollback()）
- 第五步：关闭数据库
close()
- 代码示例：
import pymysql
class DbSql:
def __init__(self,host,user,password,database):
self.host = host
self.user = user
self.password = password
self.database = database
#链接数据库
self.db = pymysql.connect(host=host,user=user,
password=password,database=database)
def do_mysql(self,sql):
# 使用 cursor() 方法创建一个游标对象 cursor
cursor = self.db.cursor()
try:
# 执行sql语句
cursor.execute(sql)#sql为插入数据、更新数据或者删除数据的语句
# 提交到数据库执行
self.db.commit()
except:
# 如果发生错误则回滚
self.db.rollback()
#关闭数据库
self.db.close()