Feature/padw 112 sync function

extension/src/controller/dv_loader.rs

@@ -1,9 +1,9 @@
-use pg_sys::Hash;
 use pgrx::prelude::*;
 use std::collections::HashMap;
-use crate::model::dv_schema::{self, *};
+use crate::model::dv_schema::*;
 
-pub fn column_in_dv_schemas(table_oid: u32, column_ordinal_position: i16) -> bool {
+
+pub fn get_dv_schemas() -> Vec<DVSchema> {
 
     // get DV_SCHEMAS via Query
     let get_schemas_query: &str = r#"
@@ -33,13 +33,29 @@ pub fn column_in_dv_schemas(table_oid: u32, column_ordinal_position: i16) -> boo
         }
     });
 
-    for dv_schema in dv_schemas {
+    dv_schemas
+}
+
+pub fn column_in_dv_schemas(table_oid: u32, column_ordinal_position: i16) -> bool {
+
+    for dv_schema in get_dv_schemas() {
         if dv_schema.contains_column(table_oid, column_ordinal_position) {return true;}
     }
 
     false
 }
 
+// Load All DV Schemas
+
+pub fn dv_load_schemas_all() -> bool {
+
+    for dv_schema in get_dv_schemas() {
+        dv_data_loader(&dv_schema);
+        log!("DV Schema (Build ID) Loaded: {}", dv_schema.id.to_string())
+    }
+    true
+}
+
 pub fn dv_load_schema_from_build_id(build_id: &String) -> Option<DVSchema> {
     let get_schema_query: &str = r#"
         SELECT schema

extension/src/lib.rs

@@ -58,6 +58,17 @@ fn build_default() -> String {
     message
 }
 
+// Syncing All DV Schemas
+#[pg_extern(name="sync")]
+fn sync_default() -> String {
+    let load_complete = dv_loader::dv_load_schemas_all();
+    if load_complete {
+        "All DV schema objects updated.".to_string()
+    } else {
+        "Failed Load".to_string()
+    }
+}
+
 #[pg_extern]
 fn source_include(  schema_pattern_include: &str, 
                     table_pattern_include: default!(Option<&str>, "NULL"), 
@@ -152,7 +163,7 @@ fn source_column() -> Result<
                     row["column"].value(),
                     {
                         if is_built {
-                            Ok(Some("built".to_string()))
+                            Ok(Some("Built".to_string()))
                         } else {
                             row["status"].value()
                         }