目錄

增

改

刪

查詢資料庫

pymysql模組用於在Python程式中操作資料庫.
該模組本質是一個套接字客戶端軟體.
Windows安裝命令：pip3 install pymysql

基本使用：

# 準備資料庫、資料和遠端使用者：

mysql> select * from blog.userinfo;
+----+------+-----+
| id | name | pwd |
+----+------+-----+
|  1 | zyk  | ___ |
+----+------+-----+
1 row in set (0.00 sec)

mysql> show grants for 'zyk'@'%';
+------------------------------------------+
| Grants for 
 
[email protected]%                         |
+------------------------------------------+
| GRANT ALL PRIVILEGES ON *.* TO 'zyk'@'%' |
+------------------------------------------+
1 row in set (0.00 sec)

# 實現：使用Python程式實現使用者登陸，如果使用者存在則登陸成功

import pymysql

user, pwd = input('user:'), input('pwd:')

# 1. 連線資料庫
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='zyk',
    password='
 
[email protected]',
    db='blog',  # 要連線的資料庫名稱
    charset='utf8'  # 要連線的資料庫編碼
)

# 2. 建立遊標
cursor = conn.cursor()


# 3. 執行sql語句
sql = "select name,pwd from userinfo where name='%s' and pwd='%s'" % (user, pwd)

result = cursor.execute(sql)  # 返回sql查詢成功的記錄數目（查到一條資料後便停止查詢）
# print(result)   # 即：成功返回1，否則0


# 4. 關閉
cursor.close()  # 關閉遊標
conn.close()  # 關閉連線

print('log in successfully!') if result else print('logon failure!')
 

execute()之sql注入

使用者存在，繞過密碼

利用sql語句中的註釋(--)，註釋掉密碼的部分.

import pymysql

user, pwd = input('user:'), input('pwd:')

# 1. 連線資料庫
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',  # 要連線的資料庫名稱
    charset='utf8'  # 要連線的資料庫編碼
)

# 2. 建立遊標
cursor = conn.cursor()


# 3. 執行sql語句
# sql = "select name,pwd from userinfo where name='%s' and pwd='%s'" % (user, pwd)

# 使用者存在，繞過密碼
sql = "select name,pwd from userinfo where name='%s' -- abc' and pwd='%s'" % (user, pwd)    # 注意：--後面要有一個空格，'abc'為任意字元，後面還要加個單引號
print(sql)

result = cursor.execute(sql)  # 返回sql查詢成功的記錄數目
# print(result)   # 即：成功返回1，否則0


# 4. 關閉
cursor.close()  # 關閉遊標
conn.close()  # 關閉連線


print('log in successfully!') if result else print('logon failure!')



"""
程式碼輸出如下：

user:zyk
pwd:
select name,pwd from userinfo where name='zyk' -- abc' and pwd=''
log in successfully!
"""

可見，我們只輸入了使用者名稱，並沒有輸入密碼（密碼被註釋掉了），依然顯示登陸成功.

使用者不存在，繞過使用者與密碼

利用or語法，新增一條結果為True的語句，並註釋掉密碼的部分.

import pymysql

user, pwd = input('user:'), input('pwd:')

# 1. 連線資料庫
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',  # 要連線的資料庫名稱
    charset='utf8'  # 要連線的資料庫編碼
)

# 2. 建立遊標
cursor = conn.cursor()


# 3. 執行sql語句
# sql = "select name,pwd from userinfo where name='%s' and pwd='%s'" % (user, pwd)

# 使用者不存在，繞過使用者與密碼
sql = "select name,pwd from userinfo where name='%s' or 1=1 -- abc' and pwd='%s'" % (user, pwd)
print(sql)

result = cursor.execute(sql)  # 返回sql查詢成功的記錄數目
# print(result)   # 即：成功返回1，否則0


# 4. 關閉
cursor.close()  # 關閉遊標
conn.close()  # 關閉連線


print('log in successfully!') if result else print('logon failure!')



"""
程式碼輸出如下：

user:
pwd:
select name,pwd from userinfo where name='' or 1=1 -- abc' and pwd=''
log in successfully!
"""

可見，我們併為輸入使用者名稱和密碼，依然顯示登陸成功.

解決sql注入問題

pymysql模組自帶解決sql注入的問題，只要我們按照pymysql模組的規定就行.

import pymysql

user, pwd = input('user:'), input('pwd:')

# 1. 連線資料庫
conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',  # 要連線的資料庫名稱
    charset='utf8'  # 要連線的資料庫編碼
)

# 2. 建立遊標
cursor = conn.cursor()


# 3. 執行sql語句
# sql = "select name,pwd from userinfo where name='%s' and pwd='%s'" % (user, pwd)
# result = cursor.execute(sql)  # 返回sql查詢成功的記錄數目
# print(result)   # 即：成功返回1，否則0

# 改寫為（execute幫我們拼接字串，我們無需且一定不能再為%s加引號）
sql = 'select name,pwd from userinfo where name=%s and pwd=%s'

# 改寫為（用agrs引數傳入使用者名稱及密碼）
result = cursor.execute(sql, [user, pwd])


# 4. 關閉
cursor.close()  # 關閉遊標
conn.close()  # 關閉連線


print('log in successfully!') if result else print('logon failure!')

execute的arges引數可以接受list、tuple或dict：
如果args是一個列表或元組，%s可以用作查詢中的佔位符。
如果args是一個dict， %(name)s可以用作查詢中的佔位符。

# arges引數為dict時的寫法：
sql = 'select name,pwd from userinfo where name=%(name)s and pwd=%(pwd)s'
result = cursor.execute(sql, {'name': user, 'pwd': pwd})

commit()

