Skip to content

Commit 3d797c8

Browse files
committed
oracle demo updates
1 parent 1b06f73 commit 3d797c8

File tree

10 files changed

+11125
-64
lines changed

10 files changed

+11125
-64
lines changed

connectors/mssql/README.md

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ Before using the SQL Server connector (redis-connect-sqlserver) to capture the c
7373

7474
**NOTE**
7575

76-
The current [release](https://github.com/RedisLabs-Field-Engineering/redis-connect-dist/releases) has been built with JDK 1.8 and tested with JRE 1.8 and above. Please have JRE 1.8 ([OpenJRE](https://openjdk.java.net/install/) or OracleJRE) or above installed prior to running this connector.
76+
The current [release](https://github.com/RedisLabs-Field-Engineering/redis-connect-dist/releases) has been built with JDK 11 and tested with JRE 1.8 and above. Please have JRE 1.8 ([OpenJRE](https://openjdk.java.net/install/) or OracleJRE) or above installed prior to running this connector.
7777

7878
---
7979

@@ -309,7 +309,6 @@ producerConfig:
309309
connectionId: RDBConnection
310310
tables:
311311
- dbo.emp #schema.table
312-
metricsKey: RedisConnect-emp
313312
metricsEnabled: false
314313
pipelineConfig:
315314
eventTranslator: "${sourceValueTranslator}"

connectors/oracle/README.md

Lines changed: 22 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,4 +10,25 @@ All of the events for each tables are recorded in a separate Redis data structur
1010
| ℹ️ |
1111
|:---------------------------|
1212
| Quick Start: Follow the [demo](demo)|
13-
| K8s Setup: Follow the [k8s-docs](k8s-docs)|
13+
| K8s Setup: Follow the [k8s-docs](k8s-docs)|
14+
15+
<h3 class="section" id="compatibility">:rocket: Tested Versions</h3>
16+
<table class="releases-compatibility">
17+
<tbody>
18+
<tr>
19+
<td>Java</td>
20+
<td>11+</td>
21+
</tr>
22+
<tr>
23+
<td>Redis Connect</td>
24+
<td>0.8.x</td>
25+
</tr>
26+
<tr>
27+
<td>Oracle</td>
28+
<td>
29+
<span class="test-with-subcategory"> Database: </span> 12c, 19c (currently only supported for initial load / batch / snapshots) <br/>
30+
<span class="test-with-subcategory"> JDBC Driver: </span> 12.2.0.1, 19.8.0.0, 21.1.0.0 <br/>
31+
</td>
32+
</tr>
33+
</tbody>
34+
</table>

connectors/oracle/demo/README.md

Lines changed: 28 additions & 19 deletions
Original file line numberDiff line numberDiff line change
@@ -147,7 +147,7 @@ db:1 RedisConnect-Target-db redis:
147147
db:2 RedisConnect-JobConfig-Metrics-db redis:2 node:1 master 0-16383 1.99MB OK
148148

149149
demo$ docker exec -it re-node1 bash -c "redis-cli -p 12000 FT._LIST"
150-
1) "idx:emp"
150+
1) "idx:employees"
151151
```
152152
</p>
153153
</details>
@@ -226,31 +226,40 @@ start: start Redis Connect instance with provided cdc or initial loader job conf
226226
227227
<details><summary><b>INSERT few records into Oracle table (source) or create a more realistic load using https://github.com/redis-field-engineering/redis-connect-crud-loader</b></summary>
228228
229-
The Oracle [setup](setup_logminer.sh) already loads [Oracle's HR Sample Schema Tables](https://docs.oracle.com/en/database/oracle/oracle-database/19/comsc/HR-sample-schema-table-descriptions.html#GUID-506C25CE-FA5D-472A-9C4C-F9EF200823EE). If you like to work with another Schema or Table then please create using the existing `HR` schema e.g.
229+
The Oracle [setup](setup_logminer.sh) already loads [Oracle's HR Sample Schema Tables](https://docs.oracle.com/en/database/oracle/oracle-database/19/comsc/HR-sample-schema-table-descriptions.html#GUID-506C25CE-FA5D-472A-9C4C-F9EF200823EE)
230+
<p>Please follow the steps below if you need to load more data into the oracle table before starting the loader job.</p>
231+
232+
Load data using [load sql scripts](load_sql.sh):
233+
<p>
234+
235+
* 12c
230236
```bash
231-
create table hr.emp(
232-
empno number(6,0),
233-
fname varchar2(30),
234-
lname varchar2(30),
235-
job varchar2(40),
236-
mgr number(4,0),
237-
hiredate date,
238-
sal number(10,4),
239-
comm number(10,4),
240-
dept number(4,0),
241-
constraint pk_emp primary key (empno)
242-
)
243-
244-
insert into hr.emp values (1, 'Virag', 'Tripathi', 'PFE', 1, (TO_DATE('2016-08-05 04:07:50', 'yyyy-MM-dd HH:mi:ss')), 1671.34, 1235.13, 96)
237+
sudo docker cp load_sql.sh oracle-12.2.0.1-ee-$(hostname):/tmp/load_sql.sh
238+
239+
sudo docker cp employees1k_insert.sql oracle-12.2.0.1-ee-$(hostname):/opt/oracle/product/12.2.0.1/dbhome_1/demo/employees1k_insert.sql
240+
sudo docker cp update.sql oracle-12.2.0.1-ee-$(hostname):/opt/oracle/product/12.2.0.1/dbhome_1/demo/update.sql
241+
sudo docker cp delete.sql oracle-12.2.0.1-ee-$(hostname):/opt/oracle/product/12.2.0.1/dbhome_1/demo/delete.sql
242+
243+
docker exec -it oracle-12.2.0.1-ee-$(hostname) bash -c "/tmp/load_sql.sh insert"
245244
```
245+
* 19c
246+
```bash
247+
sudo docker cp load_sql.sh oracle-19.3.0-ee-$(hostname):/tmp/load_sql.sh
246248
247-
Load data using the crud loader:
249+
sudo docker cp employees1k_insert.sql oracle-19.3.0-ee-$(hostname):/opt/oracle/product/19c/dbhome_1/demo/employees1k_insert.sql
250+
sudo docker cp update.sql oracle-19.3.0-ee-$(hostname):/opt/oracle/product/19c/dbhome_1/demo/update.sql
251+
sudo docker cp delete.sql oracle-19.3.0-ee-$(hostname):/opt/oracle/product/19c/dbhome_1/demo/delete.sql
252+
253+
docker exec -it oracle-19.3.0-ee-$(hostname) bash -c "/tmp/load_sql.sh insert"
254+
```
255+
</p>
256+
257+
Load data using crud loader:
248258
<p>
249259
250260
```bash
251261
redis-connect-crud-loader/bin$ ./start.sh crudloader
252262
```
253-
254263
</p>
255264
</details>
256265
@@ -375,7 +384,7 @@ Loading Redis Connect redis-connect-oracle Configurations from /opt/redislabs/re
375384
e.g.
376385
377386
```bash
378-
demo$ sudo docker exec -it re-node1 bash -c 'redis-cli -p 12000 ft.search idx:emp "*"'
387+
demo$ sudo docker exec -it re-node1 bash -c 'redis-cli -p 12000 ft.search idx:employees "*"'
379388
```
380389
381390
</p>

connectors/oracle/demo/config/samples/oracle/mappers/mapper1.yml

Lines changed: 5 additions & 40 deletions
Original file line numberDiff line numberDiff line change
@@ -5,23 +5,15 @@ tables:
55
id: employees
66
processorID: employees
77
publishBefore: false
8-
passThrough: false
8+
passThrough: true
99
columns:
1010
- src: EMPLOYEE_ID
11-
target: EmpId
11+
target: EMPLOYEE_ID
1212
type: INT
1313
publishBefore: false
14-
- src: FIRST_NAME
15-
target: FName
16-
- src: LAST_NAME
17-
target: LName
18-
- src: EMAIL
19-
target: Email
20-
- src: JOB_ID
21-
target: JobId
22-
- src: SALARY
23-
target: Salary
24-
type: DOUBLE
14+
- src: HIRE_DATE
15+
target: HIRE_DATE
16+
type: DATE_TIME
2517
- table: JOBS
2618
mapper:
2719
id: Jobs
@@ -32,30 +24,3 @@ tables:
3224
- src: JOB_ID
3325
target: JobId
3426
type: INT
35-
- table: EMP
36-
mapper:
37-
id: emp
38-
processorID: emp
39-
publishBefore: false
40-
passThrough: false
41-
columns:
42-
- src: EMPNO
43-
target: EmployeeNumber
44-
type: INT
45-
publishBefore: false
46-
- src: FNAME
47-
target: FirstName
48-
- src: LNAME
49-
target: LastName
50-
- src: JOB
51-
target: Job
52-
- src: MGR
53-
target: Manager
54-
- src: HIREDATE
55-
target: HireDate
56-
- src: SAL
57-
target: Salary
58-
- src: COMM
59-
target: Commission
60-
- src: DEPT
61-
target: Department

connectors/oracle/demo/delete.sql

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
delete from employees where employee_id LIKE '4%'

0 commit comments

Comments
 (0)