专栏首页python3Python 3 进阶 —— 使用 P

Python 3 进阶 —— 使用 P

PyMySQL 是一个纯 Python 实现的 MySQL 客户端操作库,支持事务、存储过程、批量执行等。

PyMySQL 遵循 Python 数据库 API v2.0 规范,并包含了 pure-Python MySQL 客户端库。

安装

pip install PyMySQL

创建数据库连接

import pymysql

connection = pymysql.connect(host='localhost',
                             port=3306,
                             user='root',
                             password='root',
                             db='demo',
                             charset='utf8')

参数列表:

参数

描述

host

数据库服务器地址,默认 localhost

user

用户名,默认为当前程序运行用户

password

登录密码,默认为空字符串

database

默认操作的数据库

port

数据库端口,默认为 3306

bind_address

当客户端有多个网络接口时,指定连接到主机的接口。参数可以是主机名或IP地址。

unix_socket

unix 套接字地址,区别于 host 连接

read_timeout

读取数据超时时间,单位秒,默认无限制

write_timeout

写入数据超时时间,单位秒,默认无限制

charset

数据库编码

sql_mode

指定默认的 SQL_MODE

read_default_file

Specifies my.cnf file to read these parameters from under the [client] section.

conv

Conversion dictionary to use instead of the default one. This is used to provide custom marshalling and unmarshaling of types.

use_unicode

Whether or not to default to unicode strings. This option defaults to true for Py3k.

client_flag

Custom flags to send to MySQL. Find potential values in constants.CLIENT.

cursorclass

设置默认的游标类型

init_command

当连接建立完成之后执行的初始化 SQL 语句

connect_timeout

连接超时时间,默认 10,最小 1,最大 31536000

ssl

A dict of arguments similar to mysql_ssl_set()'s parameters. For now the capath and cipher arguments are not supported.

read_default_group

Group to read from in the configuration file.

compress

Not supported

named_pipe

Not supported

autocommit

是否自动提交,默认不自动提交,参数值为 None 表示以服务器为准

local_infile

Boolean to enable the use of LOAD DATA LOCAL command. (default: False)

max_allowed_packet

发送给服务器的最大数据量,默认为 16MB

defer_connect

是否惰性连接,默认为立即连接

auth_plugin_map

A dict of plugin names to a class that processes that plugin. The class will take the Connection object as the argument to the constructor. The class needs an authenticate method taking an authentication packet as an argument. For the dialog plugin, a prompt(echo, prompt) method can be used (if no authenticate method) for returning a string from the user. (experimental)

server_public_key

SHA256 authenticaiton plugin public key value. (default: None)

db

参数 database 的别名

passwd

参数 password 的别名

binary_prefix

Add _binary prefix on bytes and bytearray. (default: False)

执行 SQL

  • cursor.execute(sql, args) 执行单条 SQL # 获取游标 cursor = connection.cursor() # 创建数据表 effect_row = cursor.execute(''' CREATE TABLE `users` ( `name` varchar(32) NOT NULL, `age` int(10) unsigned NOT NULL DEFAULT '0', PRIMARY KEY (`name`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 ''') # 插入数据(元组或列表) effect_row = cursor.execute('INSERT INTO `users` (`name`, `age`) VALUES (%s, %s)', ('mary', 18)) # 插入数据(字典) info = {'name': 'fake', 'age': 15} effect_row = cursor.execute('INSERT INTO `users` (`name`, `age`) VALUES (%(name)s, %(age)s)', info) connection.commit()
  • executemany(sql, args) 批量执行 SQL # 获取游标 cursor = connection.cursor() # 批量插入 effect_row = cursor.executemany( 'INSERT INTO `users` (`name`, `age`) VALUES (%s, %s) ON DUPLICATE KEY UPDATE age=VALUES(age)', [ ('hello', 13), ('fake', 28), ]) connection.commit()

注意:INSERT、UPDATE、DELETE 等修改数据的语句需手动执行connection.commit()完成对数据修改的提交。

获取自增 ID

cursor.lastrowid

查询数据

# 执行查询 SQL
cursor.execute('SELECT * FROM `users`')

# 获取单条数据
cursor.fetchone()

# 获取前N条数据
cursor.fetchmany(3)

# 获取所有数据
cursor.fetchall()

游标控制

