- import pymysql
- ip ="127.0.0.1"# 数据库地址
- user = 'username'# 数据库用户名
- password="pwd"# 数据库密码
- db='db_name'# 数据库
- port=3306# 端口
- charset='utf8'# 设置字符集
- conn = pymysql.connect(host=ip,user=user,password=password,db=db,port=port,charset=charset,autocommit=True)# 建立连接
- cur = conn.cursor(pymysql.cursors.DictCursor) #游标
- sql = 'select * from tb_name limit 5;'
- cur.execute(sql)# 执行 sql 语句, insert ,update ,delete
- #conn.commit() #提交
- all = cur.fetchall()
- # one = cur.fetchone()
- # many = cur.fetchmany(2)
- cur.close()
- conn.close()
- # print(one)
- # print(many)
- print(all)
- def op_mysql(sql,many=True):
- db_info = {'user': 'username', 'password': 'pwd',
- 'host': '127.0.0.1', 'db': 'db_name', 'port': 3306, 'charset': 'utf8',
- 'autocommit': True}
- conn = pymysql.connect(**db_info) # 建立连接
- cur = conn.cursor(pymysql.cursors.DictCursor) # 游标
- cur.execute(sql) # 执行 sql 语句, insert ,update ,delete
- if many ==True:
- result = cur.fetchall()
- else:
- result = cur.fetchone()
- cur.close()
- conn.close()
- return result
- ==============================================================================================
- import Redis
- # 关系型数据库
- #MySQL oracle sqlserver,SQLite
- # 非关系型数据库 NoSQL
- # MongoDB
- # Redis 每秒钟达到 10w 次的读写, 存在内存里面
- r = Redis.Redis(host='127.0.0.1',password='pwd',port=6379,db=0,decode_responses=True)
- # 字符串
- r.set('key','value')
- info = r.get('key')
- r.expire('key',30)# 设置失效时间
- r.delete('key')# 删除 key
- # 哈希类型
- r.hset("KEY",'key','{"age":12,"addr":" 北京 "}')# 写入大 KEY 小 key
- r.hdel("KEY",'key')# 删除大 KEY 小 key
- print(r.hget("KEY","key"))
- print(r.hgetall('KEY')) #获取所有的
- d = {'qxh':'sfdsdfsf','liuying':'liy001'}
- r.hmset('students',d)
- r.flushall() #清空所有数据库的所有内容
- r.flushdb() #清空当前数据库里面的数据
- r.exists('name') #判断 key 是否存在
- r.keys() #获取当前数据库所有的 key
- r.type('name') #获取的 key 的类型
- #1, 从 aredis 里面获取所有的 key,
- #2, 判断 key 的类型
- #3, 根据 key 的类型, 使用 set /hset
- #4,set 到 bredis 里面
来源: http://www.bubuko.com/infodetail-3282713.html