python连接数据库

2019年5月1日17:56:05 发表评论 803 views
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)
print(cur.fetchall())
#更新数据库
ddd = 'update student set id = -1,name="new",age = 66, sex ="nan" where id >3'
cur.execute(ddd)
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'))

发表评论

:?: :razz: :sad: :evil: :!: :smile: :oops: :grin: :eek: :shock: :???: :cool: :lol: :mad: :twisted: :roll: :wink: :idea: :arrow: :neutral: :cry: :mrgreen: