projects
/
rainbowstream.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
unknow bug in Mac OS: Stream process die after db is truncated
[rainbowstream.git]
/
rainbowstream
/
db.py
diff --git
a/rainbowstream/db.py
b/rainbowstream/db.py
index d81f5ae192d3e995cbe84e5a2f4fc9dcae2ec1ac..cac9a73d6a62dd0f05ab45cea3afa1520891561e 100644
(file)
--- a/
rainbowstream/db.py
+++ b/
rainbowstream/db.py
@@
-1,16
+1,23
@@
+import os
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from table_def import Map
from sqlalchemy import create_engine
from sqlalchemy.orm import sessionmaker
from table_def import Map
+from .table_def import *
class RainbowDB():
class RainbowDB():
- engine
=
None
+ engine
=
None
def __init__(self):
def __init__(self):
+ if not os.path.isfile('rainbow.db'):
+ init_db()
self.engine = create_engine('sqlite:///rainbow.db', echo=False)
def store(self, tweet_id):
self.engine = create_engine('sqlite:///rainbow.db', echo=False)
def store(self, tweet_id):
+ """
+ Store tweet id
+ """
Session = sessionmaker(bind=self.engine)
session = Session()
m = Map(tweet_id)
Session = sessionmaker(bind=self.engine)
session = Session()
m = Map(tweet_id)
@@
-18,13
+25,19
@@
class RainbowDB():
session.commit()
def rainbow_query(self, rid):
session.commit()
def rainbow_query(self, rid):
+ """
+ Query base of rainbow id
+ """
Session = sessionmaker(bind=self.engine)
session = Session()
Session = sessionmaker(bind=self.engine)
session = Session()
- res = session.query(Map).filter
("rainbow_id =:rid").params(r
id=rid).all()
+ res = session.query(Map).filter
_by(rainbow_
id=rid).all()
return res
def tweet_query(self, tid):
return res
def tweet_query(self, tid):
+ """
+ Query base of tweet id
+ """
Session = sessionmaker(bind=self.engine)
session = Session()
Session = sessionmaker(bind=self.engine)
session = Session()
- res = session.query(Map).filter("tweet_id =:tid").params(tid=tid).all()
- return res
+ res = session.query(Map).filter_by(tweet_id=tid).all()
+ return res
\ No newline at end of file