首页 > 代码库 > pymysql 操作数据库

pymysql 操作数据库

2024-08-24 15:30:41   218人阅读

一.简介 

　　pymsql是Python中操作MySQL的模块，其使用方法和MySQLdb几乎相同，但目前pymysql支持python3.x而后者不支持3.x版本

　　其执行语句与sql源码相似

二.使用

1.安装

 　　pip install pymysql

2.使用操作

　　先来一例完整的连接加基本的操作

import pymysql  # 创建连接conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘t1‘)# 创建游标cursor = conn.cursor()  # 执行SQL，并返回收影响行数effect_row = cursor.execute("update hosts set host = ‘1.1.1.2‘")  # 执行SQL，并返回受影响行数#effect_row = cursor.execute("update hosts set host = ‘1.1.1.2‘ where nid > %s", (1,))  # 执行SQL，并返回受影响行数#effect_row = cursor.executemany("insert into hosts(host,color_id)values(%s,%s)", [("1.1.1.11",1),("1.1.1.11",2)])    # 提交，不然无法保存新建或者修改的数据conn.commit()  # 关闭游标cursor.close()# 关闭连接conn.close()

向数据库插入数据，使用try语句，当出现异常是主动回滚

#!/usr/bin/python3import pymysql# 打开数据库连接db = pymysql.connect("localhost","testuser","test123","TESTDB" )# 使用cursor()方法获取操作游标 cursor = db.cursor()# SQL 插入语句sql = """INSERT INTO EMPLOYEE(FIRST_NAME,         LAST_NAME, AGE, SEX, INCOME)         VALUES (‘Mac‘, ‘Mohan‘, 20, ‘M‘, 2000)"""try:   # 执行sql语句   cursor.execute(sql)   # 提交到数据库执行   db.commit()except:   # 如果发生错误则回滚   db.rollback()# 关闭数据库连接db.close()

3.向数据表中插入多条数据，使用executemany方法，在生产环境中插入多条数据 ，在后台中获取数据后，以列表的形式传入语句（[(‘v1‘,‘v2‘),(‘v3‘,‘v4‘)]）

# 创建连接conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘t1‘)# 创建游标cur = conn.cursor() if request.method == "POST":        title = request.POST.get("title")        title_en = request.POST.get("title_en")        content = request.POST.get("content")        content_en = request.POST.get("content_en")        notification_type =request.POST.get("notification_type").strip()        user_list = request.POST.get("user_list")        updated_datetime = datetime.now()        created_datetime = datetime.now()        values_list = []         for user in user_id_list:                temp = updated_datetime,created_datetime,title,title_en,content,content_en,notification_type,user[‘id‘]                values_list.append((temp))
　　　　　try:        　　cur.executemany(‘‘‘insert into app_notification(updated_datetime, created_datetime, title, title_en,                                  content, content_en, notification_type, is_read, recipient_id)                      values(%s, %s, %s, %s, %s, %s, %s, 0, %s)‘‘‘,values_list)            conn.commit()            conn.close()
　　　　　
　　　　except Exception as err:
    　　　　conn.rollback()
    　　　　logging.error(err)
    　　　　logging.error(traceback.format_exc())
    　　　　conn.close()
# 获取最新自增ID
　　new_id = cursor.lastrowid

4.数据库查询操作

Python查询Mysql使用 fetchone() 方法获取单条数据, 使用fetchall() 方法获取多条数据。

  • fetchone(): 该方法获取下一个查询结果集。结果集是一个对象
  • fetchall(): 接收全部的返回结果行.
  • rowcount: 这是一个只读属性，并返回执行execute()方法后影响的行数。
import pymysql  conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘t1‘)cursor = conn.cursor()cursor.execute("select * from hosts")  # 获取第一行数据row_1 = cursor.fetchone()  # 获取前n行数据# row_2 = cursor.fetchmany(3)# 获取所有数据# row_3 = cursor.fetchall()  conn.commit()cursor.close()conn.close()

注：在fetch数据时按照顺序进行，可以使用cursor.scroll(num,mode)来移动游标位置，如：

  • cursor.scroll(1,mode=‘relative‘)  # 相对当前位置移动
  • cursor.scroll(2,mode=‘absolute‘) # 相对绝对位置移动

5。fetch数据类型

　　关于默认获取的数据是元祖类型，如果想要或者字典类型的数据，即：

#!/usr/bin/env python# -*- coding:utf-8 -*-import pymysql  conn = pymysql.connect(host=‘127.0.0.1‘, port=3306, user=‘root‘, passwd=‘123‘, db=‘t1‘)  # 游标设置为字典类型cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)r = cursor.execute("call p1()")  result = cursor.fetchone()  conn.commit()cursor.close()conn.close()

错误处理

DB API中定义了一些数据库操作的错误及异常，下表列出了这些错误和异常:

异常描述
Warning当有严重警告时触发，例如插入数据是被截断等等。必须是 StandardError 的子类。
Error警告以外所有其他错误类。必须是 StandardError 的子类。
InterfaceError当有数据库接口模块本身的错误（而不是数据库的错误）发生时触发。 必须是Error的子类。
DatabaseError和数据库有关的错误发生时触发。 必须是Error的子类。
DataError当有数据处理时的错误发生时触发，例如：除零错误，数据超范围等等。 必须是DatabaseError的子类。
OperationalError指非用户控制的，而是操作数据库时发生的错误。例如：连接意外断开、 数据库名未找到、事务处理失败、内存分配错误等等操作数据库是发生的错误。 必须是DatabaseError的子类。
IntegrityError完整性相关的错误，例如外键检查失败等。必须是DatabaseError子类。
InternalError数据库的内部错误，例如游标（cursor）失效了、事务同步失败等等。 必须是DatabaseError子类。
ProgrammingError程序错误，例如数据表（table）没找到或已存在、SQL语句语法错误、 参数数量错误等等。必须是DatabaseError的子类。

pymysql 操作数据库


联系
我们