Python数据库 4.Python与数据库的交互_python

概述4.1Python与数据库的交互在没有DB-API之前，各数据库之间的应用接口非常混乱，实现各不相同，如果项目需要更换数据库，基本上需要把所有和数据库相关的代码都进行改动，十分不方便 4.2DB-API DB-API的出现就是为了解决这个问题，python 所有的数据库接口在一定程度上都要遵守python DB-API规范，它定义了一系列的 *** 作数据库的方式，为各种数据库提供了一致的访问接口，项目 4.1Python与数据库的交互

在没有DB-API之前，各数据库之间的应用接口非常混乱，实现各不相同，如果项目需要更换数据库，基本上需要把所有和数据库相关的代码都进行改动，十分不方便

4.2DB-API

DB-API的出现就是为了解决这个问题，python 所有的数据库接口在一定程度上都要遵守python DB-API规范，它定义了一系列的 *** 作数据库的方式，为各种数据库提供了一致的访问接口，项目中更换使用数据库变得更加方便。

4.3MysqL

开始
创建connection
获取cursor
?
执行查询执行命令获取数据处理数据
?
关闭cursor
关闭connection
结束

###################

conn = pyMysqL.connect(
?
   ‘user‘: ‘账号‘,
   ‘password‘: ‘密码‘,
   ‘db‘: ‘数据库名‘,
   ‘charset‘: ‘utf8‘,  #不是utf-8
)

#####################

db_config = {
   ‘user‘: ‘账号‘,
}
conn = pyMysqL.connect(**db_config)

1.使用步骤

1.导入模块：

import pyMysqL

2.建立连接：

pyMysqL.connect(**dbconfig) 连接是不能 *** 作数据库的,需要用连接生成游标来 *** 作

3.创建游标：

connection.cursor()

4.执行SQL语句：

cursor.execute(sql) SQL语句都是通过这个方法执行

5.获取结果：

cur.fetchall()

6.注意：

在pyMysqL中执行的SQL语句不需要加 ;

execute执行完后不是直接得到结果，需要你主动去获取

和文件一样，别忘了关闭游标与连接

事务的回滚和提交 rollbck 与commit

2.获取

print( cur .fetchone( )) #一行
print( cur .fetchall( )) #全部 返回二维元组
print( cur .fetchmany(3)) # 几条

3.with 语法 (默认将数据保存到库中)

with conn.cursor() as cur:
 cur .execute( ‘select * from student‘)
 print( cur .fetchone( )) #一行
?
conn.close()
?
########
?
with pyMysqL.connect(**MysqL_ config) as cur:
 cur .execute( ‘select * from student‘)
 print( cur .fetchone( )) #一行
 cur 此时为游标对象

4. 插入

with pyMysqL.connect(**MysqL_ config) as cur:
 cur .execute( 
  ‘insert into student values (6,"患者"，16，22)‘
  )

5. 事务（pyMysqL 默认使用事务模式）

begin ; 开始事务
rollback ； 回滚 （撤回）
commit ； 保存

开始之后只有commit 才能保存的数据库中

rollback 是在提交之前可以回滚 commit 之前写的都是在临时环境下

?
    conn = pyMysqL. connect(**MysqL_ config)
    
    cur = conn.cursor( )
    
    cur .execute( 
    ‘insert into student values (6,"患者"，16，22)‘
   )
    
    conn.commit()
    cur.close( ) 
    conn.close()

优化：插入多条数据：

?
    conn = pyMysqL. connect(**MysqL_ config)
    
    @H_502_416@with conn.cursor() @H_502_416@as cur:
    cur .execute(
     ‘insert into student values (6,"患者"，16，22)‘
   )
    conn.commit()
?
?
 @H_502_416@with conn.cursor() @H_502_416@as cur:
  cur .execute( 
 ‘insert into student values (7,"7者"，17，27)‘
 )
 conn.commit()
 conn.close()

6.fetchone fetchall

数据过多时会一条一条显示不会爆内存如果直接 print（cur .fetchall()）内存爆了

conn = pyMysqL. connect(**MysqL_ config)
?
with conn.cursor() as cur:
 cur .execute( ‘select * from student‘)
