前提:需要生成数据表
下面的第一步到第六步是生成数据表的操作步骤
第一步:数据库配置
# 数据库的配置变量
HOSTNAME = '127.0.0.1'
PORT = '3306'
DATABASE = 'test'
USERNAME = 'root'
PASSWORD = 'root'
DB_URI = 'mysql+pymysql://{}:{}@{}:{}/{}?charset=utf8mb4'.format(USERNAME,PASSWORD,HOSTNAME,PORT,DATABASE)
第二步:创建数据库引擎
engine=create_engine(DB_URI)
第三步:测试数据连接是否成功
with engine.connect() as conn:
res=conn.execute('select 1')
print(res.fetchone())
第四步:创建基类
Base=declarative_base(engine)
第五步:创建模型类
class Person(Base):
__tablename__='t_person' #创建表名,最好是t_开头
id=Column(name='id',type_=Integer,primary_key=True,autoincrement=True)
name=Column(name='name',type_=String(255))
age=Column(name='age',type_=Integer)
address=Column(name='address',type_=String(255))
country=Column(name='country',type_=String(50)) #创建表之后新加的字段
city=Column(name='city',type_=String(50)) #创建表之后新加的字段
def __str__(self):
return '姓名:{}-年领:{}-地址:{}-国家:{}-城市:{}'.format(self.name,self.age,self.address,self.country,self.city)
第六步:根据模型类创建数据表
#Base.metadata.drop_all()
Base.metadata.create_all()
第七步:创建session对象
session=sessionmaker(engine)() #注意sessionmaker返回一个函数
一、对数据进行修改操作
首先从数据库中查找对象,然后将这条数据修改为你想要的数据,最后做commit操作就可以修改数据了。
举例1:
将名字为zz的人物,改为名字为jmeter
p1=session.query(Person).filter(Person.name=='zz').first()
p1.name='jmeter'
session.commit()
举例2:
将所有名字为zz的人物,改为名字为jmeter
res=session.query(Person).filter(Person.name=='zz').all()
print(res)
for i in res:
i.name='flask'
session.commit()
二、对数据进行删除操作
首先从数据库中查找对象,然后将这条数据删除,最后做commit操作就可以删除数据了。
p1=session.query(Person).filter(Person.name=='kb').first()
session.delete(p1)
session.commit()
特别注意:
p1=session.query(Person).filter(Person.name=='kb').first()
p1是对象,可以删除;
p2=session.query(Person).filter(Person.name=='kb').all()
p2是列表对象,不可以对列表对象删除,如果要对列表对象删除,通过for循环操作
代码如下
def delete():
res1 = session.query(Person).filter(Person.sal <= 3000).all()
print(res1)
for i in res1:
session.delete(i)
session.commit()
版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
文章由极客之音整理,本文链接:https://www.bmabk.com/index.php/post/74175.html