Skip to content

Commit ac16110

Browse files
committed
Updated mysql demo
1 parent 2db50e5 commit ac16110

File tree

6 files changed

+38
-9
lines changed

6 files changed

+38
-9
lines changed

connectors/mysql/demo/README.md

Lines changed: 30 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,6 +154,9 @@ start: start Redis Connect instance with provided cdc or initial loader job conf
154154

155155
```bash
156156
demo$ ./insert_mysql.sh
157+
mysql: [Warning] Using a password on the command line interface can be insecure.
158+
count(*)
159+
12
157160
```
158161
OR
159162
```bash
@@ -187,7 +190,33 @@ redislabs/redis-connect-mysql:pre-release-alpine stage
187190
<p>
188191

189192
```bash
190-
193+
-------------------------------
194+
Staging Redis Connect redis-connect-mysql v0.4.0.7 job using Java 11.0.13 on virag-cdc started by root in /opt/redislabs/redis-connect-mysql/bin
195+
Loading Redis Connect redis-connect-mysql Configurations from /opt/redislabs/redis-connect-mysql/config/samples/loader
196+
04:20:11,322 |-INFO in ch.qos.logback.classic.LoggerContext[default] - Found resource [/opt/redislabs/redis-connect-mysql/config/logback.xml] at [file:/opt/redislabs/redis-connect-mysql/config/logback.xml]
197+
04:20:11,498 |-INFO in ch.qos.logback.classic.joran.action.ConfigurationAction - Will scan for changes in [file:/opt/redislabs/redis-connect-mysql/config/logback.xml]
198+
....
199+
....
200+
04:20:11.584 [main] INFO startup - ##################################################################
201+
04:20:11.586 [main] INFO startup -
202+
04:20:11.587 [main] INFO startup - REDIS CONNECT SETUP CLEAN - Deletes metadata related to Redis Connect from Job Management Database
203+
204+
04:20:11.587 [main] INFO startup -
205+
04:20:11.587 [main] INFO startup - ##################################################################
206+
....
207+
....
208+
04:20:13.910 [main] INFO startup - ##################################################################
209+
04:20:13.912 [main] INFO startup -
210+
04:20:13.913 [main] INFO startup - REDIS CONNECT SETUP CREATE - Seed metadata related to Redis Connect to Job Management Database
211+
04:20:13.913 [main] INFO startup -
212+
04:20:13.913 [main] INFO startup - ##################################################################
213+
04:20:14.639 [main] INFO startup - Instance: 99@virag-cdc will attempt Job Management Database (Redis) with all the configurations and scripts, if applicable, needed to execute jobs
214+
04:20:15.375 [main] INFO startup - Instance: 99@virag-cdc successfully established Redis connection for INIT service
215+
04:20:15.377 [main] INFO startup - Instance: 99@virag-cdc successfully created Job Claim Assignment Stream and Consumer Group
216+
04:20:15.391 [main] INFO startup - Instance: 99@virag-cdc successfully seeded Job related metadata
217+
04:20:15.392 [main] INFO startup - Instance: 99@virag-cdc successfully seeded Metrics related metadata
218+
04:20:15.392 [main] INFO startup - Instance: 99@virag-cdc successfully staged Job Management Database (Redis) with all the configurations and scripts, if applicable, needed to execute jobs
219+
-------------------------------
191220
```
192221
193222
</p>

connectors/mysql/demo/config/samples/loader/TaskCreator.yml

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,4 +7,4 @@ producerConfig:
77
- table: RedisConnect.emp # schema.table
88
numJobs: 5
99
config: JobConfig.yml
10-
loadQuery: "select * from (select Row_Number() over (order by (select 0)) as RowIndex, * from RedisConnect.emp) as emps Where emps.RowIndex >= ${start} and emps.RowIndex <= ${end}"
10+
loadQuery: "SELECT * FROM (SELECT e.*, ROW_NUMBER() OVER (ORDER BY e.empno) RowIndex FROM RedisConnect.emp e) emps WHERE emps.RowIndex BETWEEN ${start} and ${end}"

connectors/mysql/demo/delete_mysql.sh

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
#!/bin/bash
22

3-
sudo docker cp delete.sql mysql-5.7.33-$(hostname):delete.sql
4-
sudo docker exec -it mysql-5.7.33-$(hostname) bash -c 'mysql -h"localhost" -P3306 -uroot -pRedis@123 < delete.sql'
3+
sudo docker cp delete.sql mysql-latest-$(hostname):delete.sql
4+
sudo docker exec -it mysql-latest-$(hostname) bash -c 'mysql -h"localhost" -P3306 -uroot -pRedis@123 RedisConnect < delete.sql'
55
echo ""

connectors/mysql/demo/insert_mysql.sh

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
#!/bin/bash
22

3-
sudo docker cp insert.sql mysql-5.7.33-$(hostname):insert.sql
4-
sudo docker exec -it mysql-5.7.33-$(hostname) bash -c 'mysql -h"localhost" -P3306 -uroot -pRedis@123 < insert.sql'
3+
sudo docker cp insert.sql mysql-latest-$(hostname):insert.sql
4+
sudo docker exec -it mysql-latest-$(hostname) bash -c 'mysql -h"localhost" -P3306 -uroot -pRedis@123 RedisConnect < insert.sql'
55
echo ""

connectors/mysql/demo/update_mysql.sh

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
#!/bin/bash
22

3-
sudo docker cp update.sql mysql-5.7.33-$(hostname):update.sql
4-
sudo docker exec -it mysql-5.7.33-$(hostname) bash -c 'mysql -h"localhost" -P3306 -uroot -pRedis@123 < update.sql'
3+
sudo docker cp update.sql mysql-latest-$(hostname):update.sql
4+
sudo docker exec -it mysql-latest-$(hostname) bash -c 'mysql -h"localhost" -P3306 -uroot -pRedis@123 RedisConnect < update.sql'
55
echo ""

connectors/mysql/k8s-docs/README.md

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ Configure the files to describe your Redis Connect Job. One sample configuration
2525

2626
Redis Connect is a Java application which is a client of both the source RDBMS and the target Redis. As such, you will need:
2727
* Source database details (endpoint, port, credentials)
28-
* <a href="../" target="_blank">WAL and replication configuration</a> completed on the source database system
28+
* <a href="../" target="_blank">BinLog and replication configuration</a> completed on the source database system
2929
* Source schema details
3030
* Target Redis details and instances (one for the data, one for the Job configuration)
3131

0 commit comments

Comments
 (0)