add schema on query

crss-meterprocess-stream-source-daily-raw/crss-meterprocess-stream-source-daily-raw-dev2.yml

@@ -5,7 +5,7 @@ spring:
     driver-class-name: org.postgresql.Driver
     password: crss_metering
     username: crss_metering
-    url: jdbc:postgresql://192.168.233.9:5432/crss_metering2
+    url: jdbc:postgresql://192.168.233.9:5432/crss_metering
     maxPoolSize: 5
     test-on-borrow: true
     validation-query: SELECT 1
@@ -15,8 +15,8 @@ spring:
         output:
           content-type: application/json
 jdbc:
-  query: "select * from txn_meter_data_daily where consumed <> TRUE or consumed is null limit 10000;"
-  update: "update txn_meter_data_daily set consumed = TRUE where meter_data_id in (:meter_data_id);"
+  query: "select * from public.txn_meter_data_daily where consumed <> TRUE or consumed is null limit 10000;"
+  update: "update public.txn_meter_data_daily set consumed = TRUE where meter_data_id in (:meter_data_id);"
 
 trigger:
   fixed-delay: 5
@@ -35,7 +35,7 @@ spring:
     driver-class-name: org.postgresql.Driver
     password: crss_metering
     username: crss_metering
-    url: jdbc:postgresql://192.168.233.9:5432/crss_metering2
+    url: jdbc:postgresql://192.168.233.9:5432/crss_metering
     maxPoolSize: 5
     test-on-borrow: true
     validation-query: SELECT 1
@@ -45,8 +45,8 @@ spring:
         output:
           content-type: application/json
 jdbc:
-  query: "select * from txn_meter_data_monthly where consumed <> TRUE or consumed is null limit 10000;"
-  update: "update txn_meter_data_monthly set consumed = TRUE where meter_data_id in (:meter_data_id);"
+  query: "select * from public.txn_meter_data_monthly where consumed <> TRUE or consumed is null limit 10000;"
+  update: "update public.txn_meter_data_monthly set consumed = TRUE where meter_data_id in (:meter_data_id);"
 
 trigger:
   fixed-delay: 5
@@ -64,7 +64,7 @@ spring:
     driver-class-name: org.postgresql.Driver
     password: crss_metering
     username: crss_metering
-    url: jdbc:postgresql://192.168.233.9:5432/crss_metering2
+    url: jdbc:postgresql://192.168.233.9:5432/crss_metering
     maxPoolSize: 5
     test-on-borrow: true
     validation-query: SELECT 1
@@ -74,8 +74,8 @@ spring:
         output:
           content-type: application/json
 jdbc:
-  query: "select * from txn_meter_data_monthly where consumed <> TRUE or consumed is null limit 10000;"
-  update: "update txn_meter_data_monthly set consumed = TRUE where meter_data_id in (:meter_data_id);"
+  query: "select * from public.txn_meter_data_monthly where consumed <> TRUE or consumed is null limit 10000;"
+  update: "update public.txn_meter_data_monthly set consumed = TRUE where meter_data_id in (:meter_data_id);"
 
 trigger:
   fixed-delay: 5