123 lines
3.0 KiB
Python
123 lines
3.0 KiB
Python
import json
|
|
|
|
from sqlalchemy import create_engine, Column, String, ForeignKey, Integer
|
|
from sqlalchemy.ext.declarative import declarative_base
|
|
from sqlalchemy.orm import sessionmaker
|
|
from sqlalchemy.exc import IntegrityError
|
|
|
|
engine = create_engine('sqlite:///data/qotnews.sqlite', connect_args={'timeout': 360})
|
|
Session = sessionmaker(bind=engine)
|
|
|
|
Base = declarative_base()
|
|
|
|
class Story(Base):
|
|
__tablename__ = 'stories'
|
|
|
|
sid = Column(String(16), primary_key=True)
|
|
ref = Column(String(16), unique=True)
|
|
meta_json = Column(String)
|
|
full_json = Column(String)
|
|
title = Column(String)
|
|
|
|
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)
|
|
source = Column(String(16))
|
|
|
|
def init():
|
|
Base.metadata.create_all(engine)
|
|
|
|
def get_story(sid):
|
|
session = Session()
|
|
return session.query(Story).get(sid)
|
|
|
|
def put_story(story):
|
|
story = story.copy()
|
|
full_json = json.dumps(story)
|
|
|
|
story.pop('text', None)
|
|
story.pop('comments', None)
|
|
meta_json = json.dumps(story)
|
|
|
|
try:
|
|
session = Session()
|
|
s = Story(
|
|
sid=story['id'],
|
|
ref=story['ref'],
|
|
full_json=full_json,
|
|
meta_json=meta_json,
|
|
title=story.get('title', None),
|
|
)
|
|
session.merge(s)
|
|
session.commit()
|
|
except:
|
|
session.rollback()
|
|
raise
|
|
finally:
|
|
session.close()
|
|
|
|
def get_story_by_ref(ref):
|
|
session = Session()
|
|
return session.query(Story).filter(Story.ref==ref).first()
|
|
|
|
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, source=x.source) for x in q.all()]
|
|
|
|
def get_stories(amount, skip=0):
|
|
session = Session()
|
|
q = session.query(Reflist, Story.meta_json).\
|
|
order_by(Reflist.rid.desc()).\
|
|
join(Story).\
|
|
filter(Story.title != None).\
|
|
offset(skip).\
|
|
limit(amount)
|
|
return [x[1] for x in q]
|
|
|
|
def put_ref(ref, sid, source):
|
|
try:
|
|
session = Session()
|
|
r = Reflist(ref=ref, sid=sid, source=source)
|
|
session.add(r)
|
|
session.commit()
|
|
except:
|
|
session.rollback()
|
|
raise
|
|
finally:
|
|
session.close()
|
|
|
|
def del_ref(ref):
|
|
try:
|
|
session = Session()
|
|
session.query(Reflist).filter(Reflist.ref==ref).delete()
|
|
session.commit()
|
|
except:
|
|
session.rollback()
|
|
raise
|
|
finally:
|
|
session.close()
|
|
|
|
def count_stories():
|
|
try:
|
|
session = Session()
|
|
return session.query(Story).count()
|
|
finally:
|
|
session.close()
|
|
|
|
def get_story_list():
|
|
try:
|
|
session = Session()
|
|
return session.query(Story.sid).all()
|
|
finally:
|
|
session.close()
|
|
|
|
if __name__ == '__main__':
|
|
init()
|
|
|
|
#print(get_story_by_ref('hgi3sy'))
|
|
print(len(get_reflist(99999)))
|