使用orm—sqlalchemy

from sqlalchemy.orm import sessionmaker
from sqlalchemy import create_engine
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy import Column, Integer, String, DateTime, Boolean

engine = create_engine('mysql://root:@localhost:3306/news?charset=utf8')
Base = declarative_base()
Session = sessionmaker(bind=engine)


class News(Base):
    __tablename__ = 'news'
    id = Column(Integer, primary_key=True)
    title = Column(String(200), nullable=False)
    content = Column(String(20000), nullable=False)
    created_at = Column(DateTime)
    types = Column(String(10), nullable=False)
    author = Column(String(20))
    view_count = Column(Integer)
    is_valid = Column(Boolean)


class OrmText(object):
    def __init__(self):
        self.session = Session()

    def add_one(self):
        """新增一条记录"""
        try:
            orm_obj = News(
                title='伊朗感染新冠病毒人数达9000人',
                content='新闻内容',
                types='百家',
            )
            self.session.add(orm_obj)
            self.session.commit()
            return orm_obj
        except:
            print('Error')
            self.session.rollback()

    def get_one(self):
        """获取一条数据"""
        return self.session.query(News).get(6)

    def get_more(self):
        """获取多条数据"""
        return self.session.query(News).filter_by(is_valid=True)

    def get_all(self):
        """获取所有数据"""
        list = []
        for sert in self.session.query(News).all():
            list.append(sert)
        return list

    def update_data(self, update_id):
        """修改数据"""
        obj = self.session.query(News).get(update_id)
        if obj:
            obj.title = '全球市场进入暴跌模式 至少11国发生“熔断”'
            self.session.add(obj)
            self.session.commit()
            return True
        else:
            return False

    def delete_data(self, delete_id):
        """删除数据"""
        data = self.session.query(News).get(delete_id)
        self.session.delete(data)
        self.session.commit()

# 建表语句
News.metadata.create_all(engine)

# 添加数据
obj = OrmText()
rest = obj.add_one()
print(rest.id)

# 获取一条记录
rest = obj.get_one()
if rest:
    print('%s:%s' % (rest.id, rest.title))
else:
    print("数据不存在")

# 获取多条数据
obj = OrmText()
rest = obj.get_more()
print(rest.count())
print(rest)
for i in rest:
    print('%s:%s' % (i.id, i.title))

# 获取所有数据
obj = OrmText()
for i in obj.get_all():
    print(i.id, i.title)

# 修改数据
obj = OrmText()
text = obj.update_data(3)
print(text)

# 删除数据
data = OrmText()
data.delete_data(7)