You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@streampipes.apache.org by ze...@apache.org on 2021/10/02 08:56:49 UTC
[incubator-streampipes-extensions] branch dev updated: [hotfix] Add
more datatypes to MySQL adapter
This is an automated email from the ASF dual-hosted git repository.
zehnder pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git
The following commit(s) were added to refs/heads/dev by this push:
new d7672ad [hotfix] Add more datatypes to MySQL adapter
d7672ad is described below
commit d7672ad5c311fbba20a0e2ba3fad36c1d06443af
Author: Philipp Zehnder <ze...@fzi.de>
AuthorDate: Sat Oct 2 10:56:16 2021 +0200
[hotfix] Add more datatypes to MySQL adapter
---
.../org/apache/streampipes/sinks/brokers/jvm/BrokersJvmInit.java | 2 ++
.../sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java | 5 +++--
.../sinks/databases/jvm/jdbcclient/model/DbDataTypes.java | 5 ++---
3 files changed, 7 insertions(+), 5 deletions(-)
diff --git a/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/BrokersJvmInit.java b/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/BrokersJvmInit.java
index fc7ac50..97dad40 100644
--- a/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/BrokersJvmInit.java
+++ b/streampipes-sinks-brokers-jvm/src/main/java/org/apache/streampipes/sinks/brokers/jvm/BrokersJvmInit.java
@@ -31,6 +31,7 @@ import org.apache.streampipes.messaging.mqtt.SpMqttProtocolFactory;
import org.apache.streampipes.sinks.brokers.jvm.bufferrest.BufferRestController;
import org.apache.streampipes.sinks.brokers.jvm.jms.JmsController;
import org.apache.streampipes.sinks.brokers.jvm.kafka.KafkaController;
+import org.apache.streampipes.sinks.brokers.jvm.mqtt.MqttPublisherSink;
import org.apache.streampipes.sinks.brokers.jvm.nats.NatsController;
import org.apache.streampipes.sinks.brokers.jvm.pulsar.PulsarController;
import org.apache.streampipes.sinks.brokers.jvm.rabbitmq.RabbitMqController;
@@ -55,6 +56,7 @@ public class BrokersJvmInit extends StandaloneModelSubmitter {
new RestController(),
new BufferRestController(),
new RabbitMqController(),
+ new MqttPublisherSink(),
new WebsocketServerSink(),
new PulsarController(),
new NatsController())
diff --git a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java
index 8cd0a29..3f4a6de 100644
--- a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java
+++ b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypeFactory.java
@@ -44,7 +44,7 @@ public class DbDataTypeFactory {
return DbDataTypes.INT64;
case MY_SQL:
case POSTGRESQL:
- return DbDataTypes.BIG_INT;
+ return DbDataTypes.BIGINT;
}
throw new SpRuntimeException("Database engine " + sqlEngine + " does not support long values.");
}
@@ -216,7 +216,8 @@ public class DbDataTypeFactory {
case REAL:
case DATETIME:
return Datatypes.Float;
- case BIG_INT:
+ case BIGINT:
+ case TINYINT:
case INT64:
return Datatypes.Long;
case INT:
diff --git a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypes.java b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypes.java
index 6a897c2..e744c52 100644
--- a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypes.java
+++ b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/jdbcclient/model/DbDataTypes.java
@@ -21,8 +21,6 @@ package org.apache.streampipes.sinks.databases.jvm.jdbcclient.model;
public enum DbDataTypes {
-
-
BOOL("BOOL"),
BOOLEAN("BOOLEAN"),
TEXT("TEXT"),
@@ -32,7 +30,8 @@ public enum DbDataTypes {
DOUBLE_PRECISION("DOUBLE PRECISION"),
FLOAT("FLOAT"),
REAL("REAL"),
- BIG_INT("BIGINT"),
+ BIGINT("BIGINT"),
+ TINYINT("TINYINT"),
INT64("INT64"),
INT32("INT32"),
INT("INT"),