【一】Python操作数据库简介#

【1】什么是DB-API#

Python标准数据库规范为 DB-API， DB-API定义了一系列必须的对象和数据库操作方式，以便为各种数据库系统和数据库访问程序提供一致的访问接口。

【2】数据库操作模块#

开发人员将接口封装成不同的数据库操作模块，不同的数据库需要不同数据库操作模块
例如，MySQL数据库，它对应以下操作模块：https://wiki.python.org/moin/MySQL

最常用的应该是
- MySQL-python：也就是MySQLdb，底层是通过C操作MySQL，效率高，但是只支持py2，不支持py3。
- mysqlclient：是MySQL-python的一个分支。它增加了Python 3支持，并修复了许多错误。Django文档推荐的MySQL依赖库。
- PyMySQL：纯Python实现的模块，可以与Python代码兼容衔接，并也几乎兼容MySQL-python。
- MySQL Connector/Python：MySQL官方推出的纯Python实现的模块。

【二】PyMySQL简介#

纯Python实现的模块，可以与Python代码兼容衔接，并也几乎兼容MySQL-python。
遵循 Python 数据库 API v2.0 规范。
官网：https://zetcode.com/python/pymysql/

【三】PyMySQL使用#

【0】安装#

1
pip install pymysql

【1】连接数据库#

使用connect函数创建连接对象，此连接对象提供关闭数据库、事务提交、事务回滚等操作。
传入参数有很多，具体参考文档，一般参数基本连接信息 host, user, password, port(默认为3306), database。

（1）连接语法#

1
# 导入pymysql模块
2
import pymysql
3

4
# 创建连接对象
5
conn = pymysql.connect(user='root',  # 必填参数：数据库连接用户名
6
                       password='password',  # 必填参数：数据库连接密码
7
                       host='127.0.0.1',  # 必填参数：数据库服务器地址，本地可以填 localhost 或 127.0.0.1
8
                       port=3306,  # 必填参数：MySQL数据库端口，默认是3306
9
                       database='test'  # 必填参数：需要链接那个数据库
10
                       )

1
def __init__(
2
        self,
3
        *,
4
        user=None,  # The first four arguments is based on DB-API 2.0 recommendation.
5
        password="",
6
        host=None,
7
        database=None,
8
        unix_socket=None,
9
        port=0,
10
        charset="",
11
        collation=None,
12
        sql_mode=None,
13
        read_default_file=None,
14
        conv=None,
15
        use_unicode=True,
16
        client_flag=0,
17
        cursorclass=Cursor,
18
        init_command=None,
19
        connect_timeout=10,
20
        read_default_group=None,
21
        autocommit=False,
22
        local_infile=False,
23
        max_allowed_packet=16 * 1024 * 1024,
24
        defer_connect=False,
25
        auth_plugin_map=None,
26
        read_timeout=None,
27
        write_timeout=None,
28
        bind_address=None,
29
        binary_prefix=False,
30
        program_name=None,
31
        server_public_key=None,
32
        ssl=None,
33
        ssl_ca=None,
34
        ssl_cert=None,
35
        ssl_disabled=None,
36
        ssl_key=None,
37
        ssl_verify_cert=None,
38
        ssl_verify_identity=None,
39
        compress=None,  # not supported
40
        named_pipe=None,  # not supported
41
        passwd=None,  # deprecated
42
        db=None,  # deprecated
43
)

【2】主要方法介绍#

方法	功能
cursor()	获取游标对象，操作数据库，如执行DML操作，调用存储过程等
commit()	提交事务
rollback()	回滚事务
close()	关闭数据库连接

【3】操作MySQL数据库#

使用Cursor对象与数据库进行交互。
具体方法参考：https://pymysql.readthedocs.io/en/latest/modules/cursors.html

（1）创建游标对象#

1
import pymysql
2
conn = pymysql.connect(
3
    host='127.0.0.1',
4
    user='root',
5
    password='123456',
6
    port=3306,
7
    database='data'
8
)
9
# 创建游标，查询数据以元组形式返回
10
# cursor = conn.cursor()
11

12
# 创建游标，查询数据以字典形式返回
13
cursor = conn.cursor(pymysql.cursors.DictCursor)

（2）执行SQL语句#

1
# 导入pymysql模块
2
import pymysql
3
from pymysql.cursors import DictCursor
4

5
#  连接数据库，创建连接对象
6
conn = pymysql.connect(
7
    host='127.0.0.1',
8
    user='root',
9
    password='1314521',
10
    port=3306,
11
    database='emp_data'
12
)
13
# 创建游标，查询数据以元组形式返回
14
# cursor = conn.cursor()
15

