refactor(db): move r2dbc store adapters into per-domain postgres modules

Relocate all 64 R2dbc*Store implementations from dc3-common-{auth,manager,data,agentic} repositories into new dc3-db-postgres-{auth,manager,data,agentic} adapter modules (package io.github.pnoker.db.postgres.<domain>), each registered through its own AutoConfiguration. Reactive*Store ports and filter types stay in the business modules; services are untouched. Drops stale MyBatis wording from AGENTS.md and init runner javadoc.
This commit is contained in:
pnoker
2026-09-03 09:01:32 +08:00
parent 66aab58f20
commit 7fde111341
87 changed files with 618 additions and 69 deletions
+1 -2
View File
@@ -179,8 +179,7 @@ CRUD-shaped names reflect result cardinality across Service, Controller, Facade,
| return many | `listXxx(...)` | `/list_xxx` | `ListXxx` |
- Base CRUD comes from `BaseService<B,Q>`: `add`, `delete`, `update`, `getById`, and `list(Q)`.
- Reserve `select*` for raw Mapper/Manager persistence operations.
- Reserve MyBatis-Plus `remove*` for the Manager layer; business deletion uses `delete*`.
- Reserve `select*` for raw store persistence operations.
- Do not introduce `find*`, `query*`, or `fetch*` as primary CRUD verbs.
- HTTP paths are lowercase snake_case and mirror Java names.
- Use `getStatusByPage(Q)` for status maps and `dispatchRead`/`dispatchWrite` for command dispatch, following existing
+3
View File
@@ -39,6 +39,9 @@
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency><dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-agentic</artifactId>
</dependency>
<!-- Agentic domain logic (controllers, tools, config) -->
<dependency>
+3
View File
@@ -37,6 +37,9 @@
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency><dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-auth</artifactId>
</dependency>
<!-- DC3 Common Related -->
<dependency>
+3
View File
@@ -38,6 +38,9 @@
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency><dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-data</artifactId>
</dependency>
<!-- DC3 Common Related -->
<dependency>
+3
View File
@@ -38,6 +38,9 @@
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency><dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-manager</artifactId>
</dependency>
<!-- DC3 Common Related -->
<dependency>
+12
View File
@@ -37,6 +37,18 @@
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency><dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-auth</artifactId>
</dependency><dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-manager</artifactId>
</dependency><dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-data</artifactId>
</dependency><dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-agentic</artifactId>
</dependency>
<!-- DC3 Common Related -->
<dependency>
@@ -28,7 +28,7 @@ import org.springframework.context.annotation.FilterType;
/**
* Authentication Initialization Runner for DC3 IoT Platform. This class handles
* authentication initialization tasks during application startup, configuring component
* scanning for authentication-related classes and MyBatis mappers.
* scanning for authentication-related classes.
*
* @author pnoker
* @since 2016.10.1
@@ -29,7 +29,7 @@ import org.springframework.scheduling.annotation.EnableAsync;
/**
* Manager Initialization Runner for DC3 IoT Platform. This class is responsible for
* initializing manager-related components and services during application startup. It
* configures component scanning for manager packages and sets up MyBatis mapper scanning.
* configures component scanning for manager packages.
*
* @author pnoker
* @since 2016.10.1
+48
View File
@@ -0,0 +1,48 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright 2016-present the IoT DC3 original author or 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.
-->
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db</artifactId>
<version>2026.5.22</version>
</parent>
<artifactId>dc3-db-postgres-agentic</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-core</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-common-agentic</artifactId>
</dependency>
</dependencies>
</project>
@@ -0,0 +1,35 @@
/*
* Copyright 2016-present the IoT DC3 original author or authors.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.db.postgres.agentic;
import io.github.pnoker.db.r2dbc.core.dialect.R2dbcDialect;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.r2dbc.core.DatabaseClient;
/**
* Registers the PostgreSQL {@literal R2DBC} store adapters for the Agentic domain.
* The stores implement the Agentic {@code Reactive*Store} ports declared by
* {@code dc3-common-agentic}; exactly one engine adapter must be on the
* classpath, enforced by the runtime dialect cardinality guard.
*/
@AutoConfiguration
@ConditionalOnClass({DatabaseClient.class, R2dbcDialect.class})
@ComponentScan(basePackages = "io.github.pnoker.db.postgres.agentic")
public class AgenticPostgresStoresConfiguration {
}
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.agentic.repository;
package io.github.pnoker.db.postgres.agentic;
import io.github.pnoker.common.agentic.repository.ReactiveActionStore;
import io.github.pnoker.common.agentic.entity.bo.ActionBO;
import io.github.pnoker.common.entity.common.RequestHeader;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.agentic.repository;
package io.github.pnoker.db.postgres.agentic;
import io.github.pnoker.common.agentic.repository.ReactiveAttachmentStore;
import io.github.pnoker.common.agentic.entity.bo.AttachmentBO;
import io.github.pnoker.common.entity.common.RequestHeader;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.agentic.repository;
package io.github.pnoker.db.postgres.agentic;
import io.github.pnoker.common.agentic.repository.ReactiveMessageStore;
import io.github.pnoker.common.agentic.entity.bo.MessageBO;
import io.github.pnoker.common.agentic.entity.model.AgenticMessageContent;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.agentic.repository;
package io.github.pnoker.db.postgres.agentic;
import io.github.pnoker.common.agentic.repository.ReactiveModelConfigStore;
import io.github.pnoker.common.agentic.entity.bo.ModelConfigBO;
import io.github.pnoker.common.entity.common.RequestHeader;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.agentic.repository;
package io.github.pnoker.db.postgres.agentic;
import io.github.pnoker.common.agentic.repository.ReactiveModelProviderStore;
import io.github.pnoker.common.agentic.entity.bo.ModelProviderBO;
import io.github.pnoker.common.entity.common.RequestHeader;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.agentic.repository;
package io.github.pnoker.db.postgres.agentic;
import io.github.pnoker.common.agentic.repository.ReactiveSessionStore;
import io.github.pnoker.common.agentic.entity.bo.SessionBO;
import io.github.pnoker.common.agentic.entity.model.SessionExt;
@@ -0,0 +1 @@
io.github.pnoker.db.postgres.agentic.AgenticPostgresStoresConfiguration
+48
View File
@@ -0,0 +1,48 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright 2016-present the IoT DC3 original author or 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.
-->
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db</artifactId>
<version>2026.5.22</version>
</parent>
<artifactId>dc3-db-postgres-auth</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-core</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-common-auth</artifactId>
</dependency>
</dependencies>
</project>
@@ -0,0 +1,35 @@
/*
* Copyright 2016-present the IoT DC3 original author or authors.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.db.r2dbc.core.dialect.R2dbcDialect;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.r2dbc.core.DatabaseClient;
/**
* Registers the PostgreSQL {@literal R2DBC} store adapters for the Auth domain.
* The stores implement the Auth {@code Reactive*Store} ports declared by
* {@code dc3-common-auth}; exactly one engine adapter must be on the
* classpath, enforced by the runtime dialect cardinality guard.
*/
@AutoConfiguration
@ConditionalOnClass({DatabaseClient.class, R2dbcDialect.class})
@ComponentScan(basePackages = "io.github.pnoker.db.postgres.auth")
public class AuthPostgresStoresConfiguration {
}
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ApiFilter;
import io.github.pnoker.common.auth.repository.ReactiveApiStore;
import io.github.pnoker.common.auth.entity.bo.ApiBO;
import io.github.pnoker.common.auth.entity.model.ApiDO;
@@ -14,7 +14,11 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.IdentityAuditLogFilter;
import io.github.pnoker.common.auth.repository.ReactiveAuditLogQueryStore;
import io.github.pnoker.common.auth.repository.ReactiveAuditLogStore;
import io.github.pnoker.common.auth.entity.bo.IdentityAuditLogBO;
import io.github.pnoker.common.auth.entity.model.IdentityAuditLogDO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.LocalCredentialFilter;
import io.github.pnoker.common.auth.repository.ReactiveLocalCredentialStore;
import io.github.pnoker.common.auth.entity.model.LocalCredentialDO;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveMcpCatalogStore;
import io.github.pnoker.common.auth.entity.oauth.McpAuditCommand;
import io.github.pnoker.common.auth.entity.oauth.McpToolRecord;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveOAuthMcpStore;
import io.github.pnoker.common.auth.entity.oauth.McpAuditCommand;
import io.github.pnoker.common.auth.entity.oauth.McpConnectionRecord;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.MenuFilter;
import io.github.pnoker.common.auth.repository.ReactiveMenuStore;
import io.github.pnoker.common.auth.entity.bo.MenuBO;
import io.github.pnoker.common.auth.entity.model.MenuDO;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactivePermissionStore;
import lombok.RequiredArgsConstructor;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.PrincipalFilter;
import io.github.pnoker.common.auth.repository.ReactivePrincipalStore;
import io.github.pnoker.common.auth.entity.model.PrincipalDO;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveResourceLookupStore;
import io.github.pnoker.common.auth.entity.model.ResourceDO;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveResourceRegistryStore;
import io.github.pnoker.common.auth.entity.model.ApiDO;
import io.github.pnoker.common.auth.entity.model.ResourceDO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveResourceStore;
import io.github.pnoker.common.auth.repository.ResourceFilter;
import io.github.pnoker.common.auth.entity.bo.ResourceBO;
import io.github.pnoker.common.auth.entity.model.ResourceDO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveRolePrincipalBindStore;
import io.github.pnoker.common.auth.repository.RolePrincipalBindFilter;
import io.github.pnoker.common.auth.entity.bo.RolePrincipalBindBO;
import io.github.pnoker.common.auth.entity.model.RolePrincipalBindDO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveRoleResourceBindStore;
import io.github.pnoker.common.auth.repository.RoleResourceBindFilter;
import io.github.pnoker.common.auth.entity.bo.RoleResourceBindBO;
import io.github.pnoker.common.auth.entity.model.RoleResourceBindDO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveRoleStore;
import io.github.pnoker.common.auth.repository.RoleFilter;
import io.github.pnoker.common.auth.entity.bo.RoleBO;
import io.github.pnoker.common.auth.entity.model.RoleDO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveServiceAccountStore;
import io.github.pnoker.common.auth.repository.ServiceAccountFilter;
import io.github.pnoker.common.auth.entity.bo.ServiceAccountBO;
import io.github.pnoker.common.auth.entity.model.ServiceAccountDO;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveTenantDictionaryStore;
import io.github.pnoker.common.auth.entity.model.TenantDO;
import lombok.RequiredArgsConstructor;
@@ -14,7 +14,11 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveTenantMembershipCommandStore;
import io.github.pnoker.common.auth.repository.ReactiveTenantMembershipStore;
import io.github.pnoker.common.auth.repository.TenantMembershipFilter;
import io.github.pnoker.common.auth.entity.model.TenantMembershipDO;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveTenantStore;
import io.github.pnoker.common.auth.repository.TenantFilter;
import io.github.pnoker.common.auth.entity.model.TenantDO;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.auth.repository;
package io.github.pnoker.db.postgres.auth;
import io.github.pnoker.common.auth.repository.ReactiveUserStore;
import io.github.pnoker.common.auth.repository.UserFilter;
import io.github.pnoker.common.auth.entity.model.UserDO;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -0,0 +1 @@
io.github.pnoker.db.postgres.auth.AuthPostgresStoresConfiguration
+48
View File
@@ -0,0 +1,48 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright 2016-present the IoT DC3 original author or 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.
-->
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db</artifactId>
<version>2026.5.22</version>
</parent>
<artifactId>dc3-db-postgres-data</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-core</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-common-data</artifactId>
</dependency>
</dependencies>
</project>
@@ -0,0 +1,35 @@
/*
* Copyright 2016-present the IoT DC3 original author or authors.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.db.r2dbc.core.dialect.R2dbcDialect;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.r2dbc.core.DatabaseClient;
/**
* Registers the PostgreSQL {@literal R2DBC} store adapters for the Data domain.
* The stores implement the Data {@code Reactive*Store} ports declared by
* {@code dc3-common-data}; exactly one engine adapter must be on the
* classpath, enforced by the runtime dialect cardinality guard.
*/
@AutoConfiguration
@ConditionalOnClass({DatabaseClient.class, R2dbcDialect.class})
@ComponentScan(basePackages = "io.github.pnoker.db.postgres.data")
public class DataPostgresStoresConfiguration {
}
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveAlertAnalyticsStore;
import io.github.pnoker.common.data.entity.bo.dashboard.ActivityCellRow;
import io.github.pnoker.common.data.entity.bo.dashboard.AgingBucketRow;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveAlertStore;
import io.github.pnoker.common.data.entity.bo.dashboard.AlertItemRow;
import io.github.pnoker.db.r2dbc.core.dialect.R2dbcDialect;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveCommandHistoryStore;
import io.github.pnoker.common.data.entity.model.CommandHistoryDO;
import io.github.pnoker.common.enums.CommandHistorySourceEnum;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveEntityAlarmStore;
import io.github.pnoker.common.data.entity.model.EntityAlarmDO;
import io.github.pnoker.common.utils.JsonUtil;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveEntityStateStore;
import io.github.pnoker.common.enums.EntityStatusEnum;
import io.github.pnoker.common.enums.EntityTypeEnum;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveEventHistoryStore;
import io.github.pnoker.common.data.entity.model.EventHistoryDO;
import io.github.pnoker.common.utils.UuidV7;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveNotifyAdminStore;
import io.github.pnoker.common.data.entity.model.MessageDO;
import io.github.pnoker.common.data.entity.model.NotifyChannelBindDO;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveNotifyConfigStore;
import io.github.pnoker.common.data.entity.bo.MessageBO;
import io.github.pnoker.common.data.entity.bo.NotifyBO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.NotifyHistoryInsertResult;
import io.github.pnoker.common.data.repository.ReactiveNotifyHistoryStore;
import io.github.pnoker.common.data.entity.model.NotifyHistoryDO;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactivePointCommandContext;
import io.github.pnoker.common.enums.DriverTypeEnum;
import io.github.pnoker.common.enums.EnableFlagEnum;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactivePointCommandStore;
import io.github.pnoker.common.data.entity.model.PointCommandHistoryDO;
import io.github.pnoker.common.enums.PointCommandSourceEnum;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactivePointValueIngestOutbox;
import io.github.pnoker.common.data.entity.model.PointValueDO;
import io.github.pnoker.db.r2dbc.core.dialect.R2dbcDialect;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactivePointValueLatestStore;
import io.github.pnoker.common.data.entity.model.PointValueDO;
import io.github.pnoker.db.r2dbc.core.dialect.R2dbcDialect;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveRuleStateLookup;
import lombok.RequiredArgsConstructor;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveRuleStateStore;
import io.github.pnoker.common.data.entity.model.RuleStateDO;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveRuleStore;
import io.github.pnoker.common.data.entity.bo.RuleBO;
import io.github.pnoker.common.data.entity.builder.RuleBuilder;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.data.repository;
package io.github.pnoker.db.postgres.data;
import io.github.pnoker.common.data.repository.ReactiveTsdbStore;
import io.github.pnoker.common.tsdb.model.TsdbModel.AggregateFunction;
import io.github.pnoker.common.tsdb.model.TsdbModel.BucketAggregate;
@@ -0,0 +1 @@
io.github.pnoker.db.postgres.data.DataPostgresStoresConfiguration
+48
View File
@@ -0,0 +1,48 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
~ Copyright 2016-present the IoT DC3 original author or 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.
-->
<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns="http://maven.apache.org/POM/4.0.0"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db</artifactId>
<version>2026.5.22</version>
</parent>
<artifactId>dc3-db-postgres-manager</artifactId>
<name>${project.artifactId}</name>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-r2dbc</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-core</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-common-manager</artifactId>
</dependency>
</dependencies>
</project>
@@ -0,0 +1,35 @@
/*
* Copyright 2016-present the IoT DC3 original author or authors.
*
* This program is free software: you can redistribute it and/or modify
* it under the terms of the GNU Affero General Public License as
* published by the Free Software Foundation, either version 3 of the
* License, or (at your option) any later version.
*
* This program is distributed in the hope that it will be useful,
* but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
* GNU Affero General Public License for more details.
*
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.db.r2dbc.core.dialect.R2dbcDialect;
import org.springframework.boot.autoconfigure.AutoConfiguration;
import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.r2dbc.core.DatabaseClient;
/**
* Registers the PostgreSQL {@literal R2DBC} store adapters for the Manager domain.
* The stores implement the Manager {@code Reactive*Store} ports declared by
* {@code dc3-common-manager}; exactly one engine adapter must be on the
* classpath, enforced by the runtime dialect cardinality guard.
*/
@AutoConfiguration
@ConditionalOnClass({DatabaseClient.class, R2dbcDialect.class})
@ComponentScan(basePackages = "io.github.pnoker.db.postgres.manager")
public class ManagerPostgresStoresConfiguration {
}
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.CommandAttributeConfigFilter;
import io.github.pnoker.common.manager.repository.ReactiveCommandAttributeConfigStore;
import io.github.pnoker.common.entity.ext.JsonExt;
import io.github.pnoker.common.enums.EnableFlagEnum;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.CommandAttributeFilter;
import io.github.pnoker.common.manager.repository.ReactiveCommandAttributeStore;
import io.github.pnoker.common.entity.ext.CommandAttributeExt;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.CommandParamFilter;
import io.github.pnoker.common.manager.repository.ReactiveCommandParamStore;
import io.github.pnoker.common.entity.ext.CommandParamExt;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.CommandFilter;
import io.github.pnoker.common.manager.repository.ReactiveCommandStore;
import io.github.pnoker.common.entity.ext.CommandExt;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.ReactiveDashboardStore;
import io.github.pnoker.common.manager.entity.bo.dashboard.BucketRow;
import io.github.pnoker.common.manager.entity.bo.dashboard.DailyGrowthRow;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.ReactiveDeviceImportJobStore;
import io.github.pnoker.common.manager.entity.operation.DeviceImportJob;
import io.github.pnoker.db.r2dbc.core.dialect.R2dbcDialect;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.DeviceFilter;
import io.github.pnoker.common.manager.repository.ReactiveDeviceStore;
import io.github.pnoker.common.entity.ext.DeviceExt;
import io.github.pnoker.common.enums.EnableFlagEnum;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.DriverAttributeConfigFilter;
import io.github.pnoker.common.manager.repository.ReactiveDriverAttributeConfigStore;
import io.github.pnoker.common.entity.ext.JsonExt;
import io.github.pnoker.common.enums.EnableFlagEnum;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.DriverAttributeFilter;
import io.github.pnoker.common.manager.repository.ReactiveDriverAttributeStore;
import io.github.pnoker.common.entity.ext.DriverAttributeExt;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,9 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.ReactiveDriverLeaseStore;
import io.github.pnoker.common.manager.entity.model.DeviceLeaseDO;
import io.github.pnoker.common.manager.entity.model.DriverLeaseStateDO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.DriverFilter;
import io.github.pnoker.common.manager.repository.ReactiveDriverStore;
import io.github.pnoker.common.entity.ext.DriverExt;
import io.github.pnoker.common.enums.DriverTypeEnum;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.EventAttributeConfigFilter;
import io.github.pnoker.common.manager.repository.ReactiveEventAttributeConfigStore;
import io.github.pnoker.common.entity.ext.JsonExt;
import io.github.pnoker.common.enums.EnableFlagEnum;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.EventAttributeFilter;
import io.github.pnoker.common.manager.repository.ReactiveEventAttributeStore;
import io.github.pnoker.common.entity.ext.EventAttributeExt;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.EventParamFilter;
import io.github.pnoker.common.manager.repository.ReactiveEventParamStore;
import io.github.pnoker.common.entity.ext.EventParamExt;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.EventFilter;
import io.github.pnoker.common.manager.repository.ReactiveEventStore;
import io.github.pnoker.common.entity.ext.EventExt;
import io.github.pnoker.common.entity.ext.JsonExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.BindingFilter;
import io.github.pnoker.common.manager.repository.ReactiveGroupBindStore;
import io.github.pnoker.common.enums.EntityTypeEnum;
import io.github.pnoker.common.manager.entity.bo.GroupBindBO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.GroupFilter;
import io.github.pnoker.common.manager.repository.ReactiveGroupStore;
import io.github.pnoker.common.enums.EnableFlagEnum;
import io.github.pnoker.common.enums.EntityTypeEnum;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.BindingFilter;
import io.github.pnoker.common.manager.repository.ReactiveLabelBindStore;
import io.github.pnoker.common.enums.EntityTypeEnum;
import io.github.pnoker.common.manager.entity.bo.LabelBindBO;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.LabelFilter;
import io.github.pnoker.common.manager.repository.ReactiveLabelStore;
import io.github.pnoker.common.enums.EnableFlagEnum;
import io.github.pnoker.common.enums.EntityTypeEnum;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.PointAttributeConfigFilter;
import io.github.pnoker.common.manager.repository.ReactivePointAttributeConfigStore;
import io.github.pnoker.common.entity.ext.JsonExt;
import io.github.pnoker.common.enums.EnableFlagEnum;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.PointAttributeFilter;
import io.github.pnoker.common.manager.repository.ReactivePointAttributeStore;
import io.github.pnoker.common.entity.ext.JsonExt;
import io.github.pnoker.common.entity.ext.PointAttributeExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.PointFilter;
import io.github.pnoker.common.manager.repository.ReactivePointStore;
import io.github.pnoker.common.entity.ext.JsonExt;
import io.github.pnoker.common.entity.ext.PointExt;
@@ -14,7 +14,10 @@
* You should have received a copy of the GNU Affero General Public License
* along with this program. If not, see <https://www.gnu.org/licenses/>.
*/
package io.github.pnoker.common.manager.repository;
package io.github.pnoker.db.postgres.manager;
import io.github.pnoker.common.manager.repository.ProfileFilter;
import io.github.pnoker.common.manager.repository.ReactiveProfileStore;
import io.github.pnoker.common.entity.ext.JsonExt;
import io.github.pnoker.common.entity.ext.ProfileExt;
@@ -0,0 +1 @@
io.github.pnoker.db.postgres.manager.ManagerPostgresStoresConfiguration
+4
View File
@@ -38,6 +38,10 @@
<module>dc3-db-r2dbc-core</module>
<module>dc3-db-r2dbc-runtime</module>
<module>dc3-db-r2dbc-postgres</module>
<module>dc3-db-postgres-auth</module>
<module>dc3-db-postgres-manager</module>
<module>dc3-db-postgres-data</module>
<module>dc3-db-postgres-agentic</module>
<module>dc3-db-tck</module>
</modules>
+20
View File
@@ -723,6 +723,26 @@
<artifactId>dc3-db-r2dbc-core</artifactId>
<version>${dc3.version}</version>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-auth</artifactId>
<version>${dc3.version}</version>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-manager</artifactId>
<version>${dc3.version}</version>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-data</artifactId>
<version>${dc3.version}</version>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-postgres-agentic</artifactId>
<version>${dc3.version}</version>
</dependency>
<dependency>
<groupId>io.github.pnoker</groupId>
<artifactId>dc3-db-r2dbc-runtime</artifactId>