pymysql

import pymsqlmysql

  1. 鏈接數據庫
  conn = pymysql.connect(host='127.0.0.1',port=3306,user='root',password='123456',database='db3',charset='utf8')
  1. 獲取光標
  cursor = conn.cursor()
  data = [('小明',123),('小花',456)]
  sql = "insert into user(name,password) values(%s,%s);"
  1. 執行sql語句
  cursor.execute(sql,['王五','888'])
  批量執行多條sql語句
  cursor.executemany(sql,data)
  1. 獲取新增數據id
  print(cursor.lastrowid)
  1. 提交數據
  conn.commit()
  1. 關閉光標,數據庫鏈接
  cursor.close()
  conn.close()

sql = "delete from user where name=%s;"
cursor.execute(sql,['小明'])

sql = "update user set password=%s where name=%s;"
cursor.execute(sql,['888','張三'])

以字典的格式返回數據
cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)sql

sql = "select * from user;"
cursor.execute(sql)
  1. fetchall() 獲取全部結果
  ret = cursor.fetchall()
  1. fetchone() 獲取一條結果
  ret = cursor.fetchone()
  1. fetchmany() 獲取指定數量的結果
  ret = fetchmany(2)

數據回滾

try:
    cursor.execute(sql)
    conn.commit()
except Exception as e:
    conn.rollback()

移動光標

  1. 光標按絕對位置移動
    cursor.scroll(1,model='absolute')
  2. 光標按相對位置移動cursor.scroll(1,model='relative')
相關文章
相關標籤/搜索
本站公眾號
   歡迎關注本站公眾號,獲取更多信息