建立資料表:
#!/usr/bin/python3 import pymysql #打開資料庫連接 db = pymysql.connect("localhost","root","322739aa","temp" ) # 使用cursor()方法得到操作指標 cursor = db.cursor() # 使用 execute() 方法執行 SQL,如果資料表存在則删除 cursor.execute("DROP TABLE IF EXISTS EMPLOYEE") # SQL 語法建立資料表EMPLOYEE sql = """CREATE TABLE EMPLOYEE ( FIRST_NAME CHAR(20) NOT NULL, LAST_NAME CHAR(20), AGE INT, SEX CHAR(1), INCOME FLOAT )""" cursor.execute(sql) # 關閉資料庫連接 db.close()
新增資料:
# 使用cursor()方法得到操作指標 cursor = db.cursor() # SQL 語法刪除資料 sql = """INSERT INTO EMPLOYEE(FIRST_NAME, LAST_NAME, AGE, SEX, INCOME) VALUES ('Justin', 'Wu', 43, 'M', 10000)""" try: # 執行SQL语句 cursor.execute(sql) # 提交到資料庫系統執行 db.commit() print("insert a record into temp") except: # 發生異常錯誤時回復 db.rollback()
讀取資料:
# 使用cursor()方法得到操作指標 cursor = db.cursor() # SQL 語法 sql = "SELECT * FROM EMPLOYEE \ WHERE INCOME > '%d'" % (1000) try: # 執行SQL语句 cursor.execute(sql) # 使用 fetchall()得到所有資料 results = cursor.fetchall() for row in results: fname = row[0] lname = row[1] age = row[2] sex = row[3] income = row[4] #列印資料 print ("fname=%s,lname=%s,age=%d,sex=%s,income=%d" % \ (fname, lname, age, sex, income )) except: print ("Error: unable to fetch data")
更新資料:
# 使用cursor()方法得到操作指標 cursor = db.cursor() # SQL 更新语句 sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M') try: # 執行SQL语句 cursor.execute(sql) # 提交到資料庫系統執行 db.commit() except: # 發生異常錯誤時回復 db.rollback()
刪除資料:
# 使用cursor()方法得到操作指標 cursor = db.cursor() # SQL 語法刪除資料 sql = "DELETE FROM EMPLOYEE WHERE AGE > '%d'" % (20) try: # 執行SQL语句 cursor.execute(sql) # 提交到資料庫系統執行 db.commit() except: # 發生異常錯誤時回復 db.rollback()
查詢版本:
# 使用cursor()方法得到操作指標 cursor = db.cursor() # 執行SQL语句 cursor.execute("SELECT VERSION()") # 使用 fetchone() 方法得到資料 data = cursor.fetchone() print ("Database version : %s " % data)
文章標籤
全站熱搜
留言列表