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/18 09:05:25 UTC
[incubator-eventmesh] branch storage-api updated: [ISSUE #1392] connector-storage-jdbc sql Basic capabilities
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 eb1b205f [ISSUE #1392] connector-storage-jdbc sql Basic capabilities
new 0cad322c Merge pull request #1643 from githublaohu/jdbc-connector-storage
eb1b205f is described below
commit eb1b205ffef4168c5e806adc805498b486414c8f
Author: githublaohu <23...@qq.com>
AuthorDate: Tue Oct 18 16:55:22 2022 +0800
[ISSUE #1392] connector-storage-jdbc sql Basic capabilities
---
.../connector/storage/jdbc/SQL/BaseSQL.java} | 13 ++++++++-----
.../connector/storage/jdbc/SQL/BaseSQLOperation.java | 2 +-
2 files changed, 9 insertions(+), 6 deletions(-)
diff --git a/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventesh/connector/storage/jdbc/SQL/BaseSQLOperation.java b/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/SQL/BaseSQL.java
similarity index 77%
copy from eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventesh/connector/storage/jdbc/SQL/BaseSQLOperation.java
copy to eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/SQL/BaseSQL.java
index 66f0664b..2f95b0d2 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventesh/connector/storage/jdbc/SQL/BaseSQLOperation.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/SQL/BaseSQL.java
@@ -15,13 +15,16 @@
* limitations under the License.
*/
-package org.apache.eventesh.connector.storage.jdbc.SQL;
+package org.apache.eventmesh.connector.storage.jdbc.SQL;
-public interface BaseSQLOperation {
+import lombok.Data;
- public String createDatabases();
+@Data
+public class BaseSQL {
- public String queryConsumerGroupTableSQL();
+ private String createDatabases;
- public String queryCloudEventTablesSQL();
+ private String queryConsumerGroupTableSQL;
+
+ private String queryCloudEventTablesSQL;
}
diff --git a/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventesh/connector/storage/jdbc/SQL/BaseSQLOperation.java b/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/SQL/BaseSQLOperation.java
similarity index 94%
rename from eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventesh/connector/storage/jdbc/SQL/BaseSQLOperation.java
rename to eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/SQL/BaseSQLOperation.java
index 66f0664b..9eeb4804 100644
--- a/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventesh/connector/storage/jdbc/SQL/BaseSQLOperation.java
+++ b/eventmesh-connector-plugin/eventmesh-connector-storage-jdbc/src/main/java/org/apache/eventmesh/connector/storage/jdbc/SQL/BaseSQLOperation.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.eventesh.connector.storage.jdbc.SQL;
+package org.apache.eventmesh.connector.storage.jdbc.SQL;
public interface BaseSQLOperation {
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@eventmesh.apache.org
For additional commands, e-mail: commits-help@eventmesh.apache.org