所有的数据查询操作均基于游标,我们可以通过cursor.scroll(num, mode)控制游标的位置。

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

设置游标类型

查询时,默认返回的数据类型为元组,可以自定义设置返回类型。支持5种游标类型:

  • Cursor: 默认,元组类型
  • DictCursor: 字典类型
  • DictCursorMixin: 支持自定义的游标类型,需先自定义才可使用
  • SSCursor: 无缓冲元组类型
  • SSDictCursor: 无缓冲字典类型

无缓冲游标类型,适用于数据量很大,一次性返回太慢,或者服务端带宽较小时。源码注释:

Unbuffered Cursor, mainly useful for queries that return a lot of data, or for connections to remote servers over a slow network.Instead of copying every row of data into a buffer, this will fetch rows as needed. The upside of this is the client uses much less memory, and rows are returned much faster when traveling over a slow network or if the result set is very big. There are limitations, though. The MySQL protocol doesn't support returning the total number of rows, so the only way to tell how many rows there are is to iterate over every row returned. Also, it currently isn't possible to scroll backwards, as only the current row is held in memory.

创建连接时,通过 cursorclass 参数指定类型:

connection = pymysql.connect(host='localhost',
                             user='root',
                             password='root',
                             db='demo',
                             charset='utf8',
                             cursorclass=pymysql.cursors.DictCursor)

也可以在创建游标时指定类型:

cursor = connection.cursor(cursor=pymysql.cursors.DictCursor)

事务处理

  • 开启事务

connection.begin()

  • 提交修改

connection.commit()

  • 回滚事务

connection.rollback()

防 SQL 注入

  • 转义特殊字符 connection.escape_string(str)
  • 参数化语句 支持传入参数进行自动转义、格式化 SQL 语句,以避免 SQL 注入等安全问题。
# 插入数据(元组或列表)
effect_row = cursor.execute('INSERT INTO `users` (`name`, `age`) VALUES (%s, %s)', ('mary', 18))

# 插入数据(字典)
info = {'name': 'fake', 'age': 15}
effect_row = cursor.execute('INSERT INTO `users` (`name`, `age`) VALUES (%(name)s, %(age)s)', info)

# 批量插入
effect_row = cursor.executemany(
    'INSERT INTO `users` (`name`, `age`) VALUES (%s, %s) ON DUPLICATE KEY UPDATE age=VALUES(age)', [
        ('hello', 13),
        ('fake', 28),
    ])

参考资料


原文地址: https://shockerli.net/post/py... 更多文章请访问我的个人博客: https://shockerli.net

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • Appium Python API 中文

    2. current_context current_context(self):

    py3study
  • 习题16:读写文件

    小技巧就是可以让你的脚本一部分一部分地运行起来,也方便排查错误,以此类推,直到整个脚本运行起来为止

    py3study
  • Python操作MySQL(2)

    py3study
  • AVFoundation 框架初探究(二)

    接着第一篇总结 ----       系列第一篇地址:AVFoundation 框架初探究(一)       在第一篇的文章中,我们总结了主要有下面几个点的知识...

    Mr.RisingSun
  • 什么是Cadence call

    这个网友给出了最佳答案: https://answers.yahoo.com/question/index?qid=20091228152849AAkwALW

    Jerry Wang
  • 自动解码图(CS ML)

    我们提出了一种根据经验指定的分布合成新图结构的方法。 生成模型是一种自动解码器,可学习从潜在代码合成图。 结合潜在代码的经验分布来学习图综合模型。 使用经过训练...

    蔡秋纯
  • React源码解析之RootFiber

    一、Fiber的含义和作用 (1)每一个ReactElement对应一个Fiber对象

    进击的小进进
  • 具有语言偏差的传感器,用于端到端普通话-英语语码转换语音识别(CS SD)

    近年来,语言识别信息被用于提高端到端码转换语音识别的性能。然而,以往的工作都是使用额外的语言识别(LID)模型作为辅助模块,这导致了系统的复杂性。在这项工作中,...

    用户6853689
  • java解析页面包jsoup

    http://www.open-open.com/jsoup/parsing-a-document.htm

    sanmutongzi
  • 详述 Elasticsearch 集群的搭建步骤及方法

    版权声明:Follow your heart and intuition. https://...

    CG国斌

扫码关注云+社区

领取腾讯云代金券