1.概述
1.1前言
最近在存儲字模圖像集的時候，需要學習LMDB，趁此機會復習了SQLite和MySQL的使用，一起整理在此。
1.2環境
使用win7，Python 3.5.2。
2.SQLite
2.1準備
SQLite是一種嵌入式數據庫，它的數據庫就是一個文件。Python 2.5x以上版本內置了SQLite3，使用時直接import sqlite3即可。
2.2操作流程
概括地講，操作SQLite的流程是：
·通過sqlite3.open()創建與數據庫文件的連接對象connection
·通過connection.cursor()創建光標對象cursor
·通過cursor.execute()執行SQL語句
·通過connection.commit()提交當前的事務，或者通過cursor.fetchall()獲得查詢結果
·通過connection.close()關閉與數據庫文件的連接
詳細的sqlite3模塊API可以看這里：SQLite - Python
總結起來就是用cursor.execute()執行SQL語句，改變數據（插入、刪除、修改）時用connection.commit()提交變更，查詢數據時用cursor.fetchall()得到查詢結果。
2.3操作實例
2.3.1建立數據庫與建立表
#! /usr/bin/env python3
# -*- coding:utf-8 -*-
# Author : MaYi
# Blog : http://www.cnblogs.com/mayi0312/
# Date : 2019-11-07
# Name : test01
# Software : PyCharm
# Note :
import sqlite3
# 創建連接
conn = sqlite3.connect("test.db")
# 創建光標
cur = conn.cursor()
# 執行（創建數據表的）SQL語句
cur.execute("CREATE TABLE IF NOT EXISTS students (sid INTEGER PRIMARY KEY, name TEXT)")
# 提交
conn.commit()
# 關閉連接
conn.close()
這里conn是與數據庫文件test.db的連接對象，cur是conn的光標對象，通過cur.execute()執行建表操作，創建了簡單的學生信息表（學號, 名字），通過conn.commit()提交，最后用conn.close()關閉連接。
創建連接時，發現數據庫文件不存在時會自動創建，這里使用了文件“test.db”，也可以使用“:memory:”建立內存數據庫。
2.3.2插入、刪除、修改
為了便于多次運行，直接使用了內存數據庫：
#! /usr/bin/env python3
# -*- coding:utf-8 -*-
# Author : MaYi
# Blog : http://www.cnblogs.com/mayi0312/
# Date : 2019-11-07
# Name : test01
# Software : PyCharm
# Note :
import sqlite3
# 創建鏈接
conn = sqlite3.connect(":memory:")
# 創建光標
cur = conn.cursor()
# 執行（創建數據表的）SQL語句
cur.execute("CREATE TABLE students (sid INTEGER PRIMARY KEY, name TEXT)")
# 執行（插入）SQL語句
cur.execute("INSERT INTO students VALUES(?, ?)", (1, "Alice"))
cur.execute("INSERT INTO students VALUES(?, ?)", (2, "Bob"))
cur.execute("INSERT INTO students VALUES(?, ?)", (3, "Peter"))
# 執行（查詢）SQL語句
cur.execute("SELECT * FROM students")
print(cur.fetchall()) # [(1, 'Alice'), (2, 'Bob'), (3, 'Peter')]
# 執行（刪除）SQL語句
cur.execute("DELETE FROM students WHERE sid = ?", (1,))
# 執行（查詢）SQL語句
cur.execute("SELECT * FROM students")
print(cur.fetchall()) # [(2, 'Bob'), (3, 'Peter')]
# 執行（修改）SQL語句
cur.execute("UPDATE students SET name = ? WHERE sid = ?", ("Mark", 3))
# 執行（查詢）SQL語句
cur.execute("SELECT * FROM students")
print(cur.fetchall()) # [(2, 'Bob'), (3, 'Mark')]
# 關閉鏈接
conn.close()
做的事情還就非常簡單易懂的，向學生信息表中插入(1, Alice)、(2, Bob)、(3, Peter)三條記錄，刪除(1, Alice)，修改(3, Peter)為(3, Mark)。插入、刪除、修改后查詢數據庫中的內容并打印出來。
“?”是sqlite3中的占位符，execute時會用第二個參數元組里的元素按順序替換。官方文檔里建議出于安全考慮，不要直接用Python做字符串拼接。
另外，注意不需要每次execute后調用commit。
2.3.3查詢
直接用上面的代碼：
# 執行（查詢）SQL語句
cur.execute("SELECT * FROM students")
print(cur.fetchall()) # [(2, 'Bob'), (3, 'Peter')]
fetchall()返回的是記錄數組，可能通過WHERE子句做更細致的選擇。
3.MySQL
3.1準備
安裝MySQL：略（百度）
安裝pymysql：
pip install PyMySQL
3.2操作流程
同為關系型數據庫，MySQL的操作方法與SQLite是大同小異的。建立連接對象與光標對象，用execute()執行SQL語句，commit()提交事物，fetchall()獲得所有查詢結果。
3.3操作實例
3.3.1建立與數據庫連接與建立表
準備工作：
- 已經創建了數據庫TESTDB
- 連接數據庫TESTDB使用的用戶名為“mayi”，密碼為“test123”，你可以自己設定或者直接使用root用戶名及其密碼。
·數據庫連接
#! /usr/bin/env python3
# -*- coding:utf-8 -*-
# Author : MaYi
# Blog : http://www.cnblogs.com/mayi0312/
# Date : 2019-11-07
# Name : test02
# Software : PyCharm
# Note :
# 導入模塊
import pymysql
# 創建數據庫連接
conn = pymysql.connect(
host="localhost",
port=3306,
db="testdb",
user="mayi",
password="test123",
charset="utf8")
# 創建游標
cur = conn.cursor()
# 執行SQL語句（查詢Mysql版本）
cur.execute("SELECT VERSION()")
# 獲取單條數據
data = cur.fetchone()
# 打?。篋atabase version: 5.7.17-log
print("Database version: %s " % data)
# 關閉數據庫連接
conn.close()
·建立表
如果數據庫連接存在我們可以使用execute()方法來為數據庫創建表，如下所示創建表students
#! /usr/bin/env python3
# -*- coding:utf-8 -*-
# Author : MaYi
# Blog : http://www.cnblogs.com/mayi0312/
# Date : 2019-11-07
# Name : test02
# Software : PyCharm
# Note :
# 導入模塊
import pymysql
# 創建數據庫連接
conn = pymysql.connect(
host="localhost",
port=3306,
db="testdb",
user="mayi",
password="test123",
charset="utf8")
# 創建游標
cur = conn.cursor()
# 執行SQL語句，如果表存在則刪除
cur.execute("DROP TABLE IF EXISTS students")
# 使用預處理語句創建表
cre_sql = """CREATE TABLE students (
sid INT(4) PRIMARY KEY,
name VARCHAR(10)
)"""
# 執行SQL語句（建表）
cur.execute(cre_sql)
# 關閉數據庫連接
conn.close()
3.3.2插入、刪除、修改
#! /usr/bin/env python3
# -*- coding:utf-8 -*-
# Author : MaYi
# Blog : http://www.cnblogs.com/mayi0312/
# Date : 2019-11-07
# Name : test02
# Software : PyCharm
# Note :
# 導入模塊
import pymysql
# 創建數據庫連接
conn = pymysql.connect(
host="localhost",
port=3306,
db="testdb",
user="mayi",
password="test123",
charset="utf8")
# 創建游標
cur = conn.cursor()
# 執行（插入）SQL語句
cur.execute("INSERT INTO students(sid, name) VALUES(%s, '%s')" % (1, 'Alice'))
cur.execute("INSERT INTO students(sid, name) VALUES(%s, '%s')" % (2, 'Bob'))
cur.execute("INSERT INTO students(sid, name) VALUES(%s, '%s')" % (3, 'Peter'))
# 執行（查詢）SQL語句
cur.execute("SELECT * FROM students")
print(cur.fetchall()) # ((1, 'Alice'), (2, 'Bob'), (3, 'Peter'))
# 執行（刪除）SQL語句
cur.execute("DELETE FROM students WHERE sid = %s" % (1,))
# 執行（查詢）SQL語句
cur.execute("SELECT * FROM students")
print(cur.fetchall()) # ((2, 'Bob'), (3, 'Peter'))
# 執行（修改）SQL語句
cur.execute("UPDATE students SET name = '%s' WHERE sid = %s" % ('Mark', 3))
# # 執行（查詢）SQL語句
cur.execute("SELECT * FROM students")
print(cur.fetchall()) # ((2, 'Bob'), (3, 'Mark'))
# 提交
conn.commit()
# 關閉數據庫連接
conn.close()
3.3.3查詢
Python查詢MySQL使用fetchone()方法獲取單條數據，使用fetchall()方法獲取多條數據。
·fetchone()：該方法獲取下一個查詢結果集。結果集是一個對象。
·fetchall()：接收全部的返回結果條。
·rowcount：這是一個只讀屬性，并返回執行execute()方法后影響的行數。
#! /usr/bin/env python3
# -*- coding:utf-8 -*-
# Author : MaYi
# Blog : http://www.cnblogs.com/mayi0312/
# Date : 2019-11-07
# Name : test02
# Software : PyCharm
# Note :
# 導入模塊
import pymysql
# 創建數據庫連接
conn = pymysql.connect(
host="localhost",
port=3306,
db="testdb",
user="mayi",
password="test123",
charset="utf8")
# 創建游標
cur = conn.cursor()
# 執行（查詢）SQL語句
cur.execute("SELECT * FROM students")
# 返回影響的行數
print(cur.rowcount) # 2
# 取一條數據
print(cur.fetchone()) # (2, 'Bob')
# 取剩下所有數據
print(cur.fetchall()) # ((3, 'Mark'),)
# 關閉數據庫連接
conn.close()
4.LMDB
4.1準備
LMDB和SQLite/MySQL等關系型數據庫不同，屬于key-value數據庫（把LMDB想成dict會比較容易理解），鍵key與值value都是字符串。
安裝：
pip install lmdb
使用時import lmdb
4.2操作流程
概況地講，操作LMDB的流程是：
·通過env = lmdb.open()打開環境
·通過txn = env.begin()建立事務
·通過txn.put(key, value)進行插入和修改
·通過txn.delete(key)進行刪除
·通過txn.get(key)進行查詢
·通過txn.cursor()進行遍歷
·通過txn.commit()提交更改
4.3操作實例
4.3.1建立環境
#! /usr/bin/env python3
# -*- coding:utf-8 -*-
# Author : MaYi
# Blog : http://www.cnblogs.com/mayi0312/
# Date : 2019-11-07
# Name : test03
# Software : PyCharm
# Note :
import lmdb
# 打開環境
env = lmdb.open("students")
運行一下，查看當前目錄的變化：
可以看到當前目錄下多了students目錄，里面有data.mdb和lock.mdb兩個文件。
4.3.2插入、刪除、修改
插入與修改都用put實現，刪除用delete實現。
import lmdb
# 打開環境
env = lmdb.open("students")
# 建立事務
txn = env.begin(write=True)
# 插入三條記錄
txn.put(b"1", b"Alice")
txn.put(b"2", b"Bob")
txn.put(b"3", b"Peter")
# 刪除key="1"的記錄
txn.delete(b"1")
# 修改key="3"的值為"Mark"
txn.put(b"3", b"Mark")
# 提交更改
txn.commit()
注意用txn=env.begin()創建事務時，有write=True才能夠寫數據庫。
4.3.3查詢
查音箱記錄用get(key)，遍歷數據庫用cursor。
import lmdb
# 打開環境
env = lmdb.open("students")
# 建立事務
txn = env.begin()
# 查詢單條記錄
print(txn.get(b"3")) # b'Mark'
# b'2' b'Bob'
# b'3' b'Mark'
for key, value in txn.cursor():
print(key, value)
# 提交更改
txn.commit()
5.學習總結
最后回顧一下，SQLite與MySQL都是關系型數據庫，操作時創建連接對象connection與光標對象cursor，通過execute執行SQL語句，commite提交變更，fetch得到查詢結果；LMDB是key-value數據庫，操作時建立與數據庫的連接，用put/delete改變數據，用get獲取數據。
以上所述是小編給大家介紹的Python操作SQLite/MySQL/LMDB數據庫的方法，希望對大家有所幫助，如果大家有任何疑問請給我留言，小編會及時回復大家的。在此也非常感謝大家對億速云網站的支持！
如果你覺得本文對你有幫助，歡迎轉載，煩請注明出處，謝謝！
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
