AI 助理
备案控制台
开发者社区 数据库 文章 正文

12_mysql与Python交互_2

2022-11-10 80
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
本文涉及的产品
云数据库 RDS MySQL，集群系列 2核4GB
推荐场景：
搭建个人博客
RDS MySQL Serverless 基础系列，0.5-2RCU 50GB
推荐场景：
学生管理系统数据库设计 搭建个人博客
云数据库 RDS PostgreSQL，集群系列 2核4GB
简介： 12_mysql与Python交互_2

[TOC]

一、Python 中操作 MySQL 步骤

1.1 引入模块

image-20220724000647250.png

  • 在py文件中引入pymysql模块
from pymysql import *

1.2 Connection 对象

  • 用于建立与数据库的连接
  • 创建对象：调用connect()方法
conn=connect(参数列表)
  • 参数host：连接的mysql主机，如果本机是'localhost'
  • 参数port：连接的mysql主机的端口，默认是3306
  • 参数database：数据库的名称
  • 参数user：连接的用户名
  • 参数password：连接的密码
  • 参数charset：通信采用的编码方式，推荐使用utf8

1.2.1 对象的方法

  • close()关闭连接
  • commit()提交
  • cursor()返回Cursor对象，用于执行sql语句并获得结果

1.3 Cursor对象

  • 用于执行sql语句，使用频度最高的语句为select、insert、update、delete
  • 获取Cursor对象：调用Connection对象的cursor()方法
cs1=conn.cursor()

1.3.1 对象的方法

  • close()关闭
  • execute(operation [, parameters ])执行语句，返回受影响的行数，主要用于执行insert、update、delete语句，也可以执行create、alter、drop等语句
  • fetchone()执行查询语句时，获取查询结果集的第一个行数据，返回一个元组
  • fetchall()执行查询时，获取结果集的所有行，一行构成一个元组，再将这些元组装入一个元组返回
cs1 =  conn.cursor()
cs1.execute("select * from goods")  # 返回行数

# (1, 'r510vc 15.6英寸笔记本', '笔记本', '华硕', Decimal('3399.000'), b'\x01', b'\x00')
# 一条一条取，返回值为元组
cs1.fetchone() 

# 根据参数取值，参数为3，取3行数据
cs1.fetchmany(3)

# 取所有行
cs1.fetchall()

1.3.2 对象的属性

  • rowcount只读属性，表示最近一次execute()执行后受影响的行数
  • connection获得当前连接对象

二、增删改查

2.1 增删改

记得提交：conn.commit()

如果增删改查错误：回滚conn.rollback()

from pymysql import *

def main():
    # 创建Connection连接
    conn = connect(host='localhost',port=3306,database='jing_dong',user='root',password='mysql',charset='utf8')
    # 获得Cursor对象
    cs1 = conn.cursor()
    # 执行insert语句，并返回受影响的行数：添加一条数据
    # 增加
    count = cs1.execute('insert into goods_cates(name) values("硬盘")')
    #打印受影响的行数
    print(count)

    count = cs1.execute('insert into goods_cates(name) values("光盘")')
    print(count)

    # # 更新
    # count = cs1.execute('update goods_cates set name="机械硬盘" where name="硬盘"')
    # # 删除
    # count = cs1.execute('delete from goods_cates where id=6')

    # 提交之前的操作，如果之前已经之执行过多次的execute，那么就都进行提交
    conn.commit()

    # 关闭Cursor对象
    cs1.close()
    # 关闭Connection对象
    conn.close()

if __name__ == '__main__':
    main()

2.2 查询一行数据

from pymysql import *

def main():
    # 创建Connection连接，localhost=127.0.0.1
    conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset='utf8')
    # 获得Cursor对象
    cs1 = conn.cursor()
    # 执行select语句，并返回受影响的行数：查询一条数据
    count = cs1.execute('select id,name from goods where id>=4')
    # 打印受影响的行数
    print("查询到%d条数据:" % count)

    for i in range(count):
        # 获取查询的结果
        result = cs1.fetchone()
        # 打印查询的结果
        print(result)
        # 获取查询的结果

    # 关闭Cursor对象
    cs1.close()
    conn.close()

if __name__ == '__main__':
    main()

2.3 查询多行数据

from pymysql import *

def main():
    # 创建Connection连接
    conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset='utf8')
    # 获得Cursor对象
    cs1 = conn.cursor()
    # 执行select语句，并返回受影响的行数：查询一条数据
    count = cs1.execute('select id,name from goods where id>=4')
    # 打印受影响的行数
    print("查询到%d条数据:" % count)

    # for i in range(count):
    #     # 获取查询的结果
    #     result = cs1.fetchone()
    #     # 打印查询的结果
    #     print(result)
    #     # 获取查询的结果

    result = cs1.fetchall()
    print(result)

    # 关闭Cursor对象
    cs1.close()
    conn.close()

