pymysql 的简单使用

程序员文章站 2022-04-15 15:17:38

一、环境 Windows 7 x64 python 3.7.1 pymysql 0.9.3 mysql5.6.43 二、pymysql的简单使用 1、准备数据库demo_temp 2、连接数据库 3、创建表 4、一个简单的增、删、改、查实例 5、简单的事务通过下面的小动画我们可以看出，这里模拟在更 ......

一、环境

windows 7 x64 python 3.7.1 pymysql 0.9.3 mysql5.6.43

二、pymysql的简单使用

1、准备数据库demo_temp

create database demo_temp;

2、连接数据库

import pymysql.cursors
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)

3、创建表

import pymysql.cursors
# 连接数据库
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)
# 创建表users
with connect.cursor() as cursor:
    sql = """
    create table users (
    id int primary key auto_increment ,
    user char(30),
    passwd char(20))
    """
    cursor.execute(sql)
connect.close()

4、一个简单的增、删、改、查实例

import pymysql.cursors
# 连接数据库
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)

with connect.cursor() as cursor:   # 创建游标
    # 创建表
    sql = """
    create table users (
    id int primary key auto_increment ,
    user char(30),
    passwd char(20))
    """
    cursor.execute(sql)

    # 向表中插入数据
    sql = """
        insert into users (user,passwd) values ('小明','123')
        """
    cursor.execute(sql)
    connect.commit()   # 插入数据后必须更新


    # 查询数据
    sql = """
        select * from users
        """
    cursor.execute(sql)
    ret = cursor.fetchone()  # 提取查询数据
    print(ret)

    # 修改数据
    sql = """
           update users set user='葫芦娃' where id=1
           """
    cursor.execute(sql)

    # 再次查询数据
    sql = """
           select * from users
           """
    cursor.execute(sql)
    ret = cursor.fetchone()  # 提取查询数据
    print(ret)

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

# 打印内容如下
{'id': 1, 'user': '小明', 'passwd': '123'}
{'id': 1, 'user': '葫芦娃', 'passwd': '123'}

5、简单的事务

import pymysql.cursors

# 连接数据库
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)

try:
    with connect.cursor() as cursor:  # 创建游标
        # 插入数据
        sql = """
            insert into users (user,passwd) values ('11111','123')
            """
        cursor.execute(sql)
        # 更新数据
        sql_1 = """
              update users set user='葫芦娃' where id=1
        """
        cursor.execute(sql_1)
        raise nameerror   # 更新数据时主动抛出异常

except exception as e:
    connect.rollback()  # 事务回滚
connect.commit()

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

通过下面的小动画我们可以看出，这里模拟在更新数据时出现问题。而插入数据时没有问题的。然后执行事务回滚，最终数据没有被写入到数据库中。

pymysql 的简单使用

三、connection中常用api

1、open() ：检测数据库是否连接。

connect.open：如果数据库连接返回trhe，否则返回false。

2、ping(reconnect=true)

connect.ping(reconnect=true):如果reconnect=true表示连接断开后，重新进行连接。

import pymysql.cursors

# 连接数据库
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)
print(connect.open)  # 打印数据库连接状态
connect.close()  # 关闭数据库连接
connect.ping(reconnect=true)  # 重新连接数据库
print(connect.open)   # 打印数据库连接状态

下面的小动画向我们展示了当connect断开连接后，使用connect.ping(reconnect=true)又重新连接到了数据库。

pymysql 的简单使用

3、rollback()：回滚当前事务，用法在上面，这里就不再演示了。

4、select_db(db)：切换数据库。

# demo_test数据库中users表数据
mysql> select * from users;
+----+-----------+--------+
| id | user      | passwd |
+----+-----------+--------+
|  1 | 小明      | 123    |
|  2 | 小刚      | 123    |
|  3 | 小红      | 123    |
|  4 | 葫芦娃    | 123    |
|  5 | 小明      | 123    |
+----+-----------+--------+

# demo_temp2库中test表中数据
mysql> select * from test;
+------+------+----------+
| id   | user | password |
+------+------+----------+
|    1 | abc  | 123      |
+------+------+----------+

import pymysql.cursors

# 连接数据库
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)
with connect.cursor() as cursor:   # 创建游标

    # 查询demo_temp中users表的数据
    sql = """
        select * from users
        """
    cursor.execute(sql)
    ret = cursor.fetchall()  # 提取查询数据
    print(ret)
    print('-'*80)

    # 切换到demo_temp2数据库，查询test表的数据
    connect.select_db('demo_temp2')
    sql = """
           select * from test
           """
    cursor.execute(sql)
    ret = cursor.fetchall()  # 提取查询数据
    print(ret)

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

# 打印结果
[{'id': 1, 'user': '小明', 'passwd': '123'}, {'id': 2, 'user': '小刚', 'passwd': '123'}, {'id': 3, 'user': '小红', 'passwd': '123'}, 
{'id': 4, 'user': '葫芦娃', 'passwd': '123'}, {'id': 5, 'user': '小明', 'passwd': '123'}]
--------------------------------------------------------------------------------
[{'id': 1, 'user': 'abc', 'password': '123'}]

