Adding db pool config to settings, in earlier commit default was set …

…to 10 form 100
Sunbird-RC · Jan 13, 2022 · f9a2662 · f9a2662
1 parent 37addbf
commit f9a2662
Show file tree

Hide file tree

Showing 4 changed files with 11 additions and 2 deletions.
diff --git a/java/registry/src/main/java/dev/sunbirdrc/registry/model/DBConnectionInfo.java b/java/registry/src/main/java/dev/sunbirdrc/registry/model/DBConnectionInfo.java
@@ -7,6 +7,7 @@ public class DBConnectionInfo {
 	private String uri;
 	private String username;
 	private String password;
+	private int maxPoolSize;
 	private boolean profilerEnabled = false;
 
 	public String getShardId() {
@@ -57,4 +58,11 @@ public void setShardLabel(String shardLabel) {
 		this.shardLabel = shardLabel;
 	}
 
+	public int getMaxPoolSize() {
+		return maxPoolSize;
+	}
+
+	public void setMaxPoolSize(int maxPoolSize) {
+		this.maxPoolSize = maxPoolSize;
+	}
 }
diff --git a/java/registry/src/main/java/dev/sunbirdrc/registry/service/ISearchService.java b/java/registry/src/main/java/dev/sunbirdrc/registry/service/ISearchService.java
@@ -63,7 +63,7 @@ default SearchQuery getSearchQuery(JsonNode inputQueryNode, int offset, int limi
             searchQuery.setLimit(inputQueryNode.get("limit").asInt());
             searchQuery.setOffset(inputQueryNode.get("offset").asInt());
         } catch (Exception e) {
-            logger.error("Populates SearchQuery for limit/offset(optional): {}", e.getMessage());
+            logger.warn("Populates SearchQuery for limit/offset(optional): {}", e.getMessage());
         }
 
         searchQuery.setFilters(filterList);

diff --git a/java/registry/src/main/java/dev/sunbirdrc/registry/sink/SqlgProvider.java b/java/registry/src/main/java/dev/sunbirdrc/registry/sink/SqlgProvider.java
@@ -29,7 +29,7 @@ public SqlgProvider(DBConnectionInfo connectionInfo, String uuidPropertyName) {
         config.setProperty("jdbc.url", connectionInfo.getUri());
         config.setProperty("jdbc.username", connectionInfo.getUsername());
         config.setProperty("jdbc.password", connectionInfo.getPassword());
-        config.setProperty("maxPoolSize", 10);
+        config.setProperty("maxPoolSize", connectionInfo.getMaxPoolSize());
         setProvider(Constants.GraphDatabaseProvider.SQLG);
         setUuidPropertyName(uuidPropertyName);
         graph = SqlgGraph.open(config);

diff --git a/java/registry/src/main/resources/application.yml.sample b/java/registry/src/main/resources/application.yml.sample
@@ -116,6 +116,7 @@ database:
 
       username: ${connectionInfo_username:postgres}
       password: ${connectionInfo_password:postgres}
+      maxPoolSize: ${connectionInfo_maxPoolSize:100}
 
       # Any other shard information follows...
     #-