#pymysql連線資料庫的步驟
#1. 匯入pymysql
#2. 使用 pymysql.connect(host=位址, user=使用者名稱, password=密碼, port=埠, db=資料庫名) 建立資料庫的連線,得到連線物件
#3. 獲取游標物件:con.cursor(pymysql.cursors.dictcursot)
#4. 使用 cursor.excute(sql) 執行sql語句
#5. 如果是查詢操作,則使用 fetchall、fetchone、fetchmany 來讀取資料集
#如果是增刪改操作,則使用 commit() 提交操作
#6. 增刪改如果出現異常錯誤可以使用 rollback() 進行回滾操作
#7. 關閉資料庫連線:con.close()
#查詢操作
#匯入pymysql
import
pymysql
#連線資料庫
#host 資料庫主機位址
#user 資料庫使用者名稱
#password 資料庫密碼
#port 資料庫埠號
#db 資料庫的名稱
con = pymysql.connect(host='
127.0.0.1
', user='
root
', password='
123456
', port=3306, db='pp'
)#獲取資料庫游標(指定結果集中資料的型別是字典還是元組)
#pymysql.cursors.dictcursor 指定結果集中的資料以欄位型別的資料表示
cur =con.cursor(pymysql.cursors.dictcursor)
#建立sql命令
sql = '
select * from teacher'#
執行sql語句
cur.execute(sql)
#獲取查詢結果集
#fetchall 一次性將所有的查詢結果獲取出來
#fetchone 獲取一條資料
#fetchmany(size=n) 獲取指定數量的資料
results =cur.fetchall()
#result = cur.fetchone()
#result = cur.fetchmany(size=3)
#print(result)
for item in
results: #
對每條資料執行操作**
(item)
#關閉資料庫連線
con.close()
#下面是插入、刪除、修改資料
import
pymysql
con = pymysql.connect(host='
127.0.0.1
', user='
root
', password='
123456
', db='
pp', port=3306)
cur =con.cursor(pymysql.cursors.dictcursor)
cur.execute(
'insert into class (name) values (%s)
', ('
二年十一班
'))#
插入資料
#cur.execute('update class set name="拉拉啊了" where id=25')#修改
#cur.execute('delete from class where id=24')#刪除
#判斷增刪改操作是否成功,應該通過受影響的行數來判斷
print(con.affected_rows()) #
獲取受影響的行數
con.commit() #
執行提交方法才會影響資料庫
con.close()
#知識**於彭老師
pymysql連線資料庫
建立資料庫 import pymysql 開啟資料庫連線 db pymysql.connect localhost testuser test123 testdb 使用 cursor 方法建立乙個游標物件 cursor cursor db.cursor 使用 execute 方法執行 sql,如果表...
PyMysql連線資料庫
1 先安裝pymysql模組 pip install pymysql2 匯入pymysql模組 3 連線資料庫 conn pymysql.connect host localhost user root passwd 123456 port 3306 db test1 charset utf8 cu...
pymysql連線資料庫異常
一 源 如下 import pandas as pd import pymysql 開啟資料庫連線 host address user 密碼 庫名 編碼 db pymysql.connect localhost root 123456 test charset utf8 出現異常 typeerror...