引入模塊
- 在py文件中引入pymysql模塊
from pymysql import *
Connection 對象
用于建立與數(shù)據(jù)庫的連接
創(chuàng)建對象：調(diào)用connect()方法
conn=connect(參數(shù)列表)
- 參數(shù)host：連接的mysql主機，如果本機是'localhost'
- 參數(shù)port：連接的mysql主機的端口胜宇，默認(rèn)是3306
- 參數(shù)database：數(shù)據(jù)庫的名稱
- 參數(shù)user：連接的用戶名
- 參數(shù)password：連接的密碼
- 參數(shù)charset：通信采用的編碼方式酷师，推薦使用utf8
對象的方法
- close()關(guān)閉連接
- commit()提交
- cursor()返回Cursor對象，用于執(zhí)行sql語句并獲得結(jié)果
Cursor對象
- 用于執(zhí)行sql語句冗澈，使用頻度最高的語句為select、insert、update址愿、delete
- 獲取Cursor對象：調(diào)用Connection對象的cursor()方法
cs1=conn.cursor()
對象的方法
- close()關(guān)閉
- execute(operation [, parameters ])執(zhí)行語句，返回受影響的行數(shù)冻璃，主要用于執(zhí)行insert响谓、update、delete語句省艳，也可以執(zhí)行create娘纷、alter、drop等語句
- fetchone()執(zhí)行查詢語句時跋炕，獲取查詢結(jié)果集的第一個行數(shù)據(jù)赖晶，返回一個元組
- fetchall()執(zhí)行查詢時，獲取結(jié)果集的所有行辐烂，一行構(gòu)成一個元組遏插，再將這些元組裝入一個元組返回
對象的屬性
- rowcount只讀屬性，表示最近一次execute()執(zhí)行后受影響的行數(shù)
- connection獲得當(dāng)前連接對象
增刪改
from pymysql import *
def main():
# 創(chuàng)建Connection連接
conn = connect(host='localhost',port=3306,database='jing_dong',user='root',password='mysql',charset='utf8')
# 獲得Cursor對象
cs1 = conn.cursor()
# 執(zhí)行insert語句纠修，并返回受影響的行數(shù)：添加一條數(shù)據(jù)
# 增加
count = cs1.execute('insert into goods_cates(name) values("硬盤")')
#打印受影響的行數(shù)
print(count)
count = cs1.execute('insert into goods_cates(name) values("光盤")')
print(count)
# # 更新
# count = cs1.execute('update goods_cates set name="機械硬盤" where name="硬盤"')
# # 刪除
# count = cs1.execute('delete from goods_cates where id=6')
# 提交之前的操作胳嘲，如果之前已經(jīng)之執(zhí)行過多次的execute，那么就都進(jìn)行提交
conn.commit()
# 關(guān)閉Cursor對象
cs1.close()
# 關(guān)閉Connection對象
conn.close()
if __name__ == '__main__':
main()
查詢一行數(shù)據(jù)
from pymysql import *
def main():
# 創(chuàng)建Connection連接
conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset='utf8')
# 獲得Cursor對象
cs1 = conn.cursor()
# 執(zhí)行select語句扣草，并返回受影響的行數(shù)：查詢一條數(shù)據(jù)
count = cs1.execute('select id,name from goods where id>=4')
# 打印受影響的行數(shù)
print("查詢到%d條數(shù)據(jù):" % count)
for i in range(count):
# 獲取查詢的結(jié)果
result = cs1.fetchone()
# 打印查詢的結(jié)果
print(result)
# 獲取查詢的結(jié)果
# 關(guān)閉Cursor對象
cs1.close()
conn.close()
if __name__ == '__main__':
main()
查詢多行數(shù)據(jù)
from pymysql import *
def main():
# 創(chuàng)建Connection連接
conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset='utf8')
# 獲得Cursor對象
cs1 = conn.cursor()
# 執(zhí)行select語句了牛，并返回受影響的行數(shù)：查詢一條數(shù)據(jù)
count = cs1.execute('select id,name from goods where id>=4')
# 打印受影響的行數(shù)
print("查詢到%d條數(shù)據(jù):" % count)
result = cs1.fetchall()
print(result)
# 關(guān)閉Cursor對象
cs1.close()
conn.close()
if __name__ == '__main__':
main()
參數(shù)化 （防止sql注入）
- sql語句的參數(shù)化颜屠，可以有效防止sql注入
- 注意：此處不同于python的字符串格式化，全部使用%s占位
from pymysql import *
def main():
find_name = input("請輸入物品名稱：")
# 創(chuàng)建Connection連接
conn = connect(host='localhost',port=3306,user='root',password='mysql',database='jing_dong',charset='utf8')
# 獲得Cursor對象
cs1 = conn.cursor()
# # 非安全的方式
# # 輸入 " or 1=1 or " (雙引號也要輸入)
# sql = 'select * from goods where name="%s"' % find_name
# print("""sql===>%s<====""" % sql)
# # 執(zhí)行select語句白魂，并返回受影響的行數(shù)：查詢所有數(shù)據(jù)
# count = cs1.execute(sql)
# 安全的方式
# 構(gòu)造參數(shù)列表
params = [find_name]
# 執(zhí)行select語句汽纤，并返回受影響的行數(shù)：查詢所有數(shù)據(jù)
count = cs1.execute('select * from goods where name=%s', params)
# 注意：
# 如果要是有多個參數(shù)，需要進(jìn)行參數(shù)化
# 那么params = [數(shù)值1, 數(shù)值2....]福荸，此時sql語句中有多個%s即可
# 打印受影響的行數(shù)
print(count)
# 獲取查詢的結(jié)果
# result = cs1.fetchone()
result = cs1.fetchall()
# 打印查詢的結(jié)果
print(result)
# 關(guān)閉Cursor對象
cs1.close()
# 關(guān)閉Connection對象
conn.close()
if __name__ == '__main__':
main()