16
# 创建游标，查询数据以字典形式返回
17
cursor = conn.cursor(DictCursor)
18

19
sql = 'select * from emp limit 10'
20
cursor.execute(sql)

【4】查询结果#

（1）获取所有结果(fetchall)#

1
# 导入pymysql模块
2
import pymysql
3
from pymysql.cursors import DictCursor
4

5
#  连接数据库，创建连接对象
6
conn = pymysql.connect(
7
    host='127.0.0.1',
8
    user='root',
9
    password='1314521',
10
    port=3306,
11
    database='emp_data'
12
)
13
# 创建游标，查询数据以元组形式返回
14
# cursor = conn.cursor()
15

16
# 创建游标，查询数据以字典形式返回
17
cursor = conn.cursor(DictCursor)
18

19
sql = 'select * from emp limit 10'
20
cursor.execute(sql)
21
result = cursor.fetchall()  # 返回所有数据
22
print(result)

1
[{'id': 1, 'name': 'dream', 'sex': 'male', 'age': 78, 'hire_date': datetime.date(2022, 3, 6), 'post': '陌夜痴梦久生情', 'post_comment': None, 'salary': 730.33, 'office': 401, 'depart_id': 1}, {'id': 2, 'name': 'mengmeng', 'sex': 'female', 'age': 25, 'hire_date': datetime.date(2022, 1, 2), 'post': 'teacher', 'post_comment': None, 'salary': 12000.5, 'office': 401, 'depart_id': 1}, {'id': 3, 'name': 'xiaomeng', 'sex': 'male', 'age': 35, 'hire_date': datetime.date(2019, 6, 7), 'post': 'teacher', 'post_comment': None, 'salary': 15000.99, 'office': 401, 'depart_id': 1}, {'id': 4, 'name': 'xiaona', 'sex': 'female', 'age': 29, 'hire_date': datetime.date(2018, 9, 6), 'post': 'teacher', 'post_comment': None, 'salary': 11000.8, 'office': 401, 'depart_id': 1}, {'id': 5, 'name': 'xiaoqi', 'sex': 'female', 'age': 27, 'hire_date': datetime.date(2022, 8, 6), 'post': 'teacher', 'post_comment': None, 'salary': 13000.7, 'office': 401, 'depart_id': 1}, {'id': 6, 'name': 'suimeng', 'sex': 'male', 'age': 33, 'hire_date': datetime.date(2023, 3, 6), 'post': 'teacher', 'post_comment': None, 'salary': 14000.62, 'office': 401, 'depart_id': 1}, {'id': 7, 'name': '娜娜', 'sex': 'female', 'age': 69, 'hire_date': datetime.date(2010, 3, 7), 'post': 'sale', 'post_comment': None, 'salary': 300.13, 'office': 402, 'depart_id': 2}, {'id': 8, 'name': '芳芳', 'sex': 'male', 'age': 45, 'hire_date': datetime.date(2014, 5, 18), 'post': 'sale', 'post_comment': None, 'salary': 400.45, 'office': 402, 'depart_id': 2}, {'id': 9, 'name': '小明', 'sex': 'male', 'age': 34, 'hire_date': datetime.date(2016, 1, 3), 'post': 'sale', 'post_comment': None, 'salary': 350.8, 'office': 402, 'depart_id': 2}, {'id': 10, 'name': '亚洲', 'sex': 'female', 'age': 42, 'hire_date': datetime.date(2017, 2, 27), 'post': 'sale', 'post_comment': None, 'salary': 320.99, 'office': 402, 'depart_id': 2}]

（2）获取一行数据(fetchone)#

1
# 导入pymysql模块
2
import pymysql
3
from pymysql.cursors import DictCursor
4

5
#  连接数据库，创建连接对象
6
conn = pymysql.connect(
7
    host='127.0.0.1',
8
    user='root',
9
    password='1314521',
10
    port=3306,
11
    database='emp_data'
12
)
13
# 创建游标，查询数据以元组形式返回
14
# cursor = conn.cursor()
15

16
# 创建游标，查询数据以字典形式返回
17
cursor = conn.cursor(DictCursor)
18

19
sql = 'select * from emp limit 10'
20
cursor.execute(sql)
21
result = cursor.fetchone()  # 返回一行数据
22
print(result)

