print out sql query for find derived

Author: incrypto32

store/postgres/src/deployment_store.rs

@@ -1077,14 +1077,15 @@ impl DeploymentStore {
 
     pub(crate) fn get_derived(
         &self,
+        logger: &Logger,
         site: Arc<Site>,
         derived_query: &DerivedEntityQuery,
         block: BlockNumber,
         excluded_keys: &Vec<EntityKey>,
     ) -> Result<BTreeMap<EntityKey, Entity>, StoreError> {
         let mut conn = self.get_conn()?;
         let layout = self.layout(&mut conn, site)?;
-        layout.find_derived(&mut conn, derived_query, block, excluded_keys)
+        layout.find_derived(logger, &mut conn, derived_query, block, excluded_keys)
     }
 
     pub(crate) fn get_changes(

store/postgres/src/relational.rs

@@ -42,7 +42,7 @@ use graph::prelude::{q, EntityQuery, StopwatchMetrics, ENV_VARS};
 use graph::schema::{
     EntityKey, EntityType, Field, FulltextConfig, FulltextDefinition, InputSchema,
 };
-use graph::slog::warn;
+use graph::slog::{trace, warn};
 use index::IndexList;
 use inflector::Inflector;
 use itertools::Itertools;
@@ -682,6 +682,7 @@ impl Layout {
 
     pub fn find_derived(
         &self,
+        logger: &Logger,
         conn: &mut PgConnection,
         derived_query: &DerivedEntityQuery,
         block: BlockNumber,
@@ -691,6 +692,7 @@ impl Layout {
         let ids = excluded_keys.iter().map(|key| &key.entity_id).cloned();
         let excluded_keys = IdList::try_from_iter(derived_query.entity_type.id_type()?, ids)?;
         let query = FindDerivedQuery::new(table, derived_query, block, excluded_keys);
+        trace!(logger, "get_derived"; "query" => format!("{:?}", debug_query(&query)));
 
         let mut entities = BTreeMap::new();
 

store/postgres/src/writable.rs

@@ -355,14 +355,14 @@ impl SyncStore {
 
     fn get_derived(
         &self,
-        _logger: &Logger,
+        logger: &Logger,
         key: &DerivedEntityQuery,
         block: BlockNumber,
         excluded_keys: Vec<EntityKey>,
     ) -> Result<BTreeMap<EntityKey, Entity>, StoreError> {
         retry::forever(&self.logger, "get_derived", || {
             self.writable
-                .get_derived(self.site.cheap_clone(), key, block, &excluded_keys)
+                .get_derived(logger, self.site.cheap_clone(), key, block, &excluded_keys)
         })
     }