python连接数据库

import pymysql

db_config = {

'host':'127.0.0.1', #全部用字符串

'port':3306, #此处用int

'user':'root',

'password':'qwe123',

'db':'moran', #数据库名字

'charset':'utf8'

}

conn = pymysql.connect(**db_config) #建立连接对象

cur = conn.cursor() #获取游标对象

# print(cur)

sql = 'select * from student'

aa = cur.execute(sql)

print(aa) #返回执行的数量

print(cur.fetchall())

aa = cur.execute(sql) #如果不加这个,下面那行打印出来是空(有点像读取文件的指针)

print(cur.fetchmany(2))

print(cur.fetchone())

ccc = 'insert into student(id,name,age) values(8,"namec",19)'

cur.execute(ccc)

cur.execute(sql)

conn.commit()

print(cur.fetchall())

#更新数据库

ddd = 'update student set id = -1,name="new",age = 66, sex ="nan" where id >3'

cur.execute(ddd)

conn.commit()

cur.execute('select * from student')#如果不加这行,打印结果会有(8, 'namec', 19, None)) 需要重新查询重新打印

print(cur.fetchall())

#------------------------------------------------------------------------------

import redis

aa = redis.StrictRedis(db = 5,host = '127.0.0.1',decode_responses=True) #在程序操作的数据为byts类型,加入decode_responses=True写入的数据为str类型,db使用的数据库序号不写使用0号,后面的编码不写的话默认是二进制类型,写的话默认是字符串类型,编码后面可以再加password

print(aa.keys())

print(aa.get('k111'))

# aa.set('ccc',1111)

aa.delete('ccc')

aa.hset('has_mr','name','a')

print(aa.hgetall('has_mr'))