1
{'id': 1, 'name': 'dream', 'sex': 'male', 'age': 78, 'hire_date': datetime.date(2022, 3, 6), 'post': '陌夜痴梦久生情', 'post_comment': None, 'salary': 730.33, 'office': 401, 'depart_id': 1}

（3）获取查询指定结果量(fetchmany)#

1
# 导入pymysql模块
2
import pymysql
3
from pymysql.cursors import DictCursor
4

5
#  连接数据库，创建连接对象
6
conn = pymysql.connect(
7
    host='127.0.0.1',
8
    user='root',
9
    password='1314521',
10
    port=3306,
11
    database='emp_data'
12
)
13
# 创建游标，查询数据以元组形式返回
14
# cursor = conn.cursor()
15

16
# 创建游标，查询数据以字典形式返回
17
cursor = conn.cursor(DictCursor)
18

19
sql = 'select * from emp limit 10'
20
cursor.execute(sql)
21
result = cursor.fetchmany(2)
22
# fetchmany(size) 获取查询结果集中指定数量的记录，size默认为1
23
print(result)

1
[{'id': 1, 'name': 'dream', 'sex': 'male', 'age': 78, 'hire_date': datetime.date(2022, 3, 6), 'post': '陌夜痴梦久生情', 'post_comment': None, 'salary': 730.33, 'office': 401, 'depart_id': 1}, {'id': 2, 'name': 'mengmeng', 'sex': 'female', 'age': 25, 'hire_date': datetime.date(2022, 1, 2), 'post': 'teacher', 'post_comment': None, 'salary': 12000.5, 'office': 401, 'depart_id': 1}]

（4）移动光标#

1
cursor.scroll(1, 'relative')  # 相对于当前位置往后移动一个单位
2
cursor.scroll(1, 'absolute')  # 相对于起始位置往后移动一个单位

【5】插入操作#

插入操作中参数可以_以元组、列表和字典形式传入_
需要使用到占位符 “%s”，注意这只是个占位符，不同于Python 中字符串格式化中的转换说明符。

转换说明符	解释
%d、%i	转换为带符号的十进制数
%o	转换为带符号的八进制数
%x、%X	转换为带符号的十六进制数
%e	转化为科学计数法表示的浮点数（e 小写）
%E	转化为科学计数法表示的浮点数（E 小写）
%f、%F	转化为十进制浮点数
%g	智能选择使用 %f 或 %e 格式
%G	智能选择使用 %F 或 %E 格式
%c	格式化字符及其ASCII码
%r	使用 repr() 函数将表达式转换为字符串
%s	使用 str() 函数将表达式转换为字符串

未插入之前

1
# 导入pymysql模块
2
import pymysql
3
from pymysql.cursors import DictCursor
4

5
#  连接数据库，创建连接对象
6
conn = pymysql.connect(
7
    host='127.0.0.1',
8
    user='root',
9
    password='1314521',
10
    port=3306,
11
    database='emp_data'
12
)
13
# 创建游标，查询数据以元组形式返回
14
# cursor = conn.cursor()
15

16
# 创建游标，查询数据以字典形式返回
17
cursor = conn.cursor(DictCursor)
18

19
# 元组、列表形式传参
20
sql = 'insert into person(NAME,AGE,HEIGH,SEX) VALUES(%s, %s, %s,%s)'
21
cursor.execute(sql, ("dream", 28, 160, '女'))
22
conn.commit()
23

24
# # 字典形式传参
25
sql = 'insert into person(NAME,AGE,HEIGH,SEX) VALUES(%(person_name)s, %(person_age)s, %(person_height)s, %(person_sex)s)'
26
cursor.execute(sql, {"person_height": 190, "person_name": "opp", "person_age": 18, 'person_sex': "男"})
27
conn.commit()

插入之后

【6】更新操作#

1
# 导入pymysql模块
2
import pymysql
3
from pymysql.cursors import DictCursor
4

5
#  连接数据库，创建连接对象
6
conn = pymysql.connect(
7
    host='127.0.0.1',
8
    user='root',
9
    password='1314521',
10
    port=3306,
11
    database='emp_data'
12
)
13
# 创建游标，查询数据以元组形式返回
14
# cursor = conn.cursor()
15

16
# 创建游标，查询数据以字典形式返回
17
cursor = conn.cursor(DictCursor)
18

19

20
sql = 'update  person set SEX=%s where NAME = %s'
21
cursor.execute(sql, ['保密', 'dream'])
22
conn.commit()

【7】删除操作#

1
# 导入pymysql模块
2
import pymysql
3
from pymysql.cursors import DictCursor
4

