Flush PRIVILEGES;?? -- 刷新權(quán)限并生效
6)查看授權(quán)
?? - 查看當(dāng)前用戶: show grants;
?? -查看其他用戶:? show grants for '用戶名'@'客戶端';
7)吊銷權(quán)限(取消用戶的某個權(quán)限)
?? - 語法: revoke 權(quán)限列表 on 庫名.表名 from '用戶名'@'客戶端地址'
?? - 示例: 吊銷Daniel用戶所有庫,所有列表的插入數(shù)據(jù)權(quán)限
?????????? revoke insert on *.* from 'bank_user'@'%';
?????????? revoke insert on bank.* from 'bank_user'@'%';
4. 數(shù)據(jù)庫事務(wù)(重點)
?? - 事務(wù)(Transacyion):
?? - 數(shù)據(jù)庫執(zhí)行一系列操作時，全都執(zhí)行，全都不執(zhí)行
???? 保證數(shù)據(jù)的一致性、正確性
?? - 例如在一筆轉(zhuǎn)賬中,執(zhí)行需要三個操作,
???????? 從轉(zhuǎn)出賬戶減去相應(yīng)金額
???????? 在轉(zhuǎn)入賬戶增加相應(yīng)金額
???????? 登記一筆轉(zhuǎn)賬明細
???????? 以上三個操作,要么全部成功,要么全部失敗
?? 3)使用事務(wù)的情況
???? - 涉及到多表的增刪改操作
???? - 執(zhí)行這些操作時需要保證一致性,正確性
?? 4)啟用事務(wù)條件要求:必須是Innodb存儲引擎
?? 5)事務(wù)的額特征(ACID)：
????? - 原子性(Atomicity)：事務(wù)是一個整體,要么全部執(zhí)行,要么全部不執(zhí)行
????? - 一致性(Consis.
????? tency):事務(wù)執(zhí)行完成后,從一個一致狀態(tài)變成另一個一致狀態(tài)
????? - 隔離性(Isolation)：不同的事務(wù)不會相互影響,干擾
????? - 持久性(Durability):一旦事務(wù)提交,對數(shù)據(jù)庫的修改就必須永久保留下來
?? 6)如何進行事務(wù)操作
??? - 開啟: start transaction
???? - 提交: commit
???? - 回滾:rollback
???? - 示例：在兩個賬戶間進行轉(zhuǎn)賬
???????????? 第一步:減去轉(zhuǎn)出賬戶余額
???????????? 第二步:在轉(zhuǎn)入賬號上加上相等的余額
???????????? 提交事務(wù)
???????????? start transaction;
???????????? update acct_new set balance = balance - 100
??????????????????? where acct_no = '6223450001';
???????????? update acct_new set balance = balance + 100
??????????????????? where acct_no ='622456000020';
???????????? commit;---或rollback
???????????? ----在提交事務(wù)前,重新登錄一個客戶端
???????????? ----查看數(shù)據(jù)是否變更
????
???? 7)SQL語句分類
????? - 數(shù)據(jù)查詢語言(DQL):查詢數(shù)據(jù),不改變數(shù)據(jù)
????? - 數(shù)據(jù)定義語言(DDL):定義數(shù)據(jù)結(jié)構(gòu),如建表/庫,刪除庫/表,創(chuàng)建/刪除索引,修改表結(jié)構(gòu)
????? - 數(shù)據(jù)操作語言(DML):對數(shù)據(jù)進行增刪改
????? - 數(shù)據(jù)控制語言(DCL):權(quán)限管理,事務(wù)操作,數(shù)據(jù)庫監(jiān)視...

???
-------------------------------------------------day25.new---------------------------------------------------
1.鎖
?? 1）鎖：對數(shù)據(jù)庫的控制權(quán)
?? 2）目的：解決多個工作單元并發(fā)操作數(shù)據(jù)的正確性
?? 3）分類：
???? a)鎖類型
?????? - 讀鎖（共享鎖）：加鎖后，可以讀取，但不能修改
?????? - 寫鎖（排它鎖）：加鎖后，不能進行讀寫

