import pymysql

 

# 建立數(shù)據(jù)庫連接

conn = pymysql.Connect(

  host='localhost',

  port=3306,

  user='用戶',

  passwd='密碼',

  db='數(shù)據(jù)庫',

  charset='utf8'

)

 

# 獲取游標(biāo)

cursor = conn.cursor()

# print(conn)

# print(cursor)

 

# 1、從數(shù)據(jù)庫中查詢

# sql="INSERT INTO userinfor(user_name,pass_word)"

sql = "SELECT * FROM userinfor"

# cursor執(zhí)行sql語句

cursor.execute(sql)

# 打印執(zhí)行結(jié)果的條數(shù)

print(cursor.rowcount)

 

# 使用fetch方法進(jìn)行遍歷結(jié)果 總共有三條數(shù)據(jù)

 

# rs=cursor.fetchone()#將第一條結(jié)果放入rs中

# re=cursor.fetchmany(3)#將多個(gè)結(jié)果放入re中

rr = cursor.fetchall() # 將所有的結(jié)果放入rr中

# 對結(jié)果進(jìn)行處理

for row in rr:

  print("ID是：=%s, 姓名是：=%s, 密碼是：=%s" % row)

# print(re)#輸出兩條數(shù)據(jù)，因?yàn)閒etch()方法是建立在上一次fetch()方法基礎(chǔ)上的

 

 

# 2數(shù)據(jù)庫中插入數(shù)據(jù)

sql_insert = "INSERT INTO userinfor(username,password) values('中興','123')"

# 執(zhí)行語句

cursor.execute(sql_insert)

# 事務(wù)提交，否則數(shù)據(jù)庫得不到更新

conn.commit()

print(cursor.rowcount)

 

# 修改數(shù)據(jù)庫中的內(nèi)容

sql_update = "UPDATE userinfor SET username='121' WHERE id=21"

cursor.execute(sql_update)

conn.commit()

 

# 刪除數(shù)據(jù)庫中的內(nèi)容，并利用try catch語句進(jìn)行事務(wù)回滾

try:

  sql_delete = "DELETE FROM userinfor WHERE id=6"

  cursor.execute(sql_delete)

  conn.commit()

except Exception as e:

  print(e)

  # 事務(wù)回滾，即出現(xiàn)錯(cuò)誤后，不會(huì)繼續(xù)執(zhí)行，而是回到程序未執(zhí)行的狀態(tài)，原先執(zhí)行的也不算了

  conn.rollback()

 

# 數(shù)據(jù)庫連接和游標(biāo)的關(guān)閉

conn.close()

cursor.close()