标签：描述 contain 信息 object 用户名 服务器 技术 语句 logs
sqlAlchemy是python中最著名的ORM(Object Relationship Mapping)框架了。
一句话解释的话就是，一种可以把model中的模型和数据库中的一条数据相互转换的工具。
# 初始化数据库链接
engine = create_engine(‘mysql+mysqlconnector://root:123456@localhost:3306/test‘)create_engine()函数中的字符串的意义是，数据库+数据库连接框架://用户名:密码@IP地址:端口号/数据库名称。
那么不难看出，我使用了mysql数据库，数据库连接框架用的mysqlconnector，用户名root，密码123456，ip地址是localhost(会被解析为127.0.0.1)，端口号3306(这是mysql服务器默认端口号)，test是数据库的名字。
在test数据库中，创建user表。sql如下
create table user (id varchar(20) primary key, name varchar(20))
创建表，表名为user，表中有两个字段。一个是id，varchar类型，最多支持20个字符，设置为主键，另一个是name，varchar类型，最多支持20个字符。
ps：主键是唯一的，当你重复插入时会报错，并终止插入操作。
# 定义User对象 class User(Base): # 表的名字 __tablename__ = ‘user‘ # 表的结构 id = Column(String(20), primary_key=True) name = Column(String(20))
这里可以发现，User类的字段名和表中完全一致，而且字段的属性也一样。以id字段为例，表中id的属性是varchar(20)，primary key，模型中String(20), primary_key=True。我们可以清晰的看到varchar在程序中对应String，primary_key对应程序中的primary_key属性，而且是个bool类型。
ps：这里的String是sqlAlchemy中的一个类，这样类似的类我们还会用到Column。
在sqlAlchemy中，增删改查操作是通过一个session对象(DBSession,是由sessionmaker创建的)来完成的。如果你和我一样是新手，估计也完全不懂，但是至少读一遍有个印象，我们一步一步来。
所以，我们需要创建session。
# 创建DBSession类型 DBSession = sessionmaker(bind=engine)
在此基础之上我们就能进行增删改查的操作了。先从增加开始。
# 创建Session对象 session = DBSession() # 创建User对象 new_user = User(id=‘1‘, name=‘Bob‘) # 添加到session session.add(new_user) # 提交 session.commit() # 关闭session session.close()
还有查询
# 创建session session = DBSession() # 利用session创建查询，query(对象类).filter(条件).one()/all() user = session.query(User).filter(User.id==‘1‘).one() print(‘type:{0}‘.format(type(user))) print(‘name:{0}‘.format(user.name)) # 关闭session session.close()
更新操作
要多一步，就是要先根据筛选条件拿到要更改的对象，然后给对象赋值，再次提交(commit)即可。
# 更新 session = DBSession() user_result = session.query(User).filter_by(id=‘1‘).first() user_result.name = "jack" session.commit() session.close()
删除操作
# 删除 session = DBSession() user_willdel = session.query(User).filter_by(id=‘5‘).first() session.delete(user_willdel) session.commit() session.close()
把上面零零散散的代码片段合起来
# 导入依赖 from sqlalchemy import Column, String, create_engine from sqlalchemy.orm import sessionmaker from sqlalchemy.ext.declarative import declarative_base # 创建对象的基类 Base = declarative_base() # 定义User对象 class User(Base): # 表的名字 __tablename__ = ‘user‘ # 表的结构 id = Column(String(20), primary_key=True) name = Column(String(20)) # 初始化数据库链接 engine = create_engine(‘mysql+mysqlconnector://root:123456@localhost:3306/test‘) # 创建DBSession类型 DBSession = sessionmaker(bind=engine) # 添加 # 创建Session对象 session = DBSession() # 创建User对象 new_user = User(id=‘5‘, name=‘Bob‘) # 添加到session session.add(new_user) # 提交 session.commit() # 关闭session session.close() # 查询 # 创建session session = DBSession() # 利用session创建查询，query(对象类).filter(条件).one()/all() user = session.query(User).filter(User.id==‘5‘).one() print(‘type:{0}‘.format(type(user))) print(‘name:{0}‘.format(user.name)) # 关闭session session.close() # 更新 session = DBSession() user_result = session.query(User).filter_by(id=‘1‘).first() user_result.name = "jack" session.commit() session.close() # 删除 session = DBSession() user_willdel = session.query(User).filter_by(id=‘5‘).first() session.delete(user4._willdel) session.commit() session.close()
如果运行代码发现报错了，你也许是因为以下几个原因：
3.表中数据重复，如果你像我一样设置了主键的话，是不能重复插入数据的，所以程序会报错
4.model.py中的User类描述的表结构与test数据库User表定义的结构是否一致
暂时只想到这几个原因，具体原因还要运行窗口中的报错信息。
以上内容参考廖雪峰老师的博客，传送门
还有一个哥们的博客的查询操作写的很详细，也可以看一下，传送门。
到此为止，也只能是了解了sqlAlchemy的基本操作，下一章再深入一些了解，传送门
标签：描述 contain 信息 object 用户名 服务器 技术 语句 logs
原文地址：https://www.cnblogs.com/kaerxifa/p/11050471.html
