#%%
import pymysql
# 插入語句
# 打開數據庫連接
db = pymysql.connect(host="localhost", user="root", password="root", database="python",charset="utf8")
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# 數據列表
data = [(1,'張三','18'),
(2,'李四','19'),
(3,'王五','20'),
]
try:
# 執行sql語句，插入多條數據
cursor.executemany("insert into test(id, name, score) values (%s,%s,%s)", data)
# 提交數據
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
# 關閉數據庫連接
db.close()
# ======================================================================================== #
#%%
# 導入pymysql模塊
import pymysql
# 查詢單個數據
# 連接database,參數1主機名或IP；參數2：用戶名；參數3：密碼；參數4：數據庫名稱
conn = pymysql.connect(host="localhost", user="root", password="root", database="python",charset="utf8")
# 創建一個可以執行SQL語句的光標對象
cursor = conn.cursor()
# 定義要執行的SQL語句
sql = """
select * from test
"""
# 執行SQL語句
cursor.execute(sql)
# 查詢單條數據
data = cursor.fetchone()
print(data);
# 關閉光標對象
cursor.close()
# 關閉數據庫連接
conn.close()
# ======================================================================================== #
# %%
#!/usr/bin/python
# -*- coding: UTF-8 -*-
# 插入語句
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(host="localhost", user="root", password="root", database="python",charset="utf8")
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 插入語句
sql = """INSERT into test(id,name,score)value (4,'qqq','aaa')"""
try:
# 執行sql語句
cursor.execute(sql)
# 提交到數據庫執行
db.commit()
except:
# Rollback in case there is any error
db.rollback()
# 關閉數據庫連接
db.close()
# ======================================================================================== #
# %%
#!/usr/bin/python
# -*- coding: UTF-8 -*-
# 查詢語句
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(host="localhost", user="root", password="root", database="python",charset="utf8")
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 查詢語句
sql = "SELECT * FROM test \
WHERE id >= %s" % (1)
try:
# 執行SQL語句
cursor.execute(sql)
# 獲取所有記錄列表
results = cursor.fetchall()
for row in results:
id = row[0]
name = row[1]
score = row[2]
# 打印結果
print ("id=%s,name=%s,score=%s" % \
(id, name, score ))
except:
print ("Error: unable to fecth data")
# 關閉數據庫連接
db.close()
# ======================================================================================== #
# %%
#!/usr/bin/python
# -*- coding: UTF-8 -*-
# 跟新語句
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(host="localhost", user="root", password="root", database="python",charset="utf8")
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 更新語句
sql = "UPDATE test SET id = id + 100 WHERE name = '%s'" % \
("aaa")
try:
# 執行SQL語句
cursor.execute(sql)
# 提交到數據庫執行
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
# 關閉數據庫連接
db.close()
# ======================================================================================== #
# %%
#!/usr/bin/python
# -*- coding: UTF-8 -*-
# 刪除語句
import MySQLdb
# 打開數據庫連接
db = MySQLdb.connect(host="localhost", user="root", password="root", database="python",charset="utf8")
# 使用cursor()方法獲取操作游標
cursor = db.cursor()
# SQL 刪除語句
sql = "DELETE FROM test WHERE id = %s" % (201)
try:
# 執行SQL語句
cursor.execute(sql)
# 提交修改
db.commit()
except:
# 發生錯誤時回滾
db.rollback()
# 關閉連接
db.close()
# ======================================================================================== #
# %%
# -*- coding:utf-8 -*-
# 查詢mysql版本
import MySQLdb
# 打開數據庫連接（請根據自己的用戶名、密碼及數據庫名稱進行修改）
cnn = MySQLdb.connect(host="localhost", user="root", password="root", database="python",charset="utf8")
# 使用cursor()方法獲取操作游標
cursor = cnn.cursor()
# 使用execute方法執行SQL語句
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法獲取一條數據
data = cursor.fetchone()
print ("Database version : %s " % data)
# 執行sql語句
cnn.close()
# %%