??? b)鎖粒度
?????? - 行級鎖（細粒度）：鎖定一行，并發(fā)效率高
???????? 控制較為復(fù)雜，消耗資源多
?????? - 表級鎖（粗粒度）：鎖定整張表，并發(fā)效率低
???????? 控制簡單，消耗資源較少

2.存儲引擎
?? 1)什么是存儲引擎:表的存儲方式,包括存儲機制,索引機制,鎖定方式等
?? 2)基本操作:
???? - 查看:show engines;
???? - 查看某個表的存儲引擎方式:show create table 表名

???? -建表時指定存儲引擎
????? create table t1(id int primary key)engine=InnoDB default charset=utf8;
???????????????????????????????????????? engine 指定存儲
???? - 修改存儲引擎方式
?????? alter table t1 engine = MyISAM;
?? 3)常見存儲引擎
???? a)InooDB
????? 特點:支持事務(wù),行級鎖,外鍵
????? 共享表空間
???? *.frm??? 表結(jié)構(gòu)和索引
????? *.ibd??? 表記錄
????? show global variables like '%datadir'命令查看數(shù)據(jù)存儲位置????
????? sudo -i切換到root用戶,進入目錄查看
???? - 使用場合
?????? 更新操作密集的表
?????? 有數(shù)據(jù)庫事務(wù)支持的要求
?????? 自動災(zāi)備,恢復(fù)
?????? 有外鍵約束要求
?????? 支持自增長字段(auto_increment)

???? b)MyISAM
?????? - 支持表級鎖定、不支持事務(wù)、不支持外鍵
???????? 不支持行鎖定，訪問速度較快
?????? - 獨享表空間
?????????? 表名.frm: 表結(jié)構(gòu)
?????????? 表名.myd: 表數(shù)據(jù)
?????????? 表名.myi: 表索引
?????? - 適用場合
?????????? 查詢操作較多
?????????? 數(shù)據(jù)一致性要求較低（不支持事務(wù)）
?????????? 沒有外鍵約束

??? c)Memory(內(nèi)存表):
???????? - 表結(jié)構(gòu)存儲在磁盤上(硬盤)，數(shù)據(jù)存儲在內(nèi)存
?????????? 訪問速度很快
???????? - 文件：表名.frm?? 存儲表結(jié)構(gòu)
???????? - 服務(wù)（或機器）重啟后，表中的數(shù)據(jù)丟失
???????? - 適用場合：
?????????????? 數(shù)據(jù)量小、訪問速度要求極快、訪問頻率高、
?????????????? 數(shù)據(jù)丟失后不會造成影響?
???????? - 示例:
?????????????? 1:創(chuàng)建memory引擎的表
???????????????? create table t2(id int)engine=memory;
?????????????? 2:插入數(shù)據(jù)并查詢
?????????????? 3:重啟服務(wù),再查詢,數(shù)據(jù)消失
???????????????? sudo /etc/init.d/mysql restart

???? 3. E-R模型：實體關(guān)系模型
?????????? a)實體(Entry): 現(xiàn)實中可以區(qū)分的事物稱之為實體
?????????? b)關(guān)系(Relationship): 實體之間的聯(lián)系
???????????? - 一對一
???????????? - 一對多
???????????? - 多對多
?????????? c)屬性：實體所具有的數(shù)據(jù)特征
?????????? d)E-R圖：用圖形化方式，表達實體間的關(guān)系
???????????? 矩形：表示實體
???????????? 橢圓：實體的屬性
???????????? 菱形：實體間的關(guān)系
?????????????? 一對一：菱形左右各寫一個1
?????????????? 一對多：菱形左右分別用1，N來表示
?????????????? 多對多：菱形左右分別用M, N來表示
?????????? e）練習(xí)：畫出賬戶,交易明細,客戶實體之間的E-R圖（見ER圖.pptx）
???? 4. 使用Python訪問MySQL
?????? 1）pymysql庫：Python語言訪問MySQL接口
???????? - 安裝：
?????????? 在線：sudo pip3 install pymysql
?????????? 離線：
???????????? 第一步：下載安裝包，下載地址：
???????????????? https://pypi.org/project/PyMySQL/
???????????? PyMySQL-0.9.3.tar.gz
???????? 第二步：解壓包，并執(zhí)行安裝
???????????????? tar -zxvf PyMySQL-0.9.3.tar.gz
???????????? cd PyMySQL-0.9.3
???????? 第三步:進入目錄,安裝
???????????? python3 setup.py install
???????? - 驗證：進入Python交互模式，執(zhí)行導(dǎo)入包操作
???????????????? import pymysql
???????????? 如果不報錯，則說明安裝成功

