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/17 14:32:21 UTC

[incubator-streampipes-extensions] branch STREAMPIPES-320 updated (fd450ab -> dfdcbf0)

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 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

No new revisions were added by this update.

Summary of changes:
 .../sinks/databases/jvm/iotdb/IotDb.java           |  24 ++-
 .../sinks/databases/jvm/iotdb/IotDbController.java |   1 +
 .../sinks/databases/jvm/iotdb/IotDbParameters.java |  47 ++----
 .../sinks/databases/jvm/jdbcclient/JdbcClient.java | 177 ++++++++++++++-------
 .../jvm/jdbcclient/model/DataTypeNames.java        | 171 --------------------
 .../jdbcclient/model/JdbcConnectionParameters.java |  62 ++++++++
 .../sinks/databases/jvm/mysql/Mysql.java           |  97 ++---------
 .../sinks/databases/jvm/mysql/MysqlController.java |   2 +-
 .../sinks/databases/jvm/mysql/MysqlParameters.java |  59 ++-----
 .../sinks/databases/jvm/postgresql/PostgreSql.java |  29 ++--
 .../jvm/postgresql/PostgreSqlParameters.java       |  56 ++-----
 11 files changed, 266 insertions(+), 459 deletions(-)
 delete mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DataTypeNames.java
 create mode 100644 streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/JdbcConnectionParameters.java