Merge pull request #8 from rtdi/master

fix for lowercase column names in PKs

pom.xml

@@ -4,11 +4,11 @@
 	<modelVersion>4.0.0</modelVersion>
 	<groupId>io.rtdi.bigdata.connector</groupId>
 	<artifactId>hanaconnector</artifactId>
-	<version>0.9.5</version>
+	<version>0.9.6</version>
 	<packaging>war</packaging>
 	<properties>
 		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
-		<io.rtdi.bigdata.connector.version>0.10.1</io.rtdi.bigdata.connector.version>
+		<io.rtdi.bigdata.connector.version>0.10.7</io.rtdi.bigdata.connector.version>
 	</properties>
 	<build>
 		<finalName>${project.artifactId}</finalName>

src/main/java/io/rtdi/bigdata/hanaconnector/HanaProducer.java

@@ -348,7 +348,6 @@ public String poll(String from_transaction) throws IOException {
 		long min_transactionid = Long.valueOf(from_transaction);
 		long max_transactionid = getMaxTransactionId(min_transactionid);
 		String sql = null;
-
 		if (min_transactionid != max_transactionid) { // If Hana has not processed a single record anywhere, no need to check for data
 			logger.debug("Reading change data from Hana transaction id \"{}\" to transaction id \"{}\"", min_transactionid, max_transactionid);
 			try {

src/main/java/io/rtdi/bigdata/hanaconnector/HanaTableMapping.java

@@ -520,9 +520,9 @@ private static StringBuffer createProjectionDelta(HanaTableMapping r, boolean us
 				b.append(", ");
 			}
 			if (usedriver && r.getPKColumns().contains(column.getTableColumnName())) {
-				b.append("l.");
+				b.append("l.\"");
 				b.append(column.getTableColumnName());
-				b.append(" as \"");
+				b.append("\" as \"");
 				b.append(column.getAlias());
 				b.append("\"");
 			} else {

src/main/resources/hanaconnector.properties

@@ -0,0 +1 @@
+basedir=https://github.com/rtdi/HanaConnector/blob/main/