Flask-sqlalchemy

 

sqlalchemy

1. 安装  
2. pip install sqlalchemy -i https://pypi.douban.com/simple  
3. 连接的时候依赖pymysql  

 

创建表

1. # -*- coding: utf-8 -*-  
2. from sqlalchemy.ext.declarative import declarative_base  
3. from sqlalchemy import column # 列  
4. from sqlalchemy import integer, string  # 属性  
5.     
6. base = declarative_base()  # django models  
7.     
8. # 创建表  
9. class user(base):  
10.     __tablename__ = 'user'  
11.     id = column(integer, primary_key=true, autoincrement=true)  
12.     name = column(string(32), index=true, name='名字')  
13.     
14.     
15. # 数据库连接  
16. from sqlalchemy import create_engine  
17. engine = create_engine("mysql+pymysql://root:redhat@192.168.32.71:3306/my_sql?charset=utf8")  
18.     
19. # 去engine数据库中创建所有继承base的表  
20. base.metadata.create_all(engine)  

 

增加数据

1. # -*- coding: utf-8 -*-  
2. from .create import engine, user  
3. # 增加数据  
4. # 创建会话窗口  
5. from sqlalchemy.orm import sessionmaker  
6. session = sessionmaker(engine)  
7. # 打开会话窗口  
8. db_session = session()  
9.     
10. # ---单条数据  
11. user_obj = user(name='ywb')  # 实例化  
12. db_session.add(user_obj) # 相当于 insert into  
13.     
14. # 执行会化窗口中的所有操作  
15. db_session.commit()  
16. db_session.close()  
17.     
18. # ---增加批量数据  
19. db_session.add_all([  
20.     user(name='peach'),  
21.     user(name='小红')  
22. ])  
23.     
24. db_session.commit()  
25. db_session.close()  
26.     
27. # ---扩展  
28. user1 = user(name='11')  
29. user2 = user(name='12')  
30. user3 = user(name='13')  
31. user4 = user(name='14')  
32. db_session.add(user1)  
33. db_session.add(user2)  
34. db_session.add(user3)  
35. db_session.add(user4)  
36. db_session.commit()  # 全部添加进去  
37. db_session.close()