python3_08.動動mysql

PyMySQL 是在 Python3.x 版本中用於鏈接 MySQL 服務器的一個庫。

安裝：

pip install PyMySQL

數據庫增刪改查流程差很少，主要在於sql語句。

#!/usr/bin/env python3
#-*- coding:utf-8 -*-
import pymysql
#建立一個數據庫連接
db = pymysql.connect("localhost",'root','drcom','TESTDB')
#建立一個遊標對象
#遊標是系統爲用戶開設的一個數據緩衝區，存放sql語句的執行結果
cursor = db.cursor()
#執行sql查詢，返回值是查詢到的數據條目數
cursor.execute("select version()")
#獲取查詢數據
#fetchone每次只返回一行，也就是結果集的下一行
#fetchall() 獲得結果集中剩下的全部行
data = cursor.fetchone()
print("database version:%s"%data)
#執行sql。若是表存在就刪除
cursor.execute("drop table if exists 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)
#sql插入語句
insert_db = '''INSERT INTO EMPLOYEE(FIRST_NAME,
		LAST_NAME,AGE,SEX,INCOME)
		VALUES('Mac','Mohan',20,'M',2000)'''
try:
	cursor.execute(insert_db)
#提交到數據庫執行，不執行這一步，數據是不會被真正的寫入到數據庫的
	db.commit()
except:
#若是發生錯誤則回滾
	db.rollback()

cursor.execute("SELECT * FROM TESTDB.EMPLOYEE")
result = cursor.fetchall()
print(result)
#關閉數據庫

db.close()