?
 row = cur .fetchone()
 
 while row:
  print (‘Row‘:row)
  row = cur .fetchone()

#################

?
 
 db_config = {
    ‘user‘: ‘账号‘,
    ‘password‘: ‘密码‘,
    ‘db‘: ‘数据库名‘,
    ‘charset‘: ‘utf8‘,
 }
?
    conn = pyMysqL. connect(**db_config)
 
    cur = conn.cursor( )
 
 cur .execute( ‘select * from student‘)
?
 print( cur .fetchone( )) #一行
 print( cur .fetchall( )) #全部 返回二维元组
 print( cur .fetchmany(3)) # 几条
?
 cur.close( ) 
 conn.close()
?
?
 #with conn.cursor() as cur:
  #cur .execute( ‘select * from student‘)
  #print( cur .fetchone( )) #一行
?
 #conn.close()
?
?
 #with pyMysqL.connect(**MysqL_ config) as cur:
  #cur .execute( ‘select * from student‘)
  #print( cur .fetchone( )) #一行
  #cur 此时为游标对象
  
##########################
?
?
 conn = pyMysqL. connect(**db_config) #连接pyMysqL
 
 
 cur = conn.cursor( ) #建立游标，利用游标来执行sq_语句
 
 @H_502_416@try:
    #执行sq1语句，不会返回结果，返回共影响的行数
    executes = cur .execute( ‘select * from student‘)
 
    #获取结果
    values = cur. fetchall()  
 
    @H_502_416@for value @H_502_416@in values :      #循环打印结果
        print (value)
 
    #提交到数据片，自正把数据插入或者更新到数据白 
    conn. commit ()
 
 exvept Exceplion @H_502_416@as e:
 
      print (e)
 
      #发生了异常，同滚
      conn. rollback ()
 @H_502_416@finally:
 
      #在最后使用完关闭游标和连接#关闭游林
 
      cur. close()
      conn. close()
?

4.4. Redis

在python中 *** 作redis的命令和命令行的用户几乎一模一样

1.安装python包redis：

pip install redis

2.连接redis：

redis.Redis() 为了兼容旧版本（不推荐使用）

3.连接redis：

Redis.StrictRedis()

4.在程序 *** 作的数据为bytes类型，加入decode_responses=True,写入的数据为str类型

import redis
?
conn = redis. StrictRedis( db=5)
conn.set( ‘ name‘,‘短视的‘) #以二进制格式插入
res=conn.get( ‘name‘)
print(res)               # 二进制
?
print(res.decode（‘utf-8‘）)  
?
################
?
conn = redis. StrictRedis( db=5,decode_responses=True)
res=conn.get( ‘name‘)
print(res)   
?
#连接远程数据库
conn = redis. StrictRedis(host =‘‘,port=‘‘,db=5)

?
 
 @H_502_416@import redis
 
 @H_502_416@class RedisList(object):
    @H_502_416@def __init__(self,db=0,decode_responses=@H_502_416@False):
        self.conn=redis.StrictRedis(db=db,decode_responses=decode_responses)
 
    @H_502_416@def push(self,key,*value,dire=‘r‘):
        @H_502_416@if dire==‘r‘:
            self.conn.lpush(key,*value)
        @H_502_416@else:
            self.conn.rpush(key,*value)
 
    @H_502_416@def get(self,start_index,end_index=@H_502_416@None):
        @H_502_416@if end_index:
            @H_502_416@return self.conn.lrange(key,end_index)
        @H_502_416@else:
            @H_502_416@return self.conn.lindex(key,start_index)
 
    @H_502_416@def set(self,index,value):
        self.conn.lset(key,value)
 
    @H_502_416@def pop(self,value,dire=‘r‘):
        @H_502_416@if dire==‘r‘:
            self.conn.lpop(key,value)
        @H_502_416@else:
            self.conn.rpop(key,value)
 
 @H_502_416@if __name__==‘__main__‘:
    rList=RedisList(db=1,decode_responses=@H_502_416@True)
    print(rList.get(‘name‘,0,3))
?
?
?
?
?