[LS][bi-1.6.x] Onboard "CDC for PostgreSQL" onto BI

service-model-generator/modules/service-model-generator-ls-extension/src/main/java/io/ballerina/servicemodelgenerator/extension/builder/FunctionBuilderRouter.java

@@ -32,6 +32,7 @@
 import io.ballerina.servicemodelgenerator.extension.builder.function.KafkaFunctionBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.function.McpFunctionBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.function.MssqlCdcFunctionBuilder;
+import io.ballerina.servicemodelgenerator.extension.builder.function.PostgresqlCdcFunctionBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.function.RabbitMQFunctionBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.function.SolaceFunctionBuilder;
 import io.ballerina.servicemodelgenerator.extension.model.Codedata;
@@ -57,6 +58,7 @@
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.MCP;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.MSSQL;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.OBJECT_METHOD;
+import static io.ballerina.servicemodelgenerator.extension.util.Constants.POSTGRESQL;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.RABBITMQ;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.SOLACE;
 import static io.ballerina.servicemodelgenerator.extension.util.ServiceModelUtils.deriveServiceType;
@@ -75,6 +77,7 @@ public class FunctionBuilderRouter {
         put(KAFKA, KafkaFunctionBuilder::new);
         put(SOLACE, SolaceFunctionBuilder::new);
         put(MSSQL, MssqlCdcFunctionBuilder::new);
+        put(POSTGRESQL, PostgresqlCdcFunctionBuilder::new);
     }};
 
     private static NodeBuilder<Function> getFunctionBuilder(String protocol) {

service-model-generator/modules/service-model-generator-ls-extension/src/main/java/io/ballerina/servicemodelgenerator/extension/builder/ServiceBuilderRouter.java

@@ -33,6 +33,7 @@
 import io.ballerina.servicemodelgenerator.extension.builder.service.KafkaServiceBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.service.McpServiceBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.service.MssqlCdcServiceBuilder;
+import io.ballerina.servicemodelgenerator.extension.builder.service.PostgresqlCdcServiceBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.service.RabbitMQServiceBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.service.SolaceServiceBuilder;
 import io.ballerina.servicemodelgenerator.extension.builder.service.TCPServiceBuilder;
@@ -65,6 +66,7 @@
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.KAFKA;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.MCP;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.MSSQL;
+import static io.ballerina.servicemodelgenerator.extension.util.Constants.POSTGRESQL;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.RABBITMQ;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.SOLACE;
 import static io.ballerina.servicemodelgenerator.extension.util.Constants.TCP;
@@ -88,6 +90,7 @@ public class ServiceBuilderRouter {
         put(ASB, AsbServiceBuilder::new);
         put(SOLACE, SolaceServiceBuilder::new);
         put(MSSQL, MssqlCdcServiceBuilder::new);
+        put(POSTGRESQL, PostgresqlCdcServiceBuilder::new);
         put(FTP, FTPServiceBuilder::new);
     }};
 

service-model-generator/modules/service-model-generator-ls-extension/src/main/java/io/ballerina/servicemodelgenerator/extension/builder/function/PostgresqlCdcFunctionBuilder.java

@@ -0,0 +1,106 @@
+/*
+ *  Copyright (c) 2026, WSO2 LLC. (http://www.wso2.com)
+ *
+ *  WSO2 LLC. licenses this file to you under the Apache License,
+ *  Version 2.0 (the "License"); you may not use this file except
+ *  in compliance with the License.
+ *  You may obtain a copy of the License at
+ *
+ *    http://www.apache.org/licenses/LICENSE-2.0
+ *
+ *  Unless required by applicable law or agreed to in writing,
+ *  software distributed under the License is distributed on an
+ *  "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ *  KIND, either express or implied.  See the License for the
+ *  specific language governing permissions and limitations
+ *  under the License.
+ */
+
+package io.ballerina.servicemodelgenerator.extension.builder.function;
+
+import io.ballerina.servicemodelgenerator.extension.model.Function;
+import io.ballerina.servicemodelgenerator.extension.model.Parameter;
+import io.ballerina.servicemodelgenerator.extension.model.context.AddModelContext;
+import io.ballerina.servicemodelgenerator.extension.model.context.UpdateModelContext;
+import org.eclipse.lsp4j.TextEdit;
+
+import java.util.List;
+import java.util.Map;
+
+import static io.ballerina.servicemodelgenerator.extension.builder.service.PostgresqlCdcServiceBuilder.AFTER_ENTRY_FIELD;
+import static io.ballerina.servicemodelgenerator.extension.builder.service.PostgresqlCdcServiceBuilder.BEFORE_ENTRY_FIELD;
+import static io.ballerina.servicemodelgenerator.extension.util.Constants.DATA_BINDING;
+import static io.ballerina.servicemodelgenerator.extension.util.Constants.POSTGRESQL;
+
+/**
+ * Represents the PostgreSQL CDC function builder of the service model generator. Handles special-case logic for
+ * onUpdate function which has two databinding parameters (beforeEntry and afterEntry) that must share the same type.
+ *
+ * @since 1.6.0
+ */
+public final class PostgresqlCdcFunctionBuilder extends AbstractFunctionBuilder {
+
+    private static final String ON_UPDATE_FUNCTION = "onUpdate";
+
+    @Override
+    public Map<String, List<TextEdit>> addModel(AddModelContext context) throws Exception {
+        Function function = context.function();
+        if (ON_UPDATE_FUNCTION.equals(function.getName().getValue())) {
+            expandDatabindingParams(function);
+        }
+
+        // Call parent which will generate code with expanded parameters
+        return super.addModel(context);
+    }
+
+    @Override
+    public Map<String, List<TextEdit>> updateModel(UpdateModelContext context) {
+        Function function = context.function();
+        if (ON_UPDATE_FUNCTION.equals(function.getName().getValue())) {
+            expandDatabindingParams(function);
+        }
+
+        // Call parent which will generate code with expanded parameters
+        return super.updateModel(context);
+    }
+
+    /**
+     * Expands the single databinding parameter (afterEntry) to two parameters (beforeEntry and afterEntry) for the
+     * onUpdate function. This is called before code generation to ensure both parameters are present in the generated
+     * signature with the same type.
+     * <p>
+     * This method looks for the case where afterEntry is enabled (visible in UI) and beforeEntry is disabled (hidden
+     * from UI). It then enables beforeEntry and copies the type from afterEntry.
+     * </p>
+     *
+     * @param function The onUpdate function to process
+     */
+    private void expandDatabindingParams(Function function) {
+        List<Parameter> parameters = function.getParameters();
+        Parameter beforeEntry = null;
+        Parameter afterEntry = null;
+
+        for (Parameter param : parameters) {
+            if (!DATA_BINDING.equals(param.getKind())) {
+                continue;
+            }
+            String paramName = param.getName().getValue();
+            if (BEFORE_ENTRY_FIELD.equals(paramName)) {
+                beforeEntry = param;
+            } else if (AFTER_ENTRY_FIELD.equals(paramName)) {
+                afterEntry = param;
+            }
+        }
+
+        if (beforeEntry != null && afterEntry != null && !beforeEntry.isEnabled() && afterEntry.isEnabled()) {
+            beforeEntry.setEnabled(true);
+            beforeEntry.getType().setValue(afterEntry.getType().getValue());
+        }
+
+    }
+
+    @Override
+    public String kind() {
+        return POSTGRESQL;
+    }
+}