if __name__ == '__main__':
    main()

2.4 案例

from pymysql import connect


class JD(object):
    def __init__(self):
        # 创建Connection连接
        self.conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong', charset='utf8')
        # 获得Cursor对象
        self.cursor = self.conn.cursor()

    def __del__(self):
        # 关闭Cursor对象
        self.cursor.close()
        self.conn.close()

    def execute_sql(self, sql):
        self.cursor.execute(sql)
        for temp in self.cursor.fetchall():
            print(temp)  # 每行的元组

    def show_all_items(self):
        """显示所有的商品"""
        sql = "select * from goods;"
        self.execute_sql(sql)

    def show_cates(self):
        """显示商品分类"""
        sql = "select name from goods_cates;"
        self.execute_sql(sql)

    def show_brands(self):
        """显示商品分类"""
        sql = "select name from goods_brands;"
        self.execute_sql(sql)

    @staticmethod
    def print_menu():
        print("....京东....")
        print("1:所有的商品")
        print("2：所有的商品分类")
        print("3:所有的商品品牌分类")
        num = input("请输入功能对应的序号：")
        return num

    def run(self):
        while True:
            num = self.print_menu()
            if num == "1":  # input输入的都是字符串
                # 查询所有商品
                self.show_all_items()
            elif num == "2":
                # 查询分类
                self.show_cates()
            elif num == "3":
                # 查询品牌分类
                self.show_brands()
            else:
                print("输入有误，请重新输入...")


def main():
    # 1.创建一个京东商城对象
    jd = JD()

    # 2.调用这个对象的润run方法，让其运行
    jd.run()


if __name__ == "__main__":
    main()

三、参数化(防止sql注入)

  • sql语句的参数化，可以有效防止sql注入。
  • 注意：此处不同于python的字符串格式化，全部使用%s占位。
  • sql注入：用户输入的字符串和你数据库设定的偏偏能配对。
from pymysql import *

def main():

    find_name = input("请输入物品名称：")

    # 创建Connection连接
    conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset='utf8')
    # 获得Cursor对象
    cs1 = conn.cursor()


    # # 非安全的方式
    # # 输入 " or 1=1 or "   (双引号也要输入)
    # sql = 'select * from goods where name="%s"' % find_name
    # print("""===>%s<====""" % sql)
    # # 执行select语句，并返回受影响的行数：查询所有数据
    # count = cs1.execute(sql)

    # 安全的方式
    # 构造参数列表
    params = [find_name]
    # 执行select语句，并返回受影响的行数：查询所有数据
    count = cs1.execute('select * from goods where name=%s', params)
    # 注意：
    # 如果要是有多个参数，需要进行参数化
    # 那么params = [数值1, 数值2....]，此时sql语句中有多个%s即可 

    # 打印受影响的行数
    print(count)
    # 获取查询的结果
    # result = cs1.fetchone()
    result = cs1.fetchall()
    # 打印查询的结果
    print(result)
    
    # 关闭Cursor对象
    cs1.close()
    # 关闭Connection对象
    conn.close()

if __name__ == '__main__':
    main()

3.1 sql注入

from pymysql import connect


class JD(object):
    def __init__(self):
        # 创建Connection连接
        self.conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong',charset='utf8')
        # 获得Cursor对象
        self.cursor = self.conn.cursor()

    def __del__(self):
        # 关闭Cursor对象
        self.cursor.close()
        self.conn.close()

    def execute_sql(self, sql):
        self.cursor.execute(sql)
        for temp in self.cursor.fetchall():
            print(temp)  # 每行的元组

    def show_all_items(self):
        """显示所有的商品"""
        sql = "select * from goods;"
        self.execute_sql(sql)

    def show_cates(self):
        """显示商品分类"""
        sql = "select name from goods_cates;"
        self.execute_sql(sql)

    def show_brands(self):
        """显示商品分类"""
        sql = "select name from goods_brands;"
        self.execute_sql(sql)

    def get_info_by_name(self):
        find_name = input("请输入要查询的商品的名字：")
        sql = """" select * from goods where name = '%s'; """ % find_name
        print("------>%s<------" % sql)
        self.execute_sql(sql)


    @staticmethod
    def print_menu():
        print("....京东....")
        print("1:所有的商品")
        print("2：所有的商品分类")
        print("3:所有的商品品牌分类")
        print("4:根据名字查询一个商品")
        num = input("请输入功能对应的序号：")
        return num

    def run(self):
        while True:
            num = self.print_menu()
            if num == "1":  # input输入的都是字符串
                # 查询所有商品
                self.show_all_items()
            elif num == "2":
                # 查询分类
                self.show_cates()
            elif num == "3":
                # 查询品牌分类
                self.show_brands()
            elif num == "4":
                # 根据名字查询商品
                self.get_info_by_name()
            else:
                print("输入有误，请重新输入...")


