操作使用

刪除TABLE	DROP TABLE IF EXISTS tb_name
創建TABLE	CREATE TABLE [IF NOT EXISTS] tb_name(col_name data_type,…)
更新COLUMN	UPDATE tb_name SET col_name = col_name+1 WHERE col_name = ‘%s’" %(‘M’)
插入記錄	INSERT tb_name [(col_name,…)] VALUES(val,…)
查找記錄	SELECT * FROM EMPLOYEE WHERE col_name>%s" %(s)
刪除記錄	DELETE FROM tb_name WHERE col_name >%s" %(20)

• 創建TABLE

>>> import pymysql# 打開數據庫連接 >>> db = pymysql.connect(host='localhost',user='root',passwd='20171018',db='TESTDB',charset='utf8')# 使用cursor()方法獲取操作游標 >>> flag = db.cursor()# 使用execute()方法執行SQL語句 >>> flag.execute('DROP TABLE IF EXISTS EMPLOYEE') # 如果數據表已存在，使用execute()方法刪除表# 創建數據表SQL語句 >>> sql = """CREATE TABLE EMPLOYEE( ... FIRST_NAME CHAR(20) NOT NULL, ... LAST_NAME CHAR(20), ... AGE INT, ... SEX CHAR(1), ... INCOME FLOAT)""" >>> flag.execute(sql)# 關閉數據庫連接 >>> db.close()

• 更新COLUMN

>>> import pymysql >>> db = pymysql.connect(host='localhost', user='root', passwd='20171018', db='TESTDB', charset='utf8') >>> flag = db.cursor()>>> sql = "UPDATE EMPLOYEE SET AGE = AGE+1 \ ... WHERE SEX = '%s'" %('M')>>> try: ... flag.execute(sql) ... db.commit() ... except: ... db.rollback() ... 3

• 插入記錄

>>> import pymysql >>> db = pymysql.connect(host='localhost', user='root', passwd='20171018', db='TESTDB', charset='utf8')>>> flag = db.cursor() >>> sql = """INSERT EMPLOYEE VALUES( ... 'hahaha', 'ha', 22, 'F', 2222)""">>> try: ... flag.execute(sql) # 執行sql語句 ... db.commit() # 提交到數據庫執行 ... except: ... db.rollback() # 發生錯誤時回滾 ... 1# 關閉數據庫連接 >>> db.close()

• 查詢記錄

Python查詢Mysql使用fetchone()方法獲取單條數據, 使用fetchall()方法獲取多條數據。

方法描述

fetchone()	獲取下一個查詢結果集，結果集是一個對象。
fetchall()	接收全部的返回結果行。
rowcount	這是一個只讀屬性，并返回執行execute()方法后影響的行數。

>>> import pymysql >>> db = pymysql.connect(host='localhost', user='root', passwd='20171018', db='TESTDB', charset='utf8')>>> flag = db.cursor() >>> sql = "SELECT * FROM EMPLOYEE WHERE INCOME>%s" %(1000) >>> try: ... flag.execute(sql) ... results = flag.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=%s, sex=%s, income=%s"%(fname,lna me,age,sex,income)) ... except: ... print('Error') ... 3 fname=Mac, lname=Mohan, age=20, sex=M, income=2000.0 fname=Test, lname=test, age=20, sex=M, income=2000.0 fname=hahaha, lname=ha, age=22, sex=F, income=2222.0>>> db.close()

• 刪除記錄

>>> import pymysql >>> db = pymysql.connect(host='localhost', user='root', passwd='20171018', db='TESTDB', charset='utf8') >>> flag = db.cursor()>>> sql = "DELETE FROM EMPLOYEE WHERE AGE >%s" %(20) >>> try: ... flag.execute(sql) ... db.commit() ... except: ... db.rollback() ... 3 >>> flag.execute("SELECT * FROM EMPLOYEE") 1 >>> results = flag.fetchall() >>> for i in results: ... print(i) ... ('nonono', 'no', 2, 'M', 50.0)

總結

以上是生活随笔為你收集整理的2/2 pymysql：基础操作总结的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。