pymongo

  1. from pymongo import *
  3. class TestMongo(object):
  4.     '''
  5.     初始化函数
  6.     '''
  7.     def __init__(self,ip,port):
  8.         self.clinet = MongoClient(ip, port)
  9.         self.db=self.clinet["mytest"].plan
  10.         pass
  11.     def add_one(self):
  12.         import time
  13.         post={
  14.             "title":'标题',
  15.             "content":'内容描述',
  16.             "creatTime":time.time()
  17.         }
  18.         res=self.db.insert_one(post)
  19.         return res
  20.         pass
  22.     def select_data(self,where):
  23.         '''
  24.         查询数据
  25.         :param where:
  26.         :return:
  27.         '''
  28.         return self.db.find(where)
  29.         pass
  30.     def update(self,where,content):
  31.         self.db.update(where,{"$set":content})
  33. # print(__name__)
  34. if __name__=="__main__":
  35.     obj=TestMongo('192.168.136.134',27017)
  36.     obj.add_one()
  37.     print('添加成功....')
  38.     rs=obj.select_data({})
  39.     for item in rs:
  40.         print(item)
  42. # 建立连接对象
  43. # try:
  44. #     clinet=MongoClient('192.168.136.134',27017)
  45. #     #创建数据库
  46. #     db=clinet.mytest
  47. #     colTable=db.plan
  48. #     # 插入一条数据
  49. #     # colTable.insert_one({'name':'狄仁杰','age':18,'gender':1})
  50. #     # 插入多条数据
  51. #     # colTable.insert_many([
  52. #     #     {'name': '狄仁杰1', 'age': 18, 'gender': 1},
  53. #     #     {'name': '狄仁杰2', 'age': 18, 'gender': 1},
  54. #     #     {'name': '狄仁杰3', 'age': 18, 'gender': 1},
  55. #     #     {'name': '狄仁杰4', 'age': 18, 'gender': 1},
  56. #     #     {'name': '狄仁杰5', 'age': 18, 'gender': 1},
  57. #     #     {'name': '狄仁杰6', 'age': 18, 'gender': 1},
  58. #     # ])
  59. #     # 更新一条
  60. #     # colTable.update_one({'name': '狄仁杰1'},{"$set":{'age':20}})
  61. #     # //更新多条
  62. #     # colTable.update_many({'gender': 1}, {"$set": {'age': 20}})
  63. #     # 删除多条
  64. #     # colTable.delete_many({'gender': 1})
  65. #     # 查询的使用
  66. #     # res=colTable.find({"name":"狄仁杰1"})
  67. #     res = colTable.find_one({"name": "狄仁杰1"})
  68. #     print(res)
  69. #     # for item in res:
  70. #     #     print(item)
  71. #     # print('sucess')
  72. # except  Exception as ex:
  73. #     print(ex)

pymysql

  1.  # 安装一个mysql中间模块  pip install pymysql
  2. from pymysql import *
  4. class TestMmysql(object):
  5.     '''
  6.     初始化函数
  7.     '''
  8.     def __init__(self,address,user,pwd,database):
  9.         res = address.split(":")
  10.         self.clinet = conn = connect(host=res[0], user=user, password=pwd, database=database, port=res[1], charset='utf8') 
  11.         self.sql=conn.cursor() #创建游标
  12.         pass
  13.     def add_one(self):
  14.         import time
  15.         post="insert into tb_student(title,content,creaTime) values('标题','内容描述',{})".format(time.time())
  16.         self.sql.execute(post)
  17.         self.sql.commit()
  18.         return "success"
  19.         pass
  21.     def select_data(self,where):
  22.         '''
  23.         查询数据
  24.         :param where:
  25.         :return:
  26.         '''
  27.         res=sql.execute('select * from {}'.format(where))
  28.         sql.fetchall()
  29.         return res
  30.         pass
  31.     def update(self,where,content):
  32.         self.sql.execute('update tb_student set content={} where creaTime={}'.format(content,where))
  33.         self.sql.commit()
  35. # print(__name__)
  36. if __name__=="__main__":
  37.     obj=TestMmysql('192.168.136.134',3389)
  38.     try:
  39.         obj.add_one()
  40.         print('添加成功....')
  41.         rs=obj.select_data('tb_student')
  42.         for item in rs:
  43.             print(item)
  44.     except Exception as ex:
  45.         print(ex)
  46.     finally:
  47.         sql.close()
  48.         conn.close()

redis

  1.  # 安装一个redis中间模块  pip install redis
  2. from redis import *
  3. import time
  5. try:
  6.     # 首先创建一个StrictRedis对象，便可以使用这个对象来操作redis数据库了
  7.     # 参数 host：redis服务器的ip地址
  8.     # port  6379
  9.     # password  根据配置的需要 可选的操作
  10.     # db:[0-15]
  11.     redisObj=StrictRedis(host="192.168.136.134",port=6379,db=1,password='111111')
  12.     print("连接redis服务器成功")
  13.     redisObj.set('hobby','打篮球') 添加字符串类型的数据
  14.     print(redisObj.get('hobby'))
  15.     # 添加多个键值对
  16.     redisObj.mset({'name1':'AA','name2':'BB','addr':'china.shenzhen'})
  17.     rs=redisObj.mget('name1','name2','addr')
  18.     print(rs)
  19.     # 设定超时时间
  20.     redisObj.setex('class',5,'three.class')
  21.     print(redisObj.get('class'))
  22.     time.sleep(7)
  23.     print(redisObj.get('class'))
  24.     print(redisObj.keys())
  25.     redisObj.delete('name1','name2')
  26.     print(redisObj.keys())
  27.     # list 列表的使用
  28.     redisObj.lpush('class','liyang','weo','fly')
  29.     rs=redisObj.rpush('class', 'lifei88888')
  30.     redisObj.lrem('class',1,'lifei88888')  #删除一个数据
  31.     redisObj.lset('class',3,555) #对索引对应的值进行修改
  32.     result=redisObj.lrange('class',0,-1)
  33.     print(redisObj.llen('class'))
  34.     for index in range(3):
  35.         print(redisObj.lpop('class'))  #返回并删除键为 class 的列表中的首元素
  36.     print(result)
  37.     redisObj.lpush('AA', '1', 2)
  38.     print(redisObj.keys())
  39.     redisObj.delete('class')
  41. except  Exception as ex:
  42.     print(ex)