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/05/31 11:18:36 UTC
[incubator-streampipes-extensions] branch STREAMPIPES-320 updated
(7a4bf0e -> 27915f9)
This is an automated email from the ASF dual-hosted git repository.
bossenti pushed a change to branch STREAMPIPES-320
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git.
from 7a4bf0e [STREAMPIPES-320] restructure JdbcClient
add 046a276 [STREAMPIPES-320] restructure JdbcClient
add 27915f9 [STREAMPIPES-320] adapt IoT DB client
No new revisions were added by this update.
Summary of changes:
.../sinks/databases/jvm/iotdb/IotDb.java | 54 ++--
.../sinks/databases/jvm/iotdb/IotDbController.java | 2 +-
.../sinks/databases/jvm/jdbcclient/JdbcClient.java | 279 ++-------------------
.../jvm/jdbcclient/model/StatementHandler.java | 130 ++++++++++
.../jvm/jdbcclient/model/TableDescription.java | 64 ++++-
.../jvm/jdbcclient/utils/SQLStatementUtils.java | 83 ++++++
.../sinks/databases/jvm/mysql/Column.java | 76 ------
.../sinks/databases/jvm/mysql/MysqlController.java | 1 +
8 files changed, 310 insertions(+), 379 deletions(-)
create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/utils/SQLStatementUtils.java
delete mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/mysql/Column.java