PyMySQL链接MySQL的一些事务操作

"""创建mysql数据库"""
import pymysql
# 数据库连接引用类
from pymysql.connections import Connection
# 游标操作类
from pymysql.cursors import Cursor


# 通过pymysql的方法connect()方法声明一个MySQL连接对象conn。分别传入本地IP、用户名、密码、默认端口
conn = pymysql.connect(host="localhost", user="root", password="yang123", port=3306)
# <class 'pymysql.connections.Connection'>  生成连接对象Connection的实例
print(type(conn))
# 调用连接实例对象的cursor()方法获得MySQL的操作游标
cursor = conn.cursor()
# <class 'pymysql.cursors.Cursor'>   生成游标对象Cursor的实例
print(type(cursor))
# 调用游标实例对象的execute()方法执行sql语句，查看数据库版本
cursor.execute("select version()")
# 调用游标实例对象的fetchone()方法获得数据库版本的信息
data = cursor.fetchone()
# 打印数据库版本信息
print("database version:", data)
# 利用游标执行sql语句创建数据库并设置数据库编码utf8
cursor.execute("create database demo default character set utf8")
# 关闭连接
conn.close()
# 关闭游标
cursor.close()

View Code