Python鏈接MySql
import pymysql
db_config = {
'host': 'ip',
'port': 3306,
'user': '帳號',
'password': '密碼',
'db': '數據庫名',
'charset': 'utf8'
}
# 創建鏈接對象
conn = pymysql.connect(**db_config)
# 鏈接是不能操做數據庫的,須要生成遊標來操做
# 建立cursor
cur = conn.cursor()
sql = 'select * from table'
# 執行SQL語句,SQL語句都是經過這個方法執行
cur.execute(sql)
# 獲取結果
# 取出全部
# print(cur.fetchall())
# 取出一條
# print(cur.fetchone())
# 取出具體幾條
print(cur.fetchmany(2))
步驟
- 開始
- 建立connection
- 獲取cursor
- 操做過程
- SQL語句
- 執行查詢
- 執行命令
- 獲取數據
- 處理數據
- 關閉遊標:cursor.close()
- 關閉鏈接:connection.close()
- 結束
注意
- 在pymysql中執行的SQL語句不須要加 ;
- execute執行完後不是直接獲得結果,須要你主動去獲取
- 和文件同樣,別忘了關閉遊標與鏈接
- 事務的回滾和提交(rollbck 與commit)
Python鏈接MongoDB
pip install pymongo
創建鏈接:client = pymongo.MongoClient()
指定數據庫:db = client[數據庫名]
指定集合:collection=db[集合名]
基本使用
- 查找文檔: find()
- 添加文檔:insert()
- 修改文檔:update()
- 刪除文檔:remove()
官方推薦
- 查找一條文檔: find_one()
- 查找全部:find() 只是一個對象 能夠用for 遍歷出來
- 添加一條文檔:insert_one()
- 刪除一條文檔:delete_one()
- 修改一條文檔: update_one()
- 須要用$進行操做,加上$set,不然會報錯:update only works with $ operators
- 修改多條:update_many()
Python鏈接Redis
在python中操做redis的命令和命令行的幾乎如出一轍
import redis
鏈接redis:con_redis = Redis.StrictRedis()
- 在程序操做的數據爲bytes類型,加入decode_responses=True,寫入的數據爲str類型
- Redis.StrictRedis( decode_responses=True )
操做數據:print( con_redis.keys() )