[incubator-streampipes-extensions] 03/04: add schema to generatePreparedStatement

[mi...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

micklich pushed a commit to branch feature/jdbc_rewrite
in repository https://gitbox.apache.org/repos/asf/incubator-streampipes-extensions.git

commit 930e9d0a6a53e5c236d21f1bb2ba7276ccb07884
Author: micklich <fl...@disy.net>
AuthorDate: Sun Jun 7 17:05:59 2020 +0200

    add schema to generatePreparedStatement
---
 .../streampipes/sinks/databases/jvm/postgresql/PostgresJdbcClient.java  | 2 ++
 1 file changed, 2 insertions(+)

diff --git a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/PostgresJdbcClient.java b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/PostgresJdbcClient.java
index 9e0cd42..6bc0c96 100644
--- a/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/PostgresJdbcClient.java
+++ b/streampipes-sinks-databases-jvm/src/main/java/org/apache/streampipes/sinks/databases/jvm/postgresql/PostgresJdbcClient.java
@@ -261,6 +261,8 @@ public class PostgresJdbcClient extends JdbcClient {
     StringBuilder statement1 = new StringBuilder("INSERT INTO ");
     StringBuilder statement2 = new StringBuilder("VALUES ( ");
     checkRegEx(tableName, "Tablename");
+    checkRegEx(schemaName, "Tablename");
+    statement1.append(schemaName).append(".");
     statement1.append(tableName).append(" ( ");
 
     // Starts index at 1, since the parameterIndex in the PreparedStatement starts at 1 as well