[Database][SQL] Schema and insertUsers function.

gargantext.ini

@@ -14,7 +14,7 @@ TIME_ZONE = Europe/Paris
 # PostgreSQL access
 DB_HOST = 127.0.0.1
 DB_PORT = 5432
-DB_NAME = gargandbV4
+DB_NAME = gargandbV5
 DB_USER = gargantua
 DB_PASS = C8kdcUrAQy66U
 # Logs

src/Gargantext/Database/Schema/User.hs

@@ -19,6 +19,7 @@ Functions to deal with users, database side.
 {-# LANGUAGE FunctionalDependencies      #-}
 {-# LANGUAGE Arrows                      #-}
 {-# LANGUAGE NoImplicitPrelude           #-}
+{-# LANGUAGE OverloadedStrings           #-}
 
 module Gargantext.Database.Schema.User where
 
@@ -70,7 +71,7 @@ type UserWrite = UserPoly (Maybe (Column PGInt4))        (Column PGText)
                                  (Column PGText)         (Column PGText)
                                  (Column PGText)         (Column PGText)
                                  (Column PGBool)         (Column PGBool)
-                                 (Column PGTimestamptz)
+                                 (Maybe (Column PGTimestamptz))
 
 type UserRead  = UserPoly        (Column PGInt4)         (Column PGText)
                                  (Column PGTimestamptz)  (Column PGBool)
@@ -96,10 +97,31 @@ userTable = Table "auth_user" (pUser User { user_id      = optional "id"
                                           , user_email       = required "email"
                                           , user_isStaff     = required "is_staff"
                                           , user_isActive    = required "is_active"
-                                          , user_dateJoined  = required "date_joined"
+                                          , user_dateJoined  = optional "date_joined"
                                           }
                               )
 
+-- TODO: on conflict, nice message
+insertUsers :: [UserWrite] -> Cmd Int64
+insertUsers us = mkCmd $ \c -> runInsertMany c userTable us
+
+gargantuaUser :: UserWrite
+gargantuaUser = User (Nothing) (pgStrictText "password")
+                         (Nothing) (pgBool True) (pgStrictText "gargantua")
+                         (pgStrictText "first_name")
+                         (pgStrictText "last_name")
+                         (pgStrictText "e@mail")
+                         (pgBool True) (pgBool True) (Nothing)
+
+simpleUser :: UserWrite
+simpleUser = User (Nothing) (pgStrictText "password")
+                         (Nothing) (pgBool False) (pgStrictText "user1")
+                         (pgStrictText "first_name")
+                         (pgStrictText "last_name")
+                         (pgStrictText "e@mail")
+                         (pgBool False) (pgBool True) (Nothing)
+
+
 ------------------------------------------------------------------
 queryUserTable :: Query UserRead
 queryUserTable = queryTable userTable

src/Gargantext/Database/Schema/schema.sql

+CREATE EXTENSION IF NOT EXISTS plpgsql WITH SCHEMA pg_catalog;
+COMMENT ON EXTENSION plpgsql IS 'PL/pgSQL procedural language';
+CREATE EXTENSION IF NOT EXISTS acl WITH SCHEMA public;
+
+-- CREATE USER WITH ...
+-- createdb "gargandb"
+
+CREATE TABLE public.auth_user (
+    id SERIAL,
+    password character varying(128) NOT NULL,
+    last_login timestamp with time zone,
+    is_superuser boolean NOT NULL,
+    username character varying(150) NOT NULL,
+    first_name character varying(30) NOT NULL,
+    last_name character varying(30) NOT NULL,
+    email character varying(254) NOT NULL,
+    is_staff boolean NOT NULL,
+    is_active boolean NOT NULL,
+    date_joined timestamp with time zone DEFAULT now() NOT NULL,
+    PRIMARY KEY (id)
+);
+
+ALTER TABLE public.auth_user OWNER TO gargantua;
+
+-- TODO add publication_date
+-- TODO typename -> type_id
+CREATE TABLE public.nodes (
+    id        SERIAL,
+    typename  integer NOT NULL,
+    user_id   integer NOT NULL,
+    parent_id integer REFERENCES public.nodes(id) ON DELETE CASCADE ,
+    name      character varying(255) DEFAULT ''::character varying NOT NULL,
+    date      timestamp with time zone DEFAULT now() NOT NULL,
+    hyperdata jsonb DEFAULT '{}'::jsonb NOT NULL,
+    search tsvector,
+    PRIMARY KEY (id),
+    FOREIGN KEY (user_id)  REFERENCES public.auth_user(id) ON DELETE CASCADE
+);
+ALTER TABLE public.nodes OWNER TO gargantua;
+
+
+
+CREATE TABLE public.ngrams (
+    id SERIAL,
+    terms character varying(255),
+    n integer,
+    PRIMARY KEY (id)
+);
+ALTER TABLE public.ngrams OWNER TO gargantua;
+
+-- TODO: delete ID
+CREATE TABLE public.nodes_ngrams (
+    id SERIAL,
+    node_id integer NOT NULL,
+    ngram_id integer NOT NULL,
+    weight double precision,
+    ngrams_type integer,
+    FOREIGN KEY (node_id) REFERENCES public.nodes(id) ON DELETE CASCADE,
+    FOREIGN KEY (ngram_id) REFERENCES public.ngrams(id) ON DELETE CASCADE,
+    PRIMARY KEY (node_id,ngram_id)
+);
+ALTER TABLE public.nodes_ngrams OWNER TO gargantua;
+
+--
+-- Name: nodes_ngrams_ngrams; Type: TABLE; Schema: public; Owner: gargantua
+--
+
+CREATE TABLE public.nodes_ngrams_ngrams (
+    node_id integer NOT NULL REFERENCES public.nodes(id) ON DELETE CASCADE,
+    ngram1_id integer NOT NULL REFERENCES public.ngrams(id) ON DELETE CASCADE,
+    ngram2_id integer NOT NULL REFERENCES public.ngrams(id) ON DELETE CASCADE,
+    weight double precision,
+    PRIMARY KEY (node_id,ngram1_id,ngram2_id)
+);
+
+ALTER TABLE public.nodes_ngrams_ngrams OWNER TO gargantua;
+
+
+CREATE TABLE public.nodes_nodes (
+    node1_id integer NOT NULL,
+    node2_id integer NOT NULL,
+    score real,
+    favorite boolean,
+    delete boolean,
+    PRIMARY KEY (node1_id, node2_id)
+);
+ALTER TABLE public.nodes_nodes OWNER TO gargantua;
+
+
+
+-- INDEXES
+CREATE UNIQUE INDEX ON public.auth_user(username);
+
+CREATE INDEX auth_user_username_like ON public.auth_user USING btree (username varchar_pattern_ops);
+
+--CREATE INDEX ix_nodes_typename ON public.nodes USING btree (typename);
+--CREATE INDEX ngrams_n_idx    ON public.ngrams USING btree (n);
+CREATE INDEX nodes_hyperdata_idx ON public.nodes USING gin (hyperdata);
+CREATE UNIQUE INDEX nodes_expr_idx ON public.nodes USING btree (((hyperdata ->> 'uniqId'::text)));
+
+CREATE UNIQUE INDEX nodes_expr_idx2 ON public.nodes USING btree (((hyperdata ->> 'uniqIdBdd'::text)));
+CREATE UNIQUE INDEX nodes_typename_parent_id_expr_idx ON public.nodes USING btree (typename, parent_id, ((hyperdata ->> 'uniqId'::text)));
+CREATE INDEX nodes_user_id_typename_parent_id_idx ON public.nodes USING btree (user_id, typename, parent_id);
+
+
+CREATE UNIQUE INDEX ON public.ngrams(terms);
+--CREATE UNIQUE INDEX ON public.ngrams(terms,n);
+
+CREATE INDEX nodes_ngrams_ngram_id_idx ON public.nodes_ngrams USING btree (ngram_id);
+CREATE INDEX nodes_ngrams_ngrams_node_id_idx ON public.nodes_ngrams_ngrams USING btree (node_id);
+CREATE UNIQUE INDEX ON public.nodes_ngrams USING btree (node_id,ngram_id);
+CREATE INDEX nodes_nodes_delete ON public.nodes_nodes USING btree (node1_id, node2_id, delete);
+CREATE UNIQUE INDEX nodes_nodes_node1_id_node2_id_idx ON public.nodes_nodes USING btree (node1_id, node2_id);
+
+-- TRIGGERS
+-- TODO user haskell-postgresql-simple to create this function
+-- with rights typename
+CREATE OR REPLACE FUNCTION public.search_update()
+RETURNS trigger AS $$
+begin
+  IF new.typename = 4 AND new.hyperdata @> '{"language_iso2":"EN"}' THEN
+    new.search := to_tsvector( 'english' , (new.hyperdata ->> 'title') || ' ' || (new.hyperdata ->> 'abstract'));
+  
+  ELSIF new.typename = 4 AND new.hyperdata @> '{"language_iso2":"FR"}' THEN
+    new.search := to_tsvector( 'french' , (new.hyperdata ->> 'title') || ' ' || (new.hyperdata ->> 'abstract'));
+  
+  ELSIF new.typename = 41 THEN
+    new.search := to_tsvector( 'french' , (new.hyperdata ->> 'prenom')
+                                 || ' ' || (new.hyperdata ->> 'nom')
+                                 || ' ' || (new.hyperdata ->> 'fonction')
+                             );
+  ELSE
+    new.search := to_tsvector( 'english' , new.name);
+  END IF;
+  return new;
+end
+$$ LANGUAGE plpgsql;
+
+ALTER FUNCTION public.search_update() OWNER TO gargantua;
+
+CREATE TRIGGER search_update_trigger BEFORE INSERT OR UPDATE ON nodes FOR EACH ROW EXECUTE PROCEDURE search_update();
+
+
+-- Initialize index with already existing data
+UPDATE nodes SET hyperdata = hyperdata;
+