??????? # 第一步：導(dǎo)入pymysql模塊
import pymysql
host = 'localhost'#服務(wù)器地址
user = 'root'#用戶名
passwd = '123456'#密碼
dbname = 'bank'#庫名稱

#第二步：建立到數(shù)據(jù)庫服務(wù)器的連接，創(chuàng)建連接對象
conn = pymysql.connect(host,user,passwd,dbname)
#第三步：獲取游標對象(cursor)，通過調(diào)用數(shù)據(jù)庫連接 對象獲得游標????????
cursor = conn.cursor()
#第四步：利用cursor對象提供的方法，執(zhí)行SQL語句
cursor.execute("select * from acct_new")
result = cursor.fetchall()#取查詢到的數(shù)據(jù)
for r in result:
???? tmp = "帳號：%s,戶名：%s,金額:%s"%(r[1],r[1],r[6])
???? print(tmp)
#第五步：提交事務(wù)（如果需要）
#第六步：關(guān)閉游標對象
cursor.close()
#第七步：關(guān)閉數(shù)據(jù)庫連接對象
conn.close()
?????? 2）PyMySQL訪問MySQL的流程
???????? 第一步：導(dǎo)入pymysql模塊
???????? 第二步：建立到數(shù)據(jù)庫服務(wù)器的連接，創(chuàng)建連接對象
???????? 第三步：創(chuàng)建游標對象(cursor)，通過調(diào)用數(shù)據(jù)庫連接
???????????????? 對象獲得游標
???????? 第四步：利用cursor對象提供的方法，執(zhí)行SQL語句
???????? 第五步：提交事務(wù)（如果需要）
???????? 第六步：關(guān)閉游標對象
???????? 第七步：關(guān)閉數(shù)據(jù)庫連接對象
??????
?????? 3）PyMySQL模塊的主要方法
???????? - connect:? 連接數(shù)據(jù)庫
???????????? 參數(shù)：host??? 服務(wù)器地址
?????????????? port??? 服務(wù)器端口(省略連默認端)
?????????????? user??? 用戶名
?????????????? passwd??? 密碼
?????????????? db??? 數(shù)據(jù)庫名稱
?????????????? charset??? 指定編碼格式

??????? - connection連接對象支持的方法
??????????? cursor()??????? 獲取游標
??????????? commit()??????? 提交事務(wù)
??????????? rollback()??? 回滾事務(wù)
??????????? close()??????? 關(guān)閉游標

??????? - cursor游標對象支持的方法
??????????? execute(sql)??? 執(zhí)行SQL語句
??????????? fetchall()??? 取得查詢結(jié)果集中的所有數(shù)據(jù)
??????????? fetchone()??? 取查詢結(jié)果集中一筆數(shù)據(jù)
??????????? fetchmany(size)??? 取得指定筆數(shù)數(shù)據(jù)
??????????? close()??????? 關(guān)閉游標對象

?????????? 只讀屬性：
??????????? rowcount??????? 返回修改影響的筆數(shù)
?????? 4）示例：
????? 示例1：查詢
???????? # pymysql查詢示例
???????? import pymysql
???????? from db_conf import * #導(dǎo)入配置

??????? #建立到數(shù)據(jù)庫服務(wù)器的連接，創(chuàng)建連接對象
???????? conn = pymysql.connect(host, user, \
??????????????????? password, dbname)??????????????

??????? #創(chuàng)建游標對象(cursor)，通過調(diào)用數(shù)據(jù)庫連接
???????? #對象獲得游標
???????? cursor = conn.cursor()

??????? #利用cursor對象，執(zhí)行SQL語句
???????? sql = "select * from acct"
???????? cursor.execute(sql)? #執(zhí)行SQL語句

