1.安装

pip install 
sqlalchemy

2.代码如下

1. #!/usr/bin/python
   
2. # coding=utf–8
4. from sqlalchemy import create_engine
5. from sqlalchemy.ext.declarative import declarative_base
6. from sqlalchemy.orm import sessionmaker
7. from sqlalchemy import Column, Integer, String, DateTime, Boolean
9. engine = create_engine(“mysql://root:root@127.0.0.1:3306/test?charset=utf8”)
11. Session = sessionmaker(bind=engine)
13. Base = declarative_base()
16. class News(Base):
17.     ”‘ 新闻类型 ‘”
18.     __tablename__ = ‘news’
19.     id = Column(Integer, primary_key=True)
20.     title = Column(String(200), nullable=False)
21.     content = Column(String(2000), nullable=False)
22.     types = Column(String(10), nullable=False)
23.     image = Column(String(300))
24.     author = Column(String(20))
25.     view_count = Column(Integer)
26.     created_at = Column(DateTime)
27.     is_valid = Column(Boolean)
30. class MysqlOrmTest(object):
32.     def __init__(self):
33.         self.session = Session()
35.     def add_one(self):
36.         new_obj = News(
37.             title=‘orm title’,
38.             content=‘content’,
39.             types=‘百家’
40.         )
41.         self.session.add(new_obj)
42.         self.session.commit()
43.         return new_obj
45.     def get_one(self):
46.         ”‘ 获取一条数据 ‘”
47.         return self.session.query(News).get(1)
49.     def get_more(self):
50.         ”‘ 获取多条数据 ‘”
51.         return self.session.query(News).filter_by(is_valid=1)
53.     def update_data(self):
54.         ”‘ 修改数据 ‘”
55.         obj = self.session.query(News).get(38)
56.         obj.is_valid = 0
57.         self.session.add(obj)
58.         self.session.commit()
59.         return obj
61.     def delete_data(self):
62.         ”‘ 删除数据 ‘”
63.         # 获取要删除的数据
64.         data = self.session.query(News).get(39)
65.         self.session.delete(data)
66.         self.session.commit()
68. def main():
69.     obj = MysqlOrmTest()
70.     # rest = obj.add_one()
71.     # print(dir(rest))
72.     # print(obj.get_one().title)
74.     # print(obj.get_more().count())
75.     # for row in obj.get_more():
76.     # print(row.title)
78.     # print(obj.update_data())
80.     obj.delete_data()
84. if __name__ == ‘__main__’:
85.     main()