Python实现连接操作MySql数据库 - Go语言中文社区

Python实现连接操作MySql数据库


        在本文中介绍 Python3 使用PyMySQL连接数据库,并实现简单的增删改查。(注意是python3)

1、安装PyMySQL

        PyMySQL 是在 Python3.x 版本中用于连接 MySQL 服务器的一个库,Python2中则使用mysqldb。PyMySQL 遵循 Python 数据库 API v2.0 规范,并包含了 pure-Python MySQL 客户端库。在使用 PyMySQL 之前,我们需要确保 PyMySQL 已安装。

① 使用pip命令安装

        pip install PyMySQL


② 如果你的系统不支持 pip 命令,可以使用以下git方式安装

        //使用git下载安装包
        $ git clone https://github.com/PyMySQL/PyMySQL
        $ cd PyMySQL/
        $ python3 setup.py install

2、Python连接MySql数据库

连接数据库前,请先确认以下事项:

        Ⅰ 在你的机子上已经安装了 Python MySQLdb 模块。
        Ⅱ 您已经创建了数据库 test
        Ⅲ 连接数据库test使用的用户名为 root,密码为 root,你可以可以自己设定或者直接使用root用户名及其密码。

    # *===================================*
    # * Created by Zhihua_w.
    # * Author: Wei ZhiHua
    # * Date: 2017/1/10 0003
    # * Time: 下午 2:28
    # * Project: PYTHON STUDY
    # * Power: DATABASE
    # *===================================*
    
    import pymysql
    
    # 打开数据库连接(ip/数据库用户名/登录密码/数据库名)
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = db.cursor()
    
    # 使用 execute()  方法执行 SQL 查询
    cursor.execute("SELECT VERSION()")
    # 使用 fetchone() 方法获取单条数据.
    data = cursor.fetchone()
    print("Database version : %s " % data)
    
    # 关闭数据库连接
    db.close()

3、Python操作MySql数据库实现增删改查

① 数据库插入操作

    # *===================================*
    # * Created by Zhihua_w.
    # * Author: Wei ZhiHua
    # * Date: 2017/1/10 0004
    # * Time: 下午 2:32
    # * Project: PYTHON STUDY
    # * Power: DATABASE
    # *===================================*
    
    import pymysql
    
    # 打开数据库连接(ip/数据库用户名/登录密码/数据库名)
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = db.cursor()
    
    # SQL 插入语句
    sql = """INSERT INTO user(name)
             VALUES ('Mac')"""
    try:
       # 执行sql语句
       cursor.execute(sql)
       # 提交到数据库执行
       db.commit()
    except:
       # 如果发生错误则回滚
       db.rollback()
    
    # 关闭数据库连接
    db.close()

② 数据库查询

    # *===================================*
    # * Created by Zhihua_w.
    # * Author: Wei ZhiHua
    # * Date: 2017/1/10 0005
    # * Time: 下午 2:39
    # * Project: PYTHON STUDY
    # * Power: DATABASE
    # *===================================*
    
    import pymysql
    
    # 打开数据库连接(ip/数据库用户名/登录密码/数据库名)
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = db.cursor()
    
    # SQL 查询语句
    sql = "SELECT * FROM user"
    
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 获取所有记录列表
        results = cursor.fetchall()
        for row in results:
            id = row[0]
            name = row[1]
            # 打印结果
            print("id=%s,name=%s" % 
                  (id, name))
    except:
        print("Error: unable to fecth data")
    
    # 关闭数据库连接
    db.close()

③ 数据库更新

    # *===================================*
    # * Created by Zhihua_w.
    # * Author: Wei ZhiHua
    # * Date: 2017/1/10 0005
    # * Time: 下午 2:39
    # * Project: PYTHON STUDY
    # * Power: DATABASE
    # *===================================*
    
    import pymysql
    
    # 打开数据库连接(ip/数据库用户名/登录密码/数据库名)
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = db.cursor()
    
    # SQL 更新语句
    sql = "UPDATE user SET name = 'Bob' WHERE id = 1"
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 提交到数据库执行
        db.commit()
    except:
        # 发生错误时回滚
        db.rollback()
       
    # 关闭数据库连接
    db.close()

④ 数据库删除

    # *===================================*
    # * Created by Zhihua_w.
    # * Author: Wei ZhiHua
    # * Date: 2017/1/10 0006
    # * Time: 下午 2:49
    # * Project: PYTHON STUDY
    # * Power: DATABASE
    # *===================================*
    
    import pymysql
    
    # 打开数据库连接(ip/数据库用户名/登录密码/数据库名)
    db = pymysql.connect("localhost", "root", "root", "test")
    # 使用 cursor() 方法创建一个游标对象 cursor
    cursor = db.cursor()
    
    # SQL 删除语句
    sql = "DELETE FROM user WHERE id  = 1"
    try:
        # 执行SQL语句
        cursor.execute(sql)
        # 提交修改
        db.commit()
    except:
        # 发生错误时回滚
        db.rollback()
    
    # 关闭数据库连接
    db.close()

版权声明:本文来源CSDN,感谢博主原创文章,遵循 CC 4.0 by-sa 版权协议,转载请附上原文出处链接和本声明。
原文链接:https://blog.csdn.net/Zhihua_W/article/details/54313258
站方申明:本站部分内容来自社区用户分享,若涉及侵权,请联系站方删除。
  • 发表于 2020-02-13 12:03:20
  • 阅读 ( 1407 )
  • 分类:数据库

0 条评论

请先 登录 后评论

官方社群

GO教程

猜你喜欢