python和多個數據庫的連接

1、mongodb連接數據庫

import pymongo

#連接數據庫
client = pymongo.MongoClient('localhost')
#連接指定數據庫
db = client['shop']
#指定goods 集合
result = db['goods'].find()
ww = db['goods'].insert_one({'a':'qw'})
aa = db['test'].insert_many([{'a':'qw'},{'a':'qw'}])
# print(ww) #<pymongo.cursor.Cursor object at 0x0000000002F3A7F0>
print(result) #<pymongo.cursor.Cursor object at 0x0000000002F3A7F0>
for i in result: #需要遍歷才能拿到每條document的信息
print(i)

2、連接redis數據庫

import redis

#開啟一個鏈接
rd = redis.Redis()

#建立連接池，為多個用戶開啟好鏈接，用戶直接拿，用完放回
red_pool = redis.ConnectionPool(host='localhost',port=6379,db=4)
rds = redis.Redis(connection_pool=red_pool)

r = rd.set('test1',1)
print(r) #插入成功返回 1 就是True

g = rd.get('test1') #返回b'1 二進制，，需要解碼
print(g.decode('utf-8'))

3、python 和 mysql連接

import pymysql

#與mysql數據庫建立鏈接，加cursorclass=pymysql.cursors.DictCursor每條數據返回的是字典類型，不加是元組類型
db = pymysql.connect(host='127.0.0.1',user='root',password='123456',database='hei',port=3306,cursorclass=pymysql.cursors.DictCursor)

#創建游標對象
cursor = db.cursor()
re = 'select * from user'
#插入數據
# ins = 'insert into user (id,name) values(null,"q")'
#cursor.execute(ins)
# db.commit()
#循環插入數據
for i in range(97,123):
ins = 'insert into user (id,name) values(null,%s)'
excu = cursor.execute(ins,[str(chr(i))])
db.commit()
#執行命令
# cursor.execute(ins)
r = cursor.execute(re)
print(r)
# f = cursor.fetchall() #[{'id': 6, 'name': 'c'},{'id': 7, 'name': 'r'}] 多條數據 列表類型
# ((6, 'c'), (9, 'd'), (11, 'q'), (8, 'v'), (4, 'w'), (1, '星期八'))
d = cursor.fetchone() #{'id': 6, 'name': 'c'}一台數據字典類型 (6, 'c')
# print(f)
print(d)
#執行插入 更新修改 刪除 命令需要提交
db.close()

轉載：https://blog.csdn.net/panjunxiao/java/article/details/102616251