repo-sqale: added ConnectorHostSqlTransformer, finished mapping

Evolveum · Mar 15, 2021 · 4f43657 · 4f43657
1 parent dda0170
commit 4f43657
Show file tree

Hide file tree

Showing 4 changed files with 40 additions and 12 deletions.
diff --git a/...n/java/com/evolveum/midpoint/repo/sqale/qmodel/connector/ConnectorHostSqlTransformer.java b/...n/java/com/evolveum/midpoint/repo/sqale/qmodel/connector/ConnectorHostSqlTransformer.java
@@ -0,0 +1,34 @@
+/*
+ * Copyright (C) 2010-2021 Evolveum and contributors
+ *
+ * This work is dual-licensed under the Apache License 2.0
+ * and European Union Public License. See LICENSE file for details.
+ */
+package com.evolveum.midpoint.repo.sqale.qmodel.connector;
+
+import org.jetbrains.annotations.NotNull;
+
+import com.evolveum.midpoint.repo.sqale.qmodel.object.ObjectSqlTransformer;
+import com.evolveum.midpoint.repo.sqlbase.JdbcSession;
+import com.evolveum.midpoint.repo.sqlbase.SqlTransformerSupport;
+import com.evolveum.midpoint.xml.ns._public.common.common_3.ConnectorHostType;
+
+public class ConnectorHostSqlTransformer
+        extends ObjectSqlTransformer<ConnectorHostType, QConnectorHost, MConnectorHost> {
+
+    public ConnectorHostSqlTransformer(
+            SqlTransformerSupport transformerSupport, QConnectorHostMapping mapping) {
+        super(transformerSupport, mapping);
+    }
+
+    @Override
+    public @NotNull MConnectorHost toRowObjectWithoutFullObject(
+            ConnectorHostType schemaObject, JdbcSession jdbcSession) {
+        MConnectorHost row = super.toRowObjectWithoutFullObject(schemaObject, jdbcSession);
+
+        row.hostname = schemaObject.getHostname();
+        row.port = schemaObject.getPort();
+
+        return row;
+    }
+}
diff --git a/.../main/java/com/evolveum/midpoint/repo/sqale/qmodel/connector/ConnectorSqlTransformer.java b/.../main/java/com/evolveum/midpoint/repo/sqale/qmodel/connector/ConnectorSqlTransformer.java
@@ -22,7 +22,8 @@ public ConnectorSqlTransformer(
     }
 
     @Override
-    public @NotNull MConnector toRowObjectWithoutFullObject(ConnectorType schemaObject, JdbcSession jdbcSession) {
+    public @NotNull MConnector toRowObjectWithoutFullObject(
+            ConnectorType schemaObject, JdbcSession jdbcSession) {
         MConnector row = super.toRowObjectWithoutFullObject(schemaObject, jdbcSession);
 
         row.connectorBundle = schemaObject.getConnectorBundle();

diff --git a/...rc/main/java/com/evolveum/midpoint/repo/sqale/qmodel/connector/QConnectorHostMapping.java b/...rc/main/java/com/evolveum/midpoint/repo/sqale/qmodel/connector/QConnectorHostMapping.java
@@ -10,15 +10,12 @@
 import static com.evolveum.midpoint.xml.ns._public.common.common_3.ConnectorHostType.F_HOSTNAME;
 import static com.evolveum.midpoint.xml.ns._public.common.common_3.ConnectorHostType.F_PORT;
 
-import com.evolveum.midpoint.repo.sqale.qmodel.object.ObjectSqlTransformer;
-import com.evolveum.midpoint.repo.sqale.qmodel.object.QObject;
 import com.evolveum.midpoint.repo.sqale.qmodel.object.QObjectMapping;
 import com.evolveum.midpoint.repo.sqlbase.SqlTransformerSupport;
 import com.evolveum.midpoint.xml.ns._public.common.common_3.ConnectorHostType;
-import com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType;
 
 /**
- * Mapping between {@link QObject} and {@link ObjectType}.
+ * Mapping between {@link QConnectorHost} and {@link ConnectorHostType}.
  */
 public class QConnectorHostMapping
         extends QObjectMapping<ConnectorHostType, QConnectorHost, MConnectorHost> {
@@ -41,10 +38,8 @@ protected QConnectorHost newAliasInstance(String alias) {
     }
 
     @Override
-    public ObjectSqlTransformer<ConnectorHostType, QConnectorHost, MConnectorHost>
-    createTransformer(SqlTransformerSupport transformerSupport) {
-        // TODO create specific transformer
-        return new ObjectSqlTransformer<>(transformerSupport, this);
+    public ConnectorHostSqlTransformer createTransformer(SqlTransformerSupport transformerSupport) {
+        return new ConnectorHostSqlTransformer(transformerSupport, this);
     }
 
     @Override

diff --git a/...le/src/main/java/com/evolveum/midpoint/repo/sqale/qmodel/connector/QConnectorMapping.java b/...le/src/main/java/com/evolveum/midpoint/repo/sqale/qmodel/connector/QConnectorMapping.java
@@ -10,14 +10,12 @@
 import static com.evolveum.midpoint.xml.ns._public.common.common_3.ConnectorType.*;
 
 import com.evolveum.midpoint.repo.sqale.RefItemFilterProcessor;
-import com.evolveum.midpoint.repo.sqale.qmodel.object.QObject;
 import com.evolveum.midpoint.repo.sqale.qmodel.object.QObjectMapping;
 import com.evolveum.midpoint.repo.sqlbase.SqlTransformerSupport;
 import com.evolveum.midpoint.xml.ns._public.common.common_3.ConnectorType;
-import com.evolveum.midpoint.xml.ns._public.common.common_3.ObjectType;
 
 /**
- * Mapping between {@link QObject} and {@link ObjectType}.
+ * Mapping between {@link QConnector} and {@link ConnectorType}.
  */
 public class QConnectorMapping
         extends QObjectMapping<ConnectorType, QConnector, MConnector> {