MySQL— pymysql模組（防止sql注入），視覺化軟體Navicat
阿新 • • 發佈：2018-11-09
一.Pymysql
import pymysql #python2.X 中是 mysqldb 和 pythonmysql 用法是一模一樣的 #pymysql可以偽裝成上面這兩個模組 user = input('username: ') pwd = input('password: ') #連線資料庫 conn = pymysql.connect(host='localhost',user='root',password='gkx321',database='db222') cursor = conn.cursor() #類似檔案控制代碼。 比如conn是打開了一個櫃子，cursor就是我們拿東西的手pymysql初識# cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) #設定為字典格式，fetch的時候可以顯示欄位名，以字典形式 #注意以後絕對不要這麼拼接 # sql = "select * from userinfo where username='%s' and password = '%s' "%(user,pwd) # username: uu' or 1=1 -- # password: gkx # (1, 'gkx', 'gkx123') # 登陸成功 #正確方式 sql = "select * from userinfo where username = %s and password = %s" #三種方式 元組，列表，字典 # cursor.execute(sql) cursor.execute(sql,(user,pwd)) #執行語句 ,末尾加不加逗號都行 #r = cursor.execute(sql,(user,pwd)) #有個返回值，表示受影響的行數 # cursor.execute(sql,[user,pwd]) # sql = "select * from userinfo where username = %（u）s and password = %(p)s " # cursor.execute(sql,{'u':user,'p':pwd})ret = cursor.fetchone() #fetchone類似 readline 執行一次，只讀取一行。 print(ret) cursor.close() conn.close() if ret: print('登陸成功') else: print('登陸失敗')
#總結 #查詢需要 fetchone #更新和insert 需要 conn.commit() #create drop alter 只要 cursor.execute() import pymysql conn = pymysql.connect(host='localhost',user='root',password='gkx321',database='db222') # cursor = conn.cursor() #類似檔案控制代碼。 比如conn是打開了一個櫃子，cursor就是我們拿東西的手 cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) #設定為字典型別的 cursor ''' #增加 刪除 改 # user = 'ccc' # pwd = 'ccc123' sql = "insert into userinfo(username,password) values(%s,%s)" # cursor.execute(sql,(user,pwd,)) cursor.executemany(sql,[('ww','ww123'),('aaa','aaa123')]) #增加多行，只適合insert時候用 # r = cursor.execute(sql,(user,pwd,)) #返回值，受影響的行數 conn.commit() #增刪改 三種操作一定要 commit 不提交資料庫不知道要修改 for 迴圈中 可以 全部execute後，再進行一次 commit ''' #查 sql = "select * from userinfo" cursor.execute(sql) # 既然fetchone像檔案中的readline，那麼就有類似 tell和seek的語句： cursor.scroll(2,mode='relative') #根據當前位置，相對移動 .2表示從當前位置，選擇下下行，自然1就是選擇下一行了 cursor.scroll(2,mode='absolute') #根據絕對位置移動 2表示從第1行往後的2行，即表示選擇第3行 #可以通過設定cursor，來讓fetchone顯示的時候，帶上欄位名，以字典形式 ret = cursor.fetchone() #只有查詢的時候才需要 print(ret) ret = cursor.fetchone() print(ret) ret = cursor.fetchall() print(ret) # # ret1 = cursor.fetchall() #返回一個元組，每條資料又是一個元組 # print(ret1) #要注意的是，儘量還是要用sql語句操作，因為比如fetchall/fetchmany 會把所有資料放到記憶體中來，比如10萬條資料，那麼是相當佔記憶體的 #還是建議用 sql中的 limit 分頁 # ret1 = cursor.fetchall() # ret2 = cursor.fetchmany(3) cursor.close() conn.close()pymysql—增刪改查
#新插入資料的自增id cursor.lastrowid import pymysql conn = pymysql.connect(host='localhost',user='root',password='gkx321',database='db222') cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) sql = "insert into userinfo(username,password) values('ddd','ddd123')" cursor.execute(sql) print(cursor.lastrowid) # #獲取插入資料的自增id #那如果是插入多行呢，也只獲取最後一行的 自增id，所以有需要外來鍵的話，只能一個個插入再獲取 conn.commit() cursor.close() conn.close()新插入資料的自增id
import pymysql import sys conn = pymysql.connect(host='localhost',user='root',password='gkx321',database='db222') cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) def select(sql,cursor,conn): ret = cursor.execute(sql) print('受影響行數為%s行'%ret) ret2 = cursor.fetchall() return ret2 def drop(sql,cursor,conn): ret = cursor.execute(sql) return '\033[34m操作成功\033[0m' def change(sql,cursor,conn): ret = cursor.execute(sql) conn.commit() if ret: return '\033[34m受影響行數為%s行\033[0m'%ret else: print('輸入不正確') return False # def quit(sql, cursor, conn): # print('退出了') # exit() def login(cursor,conn): count = 0 while count<3: user = input('使用者名稱:') pwd = input('密碼：') sql = "select * from user where username=%s and password=%s" ret = cursor.execute(sql,(user,pwd)) if ret: sql = "select * from u_g left join grant_info on u_g.g_id = grant_info.id left join user on u_g.u_id = user.id;" cursor.execute(sql) ret = cursor.fetchall() for line in ret: if line['username'] == user: print('%s的許可權是%s'%(line['username'],line['grant_lst'])) return True else: print('使用者資訊有誤') count += 1 return False def op(): while True: menu = [('查詢','select'), ('增加','change'), ('新建表','drop'), ('刪除','drop'), ('更新','change'), ('退出','') ] for index,item in enumerate(menu,1): if index < len(menu): print('%s:%s'%(index,item[0]),end=' ') else: print('%s:%s'%(index,item[0])) try: choi = int(input('選擇操作序號：')) if choi == 6: print('\033[31m已選擇退出\033[0m') break print('\033[32m進行%s操作\033[0m' % menu[choi - 1][0]) except: print('\033[31m選擇有誤，請輸入序號\033[0m') continue print('\033[34m輸入sql語句，或者按q返回\033[0m') sql = input('輸入sql命令>>：') if sql == 'q': continue try: func = getattr(sys.modules[__name__], menu[choi - 1][1]) ret = func(sql, cursor, conn) if choi != 1: print(ret) else: for index,item in enumerate(ret): print(item) except: print('\033[31m語法有誤，重新輸入\033[0m') cursor.close() conn.close() ret = login(cursor, conn) if ret: op()pymysql作業1
pymysql作業1：簡單實現用pymysql進行資料庫管理
import random import pymysql conn = pymysql.connect(host='localhost',user='root',password='gkx321',database='db300w',charset='utf8') cursor = conn.cursor() # # name = 'alex' # emai = 'email' # for i in range(0,2000000): # i = str(i) # gender = random.choice(['男', '女']) # sql = "insert into userinfo(name,email,gender) values(%s,%s,gender)" # cursor.execute(sql % (name+i,emai+i)) # conn.commit() # # cursor.close() # conn.close() name = 'alex' emai = 'email' for i in range(3,3000001): gender = random.choice(['男', '女']) sql = " update userinfo set gender='%s' where id =%s;"% (gender,i) cursor.execute(sql) conn.commit() cursor.close() conn.close() #sql 拼接的時候，如果 %s 不加單引號，那麼sql語句裡也不會有單引號pymysql作業2
pymysql作業2：用pymysql向表格插入300萬條資料
# ===>要先問清楚，要求是什麼：公司開發一個專案，假設100天，可能有70天在明確需求 # 1. 基於角色的許可權管理 # 2. 明確需求分析 # 基於角色的許可權管理 # # 使用者資訊 # id username pwd role_id # 1 alex 123123 1 # 2 eric 123123 1 # # 許可權 # 1 訂單管理 # 2 使用者劵 # 3 Bug管理 # .... # # 角色表： # 1 IT部門員工 # 2 諮詢員工 # 3 IT主管 # # 角色許可權管理 #角色 #許可權 # 1 1 # 1 2 # 3 1 # 3 2 # 3 3 #那如果一個使用者有多個角色呢，可以再多一個表 角色和使用者關係表作業心得
要先問清楚，要求是什麼：公司開發一個專案，假設100天，可能有70天在明確需求
import pymysql conn = pymysql.connect(host='localhost',user='root',password='gkx321',database='sql_homework',charset='utf8') cursor = conn.cursor(cursor=pymysql.cursors.DictCursor) cursor.callproc('p3',(12,2)) #n1是12，無所謂n2是多少，不影響 ret = cursor.fetchall() print(ret) #out的值要這麼獲取，固定寫法 cursor.execute('select @_p3_0,@_p3_1') #可以只寫一個 0獲取n1，1獲取n2 ret = cursor.fetchall() print(ret) ''' 為什麼格式是這樣呢，因為pymysql內部幫我們做了這樣子的操作 set @ _p3_0 = 12 set @ _p3_1 = 2 call p3( @ _p3_0,@_p3_1) select @ _p3_0,@_p3_1 ''' # cursor.execute('select * from teacher') # ret = cursor.fetchall() # print(ret) cursor.close() conn.close()Pymysql-儲存過程的操作
# http://www.runoob.com/mysql/mysql-sql-injection.html # https://www.cnblogs.com/sdya/p/4568548.html # sql = "select * from userinfo where username='%s' and password = '%s' "%(user,pwd) #如果我們這麼拼接字串 # 當 %s 傳入為 uu' or 1=1 -- 那麼sql語句變為 # sql = "select * from userinfo where username='uu' or 1=1 -- ' and password = '%s' "%(user,pwd) （-- 為sql中的註釋符號） # 從而讓sql變得不安全，可以隨便登陸 具體見 上面例子中，《pymysql初識》mysql注入
二.navicat是MySQL其中一個視覺化軟體
#·······建議還是用終端使用MySQL······· #通過以下2步才能用 8.0登陸 navicat： # mysql加密規則 https://www.cnblogs.com/atuotuo/p/9402132.html # ALTER USER 'root'@'localhost' IDENTIFIED WITH mysql_native_password BY 'gkx321'; # 把mysql 8.0加密規則 從caching_sha2_password 更改為 mysql_native_password # Update user set host='%' where user='root'; # select user,host,plugin from user #我們用navicat這個IDE，主要還是為了學習過程中，儲存和檢視命令 #生產過程中一定不要用，會被鄙視。 ''' #1.轉儲資料庫檔案： #對著db右鍵，可以把資料庫的結構和資料匯出 #匯入的話，直接新建查詢，把sql的檔案貼上進入，執行即可。 #那在終端要怎麼備份呢？ #用 mysqldump #備份：資料表結構和資料 #開啟cmd 輸入命令： mysqldump -u root db1 > db1.sql -p 回車輸入密碼即可 #儲存位置在 cmd行輸入時候的路徑，檔名為 db1.sql #只備份：資料表結構： #mysqldump -u root -d db1 > db1.sql -p #多了個 -d #那備份的怎麼匯入呢？ #首先建立一個數據庫 create database db_name； #命令： mysqldump -uroot -p密碼 db_name < 檔案路徑 '''navicat初識
D:\python-全棧九期\navicat12
安裝包