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

相关文章
相关标签/搜索