Pyhton 鏈接數據庫

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()
    • 添加多條:insert_many()
  • 刪除一條文檔:delete_one()
    • 刪除多條:delete_many()
  • 修改一條文檔: 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() )

相關文章
相關標籤/搜索