import pymysql
 
#建立數據庫連接
conn=pymysql.Connect(
 host='localhost',
 port=3306,
 user='root',
 passwd='數據庫密碼',
 db='bigsdut',
 charset='utf8'
)
 
#獲取游標
cursor=conn.cursor()
#print(conn)
#print(cursor)
 
#1、從數據庫中查詢
#sql="INSERT INTO login(user_name,pass_word)"
sql="SELECT *FROM login"
#cursor執行sql語句
cursor.execute(sql)
#打印執行結果的條數
print(cursor.rowcount)
 
#使用fetch方法進行遍歷結果 總共有三條數據
 
#rs=cursor.fetchone()#將第一條結果放入rs中
#re=cursor.fetchmany(3)#將多個結果放入re中
rr=cursor.fetchall()#將所有的結果放入rr中
#對結果進行處理
for row in rr:
 print("ID是：=%s, 姓名是：=%s, 密碼是：=%s"%row)
#print(re)#輸出兩條數據，因為fetch()方法是建立在上一次fetch()方法基礎上的
 
 
#2數據庫中插入數據
sql_insert="INSERT INTO login(user_name,pass_word) values('中興','123')"
#執行語句
cursor.execute(sql_insert)
#事務提交，否則數據庫得不到更新
conn.commit()
print(cursor.rowcount)
 
 
#修改數據庫中的內容
sql_update="UPDATE login SET user_name='hhh' WHERE id=3"
cursor.execute(sql_update)
conn.commit()
 
#刪除數據庫中的內容，并利用try catch語句進行事務回滾
try:
 sql_delete="DELETE FROM login WHERE id=6"
 cursor.execute(sql_delete)
 conn.commit()
except Exception as e:
 print (e)
 #事務回滾，即出現錯誤后，不會繼續執行，而是回到程序未執行的狀態，原先執行的也不算了
 conn.rollback()
 
 
 
#數據庫連接和游標的關閉
conn.close()
cursor.close()