Hi all,
I did some changes in the postgres sink and depending JdbcClient.class.
Here is the small changelog:
A. I improved the error messages if wrong host/port oder user
authentication is used.
B. Changing the enum SqlAttribute data types for Double and String. In
Postgres double leads to an error described in STREAMPIPES-127.
Instead DOUBLE PRECISION has to be used [1]. Also changes String
from varchar255 to TEXT. This allows "unlimited" string lentgh.
C. Added two new db settings:
* Use schema name [2] instead of only public.
* Drop Table if Exists Option. This deletes the table if table exists,
so old will be removed and the same table name can be used.
D. Because of C. some changes had to be made in the JdbcClient.class
and also in the initializeJdbc method with two new parameters.
E. Extended documentation and string.en with the new parameters
This changes can be found in the feature/postgis-sink branch. The
compatibility with the IoT-DB, which also uses the class
JdbcClient.class, still needs to be tested! My first guess is, that
this may not be compatible, but because of STREAMPIPES-127 it seems to
be necessary to use another JdbcClien client anyway. At the moment I
used some default values(public and false) to start the IotDB.class
Sink like without compiling error.
initializeJdbc(
parameters.getGraph().getInputStreams().get(0).getEventSche
ma().getEventProperties(),
parameters.getIotDbHost(),
parameters.getIotDbPort(),
"", // Database does not exist in IoTDB model
"root." + parameters.getDbStorageGroup(),
parameters.getUsername(),
parameters.getPassword(),
".*",
"org.apache.iotdb.jdbc.IoTDBDriver",
"iotdb",
LOG,
"public",
false);
Greetings
Florian
[1] https://www.postgresql.org/docs/current/datatype-numeric.html
[2] https://www.postgresqltutorial.com/postgresql-schema/
[3] https://www.postgresql.org/docs/current/sql-droptable.html
