最近空闲，刚好一个运维的朋友问我要python3连接数据的操作，索性写个文档给他，分享给大家。
mysql数据库连接 默认端口号3306
安装好必要的mysql后，连接数据库
#首先导入PyMySQL库
import pymysql
#连接数据库，创建连接对象connection
#连接对象作用是：连接数据库、发送数据库信息、处理回滚操作（查询中断时，数据库回到最初状态）、创建新的光标对象
connection = pymysql.connect(host = 'localhost' #host属性
user = 'root' #用户名
password = '******' #此处填登录数据库的密码
db = 'mysql' #数据库名
)
python代码操作数据库PyMySql官方文档
#创建光标对象，一个连接可以有很多光标，一个光标跟踪一种数据状态。
#光标对象作用是：、创建、删除、写入、查询等等
cur = connection.cursor()
#查看有哪些数据库，通过
cur.fetchall()#获取查询所有结果
print(cur.fetchall())
创建表
#使用数据库test
cur.execute('USE test')
#在test数据库里创建表student，有name列和age列
cur.execute('CREATE TABLE student(name VARCHAR(20),age TINYINT(3))')
向刚创建的表student插入数据
sql = 'INSERT INTO student (name,age) VALUES (%s,%s)'
cur.execute(sql,('XiaoMing',23))
查看表中的数据
cur.execute('SELECT * FROM student')
print(cur.fetchone())#打印数据
关闭光标和连接
#关闭连接对象，否则会导致连接泄漏，消耗数据库资源
connection.close()
#关闭光标
cur.close()
PostgreSQL数据库连接 默认端口号5432
下载安装psycopg2，psycopg2文档方式:在命令行输入
pip3 install psycopg2
import psycopg2
conn = psycopg2.connect(database="databaseName", user="postgres", password="pass123", host="127.0.0.1", port="5432")
cur = conn.cursor() #获取光标对象
cur.execute(sql语句) #里面放入SQL语句
conn.commit() #提交
conn.close()# 关闭连接
oracle数据库连接 默认端口号1521
下载安装外包cx_Oracle，方式：在命令行输入
pip3 install cx_Oracle
连接 cx-oracle文档
#首先导入cx_Oracle库
import cx_Oracle
#连接数据库，创建连接对象connection
#连接对象作用是：连接数据库、发送数据库信息、处理回滚操作（查询中断时，数据库回到最初状态）、创建新的光标对象
connection = oracle.connect('username/password@host:port/sid')
#分别填用户名username/密码password/数据库所在IP地址host：端口号port/数据库名称sid
获取光标对象curser
cur = connection.cursor()
使用cursor进行各种操作
cur.execute(sql语句)
关闭cursur、connection
cursor.close()
sqlserver数据库连接 默认端口号1433
下载安装pymssql ,方式：在命令行输入pip install pymssql
连接 pymssql文档
#首先导入pymssql库
import pymssql
#连接数据库，创建连接对象connection
#连接对象作用是：连接数据库、发送数据库信息、处理回滚操作（查询中断时，数据库回到最初状态）、创建新的光标对象
connection = pymssql.connect('servername',#服务器名称
'username',#用户名称
'password',#密码
'sid'）#数据库名称
获取光标对象curser
cur = connection.cursor()
使用cursor进行各种操作
cur.execute(sql语句)
关闭cursur、connection
cursor.close()
redis数据库连接 默认端口号6379
普通连接redis
import redis
con = redis.Redis(host='127.0.0.1', port=6379)
连接池
redis-py使用connection pool来管理对一个redis server的所有连接，避免每次建立、释放连接的开销
import redis
pool = redis.ConnectionPool(host='192.168.0.110', port=6379)
r = redis.Redis(connection_pool=pool)
管道
redis-py,默认情况下，每次都会进行连接池的连接和断开。若是想一次执行多条命令，进行事务性操作，就要用管道。
import redis
pool = redis.ConnectionPool(host='192.168.0.110', port=6379)
r = redis.Redis(connection_pool=pool)
pipe = r.pipeline(transaction=True) #管道
r.set('zcx', '5555')
r.set('zcx', '6666')
pipe.execute()
说明：虽然提供了这么一个功能。但实际情况还是不建议使用。因为这个执行起来慢。另一方面，也没必要
发布订阅
里面有个生产者和消费者。在这里，我试着用redis来模拟
定义公共的类，包装方法和初始化连接
import redis
class redis_util(object):
def __init__(self):
self.__conn = redis.Redis(host='127.0.0.1', port=6379)
self.channel = 'mybaby' # 定义通道名称
def publish(self, msg): # 定义发布的方法
self.__conn.publish(self.channel, msg)
return True
def subscribe(self): # 定义订阅的方法
pub = self.__conn.pubsub()
pub.subscribe(self.channel)
pub.parse_response()
return pub
publisher发布者：
from polls.redis_utils import redis_util
obj = redis_util()
obj.publish('test')
subscriber订阅者：
from polls.redis_utils import redis_util
obj = redis_util()
redis_sub = obj.subscribe()
while True:
msg = redis_sub.parse_response()
print(msg)
至于发布订阅。只是表达有这么一个功能。
MongoDB数据库连接 默认端口号27017
下载安装外包pymongo，方式：在命令行输入 pip3 install pymongo
无密码连接
import pymongo
mongo_client = pymongo.MongoClient('127.0.0.1', 27017)
# 下面这种也是可以的
# mongo_client = pymongo.MongoClient('mongodb://127.0.0.1:27017')
有密码连接
import pymongo
mongo_client = pymongo.MongoClient('127.0.0.1', 26666)
mongo_auth = mongo_client.admin #或 mongo_client['admin'] admin为authenticationDatabase
mongo_auth.authenticate('用户名', '密码')
# 下面这种也是可以的
# import urllib.parse
# mongo_username = urllib.parse.quote_plus('你的用户名')
# mongo_password = urllib.parse.quote_plus('密码')
# mongo_client = pymongo.MongoClient('mongodb://%s:%s@127.0.0.1:26666' % (mongo_username,mongo_password))
print(mongo_client.server_info()) #判断是否连接成功
无密码连接
若没有Database 和Collection，则会自动创建
mongo_db = mongo_client["database"]
mongo_collection = mongo_db["collection"]
# 下面也是可以的
# mongo_db = mongo_client.database
# mongo_collection = mongo_db.collection
以上是整理的数据库连接，可以用于自动化运维人员,不足之处希望大家多多指正，谢谢！