5
#  连接数据库，创建连接对象
6
conn = pymysql.connect(
7
    host='127.0.0.1',
8
    user='root',
9
    password='1314521',
10
    port=3306,
11
    database='emp_data'
12
)
13
# 创建游标，查询数据以元组形式返回
14
# cursor = conn.cursor()
15

16
# 创建游标，查询数据以字典形式返回
17
cursor = conn.cursor(DictCursor)
18

19

20
sql = 'delete from person where NAME = %s'
21
cursor.execute(sql, ['dream'])
22
conn.commit()

增删改需要有提交事务的操作，除了execute方法，还有批量操作方法executemany()。

【8】批量插入操作#

1
# 导入pymysql模块
2
import pymysql
3
from pymysql.cursors import DictCursor
4

5
#  连接数据库，创建连接对象
6
conn = pymysql.connect(
7
    host='127.0.0.1',
8
    user='root',
9
    password='1314521',
10
    port=3306,
11
    database='emp_data'
12
)
13
# 创建游标，查询数据以元组形式返回
14
# cursor = conn.cursor()
15

16
# 创建游标，查询数据以字典形式返回
17
cursor = conn.cursor(DictCursor)
18

19
sql = 'insert into person(NAME,AGE,HEIGH,SEX) VALUES(%s, %s, %s,%s)'
20
param = [("kenny", 28, 190, "男"), ("liu", 28, 180, "女")]  # 元组列表作为传入参数
21
cursor.executemany(sql, param)
22
conn.commit()

【9】总结模版#

1
import pymysql
2
from pymysql.cursors import DictCursor
3

4

5
class MySQLHandler(object):
6
    def __init__(self, host='127.0.0.1', port=3306, user='root',
7
                 cursorclass=DictCursor, charset='utf8mb4', *,
8
                 password, database):
9
        #  连接数据库，创建连接对象
10
        self.conn = pymysql.connect(
11
            host=host,
12
            user=user,
13
            password=password,
14
            port=port,
15
            database=database,
16
            cursorclass=cursorclass,
17
            charset=charset
18
        )
19
        #  创建游标对象
20
        self.cursor = self.conn.cursor()
21

22
    # 提交事务装饰监控器
23
    @staticmethod
24
    def commit_sql(func):
25
        def inner(*args, **kwargs):
26
            self = args[0]
27
            try:
28
                res = func(*args, **kwargs)
29
                self.conn.commit()
30
                return res
31
            except Exception as e:
32
                self.conn.rollback()
33
                return e
34
            finally:
35
                self.close()
36

37
        return inner
38

39
    # 查询单条数据
40
    @commit_sql
41
    def search_one(self, sql):
42
        self.cursor.execute(sql)
43
        result = self.cursor.fetchone()
44
        return result
45

46
    # 查询所有数据
47
    @commit_sql
48
    def search_all(self, sql):
49
        self.cursor.execute(sql)
50
        results = self.cursor.fetchall()
51
        return results
52

53
    # 插入数据
54
    @commit_sql
55
    def insert_data(self, table_name, **kwargs):
56
        if kwargs:
57
            sql = f'INSERT INTO {table_name} ({", ".join(kwargs.keys())}) VALUES {tuple(kwargs.values())}'
58
        else:
59
            sql = f'INSERT INTO {table_name} () VALUES ()'
60
        print(f'当前SQL语句 :>>>> {sql}')
61
        return self.cursor.execute(sql)
62

63
    @commit_sql
64
    # 更新数据
65
    def update_data(self, sql):
66
        self.cursor.execute(sql)
67
        return sql
68

69
    # 关闭链接和服务对象
70
    def close(self):
71
        self.cursor.close()
72
        self.conn.close()

【四】SQL注入问题#

【1】什么是SQL注入问题#

SQL注入是一种常见的网络攻击手法
它利用sql的语法特性和程序员编写程序时产生的漏洞，用一些特殊符号的组合产生特殊的含义，使得正常的sql语句失效，从而逃脱正常的业务逻辑，完成一些如跳过密码验证等的非法操作。

【2】产生原因#

SQL语句使用了动态拼接的方式。

【3】示例#

（0）准备#

创建表

1
create table user(
2
  id int primary key auto_increment,
3
    name varchar(32),
4
    password varchar(32)
5
);

插入数据

1
insert into user(name,password) values("dream","521"),("chimeng","1314");

查看数据

1
select * from user;

