You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by bo...@apache.org on 2021/06/08 14:04:15 UTC
[incubator-streampipes-extensions] branch dev updated (981c953 ->
d8dc190)
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
from 981c953 [STREAMPIPES-373] Modify output topic of dashboard sink
add d1a4ff4 [STREAMPIPES-320] Rework SQL clients
add e1c550b adaptions to changes in ObjectDetection
add c31ab87 [STREANPIPES-334] add UI option for label name
add a725730 [STREANPIPES-334] implement changes for Buffer Labeler as well
add 280d390 [STREAMPIPES-320] create enum for supported sql engines
add 9989f6e [STREAMPIPES-320] create class for data types of different SupportedSQLEngines
add 7d958fe [STREAMPIPES-320] renaming
add d1bf8bc [STREAMPIPES-320] model supported data base engines
add 74f2366 [STREAMPIPES-320] model data types of the several db engines
add 32fb1f3 [STREAMPIPES-320] create separate class for ParameterInformation
add a5451c8 [STREAMPIPES-320] create util class for statements
add 4f629e2 [STREAMPIPES-320] adapt JdbcClient to new model
add fd450ab [STREAMPIPES-320] adapt sinks to changes in JdbcClient
add 47a9ecb [STREAMPIPES-320] remove DataTypeNames.java
add b1bb5b4 [STREAMPIPES-320] change from EventProperties to EventSchema
add b9fb58b [STREAMPIPES-320] refactor ensureDatabaseExists
add bec1327 [STREAMPIPES-320] introduce JDBCConnectionParameters
add d829f8c [STREAMPIPES-320] fix PostgreSqlParameters
add dfdcbf0 [STREAMPIPES-320] implement table validation
add 3deaf97 [STREAMPIPES-320] harmonize createTable()
add d968b83 [STREAMPIPES-320] make sslFactory SQL dialect specific
add dc76354 [STREAMPIPES-320] move quotedColumn parameter to JdbcConnectionParameters
add de9888d [STREAMPIPES-320] harmonize save() method
add 7a4bf0e [STREAMPIPES-320] restructure JdbcClient
add 046a276 [STREAMPIPES-320] restructure JdbcClient
add 27915f9 [STREAMPIPES-320] adapt IoT DB client
add 62d9c47 Revert "[STREANPIPES-334] implement changes for Buffer Labeler as well"
add f591f8b Revert "[STREANPIPES-334] add UI option for label name"
add fd236f7 Revert "adaptions to changes in ObjectDetection"
add 76151b5 Merge remote-tracking branch 'origin/STREAMPIPES-320' into STREAMPIPES-320
new d8dc190 Merge pull request #40 from apache/STREAMPIPES-320
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../sinks/databases/jvm/iotdb/IotDb.java | 81 ++--
.../sinks/databases/jvm/iotdb/IotDbController.java | 1 +
.../sinks/databases/jvm/iotdb/IotDbParameters.java | 49 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 515 ++++-----------------
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 213 +++++++++
.../jvm/jdbcclient/model/DbDataTypes.java | 38 ++
.../jvm/jdbcclient/model/DbDescription.java | 62 +++
.../jdbcclient/model/JdbcConnectionParameters.java | 76 +++
.../jvm/jdbcclient/model/ParameterInformation.java | 20 +
.../jvm/jdbcclient/model/StatementHandler.java | 158 +++++++
.../jvm/jdbcclient/model/SupportedDbEngines.java | 29 ++
.../jvm/jdbcclient/model/TableDescription.java | 147 ++++++
.../jvm/jdbcclient/utils/SQLStatementUtils.java | 83 ++++
.../jvm/jdbcclient/utils/StatementUtils.java | 50 ++
.../sinks/databases/jvm/mysql/Column.java | 76 ---
.../sinks/databases/jvm/mysql/Mysql.java | 209 +--------
.../sinks/databases/jvm/mysql/MysqlController.java | 3 +-
.../sinks/databases/jvm/mysql/MysqlParameters.java | 61 +--
.../sinks/databases/jvm/postgresql/PostgreSql.java | 34 +-
.../jvm/postgresql/PostgreSqlParameters.java | 58 +--
20 files changed, 1094 insertions(+), 869 deletions(-)
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypes.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDescription.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/JdbcConnectionParameters.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/ParameterInformation.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/StatementHandler.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/SupportedDbEngines.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/TableDescription.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/utils/SQLStatementUtils.java
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/utils/StatementUtils.java
delete mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/mysql/Column.java
[incubator-streampipes-extensions] 01/01: Merge pull request #40
from apache/STREAMPIPES-320
Posted by bo...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
commit d8dc190fa30b28b31ef1cdf28303d0d0b9840dea
Merge: 981c953 76151b5
Author: Tim <50...@users.noreply.github.com>
AuthorDate: Tue Jun 8 16:04:06 2021 +0200
Merge pull request #40 from apache/STREAMPIPES-320
[Streampipes 320] Rework SQL Sinks
.../sinks/databases/jvm/iotdb/IotDb.java | 81 ++--
.../sinks/databases/jvm/iotdb/IotDbController.java | 1 +
.../sinks/databases/jvm/iotdb/IotDbParameters.java | 49 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 515 ++++-----------------
.../jvm/jdbcclient/model/DbDataTypeFactory.java | 213 +++++++++
.../jvm/jdbcclient/model/DbDataTypes.java | 38 ++
.../jvm/jdbcclient/model/DbDescription.java | 62 +++
.../jdbcclient/model/JdbcConnectionParameters.java | 76 +++
.../jvm/jdbcclient/model/ParameterInformation.java | 20 +
.../jvm/jdbcclient/model/StatementHandler.java | 158 +++++++
.../jvm/jdbcclient/model/SupportedDbEngines.java | 29 ++
.../jvm/jdbcclient/model/TableDescription.java | 147 ++++++
.../jvm/jdbcclient/utils/SQLStatementUtils.java | 83 ++++
.../jvm/jdbcclient/utils/StatementUtils.java | 50 ++
.../sinks/databases/jvm/mysql/Column.java | 76 ---
.../sinks/databases/jvm/mysql/Mysql.java | 209 +--------
.../sinks/databases/jvm/mysql/MysqlController.java | 3 +-
.../sinks/databases/jvm/mysql/MysqlParameters.java | 61 +--
.../sinks/databases/jvm/postgresql/PostgreSql.java | 34 +-
.../jvm/postgresql/PostgreSqlParameters.java | 58 +--
20 files changed, 1094 insertions(+), 869 deletions(-)