# -*- coding: utf-8 -*-
# @Time : 2023/5/15 19:50
# @Author : yanfa
# @user : yanfa
# @File : pymysql_.py
# @remark: 常用第三方库 pymysql
""""""
import sys
"""一、pymysql概述
1、python的数据库接口标准是Python DB-API
2、PyMySQL是从python连接到MYSQL数据库服务器的接口
3、PyMySQL的目标是成为MySQL的替代品
4、官方文档：http://pymysql.readthedocs.io/"""
"""二、pymysql安装
1、使用pip安装：pip install pymysql
2、使用pycharm界面安装"""
"""三、pymysql连接数据库
host：服务器地址
user：用户名
password：密码
database：数据库名称
charset：编码方式，推荐使用utf8mb4
"""
# 1、导入包
import pymysql
# 2、建立连接
conn=pymysql.connect(host="主机地址",
user="用户名",
password="密码",
database="数据库名称",
charset="utf8mb4")
# 3、关闭连接
conn.close()
"""封装获取连接的函数"""
def get_conn():
conn=pymysql.connect(host="主机地址",
user="用户名",
password="密码",
database="数据库名称",
charset="utf8mb4")
return conn
"""四、pymysql入门实例
获取连接对象：打开、关闭
获取游标对象：执行sql-execute()、查询记录、关闭游标"""
# def test_demo():
# # 1、获取连接对象
# conn=get_conn()
# # 2、获取游标对象
# cursor=conn.cursor()
# # 3、执行sql
# cursor.execute("select * from table")
# # 4、查询结果
# result1=cursor.fetchone() #获取第一条
# result2=cursor.fetchall() #获取全部
# result3=cursor.fetchmany(10) #获取前10条
# # 5、关闭游标
# cursor.close()
# # 6、关闭连接
# conn.close()
"""五、常用数据库操作
CRUD操作：
1）创建表：
2）插入记录
3）查询记录
4）更新记录
5）删除记录
执行事务：
1)提交：commit
2)回滚：rollback"""
# 5.1 创建表testcase
def test_create():
conn=get_conn() #获取连接
cursor=conn.cursor() #获取游标
sql="create table `testcase`(" \
"`id` int(11) not null auto_increment" \
"`name` varchar(255) collale utf8_bin not null)"
cursor.execute(sql) #执行建表语句
cursor.close() #关闭游标
conn.close() #关闭连接
# 5.2 插入记录
def test_insert():
conn=get_conn() #获取连接
cursor=conn.cursor() #获取游标
sql="insert into testcase (id,name) values('123','yanfa')"
cursor.execute(sql) #执行建表语句
conn.commit() #提交
cursor.close() #关闭游标
conn.close() #关闭连接
# 5.3 执行事务
def test_insert1():
conn=get_conn() #获取连接
cursor=conn.cursor() #获取游标
sql="insert into testcase (id,name) values('123','yanfa')"
try:
cursor.execute(sql)
conn.commit()
except:
conn.rollback()
finally:
cursor.close() # 关闭游标
conn.close()
# 5.4 查询操作
def test_retrieve():
conn=get_conn() #获取连接
cursor=conn.cursor() #获取游标
sql="select * from testcase "
# 捕获异常
try:
cursor.execute(sql)
record=cursor.fetchone()
print(record)
except Exception as e:
print(sys.exc_info()) #打印错误信息
finally:
cursor.close() # 关闭游标
conn.close() # 关闭连接
# 5.5 更新操作
def test_update():
conn=get_conn() #获取连接
cursor=conn.cursor() #获取游标
sql="update testcase set name='lisi' where name='yanfa'"
# 捕获异常
try:
cursor.execute(sql) #执行sql
conn.commit() #提交事务
except:
conn.rollback() # 回滚事务
finally:
cursor.close() # 关闭游标
conn.close() # 关闭连接
# 5.6 删除
def test_delete():
conn=get_conn() #获取连接
cursor=conn.cursor() #获取游标
sql="delete from testcase where name='yanfa'"
# 捕获异常
try:
cursor.execute(sql) #执行sql
conn.commit() #提交事务
except:
conn.rollback() # 回滚事务
finally:
cursor.close() # 关闭游标
conn.close() # 关闭连接