SQLAchemy模块

时间:2024-07-18 13:07:44

老师的博客:http://www.cnblogs.com/wupeiqi/articles/5713330.html

有一篇习详细的博客: http://www.keakon.net/2012/12/03/SQLAlchemy%E4%BD%BF%E7%94%A8%E7%BB%8F%E9%AA%8C

SQLAlchemy是Python编程语言下的一款ORM框架,该框架建立在数据库API之上,使用关系对象映射进行数据库操作,简言之便是:将对象转换成SQL,然后使用数据API执行SQL并获取执行结果。

安装:pip3 install SQLAlchemy

导入常用的模块

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index,CHAR,VARCHAR
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy import create_engine

连接

连接数据库的用engine,不同的数据库和不同的连接模块的连接的写法不一样,我们用的是mysql和pymysql具体见下表:

MySQL-Python
mysql+mysqldb://<user>:<password>@<host>[:<port>]/<dbname> pymysql
mysql+pymysql://<username>:<password>@<host>/<dbname>[?<options>]
例如:engine = create_engine("mysql+pymysql://root:@localhost/review60?charset=utf8", max_overflow=5) # 表示最大连接数
MySQL-Connector 
  mysql+mysqlconnector://<user>:<password>@<host>[:<port>]/<dbname>
cx_Oracle
oracle+cx_oracle://user:pass@host:port/dbname[?key=value&key=value...]
更多详见:http://docs.sqlalchemy.org/en/latest/dialects/index.html

创建列表

from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, ForeignKey, UniqueConstraint, Index,CHAR,VARCHAR
#string是char,varchar的集合
from sqlalchemy.orm import sessionmaker, relationship
from sqlalchemy import create_engine
# 创建父类
Base=declarative_base()
# 创建表单
class User_Type(Base):
__tablename__='usertype' # 表的名称
id = Column(Integer,primary_key=True,autoincrement=True)#主键加自增
title = Column(CHAR(20), nullable=True, index=True)
class User(Base):
__tablename__='user'
id = Column(Integer , primary_key=True,autoincrement=True)
name=Column(CHAR,nullable=False,index=True)
email = Column(CHAR,nullable=False, unique=True)
user_type_id = Column(Integer, ForeignKey('usertype.id'))#表名和列名 外键 __table_args__ = (
UniqueConstraint('id', 'name', name='uix_id_name'),#联合索引的名字
Index('ix_id_name', 'name', 'email'),#第一个是索引的名字
)
engine = create_engine("mysql+pymysql://root:@localhost:3306/review60?charset=utf8", max_overflow=5) # 表示最大连接数
Base.metadata.create_all(engine) #连接数据库,并且把所有的类当做列表创建的mysql里面

删除表

engine = create_engine("mysql+pymysql://root:@localhost:3306/review60?charset=utf8", max_overflow=5)  # 表示最大连接数
Base.metadata.create_all(engine) #连接数据库,并且把所有的类当做列表删除

一般由于创建和删除在函数中表少用,所以我们一般他给分装起来。要用的话直接调用就好。

# 创建表
def create_table():
engine = create_engine("mysql+pymysql://root:@localhost:3306/review60?charset=utf8", max_overflow=5) # 表示最大连接数
Base.metadata.create_all(engine) #连接数据库,并且把所有的类当做列表创建的mysql里面
# 删除表
def drop_table():
engine = create_engine("mysql+pymysql://root:@localhost:3306/review60?charset=utf8", max_overflow=5) # 表示最大连接数
Base.metadata.drop_all(engine)

列表的操作

engine = create_engine("mysql+pymysql://root:@localhost:3306/review60?charset=utf8", max_overflow=5)
Session=sessionmaker(bind=engine) #绑定,创建会议
session=Session()#我去,在sessionmaker里面的call方法返回得是个是个类,所以下面可以调用方法
# 增
obj=User_Type(title='普通用户')
session.add(obj)
obj=User_Type(title='白金用户')
session.add(obj)
obj=User_Type(title='铂金用户')
session.add(obj) # 查
a=session.query(User_Type).all() #查询所有
for row in a :
print(row.id,row.title)
b=session.query(User.name,User.id,User.email).filter(User.id > 0).all(); #按条件筛选
for i1,i2,i3 in b :
print(i1,i2,i3)
c=session.query(User.name,User.id,User.email).filter(User.id > 0).first();#按条件筛选且只选一个
print(c) #由于只有一个直接得到列表
# 改
session.query(User_Type).filter(User_Type.title=='白金用户').update({'title':'黑铁用户'})
session.query(User_Type).filter(User_Type.title=='黑铁用户').update({User_Type.title:'黄金用户'})
session.query(User_Type).filter(User_Type.title=='黄金用户').update({'title':User_Type.title + "哈哈"}, synchronize_session=False)
session.query(User).filter(User.email=='').update({User.id:User.id+99999},synchronize_session='evaluate') # 删除
session.query(User).filter(User.id > 2).delete() session.commit()
session.close()

。