热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

Python操作MySQL(pymysql模块)详解及示例代码

本文介绍了使用Python操作MySQL数据库的方法,详细讲解了pymysql模块的安装和连接MySQL数据库的步骤,并提供了示例代码。内容涵盖了创建表、插入数据、查询数据等操作,帮助读者快速掌握Python操作MySQL的技巧。


目录

python连接mysql数据库

操作表与数据




详解

python连接mysql数据库


pymysql是一个第三方模块,需要通过pip install pymysql进行安装。



    import pymysql


    # 连接mysql数据库
    cOnn= pymysql.connect(host='mysql服务器ip',
                          port='mysql服务器端口(默认为3306)',
                          user='mysql服务器用户名',
                          password='mysql服务器用户密码',  
                          database='mysql服务器数据库',
                          charset='utf8')  # 注意:charset='utf8' 不能写成utf-8




    # 使用 cursor()方法 创建一个游标对象 cursor
    cursor = conn.cursor()  # 创建一个游标对象,查询返回元组
    cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)  # 创建一个游标对象,查询返回字典,占用空间多

    (左右滑动查看完整python代码)




    操作表与数据


    创建表


      import pymysql


      # 连接mysql数据库
      cOnn= pymysql.connect(host='mysql服务器ip',
                            port='mysql服务器端口(默认为3306)',
                            user='mysql服务器用户名',
                            password='mysql服务器用户密码',
                            database='mysql服务器数据库',
                            charset='utf8')




      # 使用 cursor()方法 创建一个游标对象 cursor
      cursor = conn.cursor()  # 创建一个游标对象,查询返回元组
      # cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)  # 创建一个游标对象,查询返回字典,占用空间多




      # 使用 execute()方法 执行sql,如果表存在则删除
      cursor.execute("DROP TABLE IF EXISTS user")


      # 创建表
      sql = '''CREATE TABLE user (
              NAME CHAR(20) NOT NULL,
              AGE INT,  
              SEX CHAR(1),
              INCOME FLOAT)'''


      # 执行sql
      cursor.execute(sql)


      # 关闭游标
      cursor.close()


      # 关闭数据库连接
      conn.close()

      (左右滑动查看完整python代码)




      操作数据(查询)


        import pymysql


        # 连接mysql数据库
        cOnn= pymysql.connect(host='mysql服务器ip',
                              port='mysql服务器端口(默认为3306)',
                              user='mysql服务器用户名',
                              password='mysql服务器用户密码',
                              database='mysql服务器数据库',
                              charset='utf8')




        # 使用 cursor()方法 创建一个游标对象 cursor
        cursor = conn.cursor()  # 创建一个游标对象,查询返回元组
        # cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)  # 创建一个游标对象,查询返回字典,占用空间多




        sql = "SELECT * FROM user WHERE INCOME > %s" % (1000)
        try:
           cursor.execute(sql)  # 执行SQL语句
           print(cursor.rowcount)  # 获取查出多少行结果
           print(cursor.fetchone())  # 获取一条结果
           print(cursor.fetchmany(10))  # 获取10条结果
           print(cursor.fetchall())  # 获取全部结果
        except Exception as e:
           print(f"SQL执行失败:{e}")




        # 关闭游标
        cursor.close()


        # 关闭数据库连接
        conn.close()

        (左右滑动查看完整python代码)




        操作数据(增删改)


          import pymysql


          # 连接mysql数据库
          cOnn= pymysql.connect(host='mysql服务器ip',
                                port='mysql服务器端口(默认为3306)',
                                user='mysql服务器用户名',
                                password='mysql服务器用户密码',
                                database='mysql服务器数据库',
                                charset='utf8')


          cursor = conn.cursor()  # 创建一个游标对象


          # 增
          sql = "INSERT INTO user(NAME,AGE, SEX, INCOME) \
                VALUES (%s,  %s,  %s,  %s )" % \
                ('pamela', 18, 'F', 1000)


          # 删
          sql = "DELETE FROM user WHERE AGE > %s" % (20)


          # 改
          sql = "UPDATE user SET AGE = AGE + 1 WHERE SEX = '%s'" % ('M')


          try:
             cursor.execute(sql)  # 执行SQL语句
             conn.commit()  # 提交到数据库执行,对存储的数据修改后需要commit
          except Exception as e:
             print(f"SQL执行失败:{e}")
             conn.rollback()  # 如果发生错误则回滚




          cursor.close()  # 关闭游标


          conn.close()  # 关闭数据库连接

          (左右滑动查看完整python代码)




          注意:sql注入问题


          给sql语句传参数,要注意sql注入的问题,传参数不要通过字符串拼接,要通过execute方法来传。


            import pymysql


            # 连接mysql数据库
            cOnn= pymysql.connect(host='mysql服务器ip',
            port='mysql服务器端口(默认为3306)',
            user='mysql服务器用户名',
            password='mysql服务器用户密码',
            database='mysql服务器数据库',
            charset='utf8')
            cursor = conn.cursor() # 创建一个游标对象,查询返回元组


            # sql = "SELECT * FROM user WHERE INCOME > %s" % (1000)
            sql = "SELECT * FROM user WHERE INCOME > %s"
            try:
            cursor.execute(sql, (1000,)) # 执行SQL语句,在第二个参数中传参(把所有参数放在一个元组中)
            except Exception as e:
            print(f"SQL执行失败:{e}")




            cursor.close() # 关闭游标


            conn.close() # 关闭数据库连接

            (左右滑动查看完整python代码)




            其他


            数据备份


              语法:
              备份数据(在cmd命令行直接执行)
              mysqldump -h服务器 -u用户名 -p密码 数据库名 > 备份文件.sql




              #单库备份
              mysqldump -h127.0.0.1 -uroot -p123 db1 > db1.sql
              mysqldump -h127.0.0.1 -uroot -p123 db1 table1 table2 > db1-table1-table2.sql


              #多库备份
              mysqldump -h127.0.0.1 -uroot -p123 --databases db1 db2 db3 > db1_db2_db3.sql


              #备份所有库
              mysqldump -h127.0.0.1 -uroot -p123 --all-databases > all.sql

              (左右滑动查看完整内容)




              数据恢复


                语法:
                恢复数据(在mysql中执行命令)
                切换到一个要备份的数据库中
                source 备份文件.sql




                #方法一:
                命令行:
                mysql -uroot -p123 all.sql


                #方法二:
                mysql中:
                use db1;
                SET SQL_LOG_BIN=0;   #关闭二进制日志,只对当前session生效
                source /root/db1.sql

                (左右滑动查看完整内容)




                事务和锁


                  begin;  # 开启事务
                  select * from user where NAME = 'pamela' for update;  # 查询,for update添加行级锁(select语句后面加一个for update)
                  update user set INCOME=10000 where NAME = 'pamela'; # 完成更新
                  commit;  # 提交事务,释放行级锁

                  (左右滑动查看完整内容)






                  推荐阅读
                  • Python SQLAlchemy库的使用方法详解
                    本文详细介绍了Python中使用SQLAlchemy库的方法。首先对SQLAlchemy进行了简介,包括其定义、适用的数据库类型等。然后讨论了SQLAlchemy提供的两种主要使用模式,即SQL表达式语言和ORM。针对不同的需求,给出了选择哪种模式的建议。最后,介绍了连接数据库的方法,包括创建SQLAlchemy引擎和执行SQL语句的接口。 ... [详细]
                  • 本文介绍了计算机网络的定义和通信流程,包括客户端编译文件、二进制转换、三层路由设备等。同时,还介绍了计算机网络中常用的关键词,如MAC地址和IP地址。 ... [详细]
                  • 31.项目部署
                    目录1一些概念1.1项目部署1.2WSGI1.3uWSGI1.4Nginx2安装环境与迁移项目2.1项目内容2.2项目配置2.2.1DEBUG2.2.2STAT ... [详细]
                  • 本文介绍了Python高级网络编程及TCP/IP协议簇的OSI七层模型。首先简单介绍了七层模型的各层及其封装解封装过程。然后讨论了程序开发中涉及到的网络通信内容,主要包括TCP协议、UDP协议和IPV4协议。最后还介绍了socket编程、聊天socket实现、远程执行命令、上传文件、socketserver及其源码分析等相关内容。 ... [详细]
                  • Python实现变声器功能(萝莉音御姐音)的方法及步骤
                    本文介绍了使用Python实现变声器功能(萝莉音御姐音)的方法及步骤。首先登录百度AL开发平台,选择语音合成,创建应用并填写应用信息,获取Appid、API Key和Secret Key。然后安装pythonsdk,可以通过pip install baidu-aip或python setup.py install进行安装。最后,书写代码实现变声器功能,使用AipSpeech库进行语音合成,可以设置音量等参数。 ... [详细]
                  • web.py开发web 第八章 Formalchemy 服务端验证方法
                    本文介绍了在web.py开发中使用Formalchemy进行服务端表单数据验证的方法。以User表单为例,详细说明了对各字段的验证要求,包括必填、长度限制、唯一性等。同时介绍了如何自定义验证方法来实现验证唯一性和两个密码是否相等的功能。该文提供了相关代码示例。 ... [详细]
                  • MySQL语句大全:创建、授权、查询、修改等【MySQL】的使用方法详解
                    本文详细介绍了MySQL语句的使用方法,包括创建用户、授权、查询、修改等操作。通过连接MySQL数据库,可以使用命令创建用户,并指定该用户在哪个主机上可以登录。同时,还可以设置用户的登录密码。通过本文,您可以全面了解MySQL语句的使用方法。 ... [详细]
                  • 合并列值-合并为一列问题需求:createtabletab(Aint,Bint,Cint)inserttabselect1,2,3unionallsel ... [详细]
                  • 开源Keras Faster RCNN模型介绍及代码结构解析
                    本文介绍了开源Keras Faster RCNN模型的环境需求和代码结构,包括FasterRCNN源码解析、RPN与classifier定义、data_generators.py文件的功能以及损失计算。同时提供了该模型的开源地址和安装所需的库。 ... [详细]
                  • 基于PgpoolII的PostgreSQL集群安装与配置教程
                    本文介绍了基于PgpoolII的PostgreSQL集群的安装与配置教程。Pgpool-II是一个位于PostgreSQL服务器和PostgreSQL数据库客户端之间的中间件,提供了连接池、复制、负载均衡、缓存、看门狗、限制链接等功能,可以用于搭建高可用的PostgreSQL集群。文章详细介绍了通过yum安装Pgpool-II的步骤,并提供了相关的官方参考地址。 ... [详细]
                  • 本文介绍了在开发Android新闻App时,搭建本地服务器的步骤。通过使用XAMPP软件,可以一键式搭建起开发环境,包括Apache、MySQL、PHP、PERL。在本地服务器上新建数据库和表,并设置相应的属性。最后,给出了创建new表的SQL语句。这个教程适合初学者参考。 ... [详细]
                  • 开发笔记:加密&json&StringIO模块&BytesIO模块
                    篇首语:本文由编程笔记#小编为大家整理,主要介绍了加密&json&StringIO模块&BytesIO模块相关的知识,希望对你有一定的参考价值。一、加密加密 ... [详细]
                  • 本文介绍了如何找到并终止在8080端口上运行的进程的方法,通过使用终端命令lsof -i :8080可以获取在该端口上运行的所有进程的输出,并使用kill命令终止指定进程的运行。 ... [详细]
                  • 本文介绍了RPC框架Thrift的安装环境变量配置与第一个实例,讲解了RPC的概念以及如何解决跨语言、c++客户端、web服务端、远程调用等需求。Thrift开发方便上手快,性能和稳定性也不错,适合初学者学习和使用。 ... [详细]
                  • 本文介绍了如何使用python从列表中删除所有的零,并将结果以列表形式输出,同时提供了示例格式。 ... [详细]
                  author-avatar
                  青藤摄影876
                  这个家伙很懒,什么也没留下!
                  PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
                  Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有