def main():
    # 1.创建一个京东商城对象
    jd = JD()

    # 2.调用这个对象的润run方法，让其运行
    jd.run()


if __name__ == "__main__":
    main()

3.2 防止sql注入

from pymysql import connect


class JD(object):
    def __init__(self):
        # 创建Connection连接
        self.conn = connect(host='localhost', port=3306, user='root', password='mysql', database='jing_dong',charset='utf8')
        # 获得Cursor对象
        self.cursor = self.conn.cursor()

    def __del__(self):
        # 关闭Cursor对象
        self.cursor.close()
        self.conn.close()

    def execute_sql(self, sql):
        self.cursor.execute(sql)
        for temp in self.cursor.fetchall():
            print(temp)  # 每行的元组

    def show_all_items(self):
        """显示所有的商品"""
        sql = "select * from goods;"
        self.execute_sql(sql)

    def show_cates(self):
        """显示商品分类"""
        sql = "select name from goods_cates;"
        self.execute_sql(sql)

    def show_brands(self):
        """显示商品分类"""
        sql = "select name from goods_brands;"
        self.execute_sql(sql)

    def get_info_by_name(self):
        find_name = input("请输入要查询的商品的名字：")
        sql = "select * from goods name = %s"
        self.cursor.execute(sql, [find_name])
        print(self.cursor.fetchall())

    @staticmethod
    def print_menu():
        print("....京东....")
        print("1:所有的商品")
        print("2：所有的商品分类")
        print("3:所有的商品品牌分类")
        print("4:根据名字查询一个商品")
        num = input("请输入功能对应的序号：")
        return num

    def run(self):
        while True:
            num = self.print_menu()
            if num == "1":  # input输入的都是字符串
                # 查询所有商品
                self.show_all_items()
            elif num == "2":
                # 查询分类
                self.show_cates()
            elif num == "3":
                # 查询品牌分类
                self.show_brands()
            elif num == "4":
                # 根据名字查询商品
                self.get_info_by_name()
            else:
                print("输入有误，请重新输入...")


def main():
    # 1.创建一个京东商城对象
    jd = JD()

    # 2.调用这个对象的润run方法，让其运行
    jd.run()


if __name__ == "__main__":
    main()
