Support discriminator multitenancy

Author: dstepanov

data-hibernate-reactive/src/main/java/io/micronaut/data/hibernate/reactive/operations/DefaultHibernateReactiveRepositoryOperations.java

@@ -42,7 +42,6 @@
 import io.micronaut.data.model.runtime.UpdateOperation;
 import io.micronaut.data.operations.reactive.ReactorCriteriaRepositoryOperations;
 import io.micronaut.data.runtime.convert.DataConversionService;
-import io.micronaut.data.runtime.operations.internal.query.BindableParametersPreparedQuery;
 import io.micronaut.transaction.reactive.ReactorReactiveTransactionOperations;
 import jakarta.persistence.EntityGraph;
 import jakarta.persistence.FlushModeType;

data-jdbc/src/test/groovy/io/micronaut/data/jdbc/h2/H2DiscriminatorMultitenancySpec.groovy

@@ -0,0 +1,12 @@
+package io.micronaut.data.jdbc.h2
+
+import io.micronaut.data.tck.tests.AbstractDiscriminatorMultitenancySpec
+
+class H2DiscriminatorMultitenancySpec extends AbstractDiscriminatorMultitenancySpec implements H2TestPropertyProvider {
+
+    @Override
+    Map<String, String> getExtraProperties() {
+        return [accountRepositoryClass: H2AccountRepository.name]
+    }
+
+}

data-jdbc/src/test/groovy/io/micronaut/data/jdbc/mariadb/MariaDiscriminatorMultitenancySpec.groovy

@@ -0,0 +1,13 @@
+package io.micronaut.data.jdbc.mariadb
+
+import io.micronaut.data.jdbc.mysql.MySqlAccountRepository
+import io.micronaut.data.tck.tests.AbstractDiscriminatorMultitenancySpec
+
+class MariaDiscriminatorMultitenancySpec extends AbstractDiscriminatorMultitenancySpec implements MariaTestPropertyProvider {
+
+    @Override
+    Map<String, String> getExtraProperties() {
+        return [accountRepositoryClass: MySqlAccountRepository.name]
+    }
+
+}

data-jdbc/src/test/groovy/io/micronaut/data/jdbc/mysql/MySqlDiscriminatorMultitenancySpec.groovy

@@ -0,0 +1,13 @@
+package io.micronaut.data.jdbc.mysql
+
+
+import io.micronaut.data.tck.tests.AbstractDiscriminatorMultitenancySpec
+
+class MySqlDiscriminatorMultitenancySpec extends AbstractDiscriminatorMultitenancySpec implements MySQLTestPropertyProvider {
+
+    @Override
+    Map<String, String> getExtraProperties() {
+        return [accountRepositoryClass: MySqlAccountRepository.name]
+    }
+
+}

data-jdbc/src/test/groovy/io/micronaut/data/jdbc/oraclexe/OracleXEDiscriminatorMultitenancySpec.groovy

@@ -0,0 +1,13 @@
+package io.micronaut.data.jdbc.oraclexe
+
+
+import io.micronaut.data.tck.tests.AbstractDiscriminatorMultitenancySpec
+
+class OracleXEDiscriminatorMultitenancySpec extends AbstractDiscriminatorMultitenancySpec implements OracleTestPropertyProvider {
+
+    @Override
+    Map<String, String> getExtraProperties() {
+        return [accountRepositoryClass: OracleXEAccountRepository.name]
+    }
+
+}

data-jdbc/src/test/groovy/io/micronaut/data/jdbc/postgres/PostgresDiscriminatorMultitenancySpec.groovy

@@ -0,0 +1,13 @@
+package io.micronaut.data.jdbc.postgres
+
+
+import io.micronaut.data.tck.tests.AbstractDiscriminatorMultitenancySpec
+
+class PostgresDiscriminatorMultitenancySpec extends AbstractDiscriminatorMultitenancySpec implements PostgresTestPropertyProvider {
+
+    @Override
+    Map<String, String> getExtraProperties() {
+        return [accountRepositoryClass: PostgresAccountRepository.name]
+    }
+
+}

data-jdbc/src/test/groovy/io/micronaut/data/jdbc/sqlserver/SqlServerDiscriminatorMultitenancySpec.groovy

@@ -0,0 +1,13 @@
+package io.micronaut.data.jdbc.sqlserver
+
+
+import io.micronaut.data.tck.tests.AbstractDiscriminatorMultitenancySpec
+
+class SqlServerDiscriminatorMultitenancySpec extends AbstractDiscriminatorMultitenancySpec implements MSSQLTestPropertyProvider {
+
+    @Override
+    Map<String, String> getExtraProperties() {
+        return [accountRepositoryClass: MSAccountRepository.name]
+    }
+
+}

data-jdbc/src/test/java/io/micronaut/data/jdbc/h2/H2AccountRepository.java

@@ -0,0 +1,27 @@
+/*
+ * Copyright 2017-2020 original authors
+ *
+ * Licensed 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
+ *
+ * https://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.micronaut.data.jdbc.h2;
+
+import io.micronaut.data.jdbc.annotation.JdbcRepository;
+import io.micronaut.data.model.query.builder.sql.Dialect;
+import io.micronaut.data.repository.CrudRepository;
+import io.micronaut.data.tck.entities.Account;
+import io.micronaut.data.tck.repositories.AccountRepository;
+import io.micronaut.data.tck.repositories.ArraysEntityRepository;
+
+@JdbcRepository(dialect = Dialect.H2)
+public interface H2AccountRepository extends AccountRepository {
+}

data-jdbc/src/test/java/io/micronaut/data/jdbc/mysql/MySqlAccountRepository.java

@@ -0,0 +1,24 @@
+/*
+ * Copyright 2017-2020 original authors
+ *
+ * Licensed 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
+ *
+ * https://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.micronaut.data.jdbc.mysql;
+
+import io.micronaut.data.jdbc.annotation.JdbcRepository;
+import io.micronaut.data.model.query.builder.sql.Dialect;
+import io.micronaut.data.tck.repositories.AccountRepository;
+
+@JdbcRepository(dialect = Dialect.MYSQL)
+public interface MySqlAccountRepository extends AccountRepository {
+}

data-jdbc/src/test/java/io/micronaut/data/jdbc/oraclexe/OracleXEAccountRepository.java

@@ -0,0 +1,24 @@
+/*
+ * Copyright 2017-2020 original authors
+ *
+ * Licensed 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
+ *
+ * https://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.micronaut.data.jdbc.oraclexe;
+
+import io.micronaut.data.jdbc.annotation.JdbcRepository;
+import io.micronaut.data.model.query.builder.sql.Dialect;
+import io.micronaut.data.tck.repositories.AccountRepository;
+
+@JdbcRepository(dialect = Dialect.ORACLE)
+public interface OracleXEAccountRepository extends AccountRepository {
+}