1
+----+---------+----------+
2
| id | name    | password |
3
+----+---------+----------+
4
|  1 | dream   | 521      |
5
|  2 | chimeng | 1314     |
6
+----+---------+----------+
7
2 rows in set (0.00 sec)

（1）登录注册#

1
import pymysql
2

3

4
def connect_mysql():
5
    import pymysql
6

7
    # （1）链接数据库
8
    conn = pymysql.connect(
9
        # 指定 ip端口
10
        host='127.0.0.1',
11
        port=3306,
12

13
        # 指定用户名密码
14
        user='root',
15
        password='1314521',
16

17
        # 指定数据库
18
        database='emp_data',
19

20
        # 指定编码
21
        charset='utf8'
22
    )
23

24
    return conn
25

26

27
def create_cursor(username, password):
28
    conn = connect_mysql()
29
    # （2）创建游标对象 - 执行命令 对象
30
    # cursor=pymysql.cursors.DictCursor：将查询的参数以字典的形式返回
31
    cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)
32

33
    # （3）创建SQL语句
34
    sql = 'select * from user where name = %s and password=%s;'%(username,password)
35

36
    rows = cursor.execute(sql)
37
    return rows, cursor
38

39

40
def register():
41
    username = input("username:>>>>").strip()
42
    password = input("password:>>>>").strip()
43
    rows, cursor = create_cursor(username, password)
44
    if rows:
45
        print("successfully login")
46
        print(cursor.fetchall())
47
    else:
48
        print("Failed to login")
49

50

51
if __name__ == '__main__':
52
    register()

（2）问题#

上面的登录注册SQL语句为

1
'select * from user where name = "%s" and password= "%s";' % (username, password)

没有对用户的输入做任何处理，直接放到了SQL语句中。
那么，当黑客输入了dream OR 1=1 – dream 作为用户名时，原来的SQL语句就会变成下面的样子：

1
select * from user where name = dream or 1=1 -- dream and password="";

where name =dream or 1=1 是一个恒成立的条件，所以无论输入什么用户名都会返回True；
而 — 后面的语句被当作注释忽略掉了，密码验证也被跳过。
最终，绕过验证，成功登录。

【4】解决办法#

针对参数不要采用拼接处理，交给pymysql中的方法（execute）自动处理，并对输入数据进行检查校验

1
# 元组,列表形式
2
param = ('dream','123445')
3
sql = 'SELECT username FROM user WHERE name = %s AND password = %s'
4
cursor.execute(sql, param)
5

6
# 字典形式
7
param = {'name':'hope','password':'123445'}
8
sql = 'SELECT username FROM user WHERE name = %(name)s AND password = %(pwd)s'
9
cursor.execute(sql, param)

需要注意的是，不要因为参数是其他类型而换掉 %s，pymysql 的占位符并不是 python 的通用格式化转换说明符。
同时，也不要因为参数是 string 就在 %s 两边加引号，mysql 会自动去处理。

【五】PyMySQL进阶#

【1】主动提交事务#

因为在增删改查中，只有查的权限是最简单的，因此查无需过多的权限
但是增删改都涉及到数据库数据的变动，需要额外的确认才行(即提交事务)

1
import pymysql
2

3

4
def create_mysql_connection():
5
    conn = pymysql.connect(
6
        # 指定 IP 和 PORT
7
        host='127.0.0.1',
8
        port=3306,
9

10
        # 指定用户名和密码
11
        user='root',
12
        password='1314521',
13

14
        # 指定默认编码
15
        charset='utf8',
16

17
        # 指定数据库
18
        database='day05',
19
    )
20

21
    # 创建游标对象
22
    cursor = conn.cursor(pymysql.cursors.DictCursor)
23

24
    # 返回游标对象
25
    return cursor, conn
26

27

28
cursor, conn = create_mysql_connection()
29

30

31
# 增加数据
32
def add_data():
33
    # （1） 拿到想要处理的数据
34
    username = input("Username:>>>").strip()
35
    password = input("Password:>>>").strip()
36

37
    # （2） 创建SQL语句
38
    sql = "INSERT INTO user(name,password) values (%s,%s);"
39

40
    # （3）查看SQL语句执行状态
41
    rows = cursor.execute(sql, (username, password))
42
    print(rows)
43

44
    # （4） 提交事务 ：确认此次数据库更改操作
45
    conn.commit()
46

47

48
# 更改数据
49
def change_data():
50
    username = input("Username:>>>").strip()
51
    password = input("Password:>>>").strip()
52
    sql = "update user set name=%s, password=%s where id=1;"
53