文章标签：
云数据库 RDS MySQL 版
Python
SQL
关系型数据库
数据安全/隐私保护
MySQL
数据库
关键词：
云数据库 RDS MySQL 版交互
Python交互
MySQL Python交互
mysql Python
云数据库 RDS MySQL 版python
相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL，然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心，利用清洁计算为万物互联的新世界提供源源不断的能源动力，目前开服的区域包括中国（华北、华东、华南、香港）、新加坡、美国（美东、美西）、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程，来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品：云服务器ECS 云服务器 ECS（Elastic Compute Service）是一种弹性可伸缩的计算服务，助您降低 IT 成本，提升运维效率，使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
花海沙
目录
相关文章
gudanhero2018
|
4月前
|
SQL 关系型数据库 MySQL
MySQL操作利器——mysql-connector-python库详解
MySQL操作利器——mysql-connector-python库详解
gudanhero2018
1127 0
AIweker
|
1月前
|
关系型数据库 MySQL 数据库
Python处理数据库：MySQL与SQLite详解 | python小知识
本文详细介绍了如何使用Python操作MySQL和SQLite数据库，包括安装必要的库、连接数据库、执行增删改查等基本操作，适合初学者快速上手。
AIweker
264 15
xibeijing
|
1月前
|
SQL 关系型数据库 MySQL
PHP与MySQL的高效交互：从基础到实践####
本文深入探讨了PHP与MySQL数据库之间的高效交互技术，涵盖了从基础连接到高级查询优化的全过程。不同于传统的摘要概述，这里我们直接以一段精简代码示例作为引子，展示如何在PHP中实现与MySQL的快速连接与简单查询，随后文章将围绕这一核心，逐步展开详细讲解，旨在为读者提供一个从入门到精通的实战指南。 ```php <?php // 数据库配置信息 $servername = "localhost"; $username = "root"; $password = "password"; $dbname = "test_db"; // 创建连接 $conn = new mysqli($se
xibeijing
42 0
东方睿赢
|
2月前
|
前端开发 API 开发者
Python Web开发者必看！AJAX、Fetch API实战技巧，让前后端交互如丝般顺滑！
在Web开发中，前后端的高效交互是提升用户体验的关键。本文通过一个基于Flask框架的博客系统实战案例，详细介绍了如何使用AJAX和Fetch API实现不刷新页面查看评论的功能。从后端路由设置到前端请求处理，全面展示了这两种技术的应用技巧，帮助Python Web开发者提升项目质量和开发效率。
东方睿赢
68 1
zzy的aly
|
3月前
|
关系型数据库 MySQL 数据库
Mysql学习笔记(四)：Python与Mysql交互--实现增删改查
如何使用Python与MySQL数据库进行交互，实现增删改查等基本操作的教程。
zzy的aly
81 1
bruce_xiaowei
|
3月前
|
Python
Python软链接：Python 2与现代Python的交互
Python软链接：Python 2与现代Python的交互
bruce_xiaowei
40 4
龙大吉
|
3月前
|
前端开发 API 开发者
从零到精通，AJAX与Fetch API让你的Python Web前后端交互无所不能！
从零到精通，AJAX与Fetch API让你的Python Web前后端交互无所不能！
龙大吉
52 3
bruce_xiaowei
|
3月前
|
Python
Python软链接：Python 2与现代Python的交互
Python软链接：Python 2与现代Python的交互
bruce_xiaowei
30 0
希望_睿智
|
4月前
|
SQL 关系型数据库 MySQL
30天拿下Python之使用MySQL
30天拿下Python之使用MySQL
希望_睿智
59 0
gudanhero2018
|
4月前
|
关系型数据库 MySQL 数据管理
pymysql：Python操作MySQL数据库的又一利器
pymysql：Python操作MySQL数据库的又一利器
gudanhero2018
43 0

热门文章

最新文章

  • 1
    [python 技巧] 快速掌握Streamlit: python快速原型开发工具
  • 2
    农历节日倒计时：基于Python的公历与农历日期转换及节日查询小程序
  • 3
    10个必备Python调试技巧：从pdb到单元测试的开发效率提升指南
  • 4
    自动化微信朋友圈：Python脚本实现自动发布动态
  • 5
    使用 pyenv 来管理多个 Python 版本(2)
  • 6
    局域网屏幕监控系统中的Python数据结构与算法实现
  • 7
    Linux 安装python3.7.6
  • 8
    [oeasy]python053_学编程为什么从hello_world_开始
  • 9
    【Python】怎么解决：urllib.error.HTTPError: HTTP Error 403: Forbidden
  • 10
    让UE自动运行Python脚本：实现与实例解析
  • 1
    Linux下安装MySQL
    70
  • 2
    XtraBackup支持哪些MySQL数据库版本？
    816
  • 3
    如何将数据从MySQL迁移到PolarDB？
    597
  • 4
    Java医院绩效考核系统源码B/S+avue+MySQL助力医院实现精细化管理
    92
  • 5
    Linux对MySQL语法校验
    107
  • 6
    【MySQL系列笔记】分库分表
    266
  • 7
    mysql 设置环境变量与未设置环境变量连接数据库的区别
    185
  • 8
    服务器Linux系统配置mysql数据库主从自动备份
    240
  • 9
    mysqlTools 一分钟部署安装本mysql多个版本，解锁繁琐部署过程
    438
  • 10
    golang使用gorm操作mysql3，数据查询
    114

    • 相关课程

    更多
  • Python Web开发基础
  • Python爬虫实战
  • Python常用数据科学库
  • Python网络爬虫实战
  • Python完全自学手册图文教程
  • Python基础快速入门实战教程

    • 相关电子书

    更多
  • From Python Scikit-Learn to Sc
  • Data Pre-Processing in Python:
  • 双剑合璧-Python和大数据计算平台的结合

    • 相关实验场景

    更多
  • MySQL基础-学生管理系统数据库设计
  • 如何快速连接云数据库RDS MySQL
  • 用Python画圣诞树
  • MySQL引擎及架构优化
  • 基于EBS部署高性能的MySQL服务
  • 5分钟上手Flink MySQL连接器

    • 推荐镜像

    更多
  • mysql
  • python-release
  • nodejs-release
    • 下一篇
    阿里云开通OSS存储服务详细流程