在資料庫裡增、刪、改，只是在記憶體中操作，所以必須要進行提交，否則插入的資料不但不會生效，還會影響到自增id等.

增

import pymysql

user, pwd = input('user:'), input('pwd:')


conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',  # 要連線的資料庫名稱
    charset='utf8'  # 要連線的資料庫編碼
)

# 建立遊標
cursor = conn.cursor()


# 增
sql = 'insert into userinfo(name, pwd) values (%s, %s)'
effect_row = cursor.execute(sql,(user, pwd))
print(effect_row)   # 返回增加的記錄數

# 同時插入多條資料：executemany()
# effect_row = cursor.executemany(sql, [("張三", '123'), ("李四", '456')])


# 一定要記得提交
conn.commit()


# 關閉
cursor.close()
conn.close()

改

import pymysql

new_name = input('>>> ')

conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',  # 要連線的資料庫名稱
    charset='utf8'  # 要連線的資料庫編碼
)

# 建立遊標
cursor = conn.cursor()


# 改
sql = "update userinfo set name=%s where name='zyk'"
effect_row = cursor.execute(sql, new_name)
print(effect_row)   # 返回修改的記錄數

# 一定要記得提交
conn.commit()


# 關閉
cursor.close()
conn.close()

刪

import pymysql

conn = pymysql.connect(
    host='127.0.0.1',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',  # 要連線的資料庫名稱
    charset='utf8'  # 要連線的資料庫編碼
)

cursor = conn.cursor()


# 刪
sql = "delete from userinfo where name='張三' or name='李四'"    # 同時刪除多條記錄
effect_row = cursor.execute(sql)
print(effect_row)   # 返回刪除的記錄數

# 一定要記得提交
conn.commit()


# 關閉
cursor.close()
conn.close()

查詢資料庫

• fetchone()        # 獲取下一行資料，第一次為首行
• fetchall()        # 獲取所有行資料
• fetchmany(4)        # 獲取4行數

表內容如下：

fetchone()

import pymysql

# 連線資料庫
conn = pymysql.connect(
    host='localhost',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',
    charset='utf8'
)

# 建立遊標
cursor = conn.cursor()


# 執行sql語句
sql = 'select * from userinfo'
cursor.execute(sql)


# 查詢第一行資料
row = cursor.fetchone()
print(row)

# 查詢第二行資料
row = cursor.fetchone()
print(row)


# 關閉
cursor.close()
conn.close()



"""
輸出：

(1, 'zyk', '___')
(2, '張三', '123')
"""

如上：在獲取行資料的時候，可以理解為開始。有一個行指標指向第一行，獲取一行，他就向下移動一行。所以當行指標移動到最後一行時，便無法在獲取到資料了(None)。此時我們可以使用如下方法來移動行指標：

• cursor.scroll(1, mode='relative')        # 相對當前位置移動
• cursor.scroll(2, mode='absolute')        # 相對絕對位置移動

值1為移動的行數，relative：可指定負數(向上移動)；adsolute：0為第一行；
mode指定的是相對於當前行移動還是​相對於首行移動.​​​​​​

fetchall()

import pymysql

# 連線資料庫
conn = pymysql.connect(
    host='localhost',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',
    charset='utf8'
)

# 建立遊標
cursor = conn.cursor()


# 執行sql語句
sql = 'select * from userinfo'
cursor.execute(sql)


# 獲取所有資料
rows = cursor.fetchall()
print(rows)


# 關閉
cursor.close()
conn.close()



"""
輸出：

((1, 'zyk', '___'), (2, '張三', '123'), (3, '李四', '456'))
"""

預設情況下，我們獲取到的返回值是元組，可使用以下方式來返回字典：

# 在例項化時，將屬性cursor設定為：
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)

fetchmany()

import pymysql

# 連線資料庫
conn = pymysql.connect(
    host='localhost',
    port=3306,
    user='zyk',
    password='[email protected]',
    db='blog',
    charset='utf8'
)

# 建立遊標
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)


# 執行sql語句
sql = 'select * from userinfo'
cursor.execute(sql)


# 獲取2條資料
rows = cursor.fetchmany(2)
print(rows)


# 如果此時想要再獲取已經獲取過的資料，就需要移動行指標
cursor.scroll(0, mode='absolute')   # 移動到第一行

rows = cursor.fetchall()
print(rows)


# 關閉
cursor.close()
conn.close()



"""
輸出：

[{'id': 1, 'name': 'zyk', 'pwd': '___'}, {'id': 2, 'name': '張三', 'pwd': '123'}]
[{'id': 1, 'name': 'zyk', 'pwd': '___'}, {'id': 2, 'name': '張三', 'pwd': '123'}, {'id': 3, 'name': '李四', 'pwd': '456'}]
"""

人生中不可避免的定律

定律一：財富定律
勤勞不一定能夠致富，但懶惰一定不能致富.

定律二：忙碌定律
人可以為了自己的夢想而去忙碌，但不能因為你忙碌而失去夢想.

定律三：擔心定律
你越是擔心的事情越有可能發生.

定律四：執著定律
任何的事情都不可過分執著，無論是風光還是難堪這些都會過去.

定律五：堵住定律
有很多越是輸不起的人，越是喜歡下大賭注.

定律六：目標定律
目標太多，最後只會是失去目標，知道自己想要什麼的人，能比都想要的人更容易成功.

定律七：方向定律
如果一個人不知道自己要嚮往哪個碼頭，那麼不管什麼風都不會是順風.

定律八：誘惑定律
凡是抵擋不住誘惑的人，十之八九是沒有經歷過誘惑的人，這與誘惑大小無關.

定律九：時間定律
時間就是生命，對於男人來說是積累，對於女人來說是消耗.

年輕本無價，一身碌碌無為
讓無價變為了低價，你應該珍惜自己的機會.