This demo requires PCF Dev and Apache Geode.

1. Start CF

   cf dev start
   

2. Login to CF

   cf login -a https://api.local.pcfdev.io --skip-ssl-validation
   

3. Create MySQL and RabbitMQ services

   cf create-service p-mysql 512mb mysql-dev
   cf create-service p-rabbitmq standard rabbitmq-dev 
   

4. Push jdbc-event-source-app, jdbc-event-processor-app, and geode-sink-app

   cf push -f geode-sink-app/manifest-dev.yml
   cf push -f jdbc-event-processor-app/manifest-dev.yml
   cf push -f jdbc-event-source-app/manifest-dev.yml
   

1. Open gfsh terminal
2. Start locator and server from gfsh

   start locator --name=locator
   configure pdx --auto-serializable-classes=com\.example\.springoneplatform\.scs\.demo\.model\.pdx\.* --read-serialized=true
   start server --name=server
   

3. Create regions

   create region --name=customer --type=PARTITION --skip-if-exists
   create region --name=customerOrder --type=PARTITION --skip-if-exists
   create region --name=item --type=PARTITION --skip-if-exists
   

1. Run schema.sql to create tables
2. Run data.sql to insert CUSTOMER, ITEM, CUSTOMER_ORDERS, and ORDER_ITEM rows
3. Start a gfsh terminal and connect to the locator

   connect
   

4. Query the regions to see that the data was extracted from the MySQL database, transformed to the proper types, and loaded into Geode

   query --query="select * from /customer"
   query --query="select * from /customerOrder"
   query --query="select * from /item"
   

1. Run trigger.sql to create the triggers that will insert DB_EVENT rows when data in other tables is inserted, updated, or deleted
2. Run delta-data.sql to do the following:
   1. DELETE an ORDER_ITEM from order1
   2. DELETE a CUSTOMER_ORDER from customer1 (will DELETE all ORDER_ITEM rows for order2 first)
   3. INSERT a ITEM (will add a new item (Stapler) that can be included in an order)
   4. INSERT a CUSTOMER_ORDER and `ORDER_ITEM (will create an order for the new item created above)
3. Query the regions again to see that the data that was deleted from the MySQL database was also deleted from Geode

   query --query="select * from /customer"
   query --query="select * from /customerOrder"
   query --query="select * from /item"
   

In order to run gfsh commands you need to open a gfsh terminal. It's recommended that you create a working directory that you open gfsh from because starting locators and servers creates directories and files.

mkdir tmp && cd tmp
gfsh

Once in the gfsh terminal:

• connect connects the gfsh session to the cluster
• list members displays all members (locators, servers) that are part of the cluster
• list regions displays all regions that have been created
• query --query="<oql here>" executes a query (OQL help)