Python数据库编程之pymysql详解

Python数据库编程之pymysql

学习之前务必安装MySQL并已启动相关服务。

一、pymsql的安装

在python3的环境中直接使用以下命令即可：

pip install pymysql
#或者
pip3 install pymysql

安装完毕后可使用以下命令查看：

pip list | grep PyMySQL
#注意大小写

结果如下：

二、连接数据库

pymysql连接数据库使用的是 pymsql.connect() 函数，其常用参数如下：

连接完数据库后，需要创建一个游标对象，模块会通过游标对象来执行sql语句以及获取查询结果，接下来直接通过代码展示各方法。
示例：

import pymysql

db = pymysql.connect(
   host="localhost",
   port=3306,
   user='root',    #在这里输入用户名
   password='888888',     #在这里输入密码
   charset='utf8mb4'
   ) #连接数据库

cursor = db.cursor() #创建游标对象

sql = 'show databases' #sql语句

cursor.execute(sql)  #执行sql语句

one = cursor.fetchone()  #获取一条数据
print('one:',one)

many = cursor.fetchmany(3) #获取指定条数的数据，不写默认为1
print('many:',many)

all = cursor.fetchall() #获取全部数据
print('all:',all)

cursor.close()  
db.close()  #关闭数据库的连接

运行结果：

one: ('coldbox',)
many: (('coldboxtest',), ('db_student',), ('information_schema',))
all: (('mysql',), ('performance_schema',), ('sys',), ('test',), ('wan',))

从结果可以看出，fetchone()，fetchmany(size)，fetchall() 三个函数返回值都是元组，但是fetchone()返回的是单个元组，另外两个返回的都是元组的嵌套。

三、创建和管理数据库

使用游标对象来执行创建和删除数据库的sql语句示例：

import pymysql

db = pymysql.connect(
   host="localhost",
   port=3306,
   user='root',    #在这里输入用户名
   password='888888',     #在这里输入密码
   charset='utf8mb4'
   )

cursor = db.cursor() #创建游标对象

try:

sql = 'show databases'
   cursor.execute(sql)
   print('未创建数据库前：',cursor.fetchall()) #获取创建数据库前全部数据库

dbname = 'justtest'
   sql = 'create database if not exists ％s'％(dbname) #创建数据库
   cursor.execute(sql)
   sql = 'show databases'
   cursor.execute(sql)
   print('创建新的数据库后：',cursor.fetchall()) #获取创建数据库后全部数据库

sql = 'drop database if exists ％s'％(dbname) #删除数据库
   cursor.execute(sql)
   sql = 'show databases'
   cursor.execute(sql)
   print('删除新的数据库后：',cursor.fetchall()) #获取删除数据库后全部数据库

except Exception as e:
   print(e)
   db.rollback()  #回滚事务

finally:
   cursor.close()
   db.close()  #关闭数据库连接

运行结果：

未创建数据库前： (('coldbox',), ('coldboxtest',), ('db_student',), ('information_schema',), ('mysql',), ('performance_schema',), ('sys',), ('test',), ('wan',))
创建新的数据库后： (('coldbox',), ('coldboxtest',), ('db_student',), ('information_schema',), ('justtest',), ('mysql',), ('performance_schema',), ('sys',), ('test',), ('wan',))
删除新的数据库后： (('coldbox',), ('coldboxtest',), ('db_student',), ('information_schema',), ('mysql',), ('performance_schema',), ('sys',), ('test',), ('wan',))

四、创建和管理表

使用游标对象来执行创建和管理表的sql语句示例：

import pymysql

db = pymysql.connect(
   host="localhost",
   port=3306,
   user='root',    #在这里输入用户名
   password='888888',     #在这里输入密码
   charset='utf8mb4',
   database='justtest'     #指定操作的数据库
   )

cursor = db.cursor() #创建游标对象

try:

tableName = 'user'
   sql = 'create table  ％s (id varchar(20) not null, name varchar(20) not null, primary key(id))'％(tableName)
   cursor.execute(sql)     #执行sql语句，创建表

sql = 'show tables'
   cursor.execute(sql)
   print('显示创建的表:',cursor.fetchall())  #显示创建的表

sql = 'desc ％s'％(tableName)
   cursor.execute(sql)
   print('显示表结构:',cursor.fetchall())  #显示表结构

except Exception as e:
   print(e)
   db.rollback()  #回滚事务

finally:
   cursor.close()
   db.close()  #关闭数据库连接

运行结果：

显示创建的表: (('user',),)
显示表结构: (('id', 'varchar(20)', 'NO', 'PRI', None, ''), ('name', 'varchar(20)', 'NO', '', None, ''))

来源：https://blog.csdn.net/youngwyj/article/details/124699636