//建立表
#!/usr/bin/python3
import pymysql
db = pymysql.connect(「localhost」, 「root」, 「123456」, 「test」)
cursor = db.cursor()
cursor.execute(「drop table if exists employee」)
sql = 「」「create table employee (
first_name char(20) not null,
last_name char(20),
age int,
*** char(1),
income float )」""
cursor.execute(sql)
db.close()
//插入
#!/usr/bin/python3
import pymysql
db = pymysql.connect(「localhost」, 「root」, 「123456」, 「test」)
cursor = db.cursor()
sql = 「」「insert into employee(first_name,
last_name, age, ***, income)
values (『mac』, 『mohan』, 20, 『m』, 2000)」""
try:
# 執行sql語句
cursor.execute(sql)
# 提交到資料庫執行
db.commit()
except:
# 如果發生錯誤則回滾
db.rollback()
db.close()
『』『第二種方式』』』
『』』import pymysql
db = pymysql.connect(「localhost」, 「testuser」, 「test123」, 「testdb」)
cursor = db.cursor()
sql = 「insert into employee(first_name,
last_name, age, ***, income)
values (』%s』, 『%s』, %s, 『%s』, %s)」 %
(『mac』, 『mohan』, 20, 『m』, 2000)
try:
# 執行sql語句
cursor.execute(sql)
# 執行sql語句
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
db.close()
『』』
//刪除
#!/usr/bin/python3
import pymysql
db = pymysql.connect(「localhost」, 「root」, 「123456」, 「test」)
cursor = db.cursor()
sql = 「delete from employee where age < %s」 % (20)
try:
# 執行sql語句
cursor.execute(sql)
# 提交修改
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
db.close()
//修改
#!/usr/bin/python3(更新操作用於更新資料表的的資料,以下例項將 testdb 表中 *** 為 『m』 的 age 字段遞增 1:)
import pymysql
db = pymysql.connect(「localhost」, 「root」, 「123456」, 「test」)
cursor = db.cursor()
sql = 「update employee set age = age + 1 where *** = 『%c』」 % (『m』)
try:
# 執行sql語句
cursor.execute(sql)
# 提交到資料庫執行
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
db.close()
//查詢
#!/usr/bin/python3
import pymysql
db = pymysql.connect(「localhost」, 「root」, 「123456」, 「test」)
cursor = db.cursor()
sql = 「select * from employee
where income > %s」 % (1000)
try:
# 執行sql語句
cursor.execute(sql)
# 獲取所有記錄列表
results = cursor.fetchall()
for row in results:
fname = row[0]
lname = row[1]
age = row[2]
*** = row[3]
income = row[4]
# 列印結果
print(「fname=%s,lname=%s,age=%s,***=%s,income=%s」 %
(fname, lname, age, ***, income))
except:
print(「error: unable to fetch data」)
db.close()
mysql與python的互動
conn connect 引數列表 cursor1 conn.cursor mode表示移動的方式 mode的預設值為relative,表示基於當前行移動到value,value為正則向下移動,value為負則向上移動 mode的值為absolute,表示基於第一條資料的位置,第一條資料位置為零 建...
python與MySQL的互動
要想和mysql資料庫互動,首先需要安裝資料庫驅動模組,python2和python3的資料庫驅動是不同的。python2中的資料庫模組是mysqldb,可以通過以下命令安裝 sudo apt get install python mysql在檔案中引入模組 import mysqldbpython...
python與mysql的互動
python 中操作mysql步驟 1.匯入pymsq,from pymysql import 2.建立 和資料庫之間的網路通路 conn connect host localhost port3306,database jing dong user root password mysql char...