??????? #取出查詢結(jié)果,并打印
???????? result = cursor.fetchall() #result是元組
???????? for r in result: #遍歷result
???????????? acct_no = r[0] #賬號
???????????? acct_name = r[1] #戶名
???????????? if r[6]: #判斷是否為空值
???????????? balance = float(r[6]) #余額
???????????? else:
???????????? balance = 0.00 #余額為空設(shè)置為0
???????????? print("賬號:%s, 戶名:%s, 余額:%.2f" % \
????????????? (acct_no, acct_name, balance))
???????? #關(guān)閉游標對象
???????? cursor.close()
???????? #關(guān)閉數(shù)據(jù)庫連接對象
???????? conn.close()
???????
??? ???? 示例2：插入
???????? # pymysql的插入示例
???????? import pymysql
???????? from db_conf import * #導(dǎo)入配置

??????? try:???????
???????????? conn = pymysql.connect(host, user, \
??????????????????? password, dbname)? #連接數(shù)據(jù)庫
???????????? cursor = conn.cursor()? #獲取游標
???????????? #執(zhí)行SQL語句
???????????? sql = '''insert into
?????????????? acct(acct_no, acct_name, cust_no,
??????????????? acct_type, reg_date, status, balance)
?????????????? values('622345000010','Robert', 'C0010',
??????????????? 1, date(now()), 1, 33.00)'''???
???????????? print(sql)
???????????? cursor.execute(sql) #執(zhí)行
???????????? conn.commit() #提交事務(wù)
???????????? print("Insert OK")
???????? except Exception as e:
???????????? print("數(shù)據(jù)庫插入異常")
???????????? print(e)
???????? finally:
???????????? cursor.close() #關(guān)閉游標
???????????? conn.close() #關(guān)閉連接
???????????
??????? 示例3：修改
???????? import pymysql
???????? from db_conf import * #導(dǎo)入配置

??????? try:???????
???????????? conn = pymysql.connect(host, user, \
??????????????????? password, dbname)? #連接數(shù)據(jù)庫
???????????? cursor = conn.cursor()? #獲取游標
???????????? #執(zhí)行SQL語句
???????????? sql = '''update acct
????????????????? set balance = balance + 1000
???????????????? where acct_no='622345000010'
???????????? '''???
???????????? cursor.execute(sql) #執(zhí)行
???????????? conn.commit() #提交事務(wù)
???????????? print("修改筆數(shù):%d" % cursor.rowcount)
???????? except Exception as e:
???????????? print("數(shù)據(jù)庫修改異常")
???????????? print(e)
???????? finally:
???????????? cursor.close() #關(guān)閉游標
???????????? conn.close() #關(guān)閉連接

??????? 示例4：刪除
??????? # pymysql刪除示例
???????? import pymysql
???????? from db_conf import * #導(dǎo)入配置

??????? try:???????
???????????? conn = pymysql.connect(host, user, \
??????????????????? password, dbname)? #連接數(shù)據(jù)庫
???????????? cursor = conn.cursor()? #獲取游標
???????????? #執(zhí)行SQL語句
???????????? sql = '''delete from acct
???????????? where acct_no='622345000010'
???????????? '''???
???????????? cursor.execute(sql) #執(zhí)行
???????????? conn.commit() #提交事務(wù)
???????????? print("刪除筆數(shù):%d" % cursor.rowcount)
???????? except Exception as e:
???????????? print("數(shù)據(jù)庫刪除異常")
???????????? print(e)
???????? finally:
???????????? cursor.close() #關(guān)閉游標
???????????? conn.close() #關(guān)閉連接

??? 課堂作業(yè)：賬戶管理修改、刪除功能添加上
?????????????
???? 5. SQL語句優(yōu)化
?????? 1）在經(jīng)常查詢、排序的字段上建立索引
?????? 2）盡量少使用不等于條件判斷，不等于會放棄使用索引
?????? 3）少使用null值判斷，null值判斷會放棄使用索引
?????? 4）條件判斷少使用or連接，in，not in
?????? 5）模糊查詢避免%前置
?????? 6）查詢時如果select *，直接寫成字段名會提高效率
?????? 7）盡量少在where子句中，使用字段進行運算。例如：
????????? select * from acct where balance / 2 > 5000
?????? 8）數(shù)值類型的字段，進行條件比較時，一般比
????????? 字符串比較效率更高

