一、PyMySQL操作数据库

首先是要安装PyMysql:pip install pymysql

查看是否安装成功PyMysql:pip list

二、操作数据库的基本流程

1、导包

2、创建连接

3、获取游标

4、执行sql

5、关闭游标

6、关闭数据库

三、具体步骤解析

1、导包

import pymysql

2、创建连接

conn = pymysql.connect(host="数据库服务器地址", port=端口号, user="用户名",
passwd="密码", database="数据库名称", charset="utf8")

3、获取游标

cursor = conn.cursor()

4.执行sql语句

cursor.excute(sql)

#获取查询结果

cursor.fetchone() 当前位置,获取第一行

cursor.fetchmany(n) 当前位置,获取第n行数据

cursor.fetchall() 当前位置,获取所有数据

#cursor属性 rownumber  标识游标当前位置 所以要定义属性:cursor.rownumber=0

conn.commit() #提交事务

5.关闭游标对象

cursor.close()

6.关闭数据库连接

conn.close()

事务:是关系型数据库特有的概念。(mysql)
事务,当对数据库有一系列操作,并且需要这些操作同时成功或同时失败时。需要将这一系列操作看成一个整体,以事务的形式进行处理。

事务提交
手动提交:conn.commit()
手动提交后,对数据库的修改生效
事务回滚
手动回滚:conn.rollback()
手动回滚,撤销对数据库的修改
自动回滚
pymysql 在关闭数据库连接时,默认是自动回滚的

数据库工具封装

1. 封装一个类,提供2个方法:查询一条记录和执行 增删改 的sql
2. 把创建数据库连接和关闭数据库连接单独封装成方法
3. 创建数据库连接和关闭数据库连接,没有必要给用户使用,可以定义为私有方法

 @classmethod
  def __get_conn(cls):
    pass
  @classmethod
  def __close_conn(cls):
    pass

4. 为了用户更方便调用,不需要创建示例,直接使用查询方法,将所有的方法定位为类方法

# 查询一条记录
  def select_one(cls):
    pass
  # 执行 增删改 sql
  @classmethod
  def uid_db(cls):
    pass

 定义创建数据库连接方法

 定义关闭数据库连接方法

定义查询一条记录的封装方法

 定义数据库增删改查的操作的封装方法

 

 

来源:Nicole sun

物联沃分享整理
物联沃-IOTWORD物联网 » Python里面数据库连接

发表评论