store friends / followers

1 files changed, 31 insertions, 0 deletions

diff --git a/lib/Dakkar/TweetArchive/Store.pm b/lib/Dakkar/TweetArchive/Store.pm
index e4a4f3b..b716166 100644
--- a/lib/Dakkar/TweetArchive/Store.pm
+++ b/lib/Dakkar/TweetArchive/Store.pm
@@ -72,6 +72,22 @@ SQL
                );
 }
 
+sub store_friends($self,$friends) {
+    my $friends_str = $json_printer->encode($friends);
+
+    $self->dbh->do(<<'SQL', {}, $friends_str);
+INSERT INTO friends(users) VALUES(?)
+SQL
+}
+
+sub store_followers($self,$followers) {
+    my $followers_str = $json_printer->encode($followers);
+
+    $self->dbh->do(<<'SQL', {}, $followers_str);
+INSERT INTO followers(users) VALUES(?)
+SQL
+}
+
 sub _schema_deploy($self,$dbh,$next_version) {
     my $method_name = "_schema_deploy_${next_version}";
     if (my $method = $self->can($method_name)) {
@@ -115,4 +131,19 @@ CREATE TABLE tweets (
 SQL
 }
 
+sub _schema_deploy_2($self,$dbh) {
+    $dbh->do(<<'SQL');
+CREATE TABLE followers (
+  taken_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT CURRENT_TIMESTAMP PRIMARY KEY,
+  users JSONB NOT NULL
+)
+SQL
+    $dbh->do(<<'SQL');
+CREATE TABLE friends (
+  taken_at TIMESTAMP WITH TIME ZONE NOT NULL DEFAULT CURRENT_TIMESTAMP PRIMARY KEY,
+  users JSONB NOT NULL
+)
+SQL
+}
+
 1;