5、cursor()：创建游标对象，用于操作数据（增、删、改、查）。

6、commit()：提交请求，当向数据库中插入数据时，需要使用commit()进行提交，否则数据将不能写入数据库。

7、close()：关闭数据库连接。

四、cursor常用api

1、cursor.execute(query, args=none)：执行sql语句。

参数:

query (str)：sql语句.
args (tuple, list or dict)：sql语句中如果有变量，或者格式化输出，会在这里填充数据。

returns：返回一个int值，表示sql语句影响到的行数。

下面演示插入数据的四种方式：

import pymysql.cursors

# 连接数据库
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)
with connect.cursor() as cursor:   # 创建游标

    # 第一种方式向表中插入数据
    sql = """
        insert into users (user,passwd) values ('123','123')
        """
    cursor.execute(sql)

    # 第二种方式向表中插入数据
    sql = """
           insert into users (user,passwd) values (%s,%s)
           """
    cursor.execute(sql,['456','456'])

    # 第三种方式向表中插入数据
    sql = """
               insert into users (user,passwd) values (%s,%s)
               """
    cursor.execute(sql, ('789', '789'))

    # 第四种方式向表中插入数据
    sql = """
               insert into users (user,passwd) values (%(a)s,%(b)s)  
               """
    cursor.execute(sql, {'a':'abc','b':'123'})  # 这里的'a'和'b'要和上面values中对应
    connect.commit()  # 插入数据后必须更新
    # 查询数据
    sql = """
        select * from users
        """
    cursor.execute(sql)
    ret = cursor.fetchall()  # 提取查询数据
    print(ret)


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

2、cursor.executemany(query, args)：可以执行多条sql语句。
参数:
query ：sql语句
args：可迭代对象
returns：返回sql语句影响到的行数。

下面是方法实例：

import pymysql.cursors

# 连接数据库
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)
with connect.cursor() as cursor:   # 创建游标

    # 插入多条数据
    sql = """
               insert into users (user,passwd) values (%s,%s)  
               """
    ret_row = cursor.executemany(sql,[['a','123'],['b','234'],['c','456']])  # 在args中传入一个可迭代对象。
    connect.commit()  # 插入数据后必须更新
    print(f'当前受影响了{ret_row}行')

    # 查询数据
    sql = """
        select * from users
        """
    cursor.execute(sql)
    ret = cursor.fetchall()  # 提取查询数据
    print(ret)

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

3、cursor.fetchone()：从查询语句中获取一条查询结果。

4、cursor.fetchall()：获取所有查询到的结果。

5、cursor.fetchmany(size)：根据size获取相应的行数。

6、cursor.mogrify(query, args=none)：返回执行的sql语句，下面是示例：

import pymysql.cursors

# 连接数据库
connect = pymysql.connect(
    host='127.0.0.1',
    user='root',
    password='123',
    db='demo_temp',
    charset='utf8',
    cursorclass=pymysql.cursors.dictcursor
)
with connect.cursor() as cursor:   # 创建游标
    sql = """
        select * from users
        """
    cursor.execute(sql)
    ret_sql = cursor.mogrify(sql)   # 返回执行的sql语句
    cursor.fetchmany(2)             # 提取查询数据
    print(ret_sql)

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

7、cursor.close()：关闭游标，关闭游标后，游标内所有数据将被清空。

参考文档：https://pymysql.readthedocs.io/en/latest/

上一篇：三星授权的AMD GPU不止用于手机还要进军自驾汽车

下一篇：请给出一个Scala RDD的HelloWorld例子

pymysql 的简单使用

一、环境

二、pymysql的简单使用

5、简单的事务

三、connection中常用api

四、cursor常用api

win10系统使用APMserv时提示80端口被占用的解决方法

使用node搭建自动发图文微博机器人的方法

基于node简单实现RSA加解密的方法步骤

React 使用Hooks简化受控组件的状态绑定

最好用的php开发工具有哪些（phpstorm使用教程）

谷歌浏览器(chrome)的免费插件时空隧道安装与使用图文教程

什么是？和磁力链接的详细使用方法

C#实现基于IE内核的简单浏览器完整实例

在arcgis使用python脚本进行字段计算时是如何解决中文问题的

c4d怎么阵列对象? c4d阵列的使用方法

pymysql 的简单使用

一、环境

二、pymysql的简单使用

5、简单的事务

三、connection中常用api

四、cursor常用api

win10系统使用APMserv时提示80端口被占用的解决方法

使用node搭建自动发图文微博机器人的方法

基于node简单实现RSA加解密的方法步骤

React 使用Hooks简化受控组件的状态绑定

最好用的php开发工具有哪些（phpstorm使用教程）

谷歌浏览器(chrome)的免费插件时空隧道安装与使用图文教程

什么是*？*和磁力链接的详细使用方法

C#实现基于IE内核的简单浏览器完整实例

在arcgis使用python脚本进行字段计算时是如何解决中文问题的

c4d怎么阵列对象? c4d阵列的使用方法

什么是？和磁力链接的详细使用方法