#### 引入模塊 ~~~ from pymysql import * ~~~ #### Connection 對象 * 用于建立與數據庫的連接 * 創建對象：調用connect()方法 ~~~ conn=connect(參數列表) ~~~ * 參數host：連接的mysql主機，如果本機是'localhost' * 參數port：連接的mysql主機的端口，默認是3306 * 參數database：數據庫的名稱 * 參數user：連接的用戶名 * 參數password：連接的密碼 * 參數charset：通信采用的編碼方式，推薦使用utf8 ##### 對象的方法 * close()關閉連接 * commit()提交 * cursor()返回Cursor對象，用于執行sql語句并獲得結果 ## Cursor對象 * 用于執行sql語句，使用頻度最高的語句為select、insert、update、delete * 獲取Cursor對象：調用Connection對象的cursor()方法 ~~~ cs1=conn.cursor() ~~~ #### 對象的方法 * close()關閉 * execute(operation \[, parameters \])執行語句，返回受影響的行數，主要用于執行insert、update、delete語句，也可以執行create、alter、drop等語句 * fetchone()執行查詢語句時，獲取查詢結果集的第一個行數據，返回一個元組 * fetchall()執行查詢時，獲取結果集的所有行，一行構成一個元組，再將這些元組裝入一個元組返回 #### 對象的屬性 * rowcount只讀屬性，表示最近一次execute()執行后受影響的行數 * connection獲得當前連接對象 示例 ~~~ from pymysql import * # 創建Connection對象 conn = connect( host='localhost', port=3306, database='test', user='root', password='' ) # 獲取Cursor對象 cs1 = conn.cursor() # 執行插入語句 #count = cs1.execute('insert into pt_user (openid) values ("bbbbbbb")') #print(count) # 受影響的行數 # 查詢 #count = cs1.execute('select * from pt_user') # for i in range(count): # result = cs1.fetchone() # print(result) #(1, 'aaaa') (3, 'bbbbbbb') #result = cs1.fetchall() #print(result) # ((1, 'aaaa'), (3, 'bbbbbbb')) # 參數化 params = [1] count = cs1.execute('select * from pt_user where id > %s', params) result = cs1.fetchall() print(result) # 提交之前的操作 查詢可以不寫 conn.commit() # 關閉Cursor對象 cs1.close() # 關閉Connection對象 conn.commit() ~~~