Updated examples. Added example for Oracle with TCPS and BLOB.

Author: viragtripathi

examples/mssql/demo/extlib/redis-connect-custom-stage-sample-0.10.0.jar

@@ -0,0 +1,74 @@
+{
+  "partitions" : 1,
+  "pipeline": {
+    "stages": [
+      {
+        "index": 1,
+        "stageName": "LOB_TO_JSON",
+        "userDefinedType": "CUSTOM"
+      },
+      {
+        "database": {
+          "credentialsFilePath" : "/opt/redislabs/redis-connect/config/samples/credentials",
+          "databaseURL": "redis://127.0.0.1:14000",
+          "databaseType": "REDIS",
+          "customConfiguration": {
+            "redis.connection.sslEnabled": false,
+            "truststore": "/opt/redislabs/redis-connect/config/samples/credentials/client-truststore.jks"
+          }
+        },
+        "index": 2,
+        "stageName": "REDIS_JSON_SINK",
+        "checkpointStageIndicator": true,
+        "metricsEnabled" : true
+      }
+    ]
+  },
+  "source": {
+    "slowConsumerMaxRetryAttempts": -1,
+    "database": {
+      "credentialsFilePath": "/opt/redislabs/redis-connect/config/samples/credentials",
+      "databaseURL": "jdbc:oracle:thin:@172.17.0.1:1521/ORCLPDB1",
+      "databaseType": "ORACLE",
+      "customConfiguration": {
+        "database.dbname" : "ORCLCDB",
+        "database.hostname" : "172.17.0.1",
+        "database.port" : 1521,
+        "database.pdb.name": "ORCLPDB1",
+        "lob.enabled": true
+      }
+    },
+    "tables": {
+      "C##RCUSER.CLOB_DATA1": {
+        "columns": [
+          { "targetColumn": "ID", "sourceColumn": "ID", "primaryKey": true},
+          { "targetColumn": "CLOB_DATA1", "sourceColumn": "CLOB_DATA1", "type": "CLOB"}
+        ],
+        "initialLoad": {
+          "partitions": 4
+        },
+        "passThroughEnabled": true
+      },
+      "C##RCUSER.CLOB_DATA2": {
+        "columns": [
+          { "targetColumn": "ID", "sourceColumn": "ID", "primaryKey": true},
+          { "targetColumn": "CLOB_DATA2", "sourceColumn": "CLOB_DATA2", "type": "CLOB"}
+        ],
+        "initialLoad": {
+          "partitions": 4
+        },
+        "passThroughEnabled": true
+      },
+      "C##RCUSER.BLOB_DATA1": {
+        "columns": [
+          { "targetColumn": "ID", "sourceColumn": "ID", "primaryKey": true},
+          { "targetColumn": "BLOB_DATA1", "sourceColumn": "BLOB_DATA1", "type": "BLOB"}
+        ],
+        "initialLoad": {
+          "partitions": 4
+        },
+        "passThroughEnabled": true
+      }
+    }
+  }
+}

examples/mssql/demo/extlib/redis-connect-custom-stage-sample-0.10.1.jar

@@ -22,12 +22,12 @@
   "source": {
     "database": {
       "credentialsFilePath": "/opt/redislabs/redis-connect/config/samples/credentials",
-      "databaseURL": "jdbc:oracle:thin:@172.17.0.1:1522/ORCLPDB1",
+      "databaseURL": "jdbc:oracle:thin:@172.17.0.1:1521/ORCLPDB1",
       "databaseType": "ORACLE",
       "customConfiguration": {
         "database.dbname" : "ORCLCDB",
         "database.hostname" : "172.17.0.1",
-        "database.port" : 1522,
+        "database.port" : 1521,
         "database.pdb.name": "ORCLPDB1"
       }
     },

examples/mysql/demo/extlib/redis-connect-custom-stage-demo-1.0-SNAPSHOT.jar

@@ -0,0 +1,44 @@
+{
+  "partitions" : 1,
+  "pipeline": {
+    "stages": [
+      {
+        "database": {
+          "credentialsFilePath" : "/opt/redislabs/redis-connect/config/samples/credentials",
+          "databaseURL": "redis://127.0.0.1:14000",
+          "databaseType": "REDIS",
+          "customConfiguration": {
+            "redis.connection.sslEnabled": false,
+            "truststore": "/opt/redislabs/redis-connect/config/samples/credentials/client-truststore.jks"
+          }
+        },
+        "index": 1,
+        "stageName": "REDIS_HASH_SINK",
+        "checkpointStageIndicator": true,
+        "metricsEnabled" : true
+      }
+    ]
+  },
+  "source": {
+    "database": {
+      "credentialsFilePath": "/opt/redislabs/redis-connect/config/samples/credentials",
+      "databaseURL": "jdbc:oracle:thin:@(DESCRIPTION= (ADDRESS= (PROTOCOL=TCPS)(PORT=2484)(HOST=172.17.0.1)) (CONNECT_DATA=(SERVICE_NAME=ORCLPDB1)) (SECURITY=(ssl_server_cert_dn=\"CN=localhost\")))",
+      "databaseType": "ORACLE",
+      "customConfiguration": {
+        "database.dbname" : "ORCLCDB",
+        "database.url" : "jdbc:oracle:thin:@(DESCRIPTION= (ADDRESS= (PROTOCOL=TCPS)(PORT=2484)(HOST=172.17.0.1)) (CONNECT_DATA=(SERVICE_NAME=ORCLPDB1)) (SECURITY=(ssl_server_cert_dn=\"CN=localhost\")))",
+        "database.pdb.name": "ORCLPDB1",
+        "truststore": "/opt/redislabs/redis-connect/config/samples/credentials/OracleTrustStore.jks"
+      }
+    },
+    "tables": {
+      "C##RCUSER.EMP": {
+        "columns": [
+          { "targetColumn": "EMPNO", "sourceColumn": "EMPNO", "primaryKey": true},
+          { "targetColumn": "HIREDATE", "sourceColumn": "HIREDATE", "type": "DATE"}
+        ],
+        "passThroughEnabled": true
+      }
+    }
+  }
+}