Python操作SQLite/MySQL/LMDB數(shù)據(jù)庫的方法
1.概述
1.1前言
最近在存儲字模圖像集的時候,需要學習LMDB,趁此機會復習了SQLite和MySQL的使用,一起整理在此。
1.2環(huán)境
使用win7,Python 3.5.2。
2.SQLite
2.1準備
SQLite是一種嵌入式數(shù)據(jù)庫,它的數(shù)據(jù)庫就是一個文件。Python 2.5x以上版本內(nèi)置了SQLite3,使用時直接import sqlite3即可。
2.2操作流程
概括地講,操作SQLite的流程是:
·通過sqlite3.open()創(chuàng)建與數(shù)據(jù)庫文件的連接對象connection
·通過connection.cursor()創(chuàng)建光標對象cursor
·通過cursor.execute()執(zhí)行SQL語句
·通過connection.commit()提交當前的事務,或者通過cursor.fetchall()獲得查詢結果
·通過connection.close()關閉與數(shù)據(jù)庫文件的連接
詳細的sqlite3模塊API可以看這里:SQLite - Python
總結起來就是用cursor.execute()執(zhí)行SQL語句,改變數(shù)據(jù)(插入、刪除、修改)時用connection.commit()提交變更,查詢數(shù)據(jù)時用cursor.fetchall()得到查詢結果。
2.3操作實例
2.3.1建立數(shù)據(jù)庫與建立表
#! /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 # 創(chuàng)建連接 conn = sqlite3.connect("test.db") # 創(chuàng)建光標 cur = conn.cursor() # 執(zhí)行(創(chuàng)建數(shù)據(jù)表的)SQL語句 cur.execute("CREATE TABLE IF NOT EXISTS students (sid INTEGER PRIMARY KEY, name TEXT)") # 提交 conn.commit() # 關閉連接 conn.close()
這里conn是與數(shù)據(jù)庫文件test.db的連接對象,cur是conn的光標對象,通過cur.execute()執(zhí)行建表操作,創(chuàng)建了簡單的學生信息表(學號, 名字),通過conn.commit()提交,最后用conn.close()關閉連接。
創(chuàng)建連接時,發(fā)現(xiàn)數(shù)據(jù)庫文件不存在時會自動創(chuàng)建,這里使用了文件“test.db”,也可以使用“:memory:”建立內(nèi)存數(shù)據(jù)庫。
2.3.2插入、刪除、修改
為了便于多次運行,直接使用了內(nèi)存數(shù)據(jù)庫:
#! /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 # 創(chuàng)建鏈接 conn = sqlite3.connect(":memory:") # 創(chuàng)建光標 cur = conn.cursor() # 執(zhí)行(創(chuàng)建數(shù)據(jù)表的)SQL語句 cur.execute("CREATE TABLE students (sid INTEGER PRIMARY KEY, name TEXT)") # 執(zhí)行(插入)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")) # 執(zhí)行(查詢)SQL語句 cur.execute("SELECT * FROM students") print(cur.fetchall()) # [(1, 'Alice'), (2, 'Bob'), (3, 'Peter')] # 執(zhí)行(刪除)SQL語句 cur.execute("DELETE FROM students WHERE sid = ?", (1,)) # 執(zhí)行(查詢)SQL語句 cur.execute("SELECT * FROM students") print(cur.fetchall()) # [(2, 'Bob'), (3, 'Peter')] # 執(zhí)行(修改)SQL語句 cur.execute("UPDATE students SET name = ? WHERE sid = ?", ("Mark", 3)) # 執(zhí)行(查詢)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)。插入、刪除、修改后查詢數(shù)據(jù)庫中的內(nèi)容并打印出來。
“?”是sqlite3中的占位符,execute時會用第二個參數(shù)元組里的元素按順序替換。官方文檔里建議出于安全考慮,不要直接用Python做字符串拼接。
另外,注意不需要每次execute后調(diào)用commit。
2.3.3查詢
直接用上面的代碼:
# 執(zhí)行(查詢)SQL語句 cur.execute("SELECT * FROM students") print(cur.fetchall()) # [(2, 'Bob'), (3, 'Peter')] fetchall()返回的是記錄數(shù)組,可能通過WHERE子句做更細致的選擇。
3.MySQL
3.1準備
安裝MySQL:略(百度)
安裝pymysql:
pip install PyMySQL
3.2操作流程
同為關系型數(shù)據(jù)庫,MySQL的操作方法與SQLite是大同小異的。建立連接對象與光標對象,用execute()執(zhí)行SQL語句,commit()提交事物,fetchall()獲得所有查詢結果。
3.3操作實例
3.3.1建立與數(shù)據(jù)庫連接與建立表
準備工作:
- 已經(jīng)創(chuàng)建了數(shù)據(jù)庫TESTDB
- 連接數(shù)據(jù)庫TESTDB使用的用戶名為“mayi”,密碼為“test123”,你可以自己設定或者直接使用root用戶名及其密碼。
·數(shù)據(jù)庫連接
#! /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 # 創(chuàng)建數(shù)據(jù)庫連接 conn = pymysql.connect( host="localhost", port=3306, db="testdb", user="mayi", password="test123", charset="utf8") # 創(chuàng)建游標 cur = conn.cursor() # 執(zhí)行SQL語句(查詢Mysql版本) cur.execute("SELECT VERSION()") # 獲取單條數(shù)據(jù) data = cur.fetchone() # 打印:Database version: 5.7.17-log print("Database version: %s " % data) # 關閉數(shù)據(jù)庫連接 conn.close()
·建立表
如果數(shù)據(jù)庫連接存在我們可以使用execute()方法來為數(shù)據(jù)庫創(chuàng)建表,如下所示創(chuàng)建表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 # 創(chuàng)建數(shù)據(jù)庫連接 conn = pymysql.connect( host="localhost", port=3306, db="testdb", user="mayi", password="test123", charset="utf8") # 創(chuàng)建游標 cur = conn.cursor() # 執(zhí)行SQL語句,如果表存在則刪除 cur.execute("DROP TABLE IF EXISTS students") # 使用預處理語句創(chuàng)建表 cre_sql = """CREATE TABLE students ( sid INT(4) PRIMARY KEY, name VARCHAR(10) )""" # 執(zhí)行SQL語句(建表) cur.execute(cre_sql) # 關閉數(shù)據(jù)庫連接 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 # 創(chuàng)建數(shù)據(jù)庫連接 conn = pymysql.connect( host="localhost", port=3306, db="testdb", user="mayi", password="test123", charset="utf8") # 創(chuàng)建游標 cur = conn.cursor() # 執(zhí)行(插入)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')) # 執(zhí)行(查詢)SQL語句 cur.execute("SELECT * FROM students") print(cur.fetchall()) # ((1, 'Alice'), (2, 'Bob'), (3, 'Peter')) # 執(zhí)行(刪除)SQL語句 cur.execute("DELETE FROM students WHERE sid = %s" % (1,)) # 執(zhí)行(查詢)SQL語句 cur.execute("SELECT * FROM students") print(cur.fetchall()) # ((2, 'Bob'), (3, 'Peter')) # 執(zhí)行(修改)SQL語句 cur.execute("UPDATE students SET name = '%s' WHERE sid = %s" % ('Mark', 3)) # # 執(zhí)行(查詢)SQL語句 cur.execute("SELECT * FROM students") print(cur.fetchall()) # ((2, 'Bob'), (3, 'Mark')) # 提交 conn.commit() # 關閉數(shù)據(jù)庫連接 conn.close()
3.3.3查詢
Python查詢MySQL使用fetchone()方法獲取單條數(shù)據(jù),使用fetchall()方法獲取多條數(shù)據(jù)。
·fetchone():該方法獲取下一個查詢結果集。結果集是一個對象。
·fetchall():接收全部的返回結果條。
·rowcount:這是一個只讀屬性,并返回執(zhí)行execute()方法后影響的行數(shù)。
#! /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 # 創(chuàng)建數(shù)據(jù)庫連接 conn = pymysql.connect( host="localhost", port=3306, db="testdb", user="mayi", password="test123", charset="utf8") # 創(chuàng)建游標 cur = conn.cursor() # 執(zhí)行(查詢)SQL語句 cur.execute("SELECT * FROM students") # 返回影響的行數(shù) print(cur.rowcount) # 2 # 取一條數(shù)據(jù) print(cur.fetchone()) # (2, 'Bob') # 取剩下所有數(shù)據(jù) print(cur.fetchall()) # ((3, 'Mark'),) # 關閉數(shù)據(jù)庫連接 conn.close()
4.LMDB
4.1準備
LMDB和SQLite/MySQL等關系型數(shù)據(jù)庫不同,屬于key-value數(shù)據(jù)庫(把LMDB想成dict會比較容易理解),鍵key與值value都是字符串。
安裝:
pip install lmdb
使用時import lmdb
4.2操作流程
概況地講,操作LMDB的流程是:
·通過env = lmdb.open()打開環(huán)境
·通過txn = env.begin()建立事務
·通過txn.put(key, value)進行插入和修改
·通過txn.delete(key)進行刪除
·通過txn.get(key)進行查詢
·通過txn.cursor()進行遍歷
·通過txn.commit()提交更改
4.3操作實例
4.3.1建立環(huán)境
#! /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 # 打開環(huán)境 env = lmdb.open("students")
運行一下,查看當前目錄的變化:
可以看到當前目錄下多了students目錄,里面有data.mdb和lock.mdb兩個文件。
4.3.2插入、刪除、修改
插入與修改都用put實現(xiàn),刪除用delete實現(xiàn)。
import lmdb # 打開環(huán)境 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()創(chuàng)建事務時,有write=True才能夠寫數(shù)據(jù)庫。
4.3.3查詢
查音箱記錄用get(key),遍歷數(shù)據(jù)庫用cursor。
import lmdb # 打開環(huán)境 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都是關系型數(shù)據(jù)庫,操作時創(chuàng)建連接對象connection與光標對象cursor,通過execute執(zhí)行SQL語句,commite提交變更,fetch得到查詢結果;LMDB是key-value數(shù)據(jù)庫,操作時建立與數(shù)據(jù)庫的連接,用put/delete改變數(shù)據(jù),用get獲取數(shù)據(jù)。
以上所述是小編給大家介紹的Python操作SQLite/MySQL/LMDB數(shù)據(jù)庫的方法,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對腳本之家網(wǎng)站的支持!
如果你覺得本文對你有幫助,歡迎轉載,煩請注明出處,謝謝!
- Python開發(fā)SQLite3數(shù)據(jù)庫相關操作詳解【連接,查詢,插入,更新,刪除,關閉等】
- 利用python操作SQLite數(shù)據(jù)庫及文件操作詳解
- Python操作SQLite數(shù)據(jù)庫過程解析
- Python連接SQLite數(shù)據(jù)庫并進行增冊改查操作方法詳解
- Python 如何操作 SQLite 數(shù)據(jù)庫
- Python 操作SQLite數(shù)據(jù)庫的示例
- python 操作sqlite數(shù)據(jù)庫的方法
- Python 操作SQLite數(shù)據(jù)庫詳情
- Python練習之操作SQLite數(shù)據(jù)庫
相關文章
python 中Arduino串口傳輸數(shù)據(jù)到電腦并保存至excel表格
這篇文章主要介紹了python Arduino串口傳輸數(shù)據(jù)到電腦并保存至excel表格,本文給大家介紹的非常詳細,具有一定的參考借鑒價值,需要的朋友可以參考下2019-10-10在Mac中PyCharm配置python Anaconda環(huán)境過程圖解
這篇文章主要介紹了在Mac中PyCharm配置python Anaconda環(huán)境過程圖解,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2020-03-03Python中openpyxl實現(xiàn)vlookup函數(shù)的實例
在本篇文章里小編給大家整理的是關于Python中openpyxl實現(xiàn)vlookup函數(shù)的實例內(nèi)容,有興趣的朋友們可以學習參考下。2020-10-10python連接、操作mongodb數(shù)據(jù)庫的方法實例詳解
這篇文章主要介紹了python連接、操作mongodb數(shù)據(jù)庫的方法,結合實例形式詳細分析了Python針對MongoDB數(shù)據(jù)庫的連接、查詢、排序等相關操作技巧,需要的朋友可以參考下2019-09-091 行 Python 代碼快速實現(xiàn) FTP 服務器
FTP 服務器,在此之前我都是使用Linux的vsftpd軟件包來搭建FTP服務器的,現(xiàn)在發(fā)現(xiàn)了利用pyftpdlib可以更加簡單的方法即可實現(xiàn)FTP服務器的功能。下面小編給大家?guī)砹? 行 Python 代碼快速實現(xiàn) FTP 服務器,需要的朋友參考下2018-01-01