qotnews/apiserver/database.py

74 lines
1.7 KiB
Python
Raw Normal View History

2020-06-25 23:41:15 +00:00
import json
2020-06-26 00:21:03 +00:00
from sqlalchemy import create_engine, Column, String, ForeignKey, Integer
2020-06-25 23:41:15 +00:00
from sqlalchemy.ext.declarative import declarative_base
from sqlalchemy.orm import sessionmaker
engine = create_engine('sqlite:///data/qotnews.sqlite')
Session = sessionmaker(bind=engine)
Base = declarative_base()
class Story(Base):
__tablename__ = 'stories'
2020-06-26 00:21:03 +00:00
sid = Column(String(16), primary_key=True)
2020-06-25 23:41:15 +00:00
meta_json = Column(String)
full_json = Column(String)
2020-06-26 00:21:03 +00:00
class Reflist(Base):
__tablename__ = 'reflist'
rid = Column(Integer, primary_key=True)
ref = Column(String(16), unique=True)
sid = Column(String, ForeignKey('stories.sid'), unique=True)
2020-06-25 23:41:15 +00:00
def init():
Base.metadata.create_all(engine)
def get_meta(sid):
session = Session()
return session.query(Story).get(sid).meta_json
def get_full(sid):
session = Session()
return session.query(Story).get(sid).full_json
2020-06-26 00:21:03 +00:00
def put_story(story):
2020-06-25 23:41:15 +00:00
full_json = json.dumps(story)
story.pop('text')
story.pop('comments')
meta_json = json.dumps(story)
try:
session = Session()
s = Story(sid=story['id'], full_json=full_json, meta_json=meta_json)
session.merge(s)
session.commit()
except:
session.rollback()
raise
finally:
session.close()
2020-06-26 00:21:03 +00:00
def get_reflist(amount):
session = Session()
q = session.query(Reflist).order_by(Reflist.rid.desc()).limit(amount)
return [dict(ref=x.ref, sid=x.sid) for x in q.all()]
def put_ref(ref, sid):
try:
session = Session()
r = Reflist(ref=ref, sid=sid)
session.add(r)
session.commit()
except:
session.rollback()
raise
finally:
session.close()
if __name__ == '__main__':
init()