Python連接Postgres/Mysql/Mongo數(shù)據(jù)庫基本操作大全
更新時間：2021年06月29日 10:12:57 作者：Machine777
在后端應(yīng)用開發(fā)中，經(jīng)常會用到Postgres/Mysql/Mongo這三種數(shù)據(jù)庫的基本操作，今天小編就給大家詳細(xì)介紹Python連接Postgres/Mysql/Mongo數(shù)據(jù)庫基本操作，感興趣的朋友一起看看吧
Postgres/Mysql/Mongo是本人在工作中最常用到的數(shù)據(jù)庫?，F(xiàn)羅列了python操作這三種數(shù)據(jù)庫的基本操作，只要掌握了基本的操作，再多加訓(xùn)練，其實(shí)可以應(yīng)用的得心應(yīng)手。
1、連接PG庫
## 導(dǎo)入psycopg2包
import psycopg2
## 連接到一個給定的數(shù)據(jù)庫
conn = psycopg2.connect(database="zabbix", user="zabbix",password="zabbix", host="127.0.0.1", port="5432")
## 建立游標(biāo)，用來執(zhí)行數(shù)據(jù)庫操作
cursor = conn.cursor()
## 執(zhí)行SQL命令
#cursor.execute("CREATE TABLE test_conn(id int, name text)")
#cursor.execute("INSERT INTO test_conn values(1,'haha')")
## 提交SQL命令
#conn.commit()
## 執(zhí)行SQL SELECT命令
cursor.execute("select * from drules;")
## 獲取SELECT返回的元組
rows = cursor.fetchall()
print('druleid|proxy_hostid|name|iprange| delay|nextcheck|status')
for row in rows:
#print(row)
print(row[0],row[1],row[2],row[3],row[4],row[5])
## 關(guān)閉游標(biāo)
cursor.close()
## 關(guān)閉數(shù)據(jù)庫連接
conn.close()
2、連接MySQL
2.1 連接數(shù)據(jù)庫
連接數(shù)據(jù)庫前，請先確認(rèn)以下事項(xiàng)：
- 您已經(jīng)創(chuàng)建了數(shù)據(jù)庫 TESTDB.
- 在TESTDB數(shù)據(jù)庫中您已經(jīng)創(chuàng)建了表 EMPLOYEE
- EMPLOYEE表字段為FIRST_NAME, LAST_NAME, AGE, SEX 和 INCOME。
- 連接數(shù)據(jù)庫TESTDB使用的用戶名為"testuser" ，密碼為 “test123”,你可以可以自己設(shè)定或者直接使用root用戶名及其密碼，Mysql數(shù)據(jù)庫用戶授權(quán)請使用Grant命令。
- 在你的機(jī)子上已經(jīng)安裝了 Python MySQLdb 模塊。 如果您對sql語句不熟悉，可以訪問我們的 SQL基礎(chǔ)教程
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# 使用execute方法執(zhí)行SQL語句
cursor.execute("SELECT VERSION()")
# 使用 fetchone() 方法獲取一條數(shù)據(jù)
data = cursor.fetchone()
print "Database version : %s " % data
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
2.2 創(chuàng)建數(shù)據(jù)庫和表
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# 如果數(shù)據(jù)表已經(jīng)存在使用 execute() 方法刪除表。
cursor.execute("DROP TABLE IF EXISTS EMPLOYEE")
# 創(chuàng)建數(shù)據(jù)表SQL語句
sql = """CREATE TABLE EMPLOYEE (
FIRST_NAME CHAR(20) NOT NULL,
LAST_NAME CHAR(20),
AGE INT,
SEX CHAR(1),
INCOME FLOAT )"""
cursor.execute(sql)
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
2.3 插入數(shù)據(jù)
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 插入語句
sql = """INSERT INTO EMPLOYEE(FIRST_NAME,
LAST_NAME, AGE, SEX, INCOME)
VALUES ('Mac', 'Mohan', 20, 'M', 2000)"""
try:
# 執(zhí)行sql語句
cursor.execute(sql)
# 提交到數(shù)據(jù)庫執(zhí)行
db.commit()
except:
# Rollback in case there is any error
db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 插入語句
sql = "INSERT INTO EMPLOYEE(FIRST_NAME, \
LAST_NAME, AGE, SEX, INCOME) \
VALUES (%s, %s, %s, %s, %s )" % \
('Mac', 'Mohan', 20, 'M', 2000)
try:
# 執(zhí)行sql語句
cursor.execute(sql)
# 提交到數(shù)據(jù)庫執(zhí)行
db.commit()
except:
# 發(fā)生錯誤時回滾
db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
2.4 數(shù)據(jù)庫查詢操作
Python查詢Mysql使用 fetchone() 方法獲取單條數(shù)據(jù), 使用fetchall() 方法獲取多條數(shù)據(jù)。
- fetchone(): 該方法獲取下一個查詢結(jié)果集。結(jié)果集是一個對象
- fetchall():接收全部的返回結(jié)果行.
- rowcount: 這是一個只讀屬性，并返回執(zhí)行execute()方法后影響的行數(shù)。
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 查詢語句
sql = "SELECT * FROM EMPLOYEE \
WHERE INCOME > %s" % (1000)
try:
# 執(zhí)行SQL語句
cursor.execute(sql)
# 獲取所有記錄列表
results = cursor.fetchall()
for row in results:
fname = row[0]
lname = row[1]
age = row[2]
sex = row[3]
income = row[4]
# 打印結(jié)果
print "fname=%s,lname=%s,age=%s,sex=%s,income=%s" % \
(fname, lname, age, sex, income )
except:
print "Error: unable to fecth data"
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
2.5 數(shù)據(jù)庫更新操作
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 更新語句
sql = "UPDATE EMPLOYEE SET AGE = AGE + 1 WHERE SEX = '%c'" % ('M')
try:
# 執(zhí)行SQL語句
cursor.execute(sql)
# 提交到數(shù)據(jù)庫執(zhí)行
db.commit()
except:
# 發(fā)生錯誤時回滾
db.rollback()
# 關(guān)閉數(shù)據(jù)庫連接
db.close()
2.6 刪除數(shù)據(jù)操作
#!/usr/bin/python
# -*- coding: UTF-8 -*-
import MySQLdb
# 打開數(shù)據(jù)庫連接
db = MySQLdb.connect("localhost", "testuser", "test123", "TESTDB", charset='utf8' )
# 使用cursor()方法獲取操作游標(biāo)
cursor = db.cursor()
# SQL 刪除語句
sql = "DELETE FROM EMPLOYEE WHERE AGE > %s" % (20)
try:
# 執(zhí)行SQL語句
cursor.execute(sql)
# 提交修改
db.commit()
except:
# 發(fā)生錯誤時回滾
db.rollback()
# 關(guān)閉連接
db.close()
3、連接Mongo庫
3.1 判讀庫是否存在
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
dblist = myclient.list_database_names()
# dblist = myclient.database_names()
if "runoobdb" in dblist:
print("數(shù)據(jù)庫已存在！")
3.2 創(chuàng)建集合（表）
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
collist = mydb. list_collection_names()
# collist = mydb.collection_names()
if "sites" in collist: # 判斷 sites 集合是否存在
print("集合已存在！")
else:
mycol = mydb["sites"]
3.3 插入集合
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
mydict = { "name": "RUNOOB", "alexa": "10000", "url": "https://www.runoob.com" }
x = mycol.insert_one(mydict)
print(x)
print(x)
3.4 返回 _id 字段
insert_one() 方法返回 InsertOneResult 對象，該對象包含 inserted_id 屬性，它是插入文檔的 id 值。
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient('mongodb://localhost:27017/')
mydb = myclient['runoobdb']
mycol = mydb["sites"]
mydict = { "name": "Google", "alexa": "1", "url": "https://www.google.com" }
x = mycol.insert_one(mydict)
print(x.inserted_id)
3.5 插入多個文檔
集合中插入多個文檔使用 insert_many() 方法，該方法的第一參數(shù)是字典列表。
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
mylist = [
{ "name": "Taobao", "alexa": "100", "url": "https://www.taobao.com" },
{ "name": "QQ", "alexa": "101", "url": "https://www.qq.com" },
{ "name": "Facebook", "alexa": "10", "url": "https://www.facebook.com" },
{ "name": "知乎", "alexa": "103", "url": "https://www.zhihu.com" },
{ "name": "Github", "alexa": "109", "url": "https://www.github.com" }
]
x = mycol.insert_many(mylist)
# 輸出插入的所有文檔對應(yīng)的 _id 值
print(x.inserted_ids)
3.6 插入指定 _id 的多個文檔
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["site2"]
mylist = [
{ "_id": 1, "name": "RUNOOB", "cn_name": "菜鳥教程"},
{ "_id": 2, "name": "Google", "address": "Google 搜索"},
{ "_id": 3, "name": "Facebook", "address": "臉書"},
{ "_id": 4, "name": "Taobao", "address": "淘寶"},
{ "_id": 5, "name": "Zhihu", "address": "知乎"}
]
x = mycol.insert_many(mylist)
# 輸出插入的所有文檔對應(yīng)的 _id 值
print(x.inserted_ids)
3.7 查詢一條數(shù)據(jù)
使用 find_one() 方法來查詢集合中的一條數(shù)據(jù)。
查詢 sites 文檔中的第一條數(shù)據(jù)：
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
x = mycol.find_one()
print(x)
3.8 查詢集合中所有數(shù)據(jù)
find() 方法可以查詢集合中的所有數(shù)據(jù)，類似 SQL 中的 SELECT * 操作。
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
for x in mycol.find():
print(x)
3.9 查詢指定字段的數(shù)據(jù)
可以使用 find() 方法來查詢指定字段的數(shù)據(jù)，將要返回的字段對應(yīng)值設(shè)置為 1。
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
for x in mycol.find({},{ "_id": 0, "name": 1, "alexa": 1 }):
print(x)
除了 _id 你不能在一個對象中同時指定 0 和 1，如果你設(shè)置了一個字段為 0，則其他都為 1，反之亦然。
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
for x in mycol.find({},{ "alexa": 0 }):
print(x)
3.10 根據(jù)指定條件查詢
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
myquery = { "name": "RUNOOB" }
mydoc = mycol.find(myquery)
for x in mydoc:
print(x)
3.11 高級查詢
以下實(shí)例用于讀取 name 字段中第一個字母 ASCII 值大于 “H” 的數(shù)據(jù)，大于的修飾符條件為 {"$gt": “H”} :
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
myquery = { "name": { "$gt": "H" } }
mydoc = mycol.find(myquery)
for x in mydoc:
print(x)
3.12 使用正則表達(dá)式查詢
正則表達(dá)式修飾符只用于搜索字符串的字段。
以下實(shí)例用于讀取 name 字段中第一個字母為 “R” 的數(shù)據(jù)，正則表達(dá)式修飾符條件為 {"$regex": “^R”} :
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
myquery = { "name": { "$regex": "^R" } }
mydoc = mycol.find(myquery)
for x in mydoc:
print(x)
3.13 返回指定條數(shù)記錄
如果我們要對查詢結(jié)果設(shè)置指定條數(shù)的記錄可以使用 limit() 方法，該方法只接受一個數(shù)字參數(shù)。
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
myresult = mycol.find().limit(3)
# 輸出結(jié)果
for x in myresult:
print(x)
3.14 修改數(shù)據(jù)
以在 MongoDB 中使用 update_one() 方法修改文檔中的記錄。該方法第一個參數(shù)為查詢的條件，第二個參數(shù)為要修改的字段。
如果查找到的匹配數(shù)據(jù)多于一條，則只會修改第一條。
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
myquery = { "alexa": "10000" }
newvalues = { "$set": { "alexa": "12345" } }
mycol.update_one(myquery, newvalues)
# 輸出修改后的 "sites" 集合
for x in mycol.find():
print(x)
update_one() 方法只能修匹配到的第一條記錄，如果要修改所有匹配到的記錄，可以使用 update_many()。
以下實(shí)例將查找所有以 F 開頭的 name 字段，并將匹配到所有記錄的 alexa 字段修改為 123：
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
myquery = { "name": { "$regex": "^F" } }
newvalues = { "$set": { "alexa": "123" } }
x = mycol.update_many(myquery, newvalues)
print(x.modified_count, "文檔已修改")
3.15 排序
sort() 方法可以指定升序或降序排序。
sort() 方法第一個參數(shù)為要排序的字段，第二個字段指定排序規(guī)則，1 為升序，-1 為降序，默認(rèn)為升序。
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
mydoc = mycol.find().sort("alexa")
for x in mydoc:
print(x)
3.16 刪除數(shù)據(jù)
使用 delete_one() 方法來刪除一個文檔，該方法第一個參數(shù)為查詢對象，指定要刪除哪些數(shù)據(jù)。
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
myquery = { "name": {"$regex": "^F"} }
x = mycol.delete_many(myquery)
print(x.deleted_count, "個文檔已刪除")
刪除多個文檔
delete_many() 方法來刪除多個文檔，該方法第一個參數(shù)為查詢對象，指定要刪除哪些數(shù)據(jù)。
刪除所有 name 字段中以 F 開頭的文檔:
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
x = mycol.delete_many({})
print(x.deleted_count, "個文檔已刪除")
3.17 刪除集合中的所有文檔
delete_many() 方法如果傳入的是一個空的查詢對象，則會刪除集合中的所有文檔：
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
x = mycol.delete_many({})
print(x.deleted_count, "個文檔已刪除")
3.17 刪除集合
使用 drop() 方法來刪除一個集合。
以下實(shí)例刪除了 customers 集合：
#!/usr/bin/python3
import pymongo
myclient = pymongo.MongoClient("mongodb://localhost:27017/")
mydb = myclient["runoobdb"]
mycol = mydb["sites"]
mycol.drop()
到此這篇關(guān)于Python連接Postgres/Mysql/Mongo數(shù)據(jù)庫基本操作的文章就介紹到這了,更多相關(guān)Python連接數(shù)據(jù)庫內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
您可能感興趣的文章:
- Python基礎(chǔ)之操作MySQL數(shù)據(jù)庫
- 教你怎么用Python操作MySql數(shù)據(jù)庫
- python中的mysql數(shù)據(jù)庫LIKE操作符詳解
- Python接口自動化淺析pymysql數(shù)據(jù)庫操作流程
- 利用python中pymysql操作MySQL數(shù)據(jù)庫的新手指南
- Python操作MySQL MongoDB Oracle三大數(shù)據(jù)庫深入對比
- Python MySQL數(shù)據(jù)庫基本操作及項(xiàng)目示例詳解
- python?實(shí)現(xiàn)?pymysql?數(shù)據(jù)庫操作方法
- Python練習(xí)之操作MySQL數(shù)據(jù)庫
相關(guān)文章
python中SQLAlchemy使用前端頁面實(shí)現(xiàn)插入數(shù)據(jù)
這篇文章主要介紹了SQLAlchemy使用前端頁面實(shí)現(xiàn)插入數(shù)據(jù)，文章內(nèi)容介紹詳細(xì)巨頭有一定的參考價值，需要的小伙伴可以參考一下2022-03-03
Python參數(shù)解析器configparser簡介
configparser是python自帶的配置參數(shù)解析器，可以用于解析.config文件中的配置參數(shù)，ini文件中由sections(節(jié)點(diǎn))-key-value組成，這篇文章主要介紹了Python參數(shù)解析器configparser,需要的朋友可以參考下2022-12-12
本文詳細(xì)介紹了Python的os和pathlib模塊在文件路徑處理中的應(yīng)用,包括常用函數(shù)和類方法,以及它們之間的對比和實(shí)例演示,旨在幫助開發(fā)者提升文件操作效率和代碼可讀性,需要的朋友可以參考下2025-03-03
火車票搶票python代碼公開揭秘！使用Python模擬搶票程序，給大家揭秘?fù)屍钡降资窃趺椿厥?，感興趣的小伙伴們可以參考一下2018-03-03
這篇文章主要介紹了Python中如何將一個類方法變?yōu)槎鄠€方法，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2019-12-12
Python通過TensorFLow進(jìn)行線性模型訓(xùn)練原理與實(shí)現(xiàn)方法詳解
這篇文章主要介紹了Python通過TensorFLow進(jìn)行線性模型訓(xùn)練原理與實(shí)現(xiàn)方法,結(jié)合實(shí)例形式詳細(xì)分析了Python通過TensorFLow進(jìn)行線性模型訓(xùn)練相關(guān)概念、算法設(shè)計(jì)與訓(xùn)練操作技巧,需要的朋友可以參考下2020-01-01
使用Python搭建服務(wù)器公網(wǎng)展示本地電腦文件的操作過程
這篇文章主要介紹了使用Python搭建服務(wù)器公網(wǎng)展示本地電腦文件,今天我們就嘗試用python,建立一個簡單的http服務(wù)器,用來展示本地電腦上指定的目錄和文件,需要的朋友可以參考下2023-08-08
這篇文章主要介紹了Python字符串詳解,本文講解了字符串相關(guān)知識、字符串的一些特性、原始字符串、unicode字符串、字符串的常用操作方法、內(nèi)建函數(shù)列表等內(nèi)容,需要的朋友可以參考下2015-05-05
python中強(qiáng)制關(guān)閉線程與協(xié)程與進(jìn)程方法
python使用中多線程、多進(jìn)程、多協(xié)程使用是比較常見的。那么如果在多線程等的使用，我們這個時候我們想從外部強(qiáng)制殺掉該線程請問如何操作？這篇文章帶你介紹，感興趣的同學(xué)可以參考閱讀2023-03-03
在Python中,heapq模塊提供了實(shí)現(xiàn)最小堆算法的數(shù)據(jù)結(jié)構(gòu),能夠用作優(yōu)先隊(duì)列,本文將詳細(xì)介紹heapq模塊,包括堆的基本概念、heapq的功能和示例代碼,需要的可以參考下2023-12-12