import pymysql# 創建連接# 參數依次對應服務器地址，用戶名，密碼，數據庫conn = pymysql.connect(host='127.0.0.1', user='root', passwd='123456', db='demo')# 創建游標cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)# 執行語句返回影響的行數effect_row = cursor.execute("select * from course")print(effect_row)# 獲取所有數據result = cursor.fetchall()result = cursor.fetchone() # 獲取下一個數據result = cursor.fetchone() # 獲取下一個數據（在上一個的基礎之上）# cursor.scroll(-1, mode='relative') # 相對位置移動# cursor.scroll(0,mode='absolute') # 絕對位置移動# 提交，不然無法保存新建或者修改的數據conn.commit()# 關閉游標cursor.close()# 關閉連接conn.close()

import pymysql# 建立連接conn = pymysql.connect(host='127.0.0.1', user='root', passwd='123456', db='demo')# 創建游標cursor = conn.cursor(cursor=pymysql.cursors.DictCursor)# 插入一條數據 %s是占位符 占位符之間用逗號隔開effect_row = cursor.execute("insert into course(cou_name,time) values(%s,%s)", ("Engilsh", 100))print(effect_row)conn.commit()cursor.close()conn.close()

import pymysql.cursors# Connect to the databaseconnection = pymysql.connect(host='localhost',        user='user',        password='passwd',        db='db',        charset='utf8mb4',        cursorclass=pymysql.cursors.DictCursor)try: with connection.cursor() as cursor:  # Create a new record  sql = "INSERT INTO `users` (`email`, `password`) VALUES (%s, %s)"  cursor.execute(sql, ('webmaster@python.org', 'very-secret')) # connection is not autocommit by default. So you must commit to save # your changes. connection.commit() with connection.cursor() as cursor:  # Read a single record  sql = "SELECT `id`, `password` FROM `users` WHERE `email`=%s"  cursor.execute(sql, ('webmaster@python.org',))  result = cursor.fetchone()  print(result)finally: connection.close()