You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@eventmesh.apache.org by mi...@apache.org on 2022/10/20 03:16:15 UTC
[incubator-eventmesh] branch storage-api updated: [ISSUE #1397] add connector-storage-jdbc ResultSetTransform realization
This is an automated email from the ASF dual-hosted git repository.
mikexue pushed a commit to branch storage-api
in repository https://gitbox.apache.org/repos/asf/incubator-eventmesh.git
The following commit(s) were added to refs/heads/storage-api by this push:
new 88cc232c [ISSUE #1397] add connector-storage-jdbc ResultSetTransform realization
new 5d52f0fb Merge pull request #1673 from githublaohu/jdbc-connector-storage
88cc232c is described below
commit 88cc232cf8074c0af59fbae234291c2784493fee
Author: githublaohu <23...@qq.com>
AuthorDate: Thu Oct 20 11:06:54 2022 +0800
[ISSUE #1397] add connector-storage-jdbc ResultSetTransform realization
---
.../api/connector/storage/data/CloudEventInfo.java | 31 +++++++++------
.../api/connector/storage/data/TopicInfo.java | 5 +++
.../storage/jdbc/ResultSetTransformUtils.java | 45 ++++++++++++++++++++++
3 files changed, 70 insertions(+), 11 deletions(-)
diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventInfo.java b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventInfo.java
index c017b33b..fe475713 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventInfo.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/CloudEventInfo.java
@@ -14,6 +14,7 @@
* See the License for the specific language governing permissions and
* limitations under the License.
*/
+
package org.apache.eventmesh.api.connector.storage.data;
import java.time.LocalDateTime;
@@ -25,32 +26,40 @@ import lombok.Data;
@Data
public class CloudEventInfo {
+ private Long cloudEventInfoId;
+
private Long cloudEventId;
- private Long id;
+ private String cloudEventTopic;
+
+ private String cloudEventStorageNodeAdress;
private String cloudEventType;
- private String producerGroupName;
+ private String cloudEventProducerGroupName;
- private LocalDateTime createTime;
+ private String cloudEventSource;
- private Set<String> eventTag;
+ private String cloudEventContentType;
- private Map<String, String> eventExtensions;
+ private Set<String> cloudEventEventTag;
- private String eventData;
+ private Map<String, String> cloudEventExtensions;
- private String replyData;
+ private String cloudEventData;
- private Map<String, String> consumeLocation;
+ private String cloudEventReplyData;
+
+ private Map<String, String> cloudEventConsumeLocation;
private CloudEventStateEnums cloudEventState;
- private CloudEventStateEnums replyState;
+ private CloudEventStateEnums cloudEventReplyState;
+
+ private LocalDateTime cloudEventCreateTime;
- private LocalDateTime updateTime;
+ private LocalDateTime cloudEventConsumeTime;
- private LocalDateTime consumeTime;
+ private LocalDateTime cloudEventOffsetTime;
}
diff --git a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/TopicInfo.java b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/TopicInfo.java
index ec1bf421..310af9f9 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/TopicInfo.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-api/src/main/java/org/apache/eventmesh/api/connector/storage/data/TopicInfo.java
@@ -17,11 +17,14 @@
package org.apache.eventmesh.api.connector.storage.data;
+import lombok.Data;
+
/**
* {tablename-queue}
*
* @author laohu
*/
+@Data
public class TopicInfo {
private String topicName;
@@ -34,4 +37,6 @@ public class TopicInfo {
private boolean order = false;
+ private Long currentId;
+
}
diff --git a/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/ResultSetTransformUtils.java b/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/ResultSetTransformUtils.java
new file mode 100644
index 00000000..ffceb76e
--- /dev/null
+++ b/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/ResultSetTransformUtils.java
@@ -0,0 +1,45 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one or more
+ * contributor license agreements. See the NOTICE file distributed with
+ * this work for additional information regarding copyright ownership.
+ * The ASF licenses this file to You under the Apache License, Version 2.0
+ * (the "License"); you may not use this file except in compliance with
+ * the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package org.apache.eventmesh.connector.storage.jdbc;
+
+import org.apache.eventmesh.api.connector.storage.data.CloudEventInfo;
+import org.apache.eventmesh.api.connector.storage.data.ConsumerGroupInfo;
+import org.apache.eventmesh.api.connector.storage.data.TopicInfo;
+
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+public class ResultSetTransformUtils {
+
+ public static String transformTableName(ResultSet resultSet) throws SQLException {
+ return resultSet.getString(1);
+ }
+
+ public static ConsumerGroupInfo transformConsumerGroup(ResultSet resultSet) {
+ return new ConsumerGroupInfo();
+ }
+
+ public static CloudEventInfo transformCloudEvent(ResultSet resultSet) {
+ return null;
+ }
+
+
+ public static TopicInfo transformTopicInfo(ResultSet resultSet) {
+ return null;
+ }
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org