Pyhton 连接数据库

Posted 2020-11-28 jiyu-hlzy

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() )