Vahekoopia

R/pk_teisendame_jooni.R

@@ -240,20 +240,31 @@ pk_teisendame_jooni <- function(obj = NULL, conf = NULL) {
       ## 9. Kustutame geom veeru.
       conn <- ruut::db_connect(conf = conf)
       q <-
-        sprintf("ALTER TABLE %s.%s DROP COLUMN geom;",
+        sprintf("ALTER TABLE \"%s\".\"%s\" DROP COLUMN geom;",
                 conf$schema,
                 conf$table)
       cat(sprintf("\n-----------------\n%s\n\n", q))
       DBI::dbSendQuery(conn, q)
-      ## 11. Vaakum.
+      ## 10. Vaakum.
       q <-
         sprintf(
-          "VACUUM (FULL, FREEZE, VERBOSE, ANALYZE, INDEX_CLEANUP) %s.%s;",
+          "VACUUM (FULL, FREEZE, VERBOSE, ANALYZE, INDEX_CLEANUP) \"%s\".\"%s\";",
           conf$schema,
           conf$table
         )
       cat(sprintf("\n-----------------\n%s\n\n", q))
       DBI::dbSendQuery(conn, q)
+      ## 11. Add foreign key.
+      q <-
+        sprintf(
+          "ALTER TABLE \"%s\".\"%s\" ADD CONSTRAINT %s_fk FOREIGN KEY (id) REFERENCES %s.bb2_epk02t_grid(id);",
+          conf$schema,
+          conf$table,
+          conf$table,
+          conf$schema
+        )
+      cat(sprintf("\n-----------------\n%s\n\n", q))
+      DBI::dbSendQuery(conn, q)
       DBI::dbDisconnect(conn)
     }
   }

R/pk_teisendame_polygoone.R

@@ -255,7 +255,7 @@ pk_teisendame_polygoone <- function(obj = NULL, conf = NULL) {
       ## 10. Kustutame geom veeru.
       conn <- ruut::db_connect(conf = conf)
       q <-
-        sprintf("ALTER TABLE %s.%s DROP COLUMN geom;",
+        sprintf("ALTER TABLE \"%s\".\"%s\" DROP COLUMN geom;",
                 conf$schema,
                 conf$table)
       cat(sprintf("\n-----------------\n%s\n\n", q))
@@ -263,12 +263,23 @@ pk_teisendame_polygoone <- function(obj = NULL, conf = NULL) {
       ## 11. Vaakum.
       q <-
         sprintf(
-          "VACUUM (FULL, FREEZE, VERBOSE, ANALYZE, INDEX_CLEANUP) %s.%s;",
+          "VACUUM (FULL, FREEZE, VERBOSE, ANALYZE, INDEX_CLEANUP) \"%s\".\"%s\";",
           conf$schema,
           conf$table
         )
       cat(sprintf("\n-----------------\n%s\n\n", q))
       DBI::dbSendQuery(conn, q)
+      ## 12. Add foreign key.
+      q <-
+        sprintf(
+          "ALTER TABLE \"%s\".\"%s\" ADD CONSTRAINT %s_fk FOREIGN KEY (id) REFERENCES %s.bb2_epk02t_grid(id);",
+          conf$schema,
+          conf$table,
+          conf$table,
+          conf$schema
+        )
+      cat(sprintf("\n-----------------\n%s\n\n", q))
+      DBI::dbSendQuery(conn, q)
       DBI::dbDisconnect(conn)
     }
   }

R/pk_teisendame_punkte.R

@@ -168,7 +168,7 @@ pk_teisendame_punkte <- function(obj = NULL, conf = NULL) {
       ## 5. Kustutame geom veeru.
       conn <- ruut::db_connect(conf = conf)
       q <-
-        sprintf("ALTER TABLE %s.%s DROP COLUMN geom;",
+        sprintf("ALTER TABLE \"%s\".\"%s\" DROP COLUMN geom;",
                 conf$schema,
                 conf$table)
       cat(sprintf("\n-----------------\n%s\n\n", q))
@@ -176,12 +176,23 @@ pk_teisendame_punkte <- function(obj = NULL, conf = NULL) {
       ## 6. Vaakum.
       q <-
         sprintf(
-          "VACUUM (FULL, FREEZE, VERBOSE, ANALYZE, INDEX_CLEANUP) %s.%s;",
+          "VACUUM (FULL, FREEZE, VERBOSE, ANALYZE, INDEX_CLEANUP) \"%s\".\"%s\";",
           conf$schema,
           conf$table
         )
       cat(sprintf("\n-----------------\n%s\n\n", q))
       DBI::dbSendQuery(conn, q)
+      ## 6. Add foreign key.
+      q <-
+        sprintf(
+          "ALTER TABLE \"%s\".\"%s\" ADD CONSTRAINT %s_fk FOREIGN KEY (id) REFERENCES %s.bb2_epk02t_grid(id);",
+          conf$schema,
+          conf$table,
+          conf$table,
+          conf$schema
+        )
+      cat(sprintf("\n-----------------\n%s\n\n", q))
+      DBI::dbSendQuery(conn, q)
       DBI::dbDisconnect(conn)
     }
   }