mirror of
https://gitee.com/pnoker/iot-dc3.git
synced 2026-10-31 10:11:49 +08:00
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:
@@ -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
|
||||
|
||||
@@ -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>
|
||||
|
||||
@@ -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>
|
||||
|
||||
@@ -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>
|
||||
|
||||
@@ -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>
|
||||
|
||||
@@ -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>
|
||||
|
||||
+1
-1
@@ -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
|
||||
|
||||
+1
-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
|
||||
|
||||
@@ -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>
|
||||
+35
@@ -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 {
|
||||
}
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+1
@@ -0,0 +1 @@
|
||||
io.github.pnoker.db.postgres.agentic.AgenticPostgresStoresConfiguration
|
||||
@@ -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>
|
||||
+35
@@ -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 {
|
||||
}
|
||||
+4
-1
@@ -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;
|
||||
+5
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+5
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+1
@@ -0,0 +1 @@
|
||||
io.github.pnoker.db.postgres.auth.AuthPostgresStoresConfiguration
|
||||
@@ -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>
|
||||
+35
@@ -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 {
|
||||
}
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+1
@@ -0,0 +1 @@
|
||||
io.github.pnoker.db.postgres.data.DataPostgresStoresConfiguration
|
||||
@@ -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>
|
||||
+35
@@ -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 {
|
||||
}
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+3
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+4
-1
@@ -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;
|
||||
+1
@@ -0,0 +1 @@
|
||||
io.github.pnoker.db.postgres.manager.ManagerPostgresStoresConfiguration
|
||||
@@ -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>
|
||||
|
||||
|
||||
@@ -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>
|
||||
|
||||
Reference in New Issue
Block a user