54
    rows = cursor.execute(sql, (username, password))
55
    print(rows)
56

57
    conn.commit()
58

59

60
# 删除数据
61
def delete_data():
62
    sql = "delete from user where id =1;"
63

64
    rows = cursor.execute(sql)
65
    print(rows)
66

67
    conn.commit()
68

69

70
# 查询数据
71
def check_data():
72
    sql = "select * from user"
73
    cursor.execute(sql)
74
    print(cursor.fetchall())
75

76

77
if __name__ == '__main__':
78
    # add_data()
79
    # change_data()
80
    # delete_data()
81
    check_data()

【2】自动提交事务#

1
import pymysql
2

3

4
def create_mysql_connection():
5
    conn = pymysql.connect(
6
        # 指定 IP 和 PORT
7
        host='127.0.0.1',
8
        port=3306,
9

10
        # 指定用户名和密码
11
        user='root',
12
        password='1314521',
13

14
        # 指定默认编码
15
        charset='utf8',
16

17
        # 指定数据库
18
        database='day05',
19

20
        # 自动提交事务
21
        autocommit=True
22
    )
23

24
    # 创建游标对象
25
    cursor = conn.cursor(pymysql.cursors.DictCursor)
26

27
    # 返回游标对象
28
    return cursor, conn
29

30

31
cursor, conn = create_mysql_connection()
32

33

34
# 增加数据
35
def add_data():
36
    # （1） 拿到想要处理的数据
37
    username = input("Username:>>>").strip()
38
    password = input("Password:>>>").strip()
39

40
    # （2） 创建SQL语句
41
    sql = "INSERT INTO user(name,password) values (%s,%s);"
42

43
    # （3）查看SQL语句执行状态
44
    rows = cursor.execute(sql, (username, password))
45
    print(rows)
46

47

48

49

50
# 更改数据
51
def change_data():
52
    username = input("Username:>>>").strip()
53
    password = input("Password:>>>").strip()
54
    sql = "update user set name=%s, password=%s where id=1;"
55

56
    rows = cursor.execute(sql, (username, password))
57
    print(rows)
58

59

60

61
# 删除数据
62
def delete_data():
63
    sql = "delete from user where id =1;"
64

65
    rows = cursor.execute(sql)
66
    print(rows)
67

68

69

70

71
# 查询数据
72
def check_data():
73
    sql = "select * from user"
74
    cursor.execute(sql)
75
    print(cursor.fetchall())
76

77

78
if __name__ == '__main__':
79
    # add_data()
80
    # change_data()
81
    # delete_data()
82
    check_data()

音乐

音乐

【一】Python操作数据库简介#

【1】什么是DB-API#

【2】数据库操作模块#

【二】PyMySQL简介#

【三】PyMySQL使用#

【0】安装#

【1】连接数据库#

（1）连接语法#

【2】主要方法介绍#

【3】操作MySQL数据库#

（1）创建游标对象#

（2）执行SQL语句#

【4】查询结果#

（1）获取所有结果(fetchall)#

（2）获取一行数据(fetchone)#

（3）获取查询指定结果量(fetchmany)#

（4）移动光标#

【5】插入操作#

【6】更新操作#

【7】删除操作#

【8】批量插入操作#

【9】总结模版#

【四】SQL注入问题#

【1】什么是SQL注入问题#

【2】产生原因#

【3】示例#

（0）准备#

（1）登录注册#

（2）问题#

【4】解决办法#

【五】PyMySQL进阶#

【1】主动提交事务#

【2】自动提交事务#

支持与分享

音乐

PyMySQL模块

【一】Python操作数据库简介#

【1】什么是DB-API#

【2】数据库操作模块#

【二】PyMySQL简介#

【三】PyMySQL使用#

【0】安装#

【1】连接数据库#

（1）连接语法#

【2】主要方法介绍#

【3】操作MySQL数据库#

（1）创建游标对象#

（2）执行SQL语句#

【4】查询结果#

（1）获取所有结果(fetchall)#

（2）获取一行数据(fetchone)#

（3）获取查询指定结果量(fetchmany)#

（4）移动光标#

【5】插入操作#

【6】更新操作#

【7】删除操作#

【8】批量插入操作#

【9】总结模版#

【四】SQL注入问题#

【1】什么是SQL注入问题#

【2】产生原因#

【3】示例#

（0）准备#

（1）登录注册#

（2）问题#

【4】解决办法#

【五】PyMySQL进阶#

【1】主动提交事务#

【2】自动提交事务#

支持与分享