1.操作Mysql（oracle的和mysql的一样，只不过是库不一样而已）

pip install pymysql #安装mysql模块

import pymysql

ip = '127.0.0.1'

port = 3306

passwd = 'root'

user = 'root'

db = 'szz'

#建立数据库连接,指定数据库的ip地址,账号、密码、端口号、操作的数据库、字符集

conn=pymysql.Connect(host=ip,port=port,user=user,passwd=passwd,db=db,charset='utf8')

#conn=pymysql.Connect(host='127.0.0.1',port=3306,user='root',passwd='root',db='szz',charset='utf8')

cur = conn.cursor() #在连接上建立一个游标

#cur = conn.cursor(cursor=pymysql.cursors.DictCursor) #建立 一个游标，指定游标类型为字典类型，操作返回的结果为字典类型,这个方便取值

# 执行SQL，并返回收影响行数

#effect_row = cursor.execute("update students set name = 'hhf' where id = 1;")

# 执行SQL，并返回受影响行数

#effect_row = cursor.executemany("insert into students (name,age) values (%s,%s); ", [("hhf", 18), ("aaa", 20)])

#sql = 'insert into nhy (id,name,sex) VALUE(80,"cc","女");'

sql2 ='select * from nhy;'

cur.execute(sql2)

#查询语句可以用这个

print(cur.fetchall()) #获取表中所有数据,返回结果为List，如果是普通游标，无素为元组，字典游标，元素为字典

#print(cur.fetchone()) #获取一条，一次获取一条

#如果先fetchall()再fetchone是没有结果的，因为游标已经移动到最后，用cur.scroll()来移动游标

#cur.scroll(0,mode='absolute') #absolute 绝对位置 就是把游标直接移到哪里

#cur.scroll(5,mode='relative') # reletive 相对位置 这个是相对于当前游标移动到哪里

#print(cur.fetchmany(3)) #获取前n行数据

conn.commit() #提交，insert,delete,update必须提交才能生效，

#有连接就有关闭

cur.close()#关闭游标

conn.close()#关闭连接

操作数据库的函数

def OperationDb(host,user,passwd,db,sql,port=3306,charset='utf8'):

conn = pymysql.connect(

host=host,user=user,passwd=passwd,port=port,

db=db,charset=charset

) #建立连接

cur = conn.cursor(cursor=pymysql.cursors.DictCursor)#建立游标

cur.execute(sql)#执行sql

#insert update delete语句需要commit()才能提交， #select 不需要

#判断是什么语句

if sql.startswith('select'):

res = cur.fetchall()

else:

conn.commit()

res = 88

cur.close()

conn.close()

return res

if __name__ == '__main__':

ip = '127.0.0.1'

port = 3306

passwd = 'root'

user = 'root'

db = 'szz'

sql = 'insert into hhf(id,name,sex) VALUE (8,"hhff","未知");' # 插入

sql2 = 'select * from hhf limit 3;' # 查询

sql3 = 'delete from hhf where id=8' # 删除

sql4 = 'update hhf set name = "hhf" where id=8' # 更新

s = OperationDb(host=ip, port=port, user=user, passwd=passwd, db=db, sql=sql2)

#也可以直接传值，

# s = OperationDb(host='127.0.0.1', user='root', passwd='root', db='szz', sql=sql2)

print(s)

2.操作redis

redis是一个nosql类型的数据库，数据都存在内存中，有很快的读写速度，python操作redis使用redis模块，pip安装即可

pip install redis #安装redis模块

import redis,json

ip = '127.0.0.1'

port=6379

db=0

passwd = ''

#连接redis

r = redis.Redis(host=ip,port=port,db=db,password=passwd)

r.set('age',18) #set值 redis里面存的数据全是字符串

r.set('name',[1,2,3,4]) #可以传字典和list 最后会被转成字符串 ,redis连接工具，reload查看更新的redis数据

r.set('name',{1,2,3,4}) #redis里面存的数据都是字符串,如果set的key已存在，就会更新值

r.setnx('ccc','hhf') #set值，如果key不存在会创建，key存在，不操作

r.setex('bbb','hahaha',15) # 可以设置key的失效时间,token的失效时间用的就是这个

name = r.get('name')#从redis中获取的数据全是bytes类型

print(name) #结果b'{1, 2, 3, 4}'

name = name.decode()#要使用decode方法给它转成字符串才能继续操作

print(r.get('aaaa'))#get不存在的key,就返回None

r.mset(hhf1='haha',hhf2=1888) #批量设置值

r.mget('name','age') #批量获取key

r.delete('age') #删除某个key

r.delete('hhf1','hhf2')#删除多个key

print(r.keys()) #获取所有的key，返回的结果是List,如果需要使用，得遍历后decode()

print(r.keys('*n*')) #获取含有n的key

# #下面操作哈希类型的key

r.hset('hhf_session','name','hhf')

r.hset('hhf_session','age',18)

print(r.hget('hhf_session','age'))#获取hhf_session里面age的值,必须两个参数

print(r.hgetall('hhf_session'))#获取哈希类型里面所有的值

r.delete('hhf_session') #把key删除，包括下面的nam和age

r.hdel('hhf_session') #会报错，该方法里面的两个参数是必填的

r.hdel('hhf_session','name')#删除hhf_session下的name属性

r.hsetnx('hname','key2','value23')#给name为hname设置key和value，和上面的不同的是key不存在的时候#才会set

r.hmset('hname',{'k1':'v1','k2':'v2'})#批量设置哈希类型的key和value

#如果key里面有冒号 就会多个文件夹

r.set('hhf:hhf','haha')

r.set('hhf:cccc','aaa')

r.hset('sss:hhf','hhf','')

r.delete("hhf:cccc")

操作redis的函数：

def OpRedis(host,passwd,k,v=False,port=6379,db=0):

#此函数只实现了redis的set与get方法 只是针对str类型

#del方法及hset hget方法未实现

r = redis.Redis(host=host,password=passwd,port=port,db=db)

#连接数据库

if v:#判断value是否传值，如果传了就说明是set方法

r.set(k,v)

res = 88

else:

res= r.get(k).decode()

#因为从redis里面获取到的数据都是字节类型的 ，要把它转成字符串

#所以要用decode方法

return res