???? 作業(yè)：完善賬戶管理系統(tǒng)的修改、刪除功能
??????????? 賬戶管理系統(tǒng)啟動時，增加登錄功能
??????????? （原理：打印菜單前，先輸入用戶名、密碼
????????????? 并到數(shù)據(jù)庫自建的用戶表中查詢
????????? 如果用戶名、密碼匹配，則登錄成功）

1 #賬戶類 2 class Acct: 3 def __init__(self,acct_no,acct_name,acct_type,balance): 4 self.acct_no=acct_no 5 self.acct_name=acct_name 6 self.acct_type = acct_type 7 self.balance = balance 8 def __str__(self): 9 ret = "賬號：%s,戶名：%s,類型：%d,余額：%.2f"%(self.acct_no,self.acct_name,self.acct_type,self.balance) 10 return ret acct.py 1 #賬戶管理類(業(yè)務(wù)邏輯層) 2 #實現(xiàn)賬戶新增,修改,刪除等邏輯處理 3 #賬戶類，僅用于數(shù)據(jù)傳輸 4 from db_oper import * 5 from acct import * 6 class AccMange:#賬戶管理類 7 def __init__(self,db_oper): 8 self.db_oper = db_oper#數(shù)據(jù)訪問對象 9 #查詢所有莊戶信息 10 def query_all_acct(self): 11 accts =[]#返回的Acct對象列表,可能有多個對象 12 #拼裝所需要的SQL 13 sql = "select * from acct_new" 14 #執(zhí)行查詢 15 result = self.db_oper.do_query(sql) 16 if not result: 17 print("查詢結(jié)果為空") 18 return None 19 #返回結(jié)果：實例化一個Acct對象列表返回 20 for r in result:#便利數(shù)據(jù)集 21 acct_no = r[0]#賬戶 22 acct_name = r[1]#姓名 23 acct_type =int(r[3])#類型 24 balance = r[6]#金額 25 accts.append(Acct(acct_no,acct_name,acct_type,balance)) 26 return accts#返回對象列表 27 #根據(jù)賬戶查詢,最多返回一個Ａcct對象 28 29 def query_by_id(self,acct_no): 30 sql = "select * from acct_new where acct_no = %s" % acct_no 31 result = self.db_oper.do_query(sql)#執(zhí)行查詢 32 if not result: 33 print("查詢返回空對象") 34 return None 35 #提取查詢結(jié)果,實例化一個Acct對象返回 36 r = result[0]#取得第一行數(shù)據(jù) 37 acct_no = r[0]#賬號 38 acct_name = r[1]#戶名 39 acct_type = int(r[3])#類型 40 balance = r[6]#余額 41 return Acct(acct_no,acct_name,acct_type,balance) 42 43 def insert_acct(self,acct_new):#插入 44 sql = '''insert into acct_new(acct_no,acct_name,acct_type,balance)values('%s','%s',%d,%.2f)'''%(acct_new.acct_no,acct_new.acct_name,acct_new.acct_type,acct_new.balance) 45 print("\nsql:%s\n"%sql) 46 result =self.db_oper.do_update(sql) 47 print("執(zhí)行結(jié)構(gòu),影響行數(shù)：%d"%result) 48 return 49 50 def update_acct(self,acct_new):#更新 51 sql="update acct set acct_type =%d,balance = %.2f where acct_no='%s'"%(acct_new.acct_type,acct_new.balance,acct_new.acct_no) 52 print("\nsql:%s\n"%sql) 53 result = self.db_oper.do_update(sql) 54 print("執(zhí)行結(jié)束,影響行數(shù):%d"%result) 55 return 56 57 def query_by_name(self,acct_name):#模糊？ 58 if not acct_name: 59 print("戶名對象非法") 60 return None 61 if acct_name =="": 62 print("用戶名不能為空") 63 return None 64 65 accts =[] 66 sql = "select * from acct_new where acct_name ='%s'" % acct_name 67 68 result = self.db_oper.do_query(sql) 69 if not result: 70 print("查詢返回空對象") 71 return None 72 73 for acct_info in result: 74 acct_no = acct_info[0] 75 acct_name = acct_info[1] 76 acct_type = int(acct_info[3]) 77 balance = acct_info[6] 78 accts.append(Acct(acct_no,acct_name,acct_type,balance)) 79 return accts 80 81 if __name__=="__main__": 82 db_oper = DBOper()#實例化訪問對象 83 db_oper.open_conn()#打開數(shù)據(jù)庫連接 84 85 am = AccMange(db_oper)#實例化AcctMange對象 86 db_oper.close_conn() 87 acct_manger.py 1 #ui 2 from db_oper import * 3 from acct_manager import * 4 from acct import * 5 6 #全局變量 7 db_oper = None#打印主菜單 8 am =None 9 def print_menu():#打印主菜單 10 #根據(jù)用戶輸入,進行不同操作 11 menu = '''－－－－－－－－－－請選取要執(zhí)行的操作－－－－－－－－－ 12 　　　　　　　　　　　　　　　　　１-查詢所有　　　　　　　　　　　　　　４-新增賬戶 13 　　　　　　　　　　　　　　　　　２-根據(jù)用戶查詢　　　　　　　　　　　５-修改賬戶 14 　　　　　　　　　　　　　　　　　３-根據(jù)用戶名查詢　　　　　　　 ６-刪除賬戶 15 ''' 16 print(menu) 17 def query_all():#查詢所有賬戶 18 accts = am.query_all_acct() 19 for a in accts: 20 print(a) 21 22 def query_by_id(): 23 acct_no = input("請輸入要查詢的賬號：") 24 if not acct_no: 25 print("輸入賬號不合法") 26 return 27 28 acct= am.query_by_id(acct_no) 29 print("\n查詢結(jié)果：") 30 print(acct)#打印賬戶信息 31 print("\n") 32 33 def query_by_name():#根據(jù)用戶名查詢 34 acct_name = input("請輸入要查詢的戶名：") 35 if not acct_name: 36 print("輸入賬號不合法") 37 return 38 39 accts =am.query_by_name(acct_name) 40 print("\n查詢結(jié)果：") 41 for acct in accts: 42 print(acct)#打印賬戶信息 43 print("\n") 44 45 def add_acct(): 46 try: 47 acct_no = input("請輸入賬號：") 48 acct_name = input("請輸入戶名:") 49 acct_type = int(input("請輸入賬戶類型(1-借記卡 2-理財卡 3-代繳代扣卡)：")) 50 balance = float(input("請輸入開戶金額:")) 51 assert acct_type in [1, 2, 3] 52 assert balance >= 0.000001 53 54 new_acct =Acct(acct_no,acct_name,acct_type,balance) 55 am.insert_acct(new_acct) 56 except Exception as e: 57 print("操作錯誤") 58 print(e) 59 return 60 61 def update_acct(): 62 try: 63 acct_no = input("請輸入賬號：") 64 acct_name = input("請輸入戶名:") 65 acct_type = int(input("請輸入賬戶類型(1-借記卡 2-理財卡 3-代繳代扣卡)：")) 66 balance = float(input("請輸入開戶金額:")) 67 68 assert acct_type in [1, 2, 3] 69 assert balance >= 0.000001 70 71 new_acct = Acct(acct_no,acct_name,acct_type,balance) 72 am.update_acct(new_acct) 73 except Exception as e: 74 print("操作錯誤") 75 print(e) 76 return 77 #主函數(shù) 78 def main(): 79 global db_oper 80 global am 81 db_oper = DBOper()#實例化數(shù)據(jù)訪問對象 82 db_oper.open_conn()#打開數(shù)據(jù)庫連接 83 am = AccMange(db_oper)#實例化AccMange對象 84 85 while True: 86 print_menu() 87 oper = input("請選則要執(zhí)行的操作:") 88 if oper == "1": #查詢所有賬戶 89 query_all() 90 elif oper == "2": #根據(jù)賬號查詢 91 query_by_id() 92 elif oper == "3": #根據(jù)戶名查詢 93 query_by_name() 94 elif oper == "4": #新增賬戶 95 add_acct() 96 elif oper == "5": #修改賬戶 97 update_acct() 98 elif oper == "6": #刪除賬戶 99 pass 100 else: 101 break 102 db_oper.close_conn() 103 104 if __name__ == "__main__": 105 main() acct_manger_ui.py 1 #數(shù)據(jù)庫配置 2 host = 'localhost'#服務(wù)器地址 3 user = 'root'#用戶名 4 passwd = '123456'#密碼 5 dbname = 'bank'#庫名稱 db_conf.py 1 #數(shù)據(jù)庫訪問類 2 import pymysql 3 import db_conf 4 class DBOper: 5 #構(gòu)造方法 6 def __init__(self): 7 self.host =db_conf.host 8 self.user =db_conf.user 9 self.passwd =db_conf.passwd 10 self.dbname =db_conf.dbname 11 self.db_conn = None#數(shù)據(jù)庫的連接對象 12 13 #連接數(shù)據(jù)庫 14 def open_conn(self): 15 try: 16 self.db_conn = pymysql.connect(self.host,self.user,self.passwd,self.dbname) 17 except Exception as e: 18 print("連接數(shù)據(jù)庫失敗") 19 print(e) 20 else: 21 print("連接數(shù)據(jù)庫成功") 22 #關(guān)閉連接 23 def close_conn(self): 24 try: 25 self.db_conn.close() 26 except Exception as e: 27 print("連接數(shù)據(jù)庫失敗") 28 print(e) 29 else: 30 print("關(guān)閉數(shù)據(jù)庫成功") 31 32 #執(zhí)行查詢返回結(jié)果集 33 def do_query(self,sql): 34 if not sql:#參數(shù)合法性判斷 35 print("sql語句不合法") 36 return None 37 if sql == "":#參數(shù)合法性判斷 38 print("sql語句不合法") 39 return None 40 41 try: 42 cursor = self.db_conn.cursor()#獲取游標 43 cursor.execute(sql)#執(zhí)行sql語句 44 result = cursor.fetchall()#獲取數(shù)據(jù) 45 cursor.close()#關(guān)閉游標 46 return result#返回查詢數(shù)據(jù)集 47 except Exception as e: 48 print("查詢出錯") 49 print(e) 50 return None 51 52 53 #執(zhí)行增刪改等變更操作 54 def do_update(self,sql): 55 if not sql:#參數(shù)合法性判斷 56 print("sql語句不合法") 57 return None 58 if sql == "":#參數(shù)合法性判斷 59 print("sql語句不合法") 60 return None 61 62 try: 63 cursor = self.db_conn.cursor()#獲取游標 64 result = cursor.execute(sql)#執(zhí)行ＳＱＬ語句 65 self.db_conn.commit()#提交事物 66 cursor.close() 67 return result#返回受影響的筆數(shù) 68 except Exception as e: 69 print("執(zhí)行sql語句出錯") 70 print(e) 71 return None 72 73 #測試 74 if __name__=="__main__": 75 dboper = DBOper() 76 dboper.open_conn() 77 ret = dboper.do_query("select * from acct_new") 78 for x in ret: 79 print(x) 80 81 ret = dboper.do_update("update acct_new set balance = balance + 100 where acct_no = '6223456000 '") 82 83 print(ret) 84 #查詢 85 # result = dboper.do_query("select * from acct_new") 86 # for x in result: 87 # print(x) 88 89 # dboper.close_conn()#關(guān)閉數(shù)據(jù)庫連接 90 91 #修改數(shù)據(jù)測試 92 # sql = '''update acct_new set balance = balance +1000 where acct_no ="6223456000"''' 93 # ret = dboper.do_update(sql) 94 # if not ret:#返回空對象,出錯 95 # print("執(zhí)行修改錯誤") 96 # #非空對象,執(zhí)行成功 97 # else: 98 # print("影響筆數(shù)：%d"% ret) 99 # dboper.close_conn()#關(guān)閉數(shù)據(jù)庫連接 100 101 102 103 db_oper.py

轉(zhuǎn)載于:https://www.cnblogs.com/shengjia/p/10385772.html

總結(jié)

以上是生活随笔為你收集整理的PYTHON1.